Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrRequestTooLarge = errors.New("put request is too large")
Functions ¶
This section is empty.
Types ¶
type BatcherFactory ¶
type BatcherFactory struct { batch.BatcherFactory Namespace string Executor internal.Executor RequestTimeout time.Duration Metrics *metrics.Metrics }
func NewBatcherFactory ¶
func (*BatcherFactory) NewReadBatcher ¶
func (b *BatcherFactory) NewReadBatcher(shardId *int64) batch.Batcher
func (*BatcherFactory) NewWriteBatcher ¶
func (b *BatcherFactory) NewWriteBatcher(shardId *int64, maxWriteBatchSize int) batch.Batcher
Click to show internal directories.
Click to hide internal directories.