15 instantiations of ConnectionStringAvailableEvent
Aspire.Hosting (2)
ConnectionStringBuilderExtensions.cs (1)
102await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
Orchestrator\ApplicationOrchestrator.cs (1)
750var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(resource, _serviceProvider);
Aspire.Hosting.Azure (1)
AzureProvisioningController.cs (1)
4235var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(targetResource, serviceProvider);
Aspire.Hosting.Azure.Tests (1)
AzureCosmosDBExtensionsTests.cs (1)
1158await builder.Eventing.PublishAsync(new ConnectionStringAvailableEvent(cosmos.Resource, app.Services));
Aspire.Hosting.Foundry (1)
FoundryExtensions.cs (1)
444var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(deployment, @event.Services);
Aspire.Hosting.Kafka.Tests (3)
AddKafkaTests.cs (3)
31await builder.Eventing.PublishAsync(new ConnectionStringAvailableEvent(kafka.Resource, app.Services)); 47await builder.Eventing.PublishAsync(new ConnectionStringAvailableEvent(kafka1.Resource, app.Services)); 48await builder.Eventing.PublishAsync(new ConnectionStringAvailableEvent(kafka2.Resource, app.Services));
Aspire.Hosting.MongoDB (1)
ReplicaSet\MongoDBReplicaSetBuilderExtensions.cs (1)
131await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(resource, evt.Services), ct)
Aspire.Hosting.OpenAI (2)
OpenAIExtensions.cs (2)
91await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct) 136await evt.Eventing.PublishAsync(new ConnectionStringAvailableEvent(r, evt.Services), ct)
Aspire.Hosting.SqlServer.Tests (2)
AddSqlServerTests.cs (2)
321await builder.Eventing.PublishAsync(new ConnectionStringAvailableEvent(sqlServer.Resource, app.Services)); 322await builder.Eventing.PublishAsync(new ConnectionStringAvailableEvent(db.Resource, app.Services));
Aspire.Hosting.Tests (2)
Orchestrator\ApplicationOrchestratorTests.cs (2)
514await applicationEventing.PublishAsync(new ConnectionStringAvailableEvent(resource.Resource, app.Services), CancellationToken.None); 515await applicationEventing.PublishAsync(new ConnectionStringAvailableEvent(resource.Resource, app.Services), CancellationToken.None);
31 references to ConnectionStringAvailableEvent
Aspire.Hosting (7)
ApplicationModel\ConnectionStringAvailableEvent.cs (1)
9/// The <see cref="ConnectionStringAvailableEvent"/> is raised when a connection string becomes available for a resource.
Ats\EventingExports.cs (1)
104internal static IResourceBuilder<T> OnConnectionStringAvailable<T>(this IResourceBuilder<T> builder, Func<ConnectionStringAvailableEvent, Task> callback)
DistributedApplicationEventingExtensions.cs (2)
78/// Subscribes a callback to the <see cref="ConnectionStringAvailableEvent"/> event for <paramref name="builder"/>. 86public static IResourceBuilder<T> OnConnectionStringAvailable<T>(this IResourceBuilder<T> builder, Func<T, ConnectionStringAvailableEvent, CancellationToken, Task> callback)
Orchestrator\ApplicationOrchestrator.cs (3)
77_eventing.Subscribe<ConnectionStringAvailableEvent>(PublishConnectionStringValue); 82private async Task PublishConnectionStringValue(ConnectionStringAvailableEvent @event, CancellationToken token) 750var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(resource, _serviceProvider);
Aspire.Hosting.Azure (1)
AzureProvisioningController.cs (1)
4235var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(targetResource, serviceProvider);
Aspire.Hosting.Azure.Storage (2)
AzureStorageExtensions.cs (2)
221var 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."); 224var 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.Foundry (1)
FoundryExtensions.cs (1)
444var connectionStringAvailableEvent = new ConnectionStringAvailableEvent(deployment, @event.Services);
Aspire.Hosting.Garnet (1)
GarnetBuilderExtensions.cs (1)
116builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(garnet, async (@event, ct) =>
Aspire.Hosting.Kafka (1)
KafkaBuilderExtensions.cs (1)
44builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(kafka, async (@event, ct) =>
Aspire.Hosting.MongoDB (1)
MongoDBBuilderExtensions.cs (1)
274builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mongoDBDatabase, async (@event, ct) =>
Aspire.Hosting.MySql (2)
MySqlBuilderExtensions.cs (2)
49builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(resource, async (@event, ct) => 179builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(mySqlDatabase, async (@event, ct) =>
Aspire.Hosting.Nats (1)
NatsBuilderExtensions.cs (1)
64builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(nats, async (@event, ct) =>
Aspire.Hosting.Oracle (1)
OracleDatabaseBuilderExtensions.cs (1)
45builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(oracleDatabaseServer, async (@event, ct) =>
Aspire.Hosting.PostgreSQL (2)
PostgresBuilderExtensions.cs (2)
66builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresServer, async (@event, ct) => 208builder.ApplicationBuilder.Eventing.Subscribe<ConnectionStringAvailableEvent>(postgresDatabase, async (@event, ct) =>
Aspire.Hosting.Qdrant (1)
QdrantBuilderExtensions.cs (1)
56builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrant, async (@event, ct) =>
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
237builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(qdrantResource, (e, ct) =>
Aspire.Hosting.RabbitMQ (1)
RabbitMQBuilderExtensions.cs (1)
47builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(rabbitMq, async (@event, ct) =>
Aspire.Hosting.Redis (1)
RedisBuilderExtensions.cs (1)
83builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(redis, async (@event, ct) =>
Aspire.Hosting.Tests (6)
Orchestrator\ApplicationOrchestratorTests.cs (6)
433applicationEventing.Subscribe<ConnectionStringAvailableEvent>(parentResource.Resource, (_, _) => 438applicationEventing.Subscribe<ConnectionStringAvailableEvent>(childResource.Resource, (_, _) => 443applicationEventing.Subscribe<ConnectionStringAvailableEvent>(grandChildResource.Resource, (_, _) => 472applicationEventing.Subscribe<ConnectionStringAvailableEvent>(resource.Resource, (_, _) => 474observedEvents.Add(nameof(ConnectionStringAvailableEvent)); 491eventName => Assert.Equal(nameof(ConnectionStringAvailableEvent), eventName),
Aspire.Hosting.Valkey (1)
ValkeyBuilderExtensions.cs (1)
132builder.Eventing.Subscribe<ConnectionStringAvailableEvent>(valkey, async (@event, ct) =>