Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

unitdb

package module

Go to main page

Versions in this module

v0

v0.2.0

Aug 20, 2021

v0.1.1

Jul 8, 2021

Changes in this version

type DB

+ func (db *DB) Sync() error

type Entry

+ Encryption bool

+ func (e *Entry) WithContract(contract uint32) *Entry

+ func (e *Entry) WithEncryption() *Entry

+ func (e *Entry) WithID(id []byte) *Entry

+ func (e *Entry) WithPayload(payload []byte) *Entry

+ func (e *Entry) WithTTL(ttl string) *Entry

type Meter

+ Aborts metrics.Counter

+ Leases metrics.Counter

type Options

+ func WithBackgroundKeyExpiry() Options

+ func WithBatchContract(contract uint32) Options

+ func WithBatchEncryption() Options

+ func WithBatchWriteInterval(dur time.Duration) Options

+ func WithBufferSize(size int64) Options

+ func WithDefaultBatchOptions() Options

+ func WithDefaultFlags() Options

+ func WithDefaultOptions() Options

+ func WithDefaultQueryLimit(limit int) Options

+ func WithDefaultQueryOptions() Options

+ func WithEncryption() Options

+ func WithEncryptionKey(key []byte) Options

+ func WithFreeBlockSize(size int64) Options

+ func WithMaxQueryLimit(limit int) Options

+ func WithMaxSyncDuration(dur time.Duration, interval int) Options

+ func WithMemdbSize(size int64) Options

+ func WithMutable() Options

type Query

+ func NewQuery(topic []byte) *Query

+ func (q *Query) WithContract(contract uint32) *Query

+ func (q *Query) WithLast(dur string) *Query

+ func (q *Query) WithLimit(limit int) *Query

type Varz

+ Aborts int64

+ Leases int64

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