writers

Documentation

Index

• Constants
• type MsgType
  • func MsgID(msg message.WriteMessage) MsgType
• type Writer

Constants

const (
	DefaultBatchTimeoutSeconds = 20
	DefaultBatchSize           = 10000
	DefaultBatchSizeBytes      = 5 * 1024 * 1024 // 5 MiB
)

Types

type MsgType

type MsgType int

const (
	MsgTypeUnset MsgType = iota
	MsgTypeMigrateTable
	MsgTypeInsert
	MsgTypeDeleteStale
)

func MsgID

func MsgID(msg message.WriteMessage) MsgType

type Writer

type Writer interface {
	Write(ctx context.Context, res <-chan message.WriteMessage) error
}