1 implementation of IDistributedApplicationEventing
Aspire.Hosting (1)
Eventing\DistributedApplicationEventing.cs (1)
10public class DistributedApplicationEventing : IDistributedApplicationEventing
36 references to IDistributedApplicationEventing
Aspire.Hosting (23)
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\DashboardLifecycleHook.cs (1)
38IDistributedApplicationEventing eventing,
Dcp\DcpExecutor.cs (2)
67private readonly IDistributedApplicationEventing _distributedApplicationEventing; 99IDistributedApplicationEventing distributedApplicationEventing,
DistributedApplication.cs (2)
467var eventing = _host.Services.GetRequiredService<IDistributedApplicationEventing>();
DistributedApplicationBuilder.cs (2)
88public IDistributedApplicationEventing Eventing { get; } = new DistributedApplicationEventing(); 252_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; }
Orchestrator\ApplicationOrchestrator.cs (2)
24private readonly IDistributedApplicationEventing _eventing; 36IDistributedApplicationEventing eventing,
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
22IDistributedApplicationEventing eventing,
Aspire.Hosting.Azure.AIFoundry (2)
AzureAIFoundryExtensions.cs (2)
227var eventing = @event.Services.GetRequiredService<IDistributedApplicationEventing>();
Aspire.Hosting.Testing (3)
DistributedApplicationTestingBuilder.cs (3)
239public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 389public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing; 473new IDistributedApplicationEventing Eventing => ((IDistributedApplicationBuilder)this).Eventing;
Aspire.Hosting.Tests (6)
DistributedApplicationTests.cs (2)
617var events = app.Services.GetRequiredService<IDistributedApplicationEventing>();
Eventing\DistributedApplicationBuilderEventingTests.cs (2)
168var eventing = app.Services.GetRequiredService<IDistributedApplicationEventing>();
Orchestrator\ApplicationOrchestratorTests.cs (2)
123var applicationEventing = builder.Eventing; 443IDistributedApplicationEventing? applicationEventing = null,
CustomResources.AppHost (1)
TalkingClockResource.cs (1)
59var eventing = @event.Eventing; // Get the eventing service for publishing events.