sinks

Documentation

Index

• type CountingSink
  • func NewCountingSink(expectedCount int64) *CountingSink
  • func (s *CountingSink) Close() error
  • func (s *CountingSink) DoneChan() chan int64
  • func (s *CountingSink) Name() string
  • func (s *CountingSink) Open(ctx context.Context) error
  • func (s *CountingSink) Send(ctx context.Context, batch *types.LogBatch) error
• type StdoutSink
  • func NewStdoutSink() *StdoutSink
  • func (s *StdoutSink) Close() error
  • func (s *StdoutSink) Name() string
  • func (s *StdoutSink) Open(ctx context.Context) error
  • func (s *StdoutSink) Send(ctx context.Context, batch *types.LogBatch) error
• type StoreSink
  • func NewStoreSink(config StoreSinkConfig) (*StoreSink, error)
  • func (s *StoreSink) Close() error
  • func (s *StoreSink) Name() string
  • func (s *StoreSink) Open(ctx context.Context) error
  • func (s *StoreSink) Send(ctx context.Context, batch *types.LogBatch) error
• type StoreSinkConfig

Types

type CountingSink

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

func NewCountingSink

func NewCountingSink(expectedCount int64) *CountingSink

func (*CountingSink) Close

func (s *CountingSink) Close() error

func (*CountingSink) DoneChan

func (s *CountingSink) DoneChan() chan int64

func (*CountingSink) Name

func (s *CountingSink) Name() string

func (*CountingSink) Open

func (s *CountingSink) Open(ctx context.Context) error

func (*CountingSink) Send

func (s *CountingSink) Send(ctx context.Context, batch *types.LogBatch) error

type StdoutSink

type StdoutSink struct {
}

func NewStdoutSink

func NewStdoutSink() *StdoutSink

func (*StdoutSink) Close

func (s *StdoutSink) Close() error

func (*StdoutSink) Name

func (s *StdoutSink) Name() string

func (*StdoutSink) Open

func (s *StdoutSink) Open(ctx context.Context) error

func (*StdoutSink) Send

func (s *StdoutSink) Send(ctx context.Context, batch *types.LogBatch) error

type StoreSink

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

func NewStoreSink

func NewStoreSink(config StoreSinkConfig) (*StoreSink, error)

func (*StoreSink) Close

func (s *StoreSink) Close() error

func (*StoreSink) Name

func (s *StoreSink) Name() string

func (*StoreSink) Open

func (s *StoreSink) Open(ctx context.Context) error

func (*StoreSink) Send

func (s *StoreSink) Send(ctx context.Context, batch *types.LogBatch) error

type StoreSinkConfig

type StoreSinkConfig struct {
	Store         storage.Store
	AddAttributes map[string]string
}