storage

Documentation

Index

• Variables
• type Storage
  • func NewStorage(path string) (*Storage, error)
  • func (b *Storage) Close() error
  • func (b *Storage) DeleteRange(min, max uint64) error
  • func (b *Storage) FirstIndex() (uint64, error)
  • func (b *Storage) Get(k []byte) ([]byte, error)
  • func (b *Storage) GetLog(idx uint64, log *raft.Log) error
  • func (b *Storage) GetUint64(key []byte) (uint64, error)
  • func (b *Storage) LastIndex() (uint64, error)
  • func (b *Storage) Set(k, v []byte) error
  • func (b *Storage) SetUint64(key []byte, val uint64) error
  • func (b *Storage) StoreLog(log *raft.Log) error
  • func (b *Storage) StoreLogs(logs []*raft.Log) error
  • func (b *Storage) Sync() error

Variables

var (

	// An error indicating a given key does not exist
	ErrKeyNotFound = errors.New("not found")
)

Types

type Storage

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

func NewStorage

func NewStorage(path string) (*Storage, error)

func (*Storage) Close

func (b *Storage) Close() error

func (*Storage) DeleteRange

func (b *Storage) DeleteRange(min, max uint64) error

func (*Storage) FirstIndex

func (b *Storage) FirstIndex() (uint64, error)

func (*Storage) Get

func (b *Storage) Get(k []byte) ([]byte, error)

func (*Storage) GetLog

func (b *Storage) GetLog(idx uint64, log *raft.Log) error

func (*Storage) GetUint64

func (b *Storage) GetUint64(key []byte) (uint64, error)

func (*Storage) LastIndex

func (b *Storage) LastIndex() (uint64, error)

func (*Storage) Set

func (b *Storage) Set(k, v []byte) error

func (*Storage) SetUint64

func (b *Storage) SetUint64(key []byte, val uint64) error

func (*Storage) StoreLog

func (b *Storage) StoreLog(log *raft.Log) error

func (*Storage) StoreLogs

func (b *Storage) StoreLogs(logs []*raft.Log) error

func (*Storage) Sync

func (b *Storage) Sync() error