telem

func ExtractTraceParent(ctx context.Context) string

func Initialize(ctx context.Context, otelcolEndpoint string) error

func InitializeOffline(ctx context.Context) error

func InjectTraceParent(ctx context.Context, traceParent string) context.Context

func RecordProduceError(name string, traceId string, topic string, partition int32, err error)

func RecordSpanError(span trace.Span, err error)

func Shutdown(ctx context.Context)

func SpanContext(ctx context.Context, traceId string) context.Context

func Start(ctx context.Context, name string) (context.Context, trace.Span)

func StartFunc(ctx context.Context) (context.Context, trace.Span)

func StartRequest(ctx context.Context) (context.Context, string, trace.Span)

func StartStep(ctx context.Context, rtxn *rkcy.RtApecsTxn) (context.Context, trace.Span, *rkcypb.ApecsTxn_Step)

func Tracer() trace.Tracer