Versions in this module Expand all Collapse all v1 v1.0.0 Mar 17, 2017 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) 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