internal

type Executor interface {
	ExecuteWrite(ctx context.Context, request *proto.WriteRequest) (*proto.WriteResponse, error)
	ExecuteRead(ctx context.Context, request *proto.ReadRequest) (proto.OxiaClient_ReadClient, error)
	ExecuteList(ctx context.Context, request *proto.ListRequest) (proto.OxiaClient_ListClient, error)
}

type ExecutorImpl struct {
	ClientPool     common.ClientPool
	ShardManager   ShardManager
	ServiceAddress string
}

type HashRange struct {
	MinInclusive uint32
	MaxInclusive uint32
}

type Shard struct {
	Id        int64
	Leader    string
	HashRange HashRange
}

type ShardManager interface {
	io.Closer
	Get(key string) int64
	GetAll() []int64
	Leader(shardId int64) string
}

type ShardStrategy interface {
	Get(key string) func(Shard) bool
}