|
@@ -58,10 +58,7 @@ func createExporter(c Config) (sdktrace.SpanExporter, error) {
|
|
// Just support jaeger and zipkin now, more for later
|
|
// Just support jaeger and zipkin now, more for later
|
|
switch c.Batcher {
|
|
switch c.Batcher {
|
|
case kindJaeger:
|
|
case kindJaeger:
|
|
- u, parseErr := url.Parse(c.Endpoint)
|
|
|
|
- if parseErr != nil {
|
|
|
|
- return nil, fmt.Errorf("invalid jaeger endpoint: %s", c.Endpoint)
|
|
|
|
- }
|
|
|
|
|
|
+ u, _ := url.Parse(c.Endpoint)
|
|
if u.Scheme == "udp" {
|
|
if u.Scheme == "udp" {
|
|
return jaeger.New(jaeger.WithAgentEndpoint(jaeger.WithAgentHost(u.Hostname()), jaeger.WithAgentPort(u.Port())))
|
|
return jaeger.New(jaeger.WithAgentEndpoint(jaeger.WithAgentHost(u.Hostname()), jaeger.WithAgentPort(u.Port())))
|
|
}
|
|
}
|