Skip to content

Commit ab309ac

Browse files
authored
Using FromIConfiguration throughout complete cascade (jaegertracing#138)
1 parent e5afda4 commit ab309ac

File tree

2 files changed

+28
-18
lines changed

2 files changed

+28
-18
lines changed

src/Jaeger/Configuration.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -162,11 +162,11 @@ public static Configuration FromIConfiguration(ILoggerFactory loggerFactory, ICo
162162
ILogger logger = loggerFactory.CreateLogger<Configuration>();
163163

164164
return new Configuration(GetProperty(JaegerServiceName, configuration), loggerFactory)
165-
.WithTracerTags(TracerTagsFromEnv(logger, configuration))
165+
.WithTracerTags(TracerTagsFromIConfiguration(logger, configuration))
166166
.WithTraceId128Bit(GetPropertyAsBool(JaegerTraceId128Bit, logger, configuration).GetValueOrDefault(false))
167-
.WithReporter(ReporterConfiguration.FromEnv(loggerFactory))
168-
.WithSampler(SamplerConfiguration.FromEnv(loggerFactory))
169-
.WithCodec(CodecConfiguration.FromEnv(loggerFactory));
167+
.WithReporter(ReporterConfiguration.FromIConfiguration(loggerFactory, configuration))
168+
.WithSampler(SamplerConfiguration.FromIConfiguration(loggerFactory, configuration))
169+
.WithCodec(CodecConfiguration.FromIConfiguration(loggerFactory, configuration));
170170
}
171171

172172
/// <summary>
@@ -519,7 +519,7 @@ public static ReporterConfiguration FromIConfiguration(ILoggerFactory loggerFact
519519
.WithLogSpans(GetPropertyAsBool(JaegerReporterLogSpans, logger, configuration).GetValueOrDefault(false))
520520
.WithFlushInterval(GetPropertyAsTimeSpan(JaegerReporterFlushInterval, logger, configuration))
521521
.WithMaxQueueSize(GetPropertyAsInt(JaegerReporterMaxQueueSize, logger, configuration))
522-
.WithSender(SenderConfiguration.FromEnv(loggerFactory));
522+
.WithSender(SenderConfiguration.FromIConfiguration(loggerFactory, configuration));
523523
}
524524

525525
/// <summary>
@@ -819,7 +819,7 @@ private static string GetProperty(string name, IConfiguration configuration)
819819
return null;
820820
}
821821

822-
private static Dictionary<string, string> TracerTagsFromEnv(ILogger logger, IConfiguration configuration)
822+
private static Dictionary<string, string> TracerTagsFromIConfiguration(ILogger logger, IConfiguration configuration)
823823
{
824824
Dictionary<string, string> tracerTagMaps = null;
825825
string tracerTags = GetProperty(JaegerTags, configuration);

test/Jaeger.Tests/ConfigurationTests.cs

Lines changed: 22 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ public void TestFromIConfig()
100100
}
101101

102102
[Fact]
103-
public void TestSamplerConst()
103+
public void TestSamplerConstFromEnv()
104104
{
105105
SetProperty(Configuration.JaegerSamplerType, ConstSampler.Type);
106106
SetProperty(Configuration.JaegerSamplerParam, "1");
@@ -138,7 +138,7 @@ public void TestSamplerConstInvalidParam()
138138
}
139139

140140
[Fact]
141-
public void TestReporterConfiguration()
141+
public void TestReporterConfigurationFromEnv()
142142
{
143143
SetProperty(Configuration.JaegerReporterLogSpans, "true");
144144
SetProperty(Configuration.JaegerAgentHost, "MyHost");
@@ -153,28 +153,38 @@ public void TestReporterConfiguration()
153153
Assert.Equal(1000, reporterConfig.MaxQueueSize);
154154
}
155155

156-
[Fact]
157-
public void TestReporterConfigurationInvalidFlushInterval()
158-
{
159-
SetProperty(Configuration.JaegerReporterFlushInterval, "X");
160-
ReporterConfiguration reporterConfig = ReporterConfiguration.FromEnv(_loggerFactory);
161-
Assert.Null(reporterConfig.FlushInterval);
162-
}
163-
164156
[Fact]
165157
public void TestReporterConfigurationFromIConfiguration()
166158
{
167159
var arrayDict = new Dictionary<string, string>
168160
{
169-
{Configuration.JaegerReporterLogSpans, "X"},
161+
{Configuration.JaegerSamplerType, ConstSampler.Type},
162+
{Configuration.JaegerSamplerParam, "1"},
163+
{Configuration.JaegerReporterLogSpans, "true"},
164+
{Configuration.JaegerAgentHost, "MyHost"},
165+
{Configuration.JaegerAgentPort, "1234"},
166+
{Configuration.JaegerReporterFlushInterval, "500"},
167+
{Configuration.JaegerReporterMaxQueueSize, "1000"}
170168
};
171169

172170
var configuration = new ConfigurationBuilder()
173171
.AddInMemoryCollection(arrayDict)
174172
.Build();
175173

176174
ReporterConfiguration reporterConfig = ReporterConfiguration.FromIConfiguration(_loggerFactory, configuration);
177-
Assert.False(reporterConfig.LogSpans);
175+
Assert.True(reporterConfig.LogSpans);
176+
Assert.Equal("MyHost", reporterConfig.SenderConfig.AgentHost);
177+
Assert.Equal(1234, reporterConfig.SenderConfig.AgentPort);
178+
Assert.Equal(TimeSpan.FromMilliseconds(500), reporterConfig.FlushInterval);
179+
Assert.Equal(1000, reporterConfig.MaxQueueSize);
180+
}
181+
182+
[Fact]
183+
public void TestReporterConfigurationInvalidFlushInterval()
184+
{
185+
SetProperty(Configuration.JaegerReporterFlushInterval, "X");
186+
ReporterConfiguration reporterConfig = ReporterConfiguration.FromEnv(_loggerFactory);
187+
Assert.Null(reporterConfig.FlushInterval);
178188
}
179189

180190
[Fact]

0 commit comments

Comments
 (0)