eventdispatch

type CloseShardRequest struct {
	ShardID uint32
}

type CreateTableOnShardRequest struct {
	UpdateShardInfo      UpdateShardInfo
	TableInfo            cluster.TableInfo
	EncodedSchema        []byte
	Engine               string
	CreateIfNotExist     bool
	Options              map[string]string
	EncodedPartitionInfo []byte
}

type Dispatch interface {
	OpenShard(context context.Context, address string, request OpenShardRequest) error
	CloseShard(context context.Context, address string, request CloseShardRequest) error
	CreateTableOnShard(context context.Context, address string, request CreateTableOnShardRequest) error
	DropTableOnShard(context context.Context, address string, request DropTableOnShardRequest) error
}

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

type DropTableOnShardRequest struct {
	UpdateShardInfo UpdateShardInfo
	TableInfo       cluster.TableInfo
}

type OpenShardRequest struct {
	Shard cluster.ShardInfo
}

type UpdateShardInfo struct {
	CurrShardInfo cluster.ShardInfo
	PrevVersion   uint64
}