4 instantiations of ConnectionStringAvailableEvent
Aspire.Hosting (1)
Orchestrator\ApplicationOrchestrator.cs (1)
453var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(resource, _serviceProvider);
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
275var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(targetResource, serviceProvider);
Aspire.Hosting.Azure.AIFoundry (1)
AzureAIFoundryExtensions.cs (1)
215var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(deployment, @event.Services);
Aspire.Hosting.Tests (1)
Orchestrator\ApplicationOrchestratorTests.cs (1)
424await applicationEventing.PublishAsync(new ConnectionStringAvailableEvent(resource.Resource, app.Services), CancellationToken.None);
27 references to ConnectionStringAvailableEvent
Aspire.Hosting (6)
ApplicationModel\ConnectionStringAvailableEvent.cs (1)
9/// The <see cref="ConnectionStringAvailableEvent"/> is raised when a connection string becomes available for a resource.
EventingExtensions.cs (2)
26/// Subscribes a callback to the <see cref="ConnectionStringAvailableEvent"/> event within the AppHost. 32public static IResourceBuilder<T> OnConnectionStringAvailable<T>(this IResourceBuilder<T> builder, Func<T, ConnectionStringAvailableEvent, CancellationToken, Task> callback)
Orchestrator\ApplicationOrchestrator.cs (3)
56_eventing.Subscribe<ConnectionStringAvailableEvent>(PublishConnectionStringValue); 61private async Task PublishConnectionStringValue(ConnectionStringAvailableEvent @event, CancellationToken token) 453var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(resource, _serviceProvider);
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
275var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(targetResource, serviceProvider);
Aspire.Hosting.Azure.AIFoundry (1)
AzureAIFoundryExtensions.cs (1)
215var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(deployment, @event.Services);
Aspire.Hosting.Azure.Storage (1)
AzureStorageExtensions.cs (1)
142var connectionString = await builder.Resource.GetBlobConnectionString().GetValueAsync(ct).ConfigureAwait(false) ?? throw new DistributedApplicationException($"{nameof(ConnectionStringAvailableEvent)} was published for the '{builder.Resource.Name}' resource but the connection string was null.");
Aspire.Hosting.Garnet (1)
GarnetBuilderExtensions.cs (1)
112builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(garnet, async (@event, ct) =>
Aspire.Hosting.Kafka (1)
KafkaBuilderExtensions.cs (1)
41builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(kafka, async (@event, ct) =>
Aspire.Hosting.MongoDB (2)
MongoDBBuilderExtensions.cs (2)
62builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBContainer, async (@event, ct) => 113builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBDatabase, async (@event, ct) =>
Aspire.Hosting.MySql (2)
MySqlBuilderExtensions.cs (2)
43builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(resource, async (@event, ct) => 109builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mySqlDatabase, async (@event, ct) =>
Aspire.Hosting.Nats (1)
NatsBuilderExtensions.cs (1)
60builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(nats, async (@event, ct) =>
Aspire.Hosting.Oracle (1)
OracleDatabaseBuilderExtensions.cs (1)
43builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(oracleDatabaseServer, async (@event, ct) =>
Aspire.Hosting.PostgreSQL (2)
PostgresBuilderExtensions.cs (2)
56builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresServer, async (@event, ct) => 152builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresDatabase, async (@event, ct) =>
Aspire.Hosting.Qdrant (1)
QdrantBuilderExtensions.cs (1)
52builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrant, async (@event, ct) =>
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
233builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrantResource, (e, ct) =>
Aspire.Hosting.RabbitMQ (1)
RabbitMQBuilderExtensions.cs (1)
45builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(rabbitMq, async (@event, ct) =>
Aspire.Hosting.Redis (1)
RedisBuilderExtensions.cs (1)
74builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(redis, async (@event, ct) =>
Aspire.Hosting.Tests (3)
Orchestrator\ApplicationOrchestratorTests.cs (3)
364applicationEventing.Subscribe<ConnectionStringAvailableEvent>(parentResource.Resource, (_, _) => 369applicationEventing.Subscribe<ConnectionStringAvailableEvent>(childResource.Resource, (_, _) => 374applicationEventing.Subscribe<ConnectionStringAvailableEvent>(grandChildResource.Resource, (_, _) =>
Aspire.Hosting.Valkey (1)
ValkeyBuilderExtensions.cs (1)
125builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(valkey, async (@event, ct) =>