IDistributedApplicationEventing

Eventing\DistributedApplicationEventing.cs (1)

10public 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 (2)

21internal static IDistributedApplicationEventing GetEventing(this IServiceProvider serviceProvider) 25return serviceProvider.GetRequiredService<IDistributedApplicationEventing>();

Backchannel\AuxiliaryBackchannelService.cs (1)

20IDistributedApplicationEventing eventing,

Backchannel\BackchannelService.cs (1)

18IDistributedApplicationEventing eventing,

Dashboard\DashboardEventHandlers.cs (2)

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

Dcp\DcpExecutor.cs (2)

73private readonly IDistributedApplicationEventing _distributedApplicationEventing; 106IDistributedApplicationEventing distributedApplicationEventing,

Devcontainers\DevcontainerPortForwardingLifecycleHook.cs (1)

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

DistributedApplication.cs (2)

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

DistributedApplicationBuilder.cs (2)

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

Eventing\DistributedApplicationEventing.cs (6)

9/// <inheritdoc cref="IDistributedApplicationEventing" /> 15/// <inheritdoc cref="IDistributedApplicationEventing.PublishAsync{T}(T, CancellationToken)" /> 22/// <inheritdoc cref="IDistributedApplicationEventing.PublishAsync{T}(T, CancellationToken)" /> 76/// <inheritdoc cref="IDistributedApplicationEventing.Subscribe{T}(Func{T, CancellationToken, Task})" /> 105/// <inheritdoc cref="IDistributedApplicationEventing.Subscribe{T}(Func{T, CancellationToken, Task})" /> 119/// <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)

84public 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\RequiredCommandValidationLifecycleHook.cs (1)

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

Orchestrator\ApplicationOrchestrator.cs (2)

31private readonly IDistributedApplicationEventing _eventing; 46IDistributedApplicationEventing eventing,

Publishing\PipelineExecutor.cs (1)

25IDistributedApplicationEventing eventing,

AzureResourcePreparer.cs (1)

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

Provisioning\Provisioners\AzureProvisioner.cs (2)

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

AzureContainerAppsInfrastructure.cs (1)

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

AzureAppServiceInfrastructure.cs (1)

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

AzureSqlServerResource.cs (1)

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

DevTunnelResourceBuilderExtensions.cs (6)

124var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>(); 684var eventing = services.GetRequiredService<IDistributedApplicationEventing>(); 758var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>();

DockerComposeInfrastructure.cs (1)

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

FoundryExtensions.cs (2)

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

KubernetesInfrastructure.cs (1)

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

Lifecycle\UnsupportedPlatformEventSubscriber.cs (1)

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

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)

MauiPlatformExtensionsTests.cs (1)

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

AddPythonAppTests.cs (2)

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

DistributedApplicationTestingBuilder.cs (3)

245public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 399public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing; 487new IDistributedApplicationEventing Eventing => ((IDistributedApplicationBuilder)this).Eventing;

DistributedApplicationTests.cs (2)

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

Eventing\DistributedApplicationBuilderEventingTests.cs (4)

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

Orchestrator\ApplicationOrchestratorTests.cs (2)

136var applicationEventing = builder.Eventing; 461IDistributedApplicationEventing? applicationEventing = null,

RequiredCommandAnnotationTests.cs (26)

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)

Program.cs (1)

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

TestResource.cs (1)

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

TestProgram.cs (1)

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