cluster

Documentation

Index

• Variables
• type CallbackContext
• type Callbacks
• type Cluster
• type KV

Variables

var (
	ErrNotLeader      = errors.New("not leader")
	ErrKeyNotFound    = errors.New("key not found")
	ErrPrefixNotFound = errors.New("prefix not found")
	ErrRestart        = errors.New("restart")
)

Types

type CallbackContext

type CallbackContext interface {
	KV
	Logger() logr.Logger
	ID() string
	Fatal(error)
}

type Callbacks

type Callbacks struct {
	Leader   func(context.Context, CallbackContext)
	Follower func(context.Context, CallbackContext)
	Cleanup  func(context.Context, CallbackContext)
}

type Cluster

type Cluster interface {
	Start(*config.Config) error
	SetCallbacks(Callbacks) error
	Stepdown()
	Stop()
	Reset()
}

type KV

type KV interface {
	Get(k string) ([]byte, error)
	GetPrefix(k string) (map[string][]byte, error)
	Set(k string, v []byte) error
	Delete(k string) error
}