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\BackchannelService.cs (1)

18IDistributedApplicationEventing eventing,

Dashboard\DashboardEventHandlers.cs (2)

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

Dcp\DcpExecutor.cs (2)

68private readonly IDistributedApplicationEventing _distributedApplicationEventing; 100IDistributedApplicationEventing 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)

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

DistributedApplicationRunner.cs (1)

17internal sealed class DistributedApplicationRunner(ILogger<DistributedApplicationRunner> logger, IHostApplicationLifetime lifetime, DistributedApplicationExecutionContext executionContext, DistributedApplicationModel model, IServiceProvider serviceProvider, IPublishingActivityReporter activityReporter, IDistributedApplicationEventing eventing, BackchannelService backchannelService, IOptions<PublishingOptions> publishingOptions) : BackgroundService

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)

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

27private readonly IDistributedApplicationEventing _eventing; 41IDistributedApplicationEventing eventing,

AzureResourcePreparer.cs (1)

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

Provisioning\Provisioners\AzureProvisioner.cs (2)

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

AzureAIFoundryExtensions.cs (2)

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

AzureContainerAppsInfrastructure.cs (1)

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

AzureAppServiceInfrastructure.cs (1)

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

DevTunnelResourceBuilderExtensions.cs (6)

119var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>(); 593var eventing = services.GetRequiredService<IDistributedApplicationEventing>(); 667var eventing = e.Services.GetRequiredService<IDistributedApplicationEventing>();

DockerComposeInfrastructure.cs (1)

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

KubernetesInfrastructure.cs (1)

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

DistributedApplicationTestingBuilder.cs (3)

239public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 389public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing; 473new IDistributedApplicationEventing Eventing => ((IDistributedApplicationBuilder)this).Eventing;

DistributedApplicationTests.cs (2)

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

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

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