boltdb

Documentation

Index

• Constants
• type Bulker
  • func NewBulker(s *Store, b int) (*Bulker, error)
  • func (b *Bulker) Close() error
  • func (b *Bulker) Delete(key []byte) error
  • func (b *Bulker) Put(key []byte, value []byte) error
• type Iterator
  • func NewIterator(s *Store) (*Iterator, error)
  • func (i *Iterator) Close() error
  • func (i *Iterator) Key() []byte
  • func (i *Iterator) Next() bool
  • func (i *Iterator) Value() []byte
• type Reader
  • func NewReader(s *Store) (*Reader, error)
  • func (r *Reader) Close() error
  • func (r *Reader) Get(key []byte) ([]byte, error)
• type Store
  • func NewStore(config *StoreConfig) (*Store, error)
  • func (s *Store) Bulker(batchSize int) (*Bulker, error)
  • func (s *Store) Close() error
  • func (s *Store) Iterator() (*Iterator, error)
  • func (s *Store) Reader() (*Reader, error)
  • func (s *Store) SetLogger(logger *log.Logger)
  • func (s *Store) Writer() (*Writer, error)
• type StoreConfig
  • func DefaultConfig() *StoreConfig
• type Writer
  • func NewWriter(s *Store) (*Writer, error)
  • func (w *Writer) Close() error
  • func (w *Writer) Delete(key []byte) error
  • func (w *Writer) Put(key []byte, value []byte) error

Constants

const (
	Filename = "boltdb.db"
	Bucket   = "DB"
)

Types

type Bulker

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

func NewBulker

func NewBulker(s *Store, b int) (*Bulker, error)

func (*Bulker) Close

func (b *Bulker) Close() error

func (*Bulker) Delete

func (b *Bulker) Delete(key []byte) error

func (*Bulker) Put

func (b *Bulker) Put(key []byte, value []byte) error

type Iterator

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

func NewIterator

func NewIterator(s *Store) (*Iterator, error)

func (*Iterator) Close

func (i *Iterator) Close() error

func (*Iterator) Key

func (i *Iterator) Key() []byte

func (*Iterator) Next

func (i *Iterator) Next() bool

func (*Iterator) Value

func (i *Iterator) Value() []byte

type Reader

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

func NewReader

func NewReader(s *Store) (*Reader, error)

func (*Reader) Close

func (r *Reader) Close() error

func (*Reader) Get

func (r *Reader) Get(key []byte) ([]byte, error)

type Store

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

func NewStore

func NewStore(config *StoreConfig) (*Store, error)

func (*Store) Bulker

func (s *Store) Bulker(batchSize int) (*Bulker, error)

func (*Store) Close

func (s *Store) Close() error

func (*Store) Iterator

func (s *Store) Iterator() (*Iterator, error)

func (*Store) Reader

func (s *Store) Reader() (*Reader, error)

func (*Store) SetLogger

func (s *Store) SetLogger(logger *log.Logger)

func (*Store) Writer

func (s *Store) Writer() (*Writer, error)

type StoreConfig

type StoreConfig struct {
	Path    string        `json:"path,omitempty"`
	Mode    os.FileMode   `json:"mode,omitempty"`
	Options *bolt.Options `json:"options,omitempty"`
}

func DefaultConfig

func DefaultConfig() *StoreConfig

type Writer

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

func NewWriter

func NewWriter(s *Store) (*Writer, error)

func (*Writer) Close

func (w *Writer) Close() error

func (*Writer) Delete

func (w *Writer) Delete(key []byte) error

func (*Writer) Put

func (w *Writer) Put(key []byte, value []byte) error