writers

Documentation

Index

• func NewTicker(interval time.Duration) (<-chan time.Time, func())
• type MsgType
  • func MsgID(msg message.WriteMessage) MsgType
• type TickerFunc
• type Writer

Functions

func NewTicker

func NewTicker(interval time.Duration) (<-chan time.Time, func())

Types

type MsgType

type MsgType int

const (
	MsgTypeUnset MsgType = iota
	MsgTypeMigrateTable
	MsgTypeInsert
	MsgTypeDeleteStale
)

func MsgID

func MsgID(msg message.WriteMessage) MsgType

type TickerFunc

type TickerFunc func(interval time.Duration) (ch <-chan time.Time, done func())

type Writer

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