Versions in this module Expand all Collapse all v0 v0.7.8 Oct 25, 2024 v0.7.7 Oct 23, 2024 Changes in this version + type ConnectBidiStreamSink struct + 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 struct + 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 struct + 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
Go to main page