8 instantiations of ConnectionStringAvailableEvent
Aspire.Hosting (2)
ConnectionStringBuilderExtensions.cs (1)
102await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
Orchestrator\ApplicationOrchestrator.cs (1)
487var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(resource, _serviceProvider);
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
268var 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)
433await 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)
64_eventing.Subscribe<ConnectionStringAvailableEvent>(PublishConnectionStringValue); 69private async Task PublishConnectionStringValue(ConnectionStringAvailableEvent @event, CancellationToken token) 487var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(resource, _serviceProvider);
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
268var 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)
373applicationEventing.Subscribe<ConnectionStringAvailableEvent>(parentResource.Resource, (_, _) => 378applicationEventing.Subscribe<ConnectionStringAvailableEvent>(childResource.Resource, (_, _) => 383applicationEventing.Subscribe<ConnectionStringAvailableEvent>(grandChildResource.Resource, (_, _) =>
Aspire.Hosting.Valkey (1)
ValkeyBuilderExtensions.cs (1)
125builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(valkey, async (@event, ct) =>