Versions in this module Expand all Collapse all v0 v0.1.0 May 2, 2020 Changes in this version + const MaxKeys + const MaxSeq + const MaxTopicLength + const MaxValueLength + var DefaultBatchOptions = &BatchOptions + func Debug(context, msg string) + func Fatal(context, msg string, err error) + func Info(context, action string) + func ParseLevel(level string, defaultLevel zerolog.Level) zerolog.Level + func ResponseHandler(w http.ResponseWriter, r *http.Request, data []byte) + type Batch struct + func (b *Batch) Abort() + func (b *Batch) Commit() error + func (b *Batch) Delete(id, topic []byte) error + func (b *Batch) DeleteEntry(e *Entry) error + func (b *Batch) Len() int + func (b *Batch) Put(value []byte) error + func (b *Batch) PutEntry(e *Entry) error + func (b *Batch) Reset() + func (b *Batch) SetOptions(opts *BatchOptions) + func (b *Batch) Write() error + type BatchGroup struct + func (g *BatchGroup) Abort() + func (g *BatchGroup) Add(fn func(*Batch, <-chan struct{}) error) + func (g *BatchGroup) Run() error + type BatchOptions struct + AllowDuplicates bool + Contract uint32 + Encryption bool + Order int8 + Topic []byte + type DB struct + func Open(path string, opts *Options) (*DB, error) + func (db *DB) Batch(fn func(*Batch, <-chan struct{}) error) error + func (db *DB) Close() error + func (db *DB) Count() int64 + func (db *DB) Delete(id, topic []byte) error + func (db *DB) DeleteEntry(e *Entry) error + func (db *DB) ExpireOldEntries() + func (db *DB) FileSize() (int64, error) + func (db *DB) Get(q *Query) (items [][]byte, err error) + func (db *DB) HandleVarz(w http.ResponseWriter, r *http.Request) + func (db *DB) Items(q *Query) (*ItemIterator, error) + func (db *DB) LogSeq() uint64 + func (db *DB) NewBatchGroup() *BatchGroup + func (db *DB) NewContract() (uint32, error) + func (db *DB) NewID() []byte + func (db *DB) Put(topic, value []byte) error + func (db *DB) PutEntry(e *Entry) error + func (db *DB) Seq() uint64 + func (db *DB) SetEntry(e *Entry, payload []byte) error + func (db *DB) Varz() (*Varz, error) + type Entry struct + Contract uint32 + ExpiresAt uint32 + ID []byte + Payload []byte + Topic []byte + func NewEntry(topic, payload []byte) *Entry + func (e *Entry) SetContract(contract uint32) *Entry + func (e *Entry) SetID(id []byte) *Entry + func (e *Entry) SetPayload(payload []byte) *Entry + func (e *Entry) SetTTL(ttl []byte) *Entry + type Filter struct + func (f *Filter) Append(h uint64) + func (f *Filter) Size() int64 + func (f *Filter) Test(h uint64) bool + type Item struct + func (item *Item) Topic() []byte + func (item *Item) Value() []byte + type ItemIterator struct + func (it *ItemIterator) Error() error + func (it *ItemIterator) First() + func (it *ItemIterator) Item() *Item + func (it *ItemIterator) Next() + func (it *ItemIterator) Release() + func (it *ItemIterator) Valid() bool + type Meter struct + Dels metrics.Counter + Gets metrics.Counter + InBytes metrics.Counter + InMsgs metrics.Counter + Leased metrics.Counter + Metrics metrics.Metrics + OutBytes metrics.Counter + OutMsgs metrics.Counter + Puts metrics.Counter + Recovers metrics.Counter + Syncs metrics.Counter + TimeSeries metrics.TimeSeries + func NewMeter() *Meter + func (m *Meter) UnregisterAll() + type Once struct + func (o *Once) Do(f func()) + func (o *Once) Reset() + type Options struct + BackgroundKeyExpiry bool + BackgroundSyncInterval time.Duration + BufferSize int64 + DefaultQueryLimit int + Encryption bool + EncryptionKey []byte + FileSystem fs.FileSystem + LogSize int64 + MaxQueryLimit int + MemdbSize int64 + MinimumFreeBlocksSize int64 + TinyBatchWriteInterval time.Duration + type Query struct + Contract uint32 + Limit int + Topic []byte + type Varz struct + Blocks int64 + Count int64 + Dels int64 + Gets int64 + HMean float64 + InBytes int64 + InMsgs int64 + Leased int64 + Long5p float64 + Max float64 + Min float64 + Now time.Time + OutBytes int64 + OutMsgs int64 + P50 float64 + P75 float64 + P95 float64 + P99 float64 + P999 float64 + Puts int64 + Recovers int64 + Seq int64 + Short5p float64 + Start time.Time + StdDev float64 + Syncs int64 + Uptime string