18 references to CommonHelpers
Aspire.Confluent.Kafka.Tests (18)
ConsumerConfigurationTests.cs (8)
24new KeyValuePair<string, string?>("ConnectionStrings:messaging", CommonHelpers.TestingEndpoint), 44Assert.Equal(CommonHelpers.TestingEndpoint, config.BootstrapServers); 60static void SetConnectionString(KafkaConsumerSettings settings) => settings.ConnectionString = CommonHelpers.TestingEndpoint; 77Assert.Equal(CommonHelpers.TestingEndpoint, config.BootstrapServers); 90new KeyValuePair<string, string?>("ConnectionStrings:messaging", CommonHelpers.TestingEndpoint), 110Assert.Equal(CommonHelpers.TestingEndpoint, config.BootstrapServers); 133new KeyValuePair<string, string?>("ConnectionStrings:messaging", CommonHelpers.TestingEndpoint), 199Assert.Equal(CommonHelpers.TestingEndpoint, config.BootstrapServers);
MetricsTests.cs (2)
27new KeyValuePair<string, string?>("ConnectionStrings:messaging", CommonHelpers.TestingEndpoint), 144new KeyValuePair<string, string?>("ConnectionStrings:messaging", CommonHelpers.TestingEndpoint),
ProducerConfigurationTests.cs (8)
22new KeyValuePair<string, string?>("ConnectionStrings:messaging", CommonHelpers.TestingEndpoint) 41Assert.Equal(CommonHelpers.TestingEndpoint, config.BootstrapServers); 54static void SetConnectionString(KafkaProducerSettings settings) => settings.ConnectionString = CommonHelpers.TestingEndpoint; 71Assert.Equal(CommonHelpers.TestingEndpoint, config.BootstrapServers); 84new KeyValuePair<string, string?>("ConnectionStrings:messaging", CommonHelpers.TestingEndpoint) 103Assert.Equal(CommonHelpers.TestingEndpoint, config.BootstrapServers); 123new KeyValuePair<string, string?>("ConnectionStrings:messaging", CommonHelpers.TestingEndpoint) 189Assert.Equal(CommonHelpers.TestingEndpoint, config.BootstrapServers);