boltlog

Documentation

Index

• Constants
• type BoltLocalUpdateLog
  • func (q *BoltLocalUpdateLog) Query(l *replicator.LocalUpdateEntry) error
  • func (q *BoltLocalUpdateLog) ReadAllAsync(since time.Time, targ chan<- replicator.LocalUpdateEntry) error
  • func (q *BoltLocalUpdateLog) Update(l *replicator.LocalUpdateEntry) error

Constants

const TSF = "20060102150405.000000000"

Types

type BoltLocalUpdateLog

type BoltLocalUpdateLog struct {
	DB           *bolt.DB
	Table, Index []byte
}

func (*BoltLocalUpdateLog) Query

func (q *BoltLocalUpdateLog) Query(l *replicator.LocalUpdateEntry) error

func (*BoltLocalUpdateLog) ReadAllAsync

func (q *BoltLocalUpdateLog) ReadAllAsync(since time.Time, targ chan<- replicator.LocalUpdateEntry) error

This function MUST return immediately and feed 'targ' in background.

func (*BoltLocalUpdateLog) Update

func (q *BoltLocalUpdateLog) Update(l *replicator.LocalUpdateEntry) error