boltcycle

Nov 11, 2019

Changes in this version

+ type CycleDB struct

+ func New(db *bolt.DB, optionalParameters ...DBConfiguration) (*CycleDB, error)

+ func (c *CycleDB) AsyncWrite(ctx context.Context, towrite []KvPair)

+ func (c *CycleDB) Close() error

+ func (c *CycleDB) CycleNodes() error

+ func (c *CycleDB) DB() *bolt.DB

+ func (c *CycleDB) Delete(keys [][]byte) ([]bool, error)

+ func (c *CycleDB) Read(toread [][]byte) ([][]byte, error)

+ func (c *CycleDB) Stats() Stats

+ func (c *CycleDB) VerifyBuckets() error

+ func (c *CycleDB) VerifyCompressed() error

+ func (c *CycleDB) Write(towrite []KvPair) error

+ type DBConfiguration func(*CycleDB) error

+ func AsyncErrors(asyncErrors chan<- error) DBConfiguration

+ func BucketTimesIn(bucketName []byte) DBConfiguration

+ func CycleLen(minNumOldBuckets int) DBConfiguration

+ func ReadMovementBacklog(readMovementBacklog int) DBConfiguration

+ type KvPair struct

+ Key []byte

+ Value []byte

+ type Stats struct

+ RecopyTransactionCount int64

+ SizeOfBacklogToCopy int

+ TotalCycleCount int64

+ TotalDeleteCount int64

+ TotalErrorsDuringRecopy int64

+ TotalItemsAsyncPut int64

+ TotalItemsDeletedDuringRecopy int64

+ TotalItemsRecopied int64

+ TotalReadCount int64

+ TotalReadMovementsAdded int64

+ TotalReadMovementsSkipped int64

+ TotalWriteCount int64

+ func (s *Stats) AtomicClone() Stats