4 implementations of Eventing
Aspire.Hosting (1)
DistributedApplicationBuilder.cs (1)
99public IDistributedApplicationEventing Eventing { get; } = new DistributedApplicationEventing();
Aspire.Hosting.Azure.Sql (1)
AzureSqlServerResource.cs (1)
680public IDistributedApplicationEventing Eventing => throw new NotImplementedException();
Aspire.Hosting.Testing (2)
DistributedApplicationTestingBuilder.cs (2)
245public IDistributedApplicationEventing Eventing => innerBuilder.Eventing; 399public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing;
51 references to Eventing
Aspire.Hosting (7)
Ats\BuilderExports.cs (2)
206return builder.Eventing.Subscribe<BeforeStartEvent>(async (@event, ct) => 230return builder.Eventing.Subscribe<AfterResourcesCreatedEvent>(async (@event, ct) =>
ContainerRegistryResourceBuilderExtensions.cs (1)
123builder.Eventing.Subscribe<BeforeStartEvent>((beforeStartEvent, cancellationToken) =>
DistributedApplicationEventingExtensions.cs (1)
96builder.ApplicationBuilder.Eventing.Subscribe<TEvent>(builder.Resource, (evt, ct) => callback(builder.Resource, evt, ct));
ExternalServiceBuilderExtensions.cs (1)
103builder.Eventing.Subscribe<InitializeResourceEvent>(resource, static async (e, ct) =>
PublisherDistributedApplicationBuilderExtensions.cs (1)
30builder.Eventing.Subscribe<PublisherAdvertisementEvent>((e, ct) => {
ResourceBuilderExtensions.cs (1)
2873builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((@event, cancellationToken) =>
Aspire.Hosting.Azure.ContainerRegistry (1)
AzureContainerRegistryExtensions.cs (1)
84builder.Eventing.Subscribe<BeforeStartEvent>((beforeStartEvent, cancellationToken) =>
Aspire.Hosting.Azure.CosmosDB (1)
AzureCosmosDBExtensions.cs (1)
487builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, _) =>
Aspire.Hosting.Azure.Functions (1)
AzureFunctionsProjectResourceExtensions.cs (1)
157builder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Azure.PostgreSQL (1)
AzurePostgresExtensions.cs (1)
309builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Azure.Redis (2)
AzureManagedRedisExtensions.cs (1)
141builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
AzureRedisExtensions.cs (1)
209builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Azure.Sql (1)
AzureSqlServerResource.cs (1)
504builder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Foundry (1)
FoundryExtensions.cs (1)
295builder.ApplicationBuilder.Eventing.Subscribe<ResourceReadyEvent>(foundryResource, (@event, ct) =>
Aspire.Hosting.Garnet (1)
GarnetBuilderExtensions.cs (1)
116builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(garnet, async (@event, ct) =>
Aspire.Hosting.JavaScript (3)
JavaScriptHostingExtensions.cs (3)
269builder.Eventing.Subscribe<BeforeStartEvent>((_, _) => 474builder.Eventing.Subscribe<BeforeStartEvent>((_, _) => 1142resource.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((_, _) =>
Aspire.Hosting.Kafka (2)
KafkaBuilderExtensions.cs (2)
42builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(kafka, async (@event, ct) => 114builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(kafkaUi, (e, ct) =>
Aspire.Hosting.Maui (2)
MauiOtlpExtensions.cs (2)
119appBuilder.Eventing.Subscribe<BeforeStartEvent>((evt, ct) => 125return appBuilder.Eventing.PublishAsync(new ResourceEndpointsAllocatedEvent(stubResource, evt.Services), ct);
Aspire.Hosting.MongoDB (2)
MongoDBBuilderExtensions.cs (2)
65builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBContainer, async (@event, ct) => 117builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBDatabase, async (@event, ct) =>
Aspire.Hosting.MySql (4)
MySqlBuilderExtensions.cs (4)
46builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(resource, async (@event, ct) => 56builder.Eventing.Subscribe<ResourceReadyEvent>(resource, async (@event, ct) => 127builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mySqlDatabase, async (@event, ct) => 245builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(phpMyAdminContainer, async (e, ct) =>
Aspire.Hosting.MySql.Tests (2)
AddMySqlTests.cs (2)
244await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(myAdmin, app.Services)); 275builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(myAdmin, app.Services));
Aspire.Hosting.Nats (1)
NatsBuilderExtensions.cs (1)
64builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(nats, async (@event, ct) =>
Aspire.Hosting.Oracle (1)
OracleDatabaseBuilderExtensions.cs (1)
44builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(oracleDatabaseServer, async (@event, ct) =>
Aspire.Hosting.PostgreSQL (3)
PostgresBuilderExtensions.cs (3)
61builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresServer, async (@event, ct) => 71builder.Eventing.Subscribe<ResourceReadyEvent>(postgresServer, async (@event, ct) => 158builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresDatabase, async (@event, ct) =>
Aspire.Hosting.Python (2)
PythonAppResourceBuilderExtensions.cs (2)
494builder.Eventing.Subscribe<BeforeStartEvent>((evt, ct) => 1335builder.ApplicationBuilder.Eventing.Subscribe<BeforeStartEvent>((_, _) =>
Aspire.Hosting.Qdrant (1)
QdrantBuilderExtensions.cs (1)
53builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrant, async (@event, ct) =>
Aspire.Hosting.RabbitMQ (1)
RabbitMQBuilderExtensions.cs (1)
46builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(rabbitMq, async (@event, ct) =>
Aspire.Hosting.Redis (2)
RedisBuilderExtensions.cs (2)
80builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(redis, async (@event, ct) => 234builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(resource, async (e, ct) =>
Aspire.Hosting.Redis.Tests (3)
AddRedisTests.cs (3)
489await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services)); 515await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services)); 536await builder.Eventing.PublishAsync<BeforeResourceStartedEvent>(new(commander, app.Services));
Aspire.Hosting.Testing (2)
DistributedApplicationTestingBuilder.cs (2)
486/// <inheritdoc cref="IDistributedApplicationBuilder.Eventing" /> 487new IDistributedApplicationEventing Eventing => ((IDistributedApplicationBuilder)this).Eventing;
Aspire.Hosting.Tests (2)
DistributedApplicationTests.cs (1)
266testProgram.AppBuilder.Eventing.Subscribe<AfterResourcesCreatedEvent>((_, _) =>
Orchestrator\ApplicationOrchestratorTests.cs (1)
136var applicationEventing = builder.Eventing;
Aspire.Hosting.Valkey (1)
ValkeyBuilderExtensions.cs (1)
129builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(valkey, async (@event, ct) =>
DotnetTool.AppHost (1)
AppHost.cs (1)
88builder.Eventing.Subscribe<BeforeStartEvent>(async (evt, _) =>