2 implementations of Services
Microsoft.AspNetCore (1)
Microsoft.Extensions.Hosting (1)
210 references to Services
Aspire.Azure.AI.OpenAI (8)
Aspire.Azure.Data.Tables (6)
Aspire.Azure.Messaging.EventHubs (6)
Aspire.Azure.Messaging.ServiceBus (6)
Aspire.Azure.Messaging.WebPubSub (6)
Aspire.Azure.Search.Documents (6)
Aspire.Azure.Security.KeyVault (6)
Aspire.Azure.Storage.Blobs (6)
Aspire.Azure.Storage.Queues (6)
Aspire.Confluent.Kafka (25)
AspireKafkaConsumerExtensions.cs (12)
125builder.Services.AddSingleton<InstrumentedConsumerBuilder<TKey, TValue>>(sp => CreateConsumerBuilder(sp, configureBuilder, settings));
126builder.Services.AddSingleton<ConsumerConnectionFactory<TKey, TValue>>(sp => CreateConsumerConnectionFactory<TKey, TValue>(sp, settings));
127builder.Services.AddSingleton<IConsumer<TKey, TValue>>(sp => sp.GetRequiredService<ConsumerConnectionFactory<TKey, TValue>>().Create());
131builder.Services.AddKeyedSingleton<InstrumentedConsumerBuilder<TKey, TValue>>(serviceKey, (sp, key) => CreateConsumerBuilder(sp, configureBuilder, settings));
132builder.Services.AddKeyedSingleton<ConsumerConnectionFactory<TKey, TValue>>(serviceKey, (sp, key) => CreateConsumerConnectionFactory<TKey, TValue>(sp, settings, key as string));
133builder.Services.AddKeyedSingleton<IConsumer<TKey, TValue>>(serviceKey, (sp, key) => sp.GetRequiredKeyedService<ConsumerConnectionFactory<TKey, TValue>>(key).Create());
140builder.Services.TryAddSingleton<MetricsChannel>();
141builder.Services.AddHostedService<MetricsService>();
142builder.Services.TryAddSingleton<ConfluentKafkaMetrics>();
145builder.Services.AddOpenTelemetry().WithMetrics(metricBuilderProvider =>
158builder.Services.AddOpenTelemetry().WithTracing(tracing =>
170builder.Services.TryAddKeyedSingleton<KafkaHealthCheck>(healthCheckName,
AspireKafkaProducerExtensions.cs (12)
125builder.Services.AddSingleton<InstrumentedProducerBuilder<TKey, TValue>>(sp => CreateProducerBuilder(sp, configureBuilder, settings));
126builder.Services.AddSingleton<ProducerConnectionFactory<TKey, TValue>>(sp => CreateProducerConnectionFactory<TKey, TValue>(sp, settings));
127builder.Services.AddSingleton<IProducer<TKey, TValue>>(sp => sp.GetRequiredService<ProducerConnectionFactory<TKey, TValue>>().Create());
131builder.Services.AddKeyedSingleton<InstrumentedProducerBuilder<TKey, TValue>>(serviceKey, (sp, key) => CreateProducerBuilder(sp, configureBuilder, settings));
132builder.Services.AddKeyedSingleton<ProducerConnectionFactory<TKey, TValue>>(serviceKey, (sp, key) => CreateProducerConnectionFactory<TKey, TValue>(sp, settings, key as string));
133builder.Services.AddKeyedSingleton<IProducer<TKey, TValue>>(serviceKey, (sp, key) => sp.GetRequiredKeyedService<ProducerConnectionFactory<TKey, TValue>>(key).Create());
140builder.Services.TryAddSingleton<MetricsChannel>();
141builder.Services.AddHostedService<MetricsService>();
142builder.Services.TryAddSingleton<ConfluentKafkaMetrics>();
145builder.Services.AddOpenTelemetry().WithMetrics(metricBuilderProvider =>
158builder.Services.AddOpenTelemetry().WithTracing(tracing =>
170builder.Services.TryAddKeyedSingleton<KafkaHealthCheck>(healthCheckName,
Aspire.Elastic.Clients.Elasticsearch (4)
Aspire.Microsoft.Azure.Cosmos (3)
Aspire.Microsoft.Data.SqlClient (4)
Aspire.Microsoft.EntityFrameworkCore.Cosmos (6)
Aspire.Microsoft.EntityFrameworkCore.SqlServer (8)
Aspire.Milvus.Client (3)
Aspire.MongoDB.Driver (6)
Aspire.MySqlConnector (5)
Aspire.NATS.Net (7)
Aspire.Npgsql (4)
Aspire.Npgsql.EntityFrameworkCore.PostgreSQL (8)
Aspire.OpenAI (5)
Aspire.Oracle.EntityFrameworkCore (7)
Aspire.Pomelo.EntityFrameworkCore.MySql (9)
Aspire.Qdrant.Client (3)
Aspire.RabbitMQ.Client (7)
Aspire.Seq (3)
Aspire.StackExchange.Redis (7)
AspireRedisExtensions.cs (6)
88builder.Services.AddKeyedTransient(optionsName, (sp, _) => new RedisSettingsAdapterService { Settings = settings });
89builder.Services.TryAddTransient<IOptionsFactory<ConfigurationOptions>, ConfigurationOptionsFactory>();
91builder.Services.Configure<ConfigurationOptions>(
103builder.Services.AddSingleton<IConnectionMultiplexer>(sp => CreateConnection(sp, connectionName, DefaultConfigSectionName, optionsName));
107builder.Services.AddKeyedSingleton<IConnectionMultiplexer>(serviceKey, (sp, _) => CreateConnection(sp, connectionName, DefaultConfigSectionName, optionsName));
117builder.Services.AddOpenTelemetry()
Aspire.StackExchange.Redis.DistributedCaching (2)
Aspire.StackExchange.Redis.OutputCaching (2)
Microsoft.AspNetCore.Tests (1)
OrleansServiceDefaults (5)
Playground.ServiceDefaults (5)
Seq.ServiceDefaults (5)
TestingAppHost1.ServiceDefaults (5)
TestShop.ServiceDefaults (5)