store

Documentation

Index

• Variables
• type BoltStore
  • func NewBoltStore(path string) (*BoltStore, error)
  • func (bs *BoltStore) Delete(key []byte) error
  • func (bs *BoltStore) DeleteWithClause(fn func(k, v []byte) bool) error
  • func (bs *BoltStore) ForEach(fn func(k, v []byte) error) error
  • func (bs *BoltStore) Get(key []byte) ([]byte, error)
  • func (bs *BoltStore) Length() int
  • func (bs *BoltStore) Put(key []byte, value []byte) error
  • func (bs *BoltStore) Sync() error
• type MemoryStore
  • func NewMemoryStore() *MemoryStore
  • func (m *MemoryStore) Delete(key []byte) error
  • func (m *MemoryStore) DeleteWithClause(fn func(k, v []byte) bool) error
  • func (m *MemoryStore) ForEach(fn func(k, v []byte) error) error
  • func (m *MemoryStore) Get(key []byte) ([]byte, error)
  • func (m *MemoryStore) Length() int
  • func (m *MemoryStore) Put(key []byte, value []byte) error
  • func (m *MemoryStore) Sync() error
• type Store

Variables

var DefaultBucket = []byte("default")

DefaultBucket is used as a default bucket for bolt

Types

type BoltStore

type BoltStore struct {
	Db *bolt.DB
}

BoltStore wraps all the bbol storage logic

func NewBoltStore

func NewBoltStore(path string) (*BoltStore, error)

NewBoltStore inits a BoltStore struct

func (*BoltStore) Delete

func (bs *BoltStore) Delete(key []byte) error

Delete a value using it's key

func (*BoltStore) DeleteWithClause

func (bs *BoltStore) DeleteWithClause(fn func(k, v []byte) bool) error

func (*BoltStore) ForEach

func (bs *BoltStore) ForEach(fn func(k, v []byte) error) error

func (*BoltStore) Get

func (bs *BoltStore) Get(key []byte) ([]byte, error)

Get a value using it's key

func (*BoltStore) Length

func (bs *BoltStore) Length() int

func (*BoltStore) Put

func (bs *BoltStore) Put(key []byte, value []byte) error

Put value associtated to key in the datastore

func (*BoltStore) Sync

func (bs *BoltStore) Sync() error

type MemoryStore

type MemoryStore struct {
	// contains filtered or unexported fields
}

func NewMemoryStore

func NewMemoryStore() *MemoryStore

func (*MemoryStore) Delete

func (m *MemoryStore) Delete(key []byte) error

func (*MemoryStore) DeleteWithClause

func (m *MemoryStore) DeleteWithClause(fn func(k, v []byte) bool) error

func (*MemoryStore) ForEach

func (m *MemoryStore) ForEach(fn func(k, v []byte) error) error

func (*MemoryStore) Get

func (m *MemoryStore) Get(key []byte) ([]byte, error)

func (*MemoryStore) Length

func (m *MemoryStore) Length() int

func (*MemoryStore) Put

func (m *MemoryStore) Put(key []byte, value []byte) error

func (*MemoryStore) Sync

func (m *MemoryStore) Sync() error

type Store

type Store interface {
	Get([]byte) ([]byte, error)
	Put([]byte, []byte) error
	Delete([]byte) error
	Length() int
	Sync() error
	ForEach(func(k, v []byte) error) error
	DeleteWithClause(fn func(k, v []byte) bool) error
}

Store kv stuff