6 instantiations of OperationEvent
Aspire.Hosting.Native.Core (1)
Diagnostics\NativeDiagnostics.cs (1)
118s_events.Publish(new OperationEvent(
Aspire.Hosting.Native.Core.Tests (5)
NativeAuxiliaryBackchannelTests.cs (2)
34host.Logs.Append(new(Guid.NewGuid(), "ipc.watch", OperationOutcome.Ok, null, null, null, null, null, 47host.Logs.Append(new(Guid.NewGuid(), "ipc.watch", OperationOutcome.Ok, null, null, null, null, null,
NativeCliProtocolTests.cs (1)
218host.Logs.Append(new OperationEvent(Guid.NewGuid(), "test.operation", OperationOutcome.Error, null, generation,
NativeDiagnosticChannelTests.cs (1)
71private static OperationEvent Event(OperationOutcome outcome) => new(
NativeSocketIsolationTests.cs (1)
332logs.Append(new OperationEvent(Guid.NewGuid(), "rpc.request", OperationOutcome.Error, null, null, null, null, null,
24 references to OperationEvent
Aspire.Hosting.Native.Core (5)
Diagnostics\OperationEventSource.cs (5)
30public void Publish(OperationEvent value) 79private readonly Channel<OperationEvent> _channel; 85_channel = Channel.CreateBounded<OperationEvent>(new BoundedChannelOptions(capacity) 92public ChannelReader<OperationEvent> Reader => _channel.Reader; 94internal ChannelWriter<OperationEvent> Writer => _channel.Writer;
Aspire.Hosting.Native.Core.AotSmoke (3)
tests\Aspire.Hosting.Native.Core.Tests\TestServices\DiagnosticCapture.cs (3)
16private readonly ConcurrentQueue<OperationEvent> _events = []; 58public ConcurrentQueue<OperationEvent> Events 65while (_subscription.Reader.TryRead(out var value))
Aspire.Hosting.Native.Core.Tests (12)
NativeDiagnosticChannelTests.cs (5)
17var first = Event(OperationOutcome.Started); 18var second = Event(OperationOutcome.Ok); 35var operation = Event(OperationOutcome.Ok); 60var operation = Event(OperationOutcome.Error); 71private static OperationEvent Event(OperationOutcome outcome) => new(
NativeDiagnosticsTests.cs (2)
56var failed = Assert.Single(capture.Events, value => value.Outcome == OperationOutcome.Error); 127var start = Assert.Single(capture.Events, value => value.Operation == "session.generation.start" && value.Outcome == OperationOutcome.Ok);
NativeSocketIsolationTests.cs (2)
78var diagnostic = Assert.Single(capture.Events, value => value.Operation == "backchannel.request" && value.Outcome == OperationOutcome.Error); 159var failure = Assert.Single(capture.Events, value => value.Operation == "rpc.request" &&
TestServices\DiagnosticCapture.cs (3)
16private readonly ConcurrentQueue<OperationEvent> _events = []; 58public ConcurrentQueue<OperationEvent> Events 65while (_subscription.Reader.TryRead(out var value))
Aspire.Hosting.Native.Server (4)
Cli\NativeCliLogBuffer.cs (1)
19public void Append(OperationEvent value)
NativeDiagnosticPump.cs (2)
15public NativeDiagnosticPump(Action<OperationEvent> consume, Action<Exception> error, NativeServerOptions options) 24await foreach (var operation in _subscription.Reader.ReadAllAsync().ConfigureAwait(false))
NativeDiagnosticWriter.cs (1)
14public void Write(OperationEvent operation)