otel

Documentation

Index

• type Forwarder
  • func NewForwarder(logsForwarder *LogsForwarder, traceForwarder *TraceForwarder) *Forwarder
  • func (f *Forwarder) BackgroundInitClient()
  • func (f *Forwarder) ConfigureRoutes(router *gin.Engine)
• type ForwarderOption
  • func WithAddress(address string) ForwarderOption
  • func WithClientConn(cc grpc.ClientConnInterface) ForwarderOption
  • func WithDialOptions(opts ...grpc.DialOption) ForwarderOption
  • func WithLogger(lg *slog.Logger) ForwarderOption
  • func WithPrivileged(privileged bool) ForwarderOption
• type LogsForwarder
  • func NewLogsForwarder(opts ...ForwarderOption) *LogsForwarder
  • func (f *LogsForwarder) Export(ctx context.Context, request *collogspb.ExportLogsServiceRequest) (*collogspb.ExportLogsServiceResponse, error)
  • func (f *LogsForwarder) SetClient(cc grpc.ClientConnInterface)
• type TraceForwarder
  • func NewTraceForwarder(opts ...ForwarderOption) *TraceForwarder
  • func (f *TraceForwarder) Export(ctx context.Context, request *coltracepb.ExportTraceServiceRequest) (*coltracepb.ExportTraceServiceResponse, error)
  • func (f *TraceForwarder) InitializeTraceForwarder() coltracepb.TraceServiceClient
  • func (f *TraceForwarder) SetClient(cc grpc.ClientConnInterface)

Types

type Forwarder

type Forwarder struct {
	*LogsForwarder
	*TraceForwarder
}

func NewForwarder

func NewForwarder(logsForwarder *LogsForwarder, traceForwarder *TraceForwarder) *Forwarder

func (*Forwarder) BackgroundInitClient

func (f *Forwarder) BackgroundInitClient()

func (*Forwarder) ConfigureRoutes

func (f *Forwarder) ConfigureRoutes(router *gin.Engine)

type ForwarderOption

type ForwarderOption func(*forwarderOptions)

func WithAddress

func WithAddress(address string) ForwarderOption

func WithClientConn

func WithClientConn(cc grpc.ClientConnInterface) ForwarderOption

func WithDialOptions

func WithDialOptions(opts ...grpc.DialOption) ForwarderOption

func WithLogger

func WithLogger(lg *slog.Logger) ForwarderOption

func WithPrivileged

func WithPrivileged(privileged bool) ForwarderOption

type LogsForwarder

type LogsForwarder struct {
	collogspb.UnsafeLogsServiceServer

	Client *util.AsyncClient[collogspb.LogsServiceClient]
	// contains filtered or unexported fields
}

func NewLogsForwarder

func NewLogsForwarder(opts ...ForwarderOption) *LogsForwarder

func (*LogsForwarder) Export

func (f *LogsForwarder) Export(
	ctx context.Context,
	request *collogspb.ExportLogsServiceRequest,
) (*collogspb.ExportLogsServiceResponse, error)

func (*LogsForwarder) SetClient

func (f *LogsForwarder) SetClient(cc grpc.ClientConnInterface)

type TraceForwarder

type TraceForwarder struct {
	coltracepb.UnsafeTraceServiceServer

	Client *util.AsyncClient[coltracepb.TraceServiceClient]
	// contains filtered or unexported fields
}

func NewTraceForwarder

func NewTraceForwarder(opts ...ForwarderOption) *TraceForwarder

func (*TraceForwarder) Export

func (f *TraceForwarder) Export(
	ctx context.Context,
	request *coltracepb.ExportTraceServiceRequest,
) (*coltracepb.ExportTraceServiceResponse, error)

func (*TraceForwarder) InitializeTraceForwarder

func (f *TraceForwarder) InitializeTraceForwarder() coltracepb.TraceServiceClient

func (*TraceForwarder) SetClient

func (f *TraceForwarder) SetClient(cc grpc.ClientConnInterface)