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