otlpink

Documentation

Index

• type OTLPSink
  • func StartOTLPSink(ctx context.Context, ll *slog.Logger, client collogpb.LogsServiceClient, ...) *OTLPSink
  • func (snk *OTLPSink) Close(ctx context.Context) error
  • func (snk *OTLPSink) Receive(ctx context.Context, ev *typesv1.Log) error

Types

type OTLPSink

type OTLPSink struct {
	// contains filtered or unexported fields
}

func StartOTLPSink

func StartOTLPSink(
	ctx context.Context,
	ll *slog.Logger,
	client collogpb.LogsServiceClient,
	name string,
	resource *typesv1.Resource,
	scope *typesv1.Scope,
	bufferSize int,
	drainBufferFor time.Duration,
	dropIfFull bool,
	notifyUnableToIngest func(err error),
) *OTLPSink

func (*OTLPSink) Close

func (snk *OTLPSink) Close(ctx context.Context) error

Close can only be called once, calling it twice will panic.

func (*OTLPSink) Receive

func (snk *OTLPSink) Receive(ctx context.Context, ev *typesv1.Log) error