package boltdb

import "github.com/dotcloud/docker/libnetwork/internal/kvstore/boltdb"

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

Source Files ¶

boltdb.go