storage

type Event struct {
	EventType int
	Data      interface{}
}

type Storage interface {
	// Start the storage
	Start() error
	// Close close the storage
	Close()
	// WatchInstance watch instance event
	WatchEvent() chan Event
	// Lock distruibuted lock
	Lock([]byte, []byte, int, time.Duration, bool, func(), metapb.Group) (bool, error)
	// Unlock unlock
	Unlock([]byte, []byte) error
	// Set set key value
	Set([]byte, []byte) error
	// Set set key value with a TTL in seconds
	SetWithTTL([]byte, []byte, int64) error
	// Get returns the value of key
	Get([]byte) ([]byte, error)
	// GetWithGroup returns the value of key
	GetWithGroup([]byte, metapb.Group) ([]byte, error)
	// Delete remove the key from the store
	Delete([]byte) error
	// Scan scan [start,end) data
	Scan([]byte, []byte, uint64) ([][]byte, [][]byte, error)
	// Scan scan [start,end) data
	ScanWithGroup([]byte, []byte, uint64, metapb.Group) ([][]byte, [][]byte, error)
	// PutToQueue put data to queue
	PutToQueue(id uint64, partition uint32, group metapb.Group, data ...[]byte) error
	// PutToQueueAndKV put data to queue and put a kv
	PutToQueueWithKV(id uint64, partition uint32, group metapb.Group, items [][]byte, kvs ...[]byte) error
	// PutToQueueWithKVAndCondition put data to queue and put a kv and a condition
	PutToQueueWithKVAndCondition(id uint64, partition uint32, group metapb.Group, items [][]byte, cond *rpcpb.Condition, kvs ...[]byte) error
	// PutToQueueWithAlloc put data to queue
	PutToQueueWithAlloc(id uint64, group metapb.Group, data ...[]byte) error
	// PutToQueueWithAllocAndKV put data to queue and put a kv
	PutToQueueWithAllocAndKV(id uint64, group metapb.Group, items [][]byte, kvs ...[]byte) error
	// PutToQueueWithAllocAndKVAndCondition put data to queue and put a kv and a condition
	PutToQueueWithAllocAndKVAndCondition(id uint64, group metapb.Group, items [][]byte, cond *rpcpb.Condition, kvs ...[]byte) error
	// ExecCommand exec command
	ExecCommand(cmd interface{}) ([]byte, error)
	// AsyncExecCommand async exec command
	AsyncExecCommand(interface{}, func(interface{}, []byte, error), interface{})
	// ExecCommandWithGroup exec command with group
	ExecCommandWithGroup(interface{}, metapb.Group) ([]byte, error)
	// AsyncExecCommandWithGroup async exec command with group
	AsyncExecCommandWithGroup(interface{}, metapb.Group, func(interface{}, []byte, error), interface{})
	// RaftStore returns the raft store
	RaftStore() raftstore.Store
}