1 instantiation of KafkaServerResource
Aspire.Hosting.Kafka.Tests (1)
KafkaPublicApiTests.cs (1)
110var action = () => new KafkaServerResource(name);
19 references to KafkaServerResource
Aspire.Hosting.Kafka (13)
KafkaBuilderExtensions.cs (13)
32public static IResourceBuilder<KafkaServerResource> AddKafka(this IDistributedApplicationBuilder builder, [ResourceName] string name, int? port = null) 37var kafka = new KafkaServerResource(name); 73.WithEndpoint(targetPort: KafkaBrokerPort, port: port, name: KafkaServerResource.PrimaryEndpointName) 74.WithEndpoint(targetPort: KafkaInternalBrokerPort, name: KafkaServerResource.InternalEndpointName) 91public static IResourceBuilder<KafkaServerResource> WithKafkaUI(this IResourceBuilder<KafkaServerResource> builder, Action<IResourceBuilder<KafkaUIContainerResource>>? configureContainer = null, string? containerName = null) 114var kafkaResources = builder.ApplicationBuilder.Resources.OfType<KafkaServerResource>(); 117foreach (var kafkaResource in kafkaResources) 174public static IResourceBuilder<KafkaServerResource> WithDataVolume(this IResourceBuilder<KafkaServerResource> builder, string? name = null, bool isReadOnly = false) 190public static IResourceBuilder<KafkaServerResource> WithDataBindMount(this IResourceBuilder<KafkaServerResource> builder, string source, bool isReadOnly = false) 200private 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)
43IResourceBuilder<KafkaServerResource> builder = null!; 66IResourceBuilder<KafkaServerResource> builder = null!; 77IResourceBuilder<KafkaServerResource> builder = null!;