Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface {
MigrateTableBatch(ctx context.Context, messages message.WriteMigrateTables) error
InsertBatch(ctx context.Context, messages message.WriteInserts) error
DeleteStaleBatch(ctx context.Context, messages message.WriteDeleteStales) error
}
Client is a client that will receive batches of messages with a mixture of tables.
type MixedBatchWriter ¶
type MixedBatchWriter struct {
// contains filtered or unexported fields
}
func (*MixedBatchWriter) Write ¶
func (w *MixedBatchWriter) Write(ctx context.Context, msgChan <-chan message.WriteMessage) error
Write starts listening for messages on the msgChan channel and writes them to the client in batches.
type Option ¶
type Option func(writer *MixedBatchWriter)
func WithBatchSize ¶
func WithBatchSizeBytes ¶
func WithLogger ¶
Source Files
Click to show internal directories.
Click to hide internal directories.