distribution

type Barge interface {
	Start() error
	WaitForLeader(timeout time.Duration) (string, bool, error)
	IsLeader() bool
	Begin() (Transaction, error)
	Stop() error
	IsStopped() bool
	NodeID() raft.ServerID
	NextObjectID(objectPath []byte) (uint8, error)
}

type Decoder interface {
	Decode(src []byte) error
}

type Encoder interface {
	Encode() []byte
}

type Iterator interface {
	Close()
	Item() *badger.Item
	Next()
	Valid() bool
	Seek(key []byte)
	ValidForPrefix(prefix []byte) bool
	Rewind()
}

type ObjectSequence struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Options struct {
	Directory       string
	ListenAddress   string
	Peers           []string
	Join            bool
	LeaderWaitDelay time.Duration
}

type Transaction interface {
	Get(key []byte, value Decoder) error
	Set(key []byte, value Encoder) error
	SetRaw(key []byte, value []byte) error
	Delete(key []byte) error

	GetKeyIterator(prefix []byte, keyOnly bool, reverse bool) Iterator

	NextObjectID(objectPath []byte) (uint8, error)

	Rollback() error
	Commit() error
}