save

Documentation

Index

• func RunWriteConsumer(ctx context.Context, incomingData <-chan *storage.BoundOutputRecord, ...) <-chan ConfirmMsg
• type ConfirmMsg
  • func (cm ConfirmMsg) String() string
• type IgnoredItemMsg
  • func NewIgnoredItemMsg(filePath string, position storage.LogRange) IgnoredItemMsg
  • func (iim IgnoredItemMsg) String() string

Functions

func RunWriteConsumer

func RunWriteConsumer(ctx context.Context, incomingData <-chan *storage.BoundOutputRecord, printOut bool) <-chan ConfirmMsg

RunWriteConsumer runs a dummy (null) write consumer

Types

type ConfirmMsg

type ConfirmMsg struct {
	FilePath string
	Position storage.LogRange
	Error    error
}

func (ConfirmMsg) String

func (cm ConfirmMsg) String() string

type IgnoredItemMsg

type IgnoredItemMsg struct {
	FilePath string
	Position storage.LogRange
}

func NewIgnoredItemMsg

func NewIgnoredItemMsg(filePath string, position storage.LogRange) IgnoredItemMsg

func (IgnoredItemMsg) String

func (iim IgnoredItemMsg) String() string