2 implementations of Eventing
Aspire.Hosting (1)
DistributedApplicationBuilder.cs (1)
78public IDistributedApplicationEventing Eventing { get; } = new DistributedApplicationEventing();
Aspire.Hosting.Tests (1)
Utils\TestDistributedApplicationBuilder.cs (1)
122public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing;
45 references to Eventing
Aspire.Hosting (2)
ResourceBuilderExtensions.cs (2)
600builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(builder.Resource, async (e, ct) => 679builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(builder.Resource, async (e, ct) =>
Aspire.Hosting.Azure.CosmosDB (1)
AzureCosmosDBExtensions.cs (1)
112builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(resource, async (@event, ct) =>
Aspire.Hosting.Azure.EventHubs (1)
AzureEventHubsExtensions.cs (1)
197builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) =>
Aspire.Hosting.Azure.Functions (1)
AzureFunctionsProjectResourceExtensions.cs (1)
31builder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Elasticsearch (1)
ElasticsearchBuilderExtensions.cs (1)
61builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(elasticsearch, async (@event, ct) =>
Aspire.Hosting.Garnet (1)
GarnetBuilderExtensions.cs (1)
62builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(garnet, async (@event, ct) =>
Aspire.Hosting.Kafka (2)
KafkaBuilderExtensions.cs (2)
39builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(kafka, async (@event, ct) => 107builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) =>
Aspire.Hosting.Milvus (4)
MilvusBuilderExtensions.cs (4)
62builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(milvus, async (@event, ct) => 76await builder.Eventing.PublishAsync<ConnectionStringAvailableEvent>(connectionStringAvailableEvent, ct).ConfigureAwait(false); 79await builder.Eventing.PublishAsync(beforeResourceStartedEvent, ct).ConfigureAwait(false); 149builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(milvusDatabaseResource, async (@event, ct) =>
Aspire.Hosting.MongoDB (1)
MongoDBBuilderExtensions.cs (1)
35builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBContainer, async (@event, ct) =>
Aspire.Hosting.MySql (5)
MySqlBuilderExtensions.cs (5)
37builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(resource, async (@event, ct) => 56await builder.Eventing.PublishAsync<ConnectionStringAvailableEvent>(connectionStringAvailableEvent, ct).ConfigureAwait(false); 59await builder.Eventing.PublishAsync(beforeResourceStartedEvent, ct).ConfigureAwait(false); 97builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mySqlDatabase, async (@event, ct) => 142builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) =>
Aspire.Hosting.MySql.Tests (2)
AddMySqlTests.cs (2)
243await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>())); 284builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()));
Aspire.Hosting.Nats (1)
NatsBuilderExtensions.cs (1)
36builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(nats, async (@event, ct) =>
Aspire.Hosting.Oracle (4)
OracleDatabaseBuilderExtensions.cs (4)
33builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(oracleDatabaseServer, async (@event, ct) => 52await builder.Eventing.PublishAsync<ConnectionStringAvailableEvent>(connectionStringAvailableEvent, ct).ConfigureAwait(false); 55await builder.Eventing.PublishAsync(beforeResourceStartedEvent, ct).ConfigureAwait(false); 91builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(oracleDatabase, async (@event, ct) =>
Aspire.Hosting.PostgreSQL (6)
PostgresBuilderExtensions.cs (6)
53builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresServer, async (@event, ct) => 72await builder.Eventing.PublishAsync<ConnectionStringAvailableEvent>(connectionStringAvailableEvent, ct).ConfigureAwait(false); 75await builder.Eventing.PublishAsync(beforeResourceStartedEvent, ct).ConfigureAwait(false); 138builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresDatabase, async (@event, ct) => 185builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 320builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>(async (e, ct) =>
Aspire.Hosting.PostgreSQL.Tests (2)
AddPostgresTests.cs (2)
467await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>())); 515await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()));
Aspire.Hosting.RabbitMQ (1)
RabbitMQBuilderExtensions.cs (1)
44builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(rabbitMq, async (@event, ct) =>
Aspire.Hosting.Redis (3)
RedisBuilderExtensions.cs (3)
47builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(redis, async (@event, ct) => 95builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 158builder.ApplicationBuilder.Eventing.Subscribe<AfterResourcesCreatedEvent>(async (e, ct) =>
Aspire.Hosting.Redis.Tests (2)
AddRedisTests.cs (2)
216await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>())); 240await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new (app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()));
Aspire.Hosting.SqlServer (4)
SqlServerBuilderExtensions.cs (4)
35builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(sqlServer, async (@event, ct) => 54await builder.Eventing.PublishAsync<ConnectionStringAvailableEvent>(connectionStringAvailableEvent, ct).ConfigureAwait(false); 57await builder.Eventing.PublishAsync(beforeResourceStartedEvent, ct).ConfigureAwait(false); 96builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(sqlServerDatabase, async (@event, ct) =>
Aspire.Hosting.Valkey (1)
ValkeyBuilderExtensions.cs (1)
60builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(valkey, async (@event, ct) =>