IDistributedApplicationEventing

Eventing\DistributedApplicationEventing.cs (1)

11public class DistributedApplicationEventing : IDistributedApplicationEventing

ApplicationModel\InitializeResourceEvent.cs (4)

13/// <param name="distributedApplicationEventing">The <see cref="IDistributedApplicationEventing"/> service for the app host.</param> 24IDistributedApplicationEventing distributedApplicationEventing, 33/// The <see cref="IDistributedApplicationEventing"/> service for the app host. 35public IDistributedApplicationEventing Eventing { get; } = distributedApplicationEventing;

Ats\EventingExports.cs (5)

58internal static IDistributedApplicationEventing GetEventing(this IServiceProvider serviceProvider) 62return serviceProvider.GetRequiredService<IDistributedApplicationEventing>(); 228public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken) 240IDistributedApplicationEventing eventing, 244internal IDistributedApplicationEventing Eventing { get; } = eventing;

Backchannel\AuxiliaryBackchannelService.cs (1)

22IDistributedApplicationEventing eventing,

Backchannel\BackchannelService.cs (1)

20IDistributedApplicationEventing eventing,

Dashboard\DashboardEventHandlers.cs (2)

41IDistributedApplicationEventing eventing, 897public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext execContext, CancellationToken cancellationToken)

Dcp\DcpExecutor.cs (2)

45private readonly IDistributedApplicationEventing _distributedApplicationEventing; 82IDistributedApplicationEventing distributedApplicationEventing,

Devcontainers\DevcontainerPortForwardingEventingSubscriber.cs (1)

53public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext execContext, CancellationToken cancellationToken)

DistributedApplication.cs (2)

624var eventing = _host.Services.GetRequiredService<IDistributedApplicationEventing>();

DistributedApplicationBuilder.cs (2)

107public IDistributedApplicationEventing Eventing { get; } = new DistributedApplicationEventing(); 435_innerBuilder.Services.AddSingleton<IDistributedApplicationEventing>(Eventing);

Eventing\DistributedApplicationEventing.cs (6)

10/// <inheritdoc cref="IDistributedApplicationEventing" /> 16/// <inheritdoc cref="IDistributedApplicationEventing.PublishAsync{T}(T, CancellationToken)" /> 23/// <inheritdoc cref="IDistributedApplicationEventing.PublishAsync{T}(T, CancellationToken)" /> 119/// <inheritdoc cref="IDistributedApplicationEventing.Subscribe{T}(Func{T, CancellationToken, Task})" /> 158/// <inheritdoc cref="IDistributedApplicationEventing.Subscribe{T}(Func{T, CancellationToken, Task})" /> 172/// <inheritdoc cref="IDistributedApplicationEventing.Unsubscribe(DistributedApplicationEventSubscription)" />

Health\ResourceHealthCheckService.cs (1)

14internal class ResourceHealthCheckService(ILogger<ResourceHealthCheckService> logger, ResourceNotificationService resourceNotificationService, ResourceLoggerService resourceLoggerService, HealthCheckService healthCheckService, IServiceProvider services, IDistributedApplicationEventing eventing, TimeProvider timeProvider) : BackgroundService

IDistributedApplicationBuilder.cs (1)

82public IDistributedApplicationEventing Eventing { get; }

Lifecycle\DotnetBuildCommandEventingSubscriber.cs (1)

19IDistributedApplicationEventing eventing,

Lifecycle\IDistributedApplicationEventingSubscriber.cs (2)

17/// <param name="eventing">The <see cref="IDistributedApplicationEventing"/> service to subscribe to events from.</param> 21Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken);

Lifecycle\RequiredCommandValidationEventingSubscriber.cs (1)

24public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken)

Lifecycle\TerminalHostEventingSubscriber.cs (1)

43public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken)

Lifecycle\TerminalHostOrphanCleanupService.cs (2)

51IDistributedApplicationEventing eventing, 515IDistributedApplicationEventing eventing,

Orchestrator\ApplicationOrchestrator.cs (2)

32private readonly IDistributedApplicationEventing _eventing; 48IDistributedApplicationEventing eventing,

Publishing\PipelineExecutor.cs (1)

22IDistributedApplicationEventing eventing,

AzureProvisioningController.cs (1)

76IDistributedApplicationEventing eventing,

EntraIdInitializationTests.cs (2)

523var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

AzureSqlServerResource.cs (1)

773public IDistributedApplicationEventing Eventing => throw new NotImplementedException();

AzureEnvironmentResourceExtensionsTests.cs (8)

857var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 1783sp.GetRequiredService<IDistributedApplicationEventing>(), 2741sp.GetRequiredService<IDistributedApplicationEventing>(), 2829sp.GetRequiredService<IDistributedApplicationEventing>(), 2939sp.GetRequiredService<IDistributedApplicationEventing>(), 4210sp.GetRequiredService<IDistributedApplicationEventing>(), 4290sp.GetRequiredService<IDistributedApplicationEventing>(),

BrowserLogsBuilderExtensionsTests.cs (2)

1357var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

DevTunnelMonitor.cs (2)

32private readonly IDistributedApplicationEventing _eventing; 61_eventing = services.GetRequiredService<IDistributedApplicationEventing>();

DevTunnelResourceBuilderExtensions.cs (3)

120var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>(); 841await services.GetRequiredService<IDistributedApplicationEventing>()

DevTunnelMonitorTests.cs (4)

113test.App.Services.GetRequiredService<IDistributedApplicationEventing>().Subscribe<ResourceEndpointsAllocatedEvent>(test.Port, async (_, ct) => 256test.App.Services.GetRequiredService<IDistributedApplicationEventing>().Subscribe<ResourceEndpointsAllocatedEvent>(test.Port, 696test.App.Services.GetRequiredService<IDistributedApplicationEventing>().Subscribe<ResourceEndpointsAllocatedEvent>(test.Port, async (_, ct) => 717test.App.Services.GetRequiredService<IDistributedApplicationEventing>().Subscribe<ResourceEndpointsAllocatedEvent>(test.Port, (_, _) =>

FoundryExtensions.cs (2)

400var eventing = @event.Services.GetRequiredService<IDistributedApplicationEventing>();

Lifecycle\MauiBuildQueueEventSubscriber.cs (1)

61public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken)

Lifecycle\UnsupportedPlatformEventSubscriber.cs (1)

23public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken)

MauiOtlpExtensions.cs (1)

514IDistributedApplicationEventing eventing,

Utilities\MauiAndroidEnvironmentAnnotation.cs (1)

45public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext execContext, CancellationToken cancellationToken)

Utilities\MauiiOSEnvironmentAnnotation.cs (1)

45public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext execContext, CancellationToken cancellationToken)

MauiBuildQueueTests.cs (8)

406var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 439var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 1341public IDistributedApplicationEventing Eventing => App.Services.GetRequiredService<IDistributedApplicationEventing>(); 1423var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

MauiiOSValidationTests.cs (6)

35await app.Services.GetRequiredService<IDistributedApplicationEventing>() 61await app.Services.GetRequiredService<IDistributedApplicationEventing>() 86await app.Services.GetRequiredService<IDistributedApplicationEventing>() 107await app.Services.GetRequiredService<IDistributedApplicationEventing>() 126await app.Services.GetRequiredService<IDistributedApplicationEventing>() 145await app.Services.GetRequiredService<IDistributedApplicationEventing>()

MauiPlatformExtensionsTests.cs (3)

295await app.Services.GetRequiredService<IDistributedApplicationEventing>() 580var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

ReplicaSet\AddMongoDBReplicaSetTests.cs (2)

332var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

AddPythonAppTests.cs (2)

2903var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

AddRedisTests.cs (4)

300var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 326var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

DistributedApplicationTestingBuilder.cs (3)

526public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 691public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing; 781new IDistributedApplicationEventing Eventing => ((IDistributedApplicationBuilder)this).Eventing;

Dcp\DcpExecutorTests.cs (1)

11458Hosting.Eventing.IDistributedApplicationEventing? distributedApplicationEventing = null,

DistributedApplicationTests.cs (2)

1267var events = app.Services.GetRequiredService<IDistributedApplicationEventing>();

Eventing\DistributedApplicationBuilderEventingTests.cs (8)

172var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 322var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 427var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 450var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

HealthCheckTests.cs (2)

93var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

Orchestrator\ApplicationOrchestratorTests.cs (2)

181var applicationEventing = builder.Eventing; 1163IDistributedApplicationEventing? applicationEventing = null,

RequiredCommandAnnotationTests.cs (28)

WithBindMountTests.cs (2)

198var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

Utils\EventingTestHelpers.cs (2)

16var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

Infrastructure\DistributedApplicationTestFactory.cs (1)

73public Task SubscribeAsync(IDistributedApplicationEventing eventing, Aspire.Hosting.DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken)

TalkingClockResource.cs (1)

60var eventing = @event.Eventing; // Get the eventing service for publishing events.

TestResource.cs (1)

85public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken)

AppHost.cs (1)

145public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken)

TestResource.cs (1)

199public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken)

TestProgram.cs (1)

207public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken)