writers

Documentation

Index

• type BatchWriter
  • func NewBatchWriter(client BatchWriterClient, opts ...Option) (*BatchWriter, error)
  • func (w *BatchWriter) Close(context.Context) error
  • func (w *BatchWriter) Flush(ctx context.Context) error
  • func (w *BatchWriter) Write(ctx context.Context, msgs <-chan message.WriteMessage) error
• type BatchWriterClient
• type MixedBatchClient
• type MixedBatchWriter
  • func NewMixedBatchWriter(client MixedBatchClient, opts ...MixedBatchWriterOption) (*MixedBatchWriter, error)
  • func (w *MixedBatchWriter) Write(ctx context.Context, msgChan <-chan message.WriteMessage) error
• type MixedBatchWriterOption
  • func WithMixedBatchWriterBatchSize(size int) MixedBatchWriterOption
  • func WithMixedBatchWriterBatchTimeout(timeout time.Duration) MixedBatchWriterOption
  • func WithMixedBatchWriterLogger(logger zerolog.Logger) MixedBatchWriterOption
  • func WithMixedBatchWriterSizeBytes(size int) MixedBatchWriterOption
• type Option
  • func WithBatchSize(size int) Option
  • func WithBatchSizeBytes(size int) Option
  • func WithBatchTimeout(timeout time.Duration) Option
  • func WithLogger(logger zerolog.Logger) Option
• type Writer

Types

type BatchWriter

type BatchWriter struct {
	// contains filtered or unexported fields
}

func NewBatchWriter

func NewBatchWriter(client BatchWriterClient, opts ...Option) (*BatchWriter, error)

func (*BatchWriter) Close

func (w *BatchWriter) Close(context.Context) error

func (*BatchWriter) Flush

func (w *BatchWriter) Flush(ctx context.Context) error

func (*BatchWriter) Write

func (w *BatchWriter) Write(ctx context.Context, msgs <-chan message.WriteMessage) error

type BatchWriterClient

type BatchWriterClient interface {
	MigrateTables(context.Context, []*message.WriteMigrateTable) error
	WriteTableBatch(ctx context.Context, name string, msgs []*message.WriteInsert) error
	DeleteStale(context.Context, []*message.WriteDeleteStale) error
}

type MixedBatchClient

type MixedBatchClient interface {
	MigrateTableBatch(ctx context.Context, messages []*message.WriteMigrateTable) error
	InsertBatch(ctx context.Context, messages []*message.WriteInsert) error
	DeleteStaleBatch(ctx context.Context, messages []*message.WriteDeleteStale) error
}

MixedBatchClient 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 NewMixedBatchWriter

func NewMixedBatchWriter(client MixedBatchClient, opts ...MixedBatchWriterOption) (*MixedBatchWriter, error)

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 MixedBatchWriterOption

type MixedBatchWriterOption func(writer *MixedBatchWriter)

func WithMixedBatchWriterBatchSize

func WithMixedBatchWriterBatchSize(size int) MixedBatchWriterOption

func WithMixedBatchWriterBatchTimeout

func WithMixedBatchWriterBatchTimeout(timeout time.Duration) MixedBatchWriterOption

func WithMixedBatchWriterLogger

func WithMixedBatchWriterLogger(logger zerolog.Logger) MixedBatchWriterOption

func WithMixedBatchWriterSizeBytes

func WithMixedBatchWriterSizeBytes(size int) MixedBatchWriterOption

type Option

type Option func(*BatchWriter)

func WithBatchSize

func WithBatchSize(size int) Option

func WithBatchSizeBytes

func WithBatchSizeBytes(size int) Option

func WithBatchTimeout

func WithBatchTimeout(timeout time.Duration) Option

func WithLogger

func WithLogger(logger zerolog.Logger) Option

type Writer

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