redis

Jul 6, 2021

Changes in this version

+ type Buffer struct

+ func NewBuffer(ctx context.Context, rdb *redis.Client, bucket string, bufferSize uint) (*Buffer, error)

+ func (rb *Buffer) Flush()

+ func (rb *Buffer) Len() int

+ func (rb *Buffer) Read() []types.RowSlice

+ func (rb *Buffer) Write(row types.RowSlice)