writers

package

v4.71.0 Latest Latest Go to latest Published: Dec 9, 2024 License: MPL-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MsgType int

const (
	MsgTypeUnset MsgType = iota
	MsgTypeMigrateTable
	MsgTypeInsert
	MsgTypeDeleteStale
	MsgTypeDeleteRecord
)

func MsgID(msg message.WriteMessage) MsgType

type Ticker interface {
	Stop()
	Reset(d time.Duration)
	Chan() <-chan time.Time
}

func NewTicker(interval time.Duration) Ticker

type TickerFunc func(time.Duration) Ticker

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

Path	Synopsis
batchwriter
mixedbatchwriter
streamingbatchwriter Package streamingbatchwriter provides a writers.Writer implementation that writes to a client that implements the streamingbatchwriter.Client interface.	Package streamingbatchwriter provides a writers.Writer implementation that writes to a client that implements the streamingbatchwriter.Client interface.