stablestore

Documentation

Index

• Constants
• type BoltDBStore
  • func NewBoltDBStore(conf *BoltDBStoreConfig) (*BoltDBStore, error)
  • func (s *BoltDBStore) Close() error
  • func (s *BoltDBStore) Get(key []byte) ([]byte, error)
  • func (s *BoltDBStore) GetBatch(keys []string) (map[string][]byte, error)
  • func (s *BoltDBStore) Put(key []byte, value []byte) error
• type BoltDBStoreConfig
• type InmemStableStore
  • func NewInmemStableStore() *InmemStableStore
  • func (i *InmemStableStore) Close() error
  • func (i *InmemStableStore) Get(key []byte) ([]byte, error)
  • func (i *InmemStableStore) GetBatch(keys []string) (map[string][]byte, error)
  • func (i *InmemStableStore) Put(key []byte, val []byte) error
• type StableStore

Constants

const (
	VDLMetadataFile = "vdl.db"
	BucketName      = "vdl_metadata"
)

Types

type BoltDBStore

type BoltDBStore struct {
	Conf       *BoltDBStoreConfig
	DB         *bolt.DB
	BucketName []byte
}

func NewBoltDBStore

func NewBoltDBStore(conf *BoltDBStoreConfig) (*BoltDBStore, error)

func (*BoltDBStore) Close

func (s *BoltDBStore) Close() error

func (*BoltDBStore) Get

func (s *BoltDBStore) Get(key []byte) ([]byte, error)

func (*BoltDBStore) GetBatch

func (s *BoltDBStore) GetBatch(keys []string) (map[string][]byte, error)

func (*BoltDBStore) Put

func (s *BoltDBStore) Put(key []byte, value []byte) error

type BoltDBStoreConfig

type BoltDBStoreConfig struct {
	//boltdb dir
	Dir string
}

type InmemStableStore

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

InmemStore implements the LogStore and StableStore interface. It should NOT EVER be used for production. It is used only for unit tests. Use the MDBStore implementation instead.

func NewInmemStableStore

func NewInmemStableStore() *InmemStableStore

NewInmemStore returns a new in-memory backend. Do not ever use for production. Only for testing.

func (*InmemStableStore) Close

func (i *InmemStableStore) Close() error

func (*InmemStableStore) Get

func (i *InmemStableStore) Get(key []byte) ([]byte, error)

func (*InmemStableStore) GetBatch

func (i *InmemStableStore) GetBatch(keys []string) (map[string][]byte, error)

func (*InmemStableStore) Put

func (i *InmemStableStore) Put(key []byte, val []byte) error

type StableStore

type StableStore interface {
	Put(key []byte, value []byte) error

	// Get returns the value for key, or an empty byte slice if key was not found.
	Get(key []byte) ([]byte, error)

	Close() error

	GetBatch(keys []string) (map[string][]byte, error)
}

StableStore is used to provide stable storage of key configurations to ensure safety.