eventdispatch

type CloseShardRequest struct {
	ShardID uint32
}

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

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
}