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> 23IDistributedApplicationEventing distributedApplicationEventing, 32/// The <see cref="IDistributedApplicationEventing"/> service for the app host. 34public IDistributedApplicationEventing Eventing { get; } = distributedApplicationEventing;

Backchannel\AuxiliaryBackchannelService.cs (1)

20IDistributedApplicationEventing eventing,

Backchannel\BackchannelService.cs (1)

18IDistributedApplicationEventing eventing,

Dashboard\DashboardEventHandlers.cs (2)

41IDistributedApplicationEventing eventing, 871public 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)

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

DistributedApplicationBuilder.cs (2)

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

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

Provisioning\Provisioners\AzureProvisioner.cs (2)

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

AzureAIFoundryExtensions.cs (2)

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

AzureContainerAppsInfrastructure.cs (1)

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

AzureAppServiceInfrastructure.cs (1)

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

DevTunnelResourceBuilderExtensions.cs (6)

123var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>(); 668var eventing = services.GetRequiredService<IDistributedApplicationEventing>(); 742var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>();

DockerComposeInfrastructure.cs (1)

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

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)

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

TestResource.cs (1)

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

Program.cs (1)

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

TestResource.cs (1)

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

TestProgram.cs (1)

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