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, 871public Task SubscribeAsync(IDistributedApplicationEventing eventing, DistributedApplicationExecutionContext execContext, CancellationToken cancellationToken)

Dcp\DcpExecutor.cs (2)

46private readonly IDistributedApplicationEventing _distributedApplicationEventing; 83IDistributedApplicationEventing distributedApplicationEventing,

Devcontainers\DevcontainerPortForwardingEventingSubscriber.cs (1)

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

DistributedApplication.cs (2)

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

DistributedApplicationBuilder.cs (2)

106public IDistributedApplicationEventing Eventing { get; } = new DistributedApplicationEventing(); 425_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, HealthCheckService healthCheckService, IServiceProvider services, IDistributedApplicationEventing eventing, TimeProvider timeProvider) : BackgroundService

IDistributedApplicationBuilder.cs (1)

85public 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)

24IDistributedApplicationEventing eventing,

AzureProvisioningController.cs (1)

76IDistributedApplicationEventing eventing,

AzureSqlServerResource.cs (1)

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

AzureEnvironmentResourceExtensionsTests.cs (8)

559var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 1463sp.GetRequiredService<IDistributedApplicationEventing>(), 2421sp.GetRequiredService<IDistributedApplicationEventing>(), 2509sp.GetRequiredService<IDistributedApplicationEventing>(), 2619sp.GetRequiredService<IDistributedApplicationEventing>(), 3890sp.GetRequiredService<IDistributedApplicationEventing>(), 3970sp.GetRequiredService<IDistributedApplicationEventing>(),

BrowserLogsBuilderExtensionsTests.cs (2)

1358var 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)

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

AddRedisTests.cs (4)

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

DistributedApplicationTestingBuilder.cs (3)

528public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 691public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing; 779new IDistributedApplicationEventing Eventing => ((IDistributedApplicationBuilder)this).Eventing;

Dcp\DcpExecutorTests.cs (1)

11385Hosting.Eventing.IDistributedApplicationEventing? distributedApplicationEventing = null,

DistributedApplicationTests.cs (2)

1212var 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)

182var applicationEventing = builder.Eventing; 1164IDistributedApplicationEventing? applicationEventing = null,

RequiredCommandAnnotationTests.cs (28)

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)

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