otlp

Documentation

Index

• func NewGrpcServer(addr string, ingester Ingester, tracer trace.Tracer) *grpcServer
• func NewHttpServer(addr string, ingester Ingester) *httpServer
• func NewIngester(tracePersister tracePersister, runRepository runGetter, ...) *ingester
• type Ingester
• type RequestType

Functions

func NewGrpcServer

func NewGrpcServer(addr string, ingester Ingester, tracer trace.Tracer) *grpcServer

func NewHttpServer

func NewHttpServer(addr string, ingester Ingester) *httpServer

func NewIngester

func NewIngester(
	tracePersister tracePersister,
	runRepository runGetter,
	eventEmitter executor.EventEmitter,
	dsRepo *datastore.Repository,
	subManager subscription.Manager,
	tracer trace.Tracer,
) *ingester

Types

type Ingester

type Ingester interface {
	Ingest(ctx context.Context, request *pb.ExportTraceServiceRequest, requestType RequestType) (*pb.ExportTraceServiceResponse, error)
}

type RequestType

type RequestType string

var (
	RequestTypeHTTP RequestType = "HTTP"
	RequestTypeGRPC RequestType = "gRPC"
)