Versions in this module Expand all Collapse all v0 v0.5.0 Oct 25, 2017 Changes in this version + var DefaultMaxSize = int64(100000) + var ONE = make([]byte, 8) + func DefaultOptions() *gorocksdb.Options + type Backpressure struct + CurrentSize int64 + MaxSize int64 + QueueName string + func (bp Backpressure) Error() string + type BackupInfo struct + FileCount int32 + Id int64 + Size int64 + Timestamp int64 + type Queue interface + BPop func(context.Context) ([]byte, error) + Clear func() (int64, error) + Delete func(keys [][]byte) error + Each func(func(index int, k, v []byte) error) error + Name func() string + Page func(int64, int64, func(index int, k, v []byte) error) error + Pop func() ([]byte, error) + Push func([]byte) error + Size func() int64 + type QueueWaiter struct + type SortedSet interface + AddElement func(timestamp string, jid string, payload []byte) error + Clear func() (int64, error) + Each func(func(idx int, key []byte, data []byte) error) error + Get func(key []byte) ([]byte, error) + MoveTo func(SortedSet, string, string, func([]byte) (string, []byte, error)) error + Name func() string + Page func(int64, int64, func(index int, key []byte, data []byte) error) error + Remove func(key []byte) error + RemoveBefore func(timestamp string) ([][]byte, error) + RemoveElement func(timestamp string, jid string) error + Size func() int64 + type Store interface + Backup func() error + Close func() error + Dead func() SortedSet + EachBackup func(func(bi BackupInfo)) error + EachQueue func(func(Queue)) + EnqueueAll func(SortedSet) error + EnqueueFrom func(SortedSet, []byte) error + Flush func() error + GetQueue func(string) (Queue, error) + History func(days int, fn func(day string, procCnt int64, failCnt int64)) error + RestoreFromLatest func() error + Retries func() SortedSet + Scheduled func() SortedSet + Stats func() map[string]string + Working func() SortedSet + func Open(dbtype string, path string) (Store, error) + func OpenRocks(path string) (Store, error) + type Transaction struct
Go to main page