boltdb

Documentation

Index

• Variables
• func New(endpoint string, options *store.Config) (store.Store, error)
• type BoltDB
  • func (b *BoltDB) AtomicDelete(key string, previous *store.KVPair) error
  • func (b *BoltDB) AtomicPut(key string, value []byte, previous *store.KVPair) (*store.KVPair, error)
  • func (b *BoltDB) Close()
  • func (b *BoltDB) Delete(key string) error
  • func (b *BoltDB) Exists(key string) (bool, error)
  • func (b *BoltDB) List(keyPrefix string) ([]*store.KVPair, error)
  • func (b *BoltDB) Put(key string, value []byte) error

Variables

var (
	// ErrBoltBucketOptionMissing is thrown when boltBcuket config option is missing
	ErrBoltBucketOptionMissing = errors.New("boltBucket config option missing")
)

Functions

func New

func New(endpoint string, options *store.Config) (store.Store, error)

New opens a new BoltDB connection to the specified path and bucket

Types

type BoltDB

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

BoltDB type implements the Store interface

func (*BoltDB) AtomicDelete

func (b *BoltDB) AtomicDelete(key string, previous *store.KVPair) error

AtomicDelete deletes a value at "key" if the key has not been modified in the meantime, throws an error if this is the case

func (*BoltDB) AtomicPut

func (b *BoltDB) AtomicPut(key string, value []byte, previous *store.KVPair) (*store.KVPair, error)

AtomicPut puts a value at "key" if the key has not been modified since the last Put, throws an error if this is the case

func (*BoltDB) Close

func (b *BoltDB) Close()

Close the db connection to the BoltDB

func (*BoltDB) Delete

func (b *BoltDB) Delete(key string) error

Delete deletes a value at "key". Unlike AtomicDelete it doesn't check whether the deleted key is at a specific version before deleting.

func (*BoltDB) Exists

func (b *BoltDB) Exists(key string) (bool, error)

Exists checks if the key exists inside the store

func (*BoltDB) List

func (b *BoltDB) List(keyPrefix string) ([]*store.KVPair, error)

List returns the range of keys starting with the passed in prefix

func (*BoltDB) Put

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

Put the key, value pair. index number metadata is prepended to the value