writer

Dec 25, 2019

Changes in this version

+ var BatchLimit = 200

+ type BatchAddContext struct

+ func NewBatchAdd(id string, change tablestore.RowChange, future *promise.Future) *BatchAddContext

+ type BatchAddResult struct

+ Err error

+ Id string

+ Value tablestore.RowResult

+ type BatchWriter struct

+ func NewBatchWriter(client tablestore.TableStoreApi, conf *Config) *BatchWriter

+ func (w *BatchWriter) BatchAdd(ctx *BatchAddContext) error

+ func (w *BatchWriter) Close()

+ func (w *BatchWriter) Flush() error

+ type Config struct

+ Concurrent int

+ FlushInterval time.Duration

+ RetryTimeout time.Duration