writer

Documentation

Index

• Variables
• type BatchAddContext
  • func NewBatchAdd(id string, change tablestore.RowChange, future *promise.Future) *BatchAddContext
• type BatchAddResult
• type BatchWriter
  • 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

Variables

var (

	// BatchLimit is number of changes in a single batchWrite request, BatchLimit must be <= 200
	BatchLimit = 200
)

Types

type BatchAddContext

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

func NewBatchAdd

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

type BatchAddResult

type BatchAddResult struct {
	Id    string
	Value tablestore.RowResult
	Err   error
}

type BatchWriter

type BatchWriter struct {
	tablestore.TableStoreApi
	// contains filtered or unexported fields
}

func NewBatchWriter

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

func (*BatchWriter) BatchAdd

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

func (*BatchWriter) Close

func (w *BatchWriter) Close()

func (*BatchWriter) Flush

func (w *BatchWriter) Flush() error

type Config

type Config struct {
	Concurrent    int
	FlushInterval time.Duration
	RetryTimeout  time.Duration
}