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)

19IDistributedApplicationEventing eventing,

Dashboard\DashboardEventHandlers.cs (2)

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

Dcp\DcpExecutor.cs (2)

58private readonly IDistributedApplicationEventing _distributedApplicationEventing; 94IDistributedApplicationEventing distributedApplicationEventing,

Devcontainers\DevcontainerPortForwardingEventingSubscriber.cs (1)

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

DistributedApplication.cs (2)

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

DistributedApplicationBuilder.cs (2)

107public IDistributedApplicationEventing Eventing { get; } = new DistributedApplicationEventing(); 413_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)

87public IDistributedApplicationEventing Eventing { get; }

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)

25IDistributedApplicationEventing eventing,

AzureProvisioningController.cs (1)

77IDistributedApplicationEventing eventing,

AzureSqlServerResource.cs (1)

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

AzureEnvironmentResourceExtensionsTests.cs (8)

561var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 1465sp.GetRequiredService<IDistributedApplicationEventing>(), 2423sp.GetRequiredService<IDistributedApplicationEventing>(), 2511sp.GetRequiredService<IDistributedApplicationEventing>(), 2621sp.GetRequiredService<IDistributedApplicationEventing>(), 3892sp.GetRequiredService<IDistributedApplicationEventing>(), 3972sp.GetRequiredService<IDistributedApplicationEventing>(),

BrowserLogsBuilderExtensionsTests.cs (2)

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

DevTunnelResourceBuilderExtensions.cs (6)

122var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>(); 704var eventing = services.GetRequiredService<IDistributedApplicationEventing>(); 783var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>();

FoundryExtensions.cs (2)

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

Lifecycle\MauiBuildQueueEventSubscriber.cs (1)

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

Lifecycle\UnsupportedPlatformEventSubscriber.cs (1)

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

MauiOtlpExtensions.cs (1)

225IDistributedApplicationEventing eventing,

Utilities\MauiAndroidEnvironmentAnnotation.cs (1)

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

Utilities\MauiiOSEnvironmentAnnotation.cs (1)

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

MauiBuildQueueTests.cs (8)

404var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 436var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>(); 935public IDistributedApplicationEventing Eventing => App.Services.GetRequiredService<IDistributedApplicationEventing>(); 1017var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();

MauiiOSValidationTests.cs (6)

34await app.Services.GetRequiredService<IDistributedApplicationEventing>() 59await app.Services.GetRequiredService<IDistributedApplicationEventing>() 83await app.Services.GetRequiredService<IDistributedApplicationEventing>() 103await app.Services.GetRequiredService<IDistributedApplicationEventing>() 121await app.Services.GetRequiredService<IDistributedApplicationEventing>() 139await app.Services.GetRequiredService<IDistributedApplicationEventing>()

MauiPlatformExtensionsTests.cs (1)

292await app.Services.GetRequiredService<IDistributedApplicationEventing>()

AddPythonAppTests.cs (2)

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

DistributedApplicationTestingBuilder.cs (3)

530public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 693public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing; 781new IDistributedApplicationEventing Eventing => ((IDistributedApplicationBuilder)this).Eventing;

Dcp\DcpExecutorTests.cs (1)

10064Hosting.Eventing.IDistributedApplicationEventing? distributedApplicationEventing = null,

DistributedApplicationTests.cs (2)

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

135var applicationEventing = builder.Eventing; 1117IDistributedApplicationEventing? applicationEventing = null,

RequiredCommandAnnotationTests.cs (28)

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)