command

type Context interface {
	// WriteBatch returns the write batch for write application's data, it's only used in write command handle.
	WriteBatch() *util.WriteBatch
	// LogIndex log index, the raft log index of the current command, it's only used in write command handle.
	LogIndex() uint64
	// Offset is the index in the current command batch
	Offset() int
	// BatchSize number of the current command batch
	BatchSize() int
	// Attrs returns a map to store attrs
	Attrs() map[string]interface{}
	// ByteBuf returns the bytebuf
	ByteBuf() *buf.ByteBuf
	// DataStorage returns data storage
	DataStorage() storage.DataStorage
	// StoreID returns store id
	StoreID() uint64
}

type LocalCommandFunc func(bhmetapb.Shard, *raftcmdpb.Request) (*raftcmdpb.Response, error)

type ReadCommandFunc func(bhmetapb.Shard, *raftcmdpb.Request, Context) (resp *raftcmdpb.Response, readedBytes uint64)

type WriteCommandFunc func(bhmetapb.Shard, *raftcmdpb.Request, Context) (writeBytes uint64, diffBytes int64, resp *raftcmdpb.Response)