Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + func BackgroundLogger() *zap.Logger + func NewDAO(o dao.DAO) dao.DAO + type BatchInsert struct + func NewBatchInsert(dao DAO, timeout time.Duration, maxSize int) *BatchInsert + func (b *BatchInsert) Flush() + func (b *BatchInsert) Put(c *tree.SyncChange) + func (b *BatchInsert) Start() + type ChangeBuffer struct + func (b *ChangeBuffer) Append(c *tree.SyncChange) + func (b *ChangeBuffer) Range() <-chan *list.Element + type ChangeChan <-chan *tree.SyncChange + func (ch ChangeChan) Changes() <-chan *tree.SyncChange + type ChangeOperation interface + GetNodeId func() string + GetSeq func() uint64 + GetSource func() string + GetTarget func() string + OpType func() OpCode + type ChangeStreamer interface + Changes func() <-chan *tree.SyncChange + type DAO interface + Archive func(uint64) error + BulkPut func([]*tree.SyncChange) error + FirstSeq func() (uint64, error) + Get func(uint64, string) (chan *tree.SyncChange, error) + HasNodeById func(id string) (bool, error) + LastSeq func() (uint64, error) + Put func(*tree.SyncChange) error + type OpCode uint8 + func (op OpCode) Create() bool + func (op OpCode) Delete() bool + func (op OpCode) Move() bool + func (op OpCode) Null() bool + func (op OpCode) Update() bool + type StreamConsumer interface + Send func(*tree.SyncChange) error + type StreamOptimizer struct + func NewOptimizer(ctx context.Context, c ChangeStreamer) (o *StreamOptimizer) + func (o StreamOptimizer) Output(ctx context.Context, c StreamConsumer) (err error)
Go to main page