store

type Backend interface {
	// Put is used to insert or update an entry.
	//
	// The entry is added if the key exists or not.
	// If value is changed, true is returned, false is returned only if
	// value stays unchanged.
	//
	// If WithInsert option is used and the key already
	// exists, nothing is done and false is returned. If key does not exist
	// the entry is added and true is returned.
	Put(*Entry, ...PutOption) (bool, error)

	// Get is used to fetch an entry. If key is not found and WithPrefix is absent ErrKeyNotFound is
	// returned.
	Get(string, ...GetOption) ([]Entry, error)

	// Delete is used to permanently delte an entry. The number of deleted keys will be returned.
	Del(string, ...DelOption) (int64, error)

	// Watch a key
	Watch(string, Watcher, ...WatchOption) error

	// WatchChan creates a watcher for a key or prefix and unmarshals events into channel.
	// The channel elements have to implement the store.KeyOpSetter interface.
	WatchChan(string, interface{}, chan error, ...WatchOption) (WatchStarter, error)

	// Close closes the connection.
	Close() error
}

type BackendKeyer interface {
	Backend
	RelKey(k string) string
	AbsKey(k string) string
	JoinKey(args ...string) string
	SplitKey(key string) []string
	KeyLeaf(key string) string
}

type DelOption interface {
	SetDelOption(*DelOptions)
}

type DelOptions struct {
	Prefix  bool
	Context context.Context
}

type Entry struct {
	Key   string
	Value []byte
}

type ErrorFunc func(error) error

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

type FilterFunc func([]byte, []byte) bool

type GetOption interface {
	SetGetOption(*GetOptions)
}

type GetOptions struct {
	Prefix    bool
	Filter    FilterFunc
	Handler   HandlerFunc
	Context   context.Context
	Unmarshal *unmarshal
}

type HandlerFunc func([]byte, []byte) error

type KeyMarshaller interface {
	MarshalKey([]string) error
}

type KeyOpSetter interface {
	SetKey(string)
	SetOp(Operation)
}

type NotifyCallback func()

type Operation string

type PutOption interface {
	SetPutOption(*PutOptions)
}

type PutOptions struct {
	Context context.Context
	TTL     time.Duration
	ErrChan chan<- error
	Insert  bool
}

type WatchOption interface {
	SetWatchOption(*WatchOptions)
}

type WatchOptions struct {
	Prefix        bool
	Context       context.Context
	NotifyCreated NotifyCallback
	ErrorHandler  ErrorFunc
}

type WatchStarter interface {
	Start()
}

type Watcher interface {
	BeforeWatch() error
	BeforeLoop() error
	OnDone() error
	OnPut([]byte, []byte) error
	OnDelete([]byte, []byte) error
}