writers

package
v4.99.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 19, 2026 License: MPL-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithFailedTables added in v4.99.0 

func WithFailedTables[T message.WriteMessage](err error, msgs []T) error

WithFailedTables names the tables of msgs in err, so that a flush that fails with it reports them. It returns err as is if it is nil, or if a message has no table name.

Types

type MsgType 

type MsgType int
const (
	MsgTypeUnset MsgType = iota
	MsgTypeMigrateTable
	MsgTypeInsert
	MsgTypeDeleteStale
	MsgTypeDeleteRecord
)

func MsgID 

func MsgID(msg message.WriteMessage) MsgType

type Ticker 

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

func NewTicker 

func NewTicker(interval time.Duration) Ticker

type TickerFunc 

type TickerFunc func(time.Duration) Ticker

type Writer 

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

Source Files

View all Source files

Directories

Path Synopsis
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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.