batchwriter

Documentation

Index

• type BatchWriter
  • func New(client Client, 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 Client
• type IgnoreMigrateTables
  • func (IgnoreMigrateTables) MigrateTables(context.Context, message.WriteMigrateTables) error
• 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 UnimplementedDeleteStale
  • func (UnimplementedDeleteStale) DeleteStale(context.Context, message.WriteDeleteStales) error

Types

type BatchWriter

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

func New

func New(client Client, 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 Client

type Client interface {
	MigrateTables(context.Context, message.WriteMigrateTables) error
	WriteTableBatch(ctx context.Context, name string, messages message.WriteInserts) error
	DeleteStale(context.Context, message.WriteDeleteStales) error
}

type IgnoreMigrateTables

type IgnoreMigrateTables struct{}

func (IgnoreMigrateTables) MigrateTables

func (IgnoreMigrateTables) MigrateTables(context.Context, message.WriteMigrateTables) error

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 UnimplementedDeleteStale

type UnimplementedDeleteStale struct{}

func (UnimplementedDeleteStale) DeleteStale

func (UnimplementedDeleteStale) DeleteStale(context.Context, message.WriteDeleteStales) error