yurishkuro

# HELP jaeger_cassandra_attempts_total attempts
# TYPE jaeger_cassandra_attempts_total counter
jaeger_cassandra_attempts_total{table="dependencies"} 0
jaeger_cassandra_attempts_total{table="duration_index"} 0
jaeger_cassandra_attempts_total{table="operation_names_v2"} 0
jaeger_cassandra_attempts_total{table="service_name_index"} 0
jaeger_cassandra_attempts_total{table="service_names"} 0
jaeger_cassandra_attempts_total{table="service_operation_index"} 0
jaeger_cassandra_attempts_total{table="tag_index"} 0
jaeger_cassandra_attempts_total{table="traces"} 0

yurishkuro

[
    {
        "parent": "node_0",
        "child": "node_7",
        "callCount": 4
    },
    {
        "parent": "node_0",
        "child": "node_13",
        "callCount": 10

yurishkuro

func (tm *TracedServeMux) AddHandler(pattern string, handler http.Handler) {
	middleware := nethttp.Middleware(tm.tracer, handler,
		nethttp.MWSpanObserver(func(span opentracing.Span, r *http.Request) {
			if !tm.copyBaggage {
				return
			}
			bag := baggage.FromContext(r.Context())
			for _, m := range bag.Members() {
				span.SetBaggageItem(m.Key(), m.Value())
			}

yurishkuro

var once sync.Once

// Init initializes OpenTelemetry SDK and uses OTel-OpenTracing Bridge
// to return an OpenTracing-compatible tracer.
func Init(serviceName string, exporterType string, ...) opentracing.Tracer {
	once.Do(func() {
		propagation.NewCompositeTextMapPropagator(
			propagation.TraceContext{},
			propagation.Baggage{},
		))

yurishkuro

func createOtelExporter(exporterType string) (sdktrace.SpanExporter, error) {
	var exporter sdktrace.SpanExporter
	var err error
	switch exporterType {
	case "jaeger":
		exporter, err = jaeger.New(
			jaeger.WithCollectorEndpoint(),
		)
	case "otlp":
		client := otlptracehttp.NewClient(

yurishkuro

// Init initializes OpenTelemetry SDK and uses OTel-OpenTracing Bridge
// to return an OpenTracing-compatible tracer.
func Init(
	serviceName string, 
	exporterType string, 
	metricsFactory metrics.Factory, 
	logger log.Factory
) opentracing.Tracer {
	exp, err := createOtelExporter(exporterType)
	if err != nil {

yurishkuro

from opentelemetry import trace
from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.trace.export import BatchSpanProcessor
from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter

trace.set_tracer_provider(TracerProvider())
trace.get_tracer_provider().add_span_processor(
    BatchSpanProcessor(OTLPSpanExporter())
)
tracer = trace.get_tracer(__name__)

yurishkuro

package cassandra

import (
        "errors"
        "sync"
        "sync/atomic"

        "github.com/jaegertracing/jaeger/pkg/cassandra"
        "go.uber.org/zap"
)

yurishkuro

type traceLogger {
  span opentracing.Span
  zl   *zap.Logger
  l    *Logger
}

func (l *Logger) Trace(ctx context.Context) (*zap.Logger, context.Context) {
  span := opentracing.SpanFromContext(ctx)
  if span == nil {
    return l.NoTrace(), ctx

yurishkuro

/* Jaeger test
   Cf. https://github.com/gogo/protobuf/blob/master/extensions.md
   Based on https://github.com/gogo/grpc-example
   
   The JSON is generated with the help of "github.com/cockroachdb/cockroach/pkg/util/protoutil"
   with `EmitDefaults: false` setting
   
        jsonpb := &protoutil.JSONPb{
                EmitDefaults: false,
                Indent:       "  ",