2 implementations of Eventing
Aspire.Hosting (1)
DistributedApplicationBuilder.cs (1)
81public IDistributedApplicationEventing Eventing { get; } = new DistributedApplicationEventing();
Aspire.Hosting.Tests (1)
Utils\TestDistributedApplicationBuilder.cs (1)
129public IDistributedApplicationEventing Eventing => _innerBuilder.Eventing;
37 references to Eventing
Aspire.Hosting (2)
ResourceBuilderExtensions.cs (2)
882builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((@event, ct) => 898builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(builder.Resource, (@event, ct) =>
Aspire.Hosting.Azure.CosmosDB (2)
AzureCosmosDBExtensions.cs (2)
87builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(builder.Resource, async (@event, ct) => 99builder.ApplicationBuilder.Eventing.Subscribe<ResourceReadyEvent>(builder.Resource, async (@event, ct) =>
Aspire.Hosting.Azure.EventHubs (2)
AzureEventHubsExtensions.cs (2)
193builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(builder.Resource, async (@event, ct) => 227builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(builder.Resource, (e, ct) =>
Aspire.Hosting.Azure.Functions (1)
AzureFunctionsProjectResourceExtensions.cs (1)
71builder.Eventing.Subscribe<BeforeStartEvent>((data, token) =>
Aspire.Hosting.Azure.ServiceBus (1)
AzureServiceBusExtensions.cs (1)
281builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(builder.Resource, async (@event, ct) =>
Aspire.Hosting.Azure.Storage (1)
AzureStorageExtensions.cs (1)
110builder.ApplicationBuilder.Eventing.Subscribe<BeforeResourceStartedEvent>(builder.Resource, async (@event, ct) =>
Aspire.Hosting.Elasticsearch (1)
ElasticsearchBuilderExtensions.cs (1)
61builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(elasticsearch, async (@event, ct) =>
Aspire.Hosting.Garnet (1)
GarnetBuilderExtensions.cs (1)
65builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(garnet, async (@event, ct) =>
Aspire.Hosting.Kafka (2)
KafkaBuilderExtensions.cs (2)
42builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(kafka, async (@event, ct) => 113builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) =>
Aspire.Hosting.MongoDB (2)
MongoDBBuilderExtensions.cs (2)
64builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBContainer, async (@event, ct) => 115builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBDatabase, async (@event, ct) =>
Aspire.Hosting.MySql (2)
MySqlBuilderExtensions.cs (2)
40builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(resource, async (@event, ct) => 115builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) =>
Aspire.Hosting.MySql.Tests (2)
AddMySqlTests.cs (2)
242await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>())); 283builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()));
Aspire.Hosting.Nats (1)
NatsBuilderExtensions.cs (1)
61builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(nats, async (@event, ct) =>
Aspire.Hosting.Oracle (1)
OracleDatabaseBuilderExtensions.cs (1)
36builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(oracleDatabaseServer, async (@event, ct) =>
Aspire.Hosting.PostgreSQL (3)
PostgresBuilderExtensions.cs (3)
55builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresServer, async (@event, ct) => 158builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 296builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>(async (e, ct) =>
Aspire.Hosting.PostgreSQL.Tests (2)
AddPostgresTests.cs (2)
466await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>())); 514await builder.Eventing.PublishAsync<AfterEndpointsAllocatedEvent>(new(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()));
Aspire.Hosting.Qdrant (1)
QdrantBuilderExtensions.cs (1)
53builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrant, async (@event, ct) =>
Aspire.Hosting.RabbitMQ (1)
RabbitMQBuilderExtensions.cs (1)
45builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(rabbitMq, async (@event, ct) =>
Aspire.Hosting.Redis (4)
RedisBuilderExtensions.cs (4)
47builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(redis, async (@event, ct) => 98builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 168builder.ApplicationBuilder.Eventing.Subscribe<AfterEndpointsAllocatedEvent>((e, ct) => 174builder.ApplicationBuilder.Eventing.Subscribe<ResourceReadyEvent>(resource, 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 (1)
SqlServerBuilderExtensions.cs (1)
38builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(sqlServer, async (@event, ct) =>
Aspire.Hosting.Valkey (1)
ValkeyBuilderExtensions.cs (1)
63builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(valkey, async (@event, ct) =>
Mongo.AppHost (1)
Program.cs (1)
14builder.Eventing.Subscribe<ResourceReadyEvent>(db.Resource, async (@event, ct) =>