teesink

Documentation

Index

• func NewTeeSink(sinks ...sink.Sink) sink.Sink
• type BatchingTee
  • func (sn *BatchingTee) Close(ctx context.Context) error
  • func (sn *BatchingTee) Receive(ctx context.Context, ev *typesv1.LogEvent) error
  • func (sn *BatchingTee) ReceiveBatch(ctx context.Context, evs []*typesv1.LogEvent) error
• type MixedBatchingTee
  • func (sn *MixedBatchingTee) Close(ctx context.Context) error
  • func (sn *MixedBatchingTee) Receive(ctx context.Context, ev *typesv1.LogEvent) error
  • func (sn *MixedBatchingTee) ReceiveBatch(ctx context.Context, evs []*typesv1.LogEvent) error
• type Tee
  • func (sn *Tee) Close(ctx context.Context) error
  • func (sn *Tee) Receive(ctx context.Context, ev *typesv1.LogEvent) error

Functions

func NewTeeSink

func NewTeeSink(sinks ...sink.Sink) sink.Sink

Types

type BatchingTee

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

func (*BatchingTee) Close

func (sn *BatchingTee) Close(ctx context.Context) error

func (*BatchingTee) Receive

func (sn *BatchingTee) Receive(ctx context.Context, ev *typesv1.LogEvent) error

func (*BatchingTee) ReceiveBatch

func (sn *BatchingTee) ReceiveBatch(ctx context.Context, evs []*typesv1.LogEvent) error

type MixedBatchingTee

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

func (*MixedBatchingTee) Close

func (sn *MixedBatchingTee) Close(ctx context.Context) error

func (*MixedBatchingTee) Receive

func (sn *MixedBatchingTee) Receive(ctx context.Context, ev *typesv1.LogEvent) error

func (*MixedBatchingTee) ReceiveBatch

func (sn *MixedBatchingTee) ReceiveBatch(ctx context.Context, evs []*typesv1.LogEvent) error

type Tee

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

func (*Tee) Close

func (sn *Tee) Close(ctx context.Context) error

func (*Tee) Receive

func (sn *Tee) Receive(ctx context.Context, ev *typesv1.LogEvent) error