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)
33public static IResourceBuilder<KafkaServerResource> AddKafka(this IDistributedApplicationBuilder builder, [ResourceName] string name, int? port = null) 38var kafka = new KafkaServerResource(name); 74.WithEndpoint(targetPort: KafkaBrokerPort, port: port, name: KafkaServerResource.PrimaryEndpointName) 75.WithEndpoint(targetPort: KafkaInternalBrokerPort, name: KafkaServerResource.InternalEndpointName) 92public static IResourceBuilder<KafkaServerResource> WithKafkaUI(this IResourceBuilder<KafkaServerResource> builder, Action<IResourceBuilder<KafkaUIContainerResource>>? configureContainer = null, string? containerName = null) 115var kafkaResources = builder.ApplicationBuilder.Resources.OfType<KafkaServerResource>(); 118foreach (var kafkaResource in kafkaResources) 175public static IResourceBuilder<KafkaServerResource> WithDataVolume(this IResourceBuilder<KafkaServerResource> builder, string? name = null, bool isReadOnly = false) 191public static IResourceBuilder<KafkaServerResource> WithDataBindMount(this IResourceBuilder<KafkaServerResource> builder, string source, bool isReadOnly = false) 201private 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!;