8 instantiations of ConnectionStringAvailableEvent
Aspire.Hosting (2)
ConnectionStringBuilderExtensions.cs (1)
102await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
Orchestrator\ApplicationOrchestrator.cs (1)
483var 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)
282var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(deployment, @event.Services);
Aspire.Hosting.GitHub.Models (1)
GitHubModelsExtensions.cs (1)
72await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
Aspire.Hosting.OpenAI (2)
OpenAIExtensions.cs (2)
79await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct) 122await 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)
60_eventing.Subscribe<ConnectionStringAvailableEvent>(PublishConnectionStringValue); 65private async Task PublishConnectionStringValue(ConnectionStringAvailableEvent @event, CancellationToken token) 483var 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)
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) =>