Slackbot
02/28/2022, 11:04 AMHardik Agrawal
02/28/2022, 11:05 AMdb, err = splunkgorm.Open(PostgresDriver, connString,
splunksql.WithAttributes([]attribute.KeyValue{
semconv.DBSystemCockroachdb,
semconv.DBNameKey.String("test"),
}),
splunksql.WithTracerProvider(<passed from app>),
)
Hardik Agrawal
02/28/2022, 11:06 AMfunc getTraceProvider(svcName string, server string) (*sdkTrace.TracerProvider, error) {
res, err := sdkResource.Merge(sdkResource.NewWithAttributes(
semconv.SchemaURL,
semconv.ServiceNameKey.String(svcName),
semconv.ServiceNamespaceKey.String(server),
), sdkResource.Default())
if err != nil {
panic(err)
}
provider := sdkTrace.NewTracerProvider(
sdkTrace.WithResource(res),
)
otel.SetTracerProvider(provider)
otel.SetTextMapPropagator(propagation.TraceContext{})
return provider, nil
}
func configureOtlp(ctx context.Context, server, svcName string) (*sdkTrace.TracerProvider, func()) {
provider, err := getTraceProvider(svcName, server)
exp, err := otlptrace.New(
context.Background(),
otlptracegrpc.NewClient(
otlptracegrpc.WithInsecure(),
otlptracegrpc.WithEndpoint("localhost:4317"),
),
)
if err != nil {
panic(err)
}
bsp := sdkTrace.NewBatchSpanProcessor(exp)
provider.RegisterSpanProcessor(bsp)
return provider, func() {
if err := provider.Shutdown(ctx); err != nil {
panic(err)
}
}
}
Pranay
Vishal Sharma
02/28/2022, 12:00 PMHardik Agrawal
02/28/2022, 12:02 PMVishal Sharma
02/28/2022, 12:04 PMHardik Agrawal
02/28/2022, 12:10 PM