1 instantiation of KafkaServerResource
Aspire.Hosting.Kafka.Tests (1)
KafkaPublicApiTests.cs (1)
99var action = () => new KafkaServerResource(name);
19 references to KafkaServerResource
Aspire.Hosting.Kafka (13)
KafkaBuilderExtensions.cs (13)
30public static IResourceBuilder<KafkaServerResource> AddKafka(this IDistributedApplicationBuilder builder, string name, int? port = null) 35var kafka = new KafkaServerResource(name); 71.WithEndpoint(targetPort: KafkaBrokerPort, port: port, name: KafkaServerResource.PrimaryEndpointName) 72.WithEndpoint(targetPort: KafkaInternalBrokerPort, name: KafkaServerResource.InternalEndpointName) 86public static IResourceBuilder<KafkaServerResource> WithKafkaUI(this IResourceBuilder<KafkaServerResource> builder, Action<IResourceBuilder<KafkaUIContainerResource>>? configureContainer = null, string? containerName = null) 109var kafkaResources = builder.ApplicationBuilder.Resources.OfType<KafkaServerResource>(); 112foreach (var kafkaResource in kafkaResources) 169public static IResourceBuilder<KafkaServerResource> WithDataVolume(this IResourceBuilder<KafkaServerResource> builder, string? name = null, bool isReadOnly = false) 185public static IResourceBuilder<KafkaServerResource> WithDataBindMount(this IResourceBuilder<KafkaServerResource> builder, string source, bool isReadOnly = false) 195private static void ConfigureKafkaContainer(EnvironmentCallbackContext context, KafkaServerResource resource)
Aspire.Hosting.Kafka.Tests (6)
AddKafkaTests.cs (3)
25var containerResource = Assert.Single(appModel.Resources.OfType<KafkaServerResource>()); 67var connectionStringResource = Assert.Single(appModel.Resources.OfType<KafkaServerResource>()) as IResourceWithConnectionString;
KafkaPublicApiTests.cs (3)
39IResourceBuilder<KafkaServerResource> builder = null!; 50IResourceBuilder<KafkaServerResource> builder = null!; 75IResourceBuilder<KafkaServerResource> builder = null!;