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)

40IDistributedApplicationEventing eventing, 880public 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)

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

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

122var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>(); 623var eventing = services.GetRequiredService<IDistributedApplicationEventing>(); 697var 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)

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

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

Eventing\DistributedApplicationBuilderEventingTests.cs (4)

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

Orchestrator\ApplicationOrchestratorTests.cs (2)

135var applicationEventing = builder.Eventing; 460IDistributedApplicationEventing? 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)