logger

Documentation

Index

• type ToLog
  • func NewToLog(ctx context.Context, vertexInstance *dfv1.VertexInstance) (*ToLog, error)
  • func (t *ToLog) Close() error
  • func (t *ToLog) GetName() string
  • func (t *ToLog) GetPartitionIdx() int32
  • func (t *ToLog) IsFull() bool
  • func (t *ToLog) Write(_ context.Context, messages []isb.Message) ([]isb.Offset, []error)

Types

type ToLog

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

ToLog prints the output to a log sinks.

func NewToLog

func NewToLog(ctx context.Context, vertexInstance *dfv1.VertexInstance) (*ToLog, error)

NewToLog returns ToLog type.

func (*ToLog) Close

func (t *ToLog) Close() error

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) Write

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

Write writes to the log.