distribution

Documentation

Index

• Constants
• Variables
• type Barge
  • func NewDistributor(listener net.Listener, options *Options, l timber.Logger) (Barge, error)
• type Decoder
• type Encoder
• type Iterator
• type ObjectSequence
  • func (s *ObjectSequence) Next() (uint8, error)
• type Options
• type Transaction

Constants

const (
	StableStorePrefix = 's'
	LogStorePrefix    = 'l'
)

Variables

var (
	ErrBargeStopped = fmt.Errorf("barge has been stopped")
)

var (
	ErrNotFound = fmt.Errorf("not found")
)

Types

type Barge

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)
}

func NewDistributor

func NewDistributor(listener net.Listener, options *Options, l timber.Logger) (Barge, error)

type Decoder

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

type Encoder

type Encoder interface {
	Encode() []byte
}

type Iterator

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

type ObjectSequence

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

func (*ObjectSequence) Next

func (s *ObjectSequence) Next() (uint8, error)

type Options

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

type Transaction

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
}