logger

Documentation

Index

• type Option
  • func WithLogger(log *zap.SugaredLogger) Option
• type ToLog
  • func NewToLog(vertex *dfv1.Vertex, fromBuffer isb.BufferReader, fetchWatermark fetch.Fetcher, ...) (*ToLog, error)
  • func (br *ToLog) Close() error
  • func (s *ToLog) ForceStop()
  • func (s *ToLog) GetName() string
  • func (s *ToLog) IsFull() bool
  • func (s *ToLog) Start() <-chan struct{}
  • func (s *ToLog) Stop()
  • func (s *ToLog) Write(_ context.Context, messages []isb.Message) ([]isb.Offset, []error)

Types

type Option

type Option func(*ToLog) error

func WithLogger

func WithLogger(log *zap.SugaredLogger) Option

type ToLog

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

ToLog prints the output to a log sinks.

func NewToLog

func NewToLog(vertex *dfv1.Vertex, fromBuffer isb.BufferReader, fetchWatermark fetch.Fetcher, publishWatermark map[string]publish.Publisher, opts ...Option) (*ToLog, error)

NewToLog returns ToLog type.

func (*ToLog) Close

func (br *ToLog) Close() error

func (*ToLog) ForceStop

func (s *ToLog) ForceStop()

ForceStop stops sinking

func (*ToLog) GetName

func (s *ToLog) GetName() string

GetName returns the name.

func (*ToLog) IsFull

func (s *ToLog) IsFull() bool

IsFull returns whether logging is full, which is never true.

func (*ToLog) Start

func (s *ToLog) Start() <-chan struct{}

Start starts sinking to Log.

func (*ToLog) Stop

func (s *ToLog) Stop()

Stop stops sinking

func (*ToLog) Write

func (s *ToLog) Write(_ context.Context, messages []isb.Message) ([]isb.Offset, []error)

Write writes to the log.