|
|
|
|
@ -12,14 +12,12 @@ import (
|
|
|
|
|
"github.com/riverqueue/river/rivertype"
|
|
|
|
|
"github.com/riverqueue/rivercontrib/otelriver"
|
|
|
|
|
"go.opentelemetry.io/otel"
|
|
|
|
|
"go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc"
|
|
|
|
|
"go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc"
|
|
|
|
|
"go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetrichttp"
|
|
|
|
|
"go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp"
|
|
|
|
|
"go.opentelemetry.io/otel/sdk/metric"
|
|
|
|
|
"go.opentelemetry.io/otel/sdk/resource"
|
|
|
|
|
"go.opentelemetry.io/otel/sdk/trace"
|
|
|
|
|
semconv "go.opentelemetry.io/otel/semconv/v1.21.0"
|
|
|
|
|
"google.golang.org/grpc"
|
|
|
|
|
"google.golang.org/grpc/credentials/insecure"
|
|
|
|
|
"os"
|
|
|
|
|
"time"
|
|
|
|
|
)
|
|
|
|
|
@ -112,18 +110,16 @@ func (w *MessageWorker) Timeout(job *river.Job[MessageArgs]) time.Duration {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func setupOTel() (func(context.Context) error, error) {
|
|
|
|
|
// OTLP gRPC exporters for traces and metrics
|
|
|
|
|
traceExp, err := otlptracegrpc.New(context.Background(),
|
|
|
|
|
otlptracegrpc.WithEndpoint("localhost:4317"),
|
|
|
|
|
otlptracegrpc.WithDialOption(grpc.WithTransportCredentials(insecure.NewCredentials())),
|
|
|
|
|
// OTLP HTTP exporters for traces and metrics
|
|
|
|
|
traceExp, err := otlptracehttp.New(context.Background(),
|
|
|
|
|
otlptracehttp.WithEndpoint("0.0.0.0:4318"),
|
|
|
|
|
)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
metricExp, err := otlpmetricgrpc.New(context.Background(),
|
|
|
|
|
otlpmetricgrpc.WithEndpoint("localhost:4317"),
|
|
|
|
|
otlpmetricgrpc.WithDialOption(grpc.WithTransportCredentials(insecure.NewCredentials())),
|
|
|
|
|
metricExp, err := otlpmetrichttp.New(context.Background(),
|
|
|
|
|
otlpmetrichttp.WithEndpoint("0.0.0.0:4318"),
|
|
|
|
|
)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
|
