anuraaga on update-extensions
anuraaga on master
Update extensions (#164) * Upd… (compare)
jeqo on update-extensions
point to module main page. (compare)
ello Im having trouble getting spring cloud sleuth work with unirest. Can someone help please?
According to https://cloud.spring.io/spring-cloud-sleuth/reference/html/#synchronous-rest-template need to register Unirest as Bean so that sleuth can intercept request and inject trace info.
Any help on how to get this working?
yow can I attach an extra baggage field to current span/scope? If I add baggage field like this:
Optional.ofNullable(BaggageField.getByName("some-header"))
.ifPresent(field -> field.updateValue("some-value"));
then only downstream spans see the value. How can I make it so that current MDC has that value, and revert when current span/scope closes?
curl -fL -o zipkin.jar https://repo1.maven.org/maven2/io/zipkin/zipkin-server/2.22.2/zipkin-server-2.22.2-exec.jar
% Total % Received % Xferd Average Speed Time Time Time Current
Dload Upload Total Spent Left Speed
0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0Warning: Failed to create the file zipkin.jar: Permission denied
0 56.8M 0 1362 0 0 35842 0 0:27:42 --:--:-- 0:27:42 35842
curl: (23) Failed writing body (0 != 1362)
Hi, i'm having trouble in implementing the tracing service in ambassador-gateway with zipkin driver. I had configured the tracing service for ambassador as shown below
apiVersion: getambassador.io/v1
kind: TracingService
metadata:
name: tracing
spec:
config:
collector_endpoint: /api/v2/spans
driver: zipkin
service: jaeger-collector.jaeger:9411
I'm able to the see the traces in jaeger UI ,when i made some requests to the services under that gate way. This time i tried instrumenting the code in one of the services by setting the global tracer with following config:
func initZipkinTracer(service string) {
collectorService := os.Getenv("COLLECTOR_SERVICE")
collectorEndPoint := os.Getenv("COLLECTOR_ENDPOINT")
CollectorURL := "http://" + collectorService + "/" + collectorEndPoint
loglib.Info("Traces collector URL", "jaeger-collector", CollectorURL)
reporter := reporterhttp.NewReporter(CollectorURL)
sampler, err := zipkin.NewCountingSampler(1)
if err != nil {
loglib.Fatal("Unable to initiate the zipkin tracer", "error", err)
}
localEndpoint := &model.Endpoint{ServiceName: service, Port: uint16(viper.GetInt32("grpc-port"))}
t, err := zipkin.NewTracer(
reporter,
zipkin.WithSampler(sampler),
zipkin.WithLocalEndpoint(localEndpoint),
)
if err != nil {
loglib.Fatal("Unable to initiate the zipkin tracer", "error", err)
}
tracer := zipkinot.Wrap(t)
opentracing.SetGlobalTracer(tracer)
}
while creating the server i enabled the tracing in the grpc middleware using otgrpc module as follows:
server.UnaryServerInterceptors(
otgrpc.OpenTracingServerInterceptor(opentracing.GlobalTracer(), otgrpc.LogPayloads()),
)
When i made the requests to services which were under ambassador , i'm getting two separate traces one from the ambassador-gateway and the other from the service where we instrumented the code as specified above .Seems like the service is unable to get the info about ambassador tracer from the request context. The expectation is that i need get only one trace which got initiated at ambassador-api-gateway, and the tracing data generated in the service as child span . What are the changes i need to made to fix this issue?
i have installed the new version of zipkin-helm on my rke cluster, the pods became running but not ready. i have no error in the log just this in the describe:
Readiness probe failed: Get "http://10.42.9.114:9411/health": context deadline exceeded (Client.Timeout exceeded while awaiting headers)
why the readiness failed even if i have no error in the log?
Thanks
Cristian
# We use start period of 30s to avoid marking the container unhealthy on slow or contended CI hosts.
#
# If in production, you have a 30s startup, please report to https://gitter.im/openzipkin/zipkin
# including the values of the /health and /info endpoints as this would be unexpected.
HEALTHCHECK --interval=5s --start-period=30s --timeout=5s CMD ["docker-healthcheck"]
Hi all, just joined to the tracing world and already i have a question.
So we have just setup 2 zipkin servers with 5 node cassandra and 3 node kafka. We can receive/store traces without issues. But when i try to search traces with min or max duration parameter set, server gives
Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /10.110.220.8:9042 (com.datastax.driver.core.exceptions.BusyPoolException: [/10.110.220.8:9042] Pool is busy (no available co
nnection and the queue has reached its max size 40960)), /10.110.220.9:9042 (com.datastax.driver.core.exceptions.BusyPoolException: [/10.110.220.9:9042] Pool is busy (no available connection and the queue has reached its max size 40960)), /10.110.220.6:9042 (com.datastax.
driver.core.exceptions.BusyPoolException: [/10.110.220.6:9042] Pool is busy (no available connection and the queue has reached its max size 40960)), /10.110.220.7:9042, /10.110.220.5:9042 [only showing errors of first 3 hosts, use getErrors() for more details])
errors. Im not sure where to look for debugging so i am open to suggestions.
Also we currently cant calculate dependencies because cron jobs not finishing before the next one starts. So this issue might be related to performance of our cassandra cluster.
cassandra: 3.11.8,
zipkin: 2.21
Thanks,