logger

Documentation

Index

• type Option
  • func WithLogger(log *zap.SugaredLogger) Option
• type ToLog
  • func NewToLog(vertexInstance *dfv1.VertexInstance, fromBuffer isb.BufferReader, ...) (*ToLog, error)
  • func (t *ToLog) Close() error
  • func (t *ToLog) ForceStop()
  • func (t *ToLog) GetName() string
  • func (t *ToLog) GetPartitionIdx() int32
  • func (t *ToLog) IsFull() bool
  • func (t *ToLog) Start() <-chan struct{}
  • func (t *ToLog) Stop()
  • func (t *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(vertexInstance *dfv1.VertexInstance,
	fromBuffer isb.BufferReader,
	fetchWatermark fetch.Fetcher,
	publishWatermark publish.Publisher,
	idleManager wmb.IdleManager,
	opts ...Option) (*ToLog, error)

NewToLog returns ToLog type.

func (*ToLog) Close

func (t *ToLog) Close() error

func (*ToLog) ForceStop

func (t *ToLog) ForceStop()

ForceStop stops sinking

func (*ToLog) GetName

func (t *ToLog) GetName() string

GetName returns the name.

func (*ToLog) GetPartitionIdx

func (t *ToLog) GetPartitionIdx() int32

GetPartitionIdx returns the partition index. for sink it is always 0.

func (*ToLog) IsFull

func (t *ToLog) IsFull() bool

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

func (*ToLog) Start

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

Start starts sinking to Log.

func (*ToLog) Stop

func (t *ToLog) Stop()

Stop stops sinking

func (*ToLog) Write

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

Write writes to the log.