8 instantiations of ConnectionStringAvailableEvent
Aspire.Hosting (2)
ConnectionStringBuilderExtensions.cs (1)
102await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
Orchestrator\ApplicationOrchestrator.cs (1)
570var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(resource, _serviceProvider);
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
263var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(targetResource, serviceProvider);
Aspire.Hosting.Azure.AIFoundry (1)
AzureAIFoundryExtensions.cs (1)
282var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(deployment, @event.Services);
Aspire.Hosting.GitHub.Models (1)
GitHubModelsExtensions.cs (1)
77await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
Aspire.Hosting.OpenAI (2)
OpenAIExtensions.cs (2)
89await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct) 132await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
Aspire.Hosting.Tests (1)
Orchestrator\ApplicationOrchestratorTests.cs (1)
438await applicationEventing.PublishAsync(new ConnectionStringAvailableEvent(resource.Resource, app.Services), CancellationToken.None);
28 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.
DistributedApplicationEventingExtensions.cs (2)
37/// Subscribes a callback to the <see cref="ConnectionStringAvailableEvent"/> event within the AppHost. 43public static IResourceBuilder<T> OnConnectionStringAvailable<T>(this IResourceBuilder<T> builder, Func<T, ConnectionStringAvailableEvent, CancellationToken, Task> callback)
Orchestrator\ApplicationOrchestrator.cs (3)
71_eventing.Subscribe<ConnectionStringAvailableEvent>(PublishConnectionStringValue); 76private async Task PublishConnectionStringValue(ConnectionStringAvailableEvent @event, CancellationToken token) 570var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(resource, _serviceProvider);
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
263var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(targetResource, serviceProvider);
Aspire.Hosting.Azure.AIFoundry (1)
AzureAIFoundryExtensions.cs (1)
282var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(deployment, @event.Services);
Aspire.Hosting.Azure.Storage (2)
AzureStorageExtensions.cs (2)
181var blobConnectionString = 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."); 184var queueConnectionString = await builder.Resource.GetQueueConnectionString().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)
42builder.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) => 122builder.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) => 151builder.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)
232builder.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)
378applicationEventing.Subscribe<ConnectionStringAvailableEvent>(parentResource.Resource, (_, _) => 383applicationEventing.Subscribe<ConnectionStringAvailableEvent>(childResource.Resource, (_, _) => 388applicationEventing.Subscribe<ConnectionStringAvailableEvent>(grandChildResource.Resource, (_, _) =>
Aspire.Hosting.Valkey (1)
ValkeyBuilderExtensions.cs (1)
125builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(valkey, async (@event, ct) =>