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)

22IDistributedApplicationEventing eventing,

Backchannel\BackchannelService.cs (1)

18IDistributedApplicationEventing eventing,

Dashboard\DashboardEventHandlers.cs (2)

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

Dcp\DcpExecutor.cs (2)

74private readonly IDistributedApplicationEventing _distributedApplicationEventing; 107IDistributedApplicationEventing distributedApplicationEventing,

Devcontainers\DevcontainerPortForwardingLifecycleHook.cs (1)

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

DistributedApplication.cs (2)

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

DistributedApplicationBuilder.cs (2)

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

Orchestrator\ApplicationOrchestrator.cs (2)

29private readonly IDistributedApplicationEventing _eventing; 44IDistributedApplicationEventing eventing,

Publishing\PipelineExecutor.cs (1)

25IDistributedApplicationEventing eventing,

AzureResourcePreparer.cs (1)

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

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

AzureAppServiceInfrastructure.cs (1)

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

DevTunnelResourceBuilderExtensions.cs (6)

119var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>(); 609var eventing = services.GetRequiredService<IDistributedApplicationEventing>(); 683var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>();

DockerComposeInfrastructure.cs (1)

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

KubernetesInfrastructure.cs (1)

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

246public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 400public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing; 488new IDistributedApplicationEventing Eventing => ((IDistributedApplicationBuilder)this).Eventing;

DistributedApplicationTests.cs (2)

920var 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,

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)