logsvcsink

Documentation

Index

• type ConnectBidiStreamSink
  • func StartBidiStreamSink(ctx context.Context, ll *slog.Logger, ...) *ConnectBidiStreamSink
  • func (snk *ConnectBidiStreamSink) Flush(ctx context.Context) error
  • func (snk *ConnectBidiStreamSink) Receive(ctx context.Context, ev *typesv1.LogEvent) error
• type ConnectStreamSink
  • func StartStreamSink(ctx context.Context, ll *slog.Logger, ...) *ConnectStreamSink
  • func (snk *ConnectStreamSink) Flush(ctx context.Context) error
  • func (snk *ConnectStreamSink) Receive(ctx context.Context, ev *typesv1.LogEvent) error
• type ConnectUnarySink
  • func StartUnarySink(ctx context.Context, ll *slog.Logger, ...) *ConnectUnarySink
  • func (snk *ConnectUnarySink) Flush(ctx context.Context) error
  • func (snk *ConnectUnarySink) Receive(ctx context.Context, ev *typesv1.LogEvent) error

Types

type ConnectBidiStreamSink

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

func StartBidiStreamSink

func StartBidiStreamSink(
	ctx context.Context,
	ll *slog.Logger,
	client ingestv1connect.IngestServiceClient,
	name string,
	machineID uint64,
	bufferSize int,
	drainBufferFor time.Duration,
	dropIfFull bool,
	notifyUnableToIngest func(err error),
) *ConnectBidiStreamSink

func (*ConnectBidiStreamSink) Flush

func (snk *ConnectBidiStreamSink) Flush(ctx context.Context) error

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

func (*ConnectBidiStreamSink) Receive

func (snk *ConnectBidiStreamSink) Receive(ctx context.Context, ev *typesv1.LogEvent) error

type ConnectStreamSink

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

func StartStreamSink

func StartStreamSink(
	ctx context.Context,
	ll *slog.Logger,
	client ingestv1connect.IngestServiceClient,
	name string,
	machineID uint64,
	bufferSize int,
	drainBufferFor time.Duration,
	dropIfFull bool,
	notifyUnableToIngest func(err error),
) *ConnectStreamSink

func (*ConnectStreamSink) Flush

func (snk *ConnectStreamSink) Flush(ctx context.Context) error

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

func (*ConnectStreamSink) Receive

func (snk *ConnectStreamSink) Receive(ctx context.Context, ev *typesv1.LogEvent) error

type ConnectUnarySink

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

func StartUnarySink

func StartUnarySink(
	ctx context.Context,
	ll *slog.Logger,
	client ingestv1connect.IngestServiceClient,
	name string,
	machineID uint64,
	bufferSize int,
	drainBufferFor time.Duration,
	dropIfFull bool,
	notifyUnableToIngest func(err error),
) *ConnectUnarySink

func (*ConnectUnarySink) Flush

func (snk *ConnectUnarySink) Flush(ctx context.Context) error

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

func (*ConnectUnarySink) Receive

func (snk *ConnectUnarySink) Receive(ctx context.Context, ev *typesv1.LogEvent) error