clickhouse

Documentation

Index

• type BatchBuilder
• type Storage
  • func (st *Storage) Close() error
  • func (st *Storage) Start(ctx context.Context) error
  • func (st *Storage) WriteBatchAsync(batch interface{})
• type StorageConfig

Types

type BatchBuilder

type BatchBuilder interface {
	BuildBatch(ctx context.Context, sourceBatch interface{}) (batches []driver.Batch, err error)
}

type Storage

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

func (*Storage) Close

func (st *Storage) Close() error

func (*Storage) Start

func (st *Storage) Start(ctx context.Context) error

func (*Storage) WriteBatchAsync

func (st *Storage) WriteBatchAsync(batch interface{})

type StorageConfig

type StorageConfig struct {
	CurrencyNum int `file:"currency_num" default:"3"`
	RetryNum    int `file:"retry_num" default:"5"`
}