Documentation
¶
Index ¶
- func BuildCreateTableRequest(table storage.Table, shardVersionUpdate metadata.ShardVersionUpdate, ...) eventdispatch.CreateTableOnShardRequest
- func CreateTableMetadata(ctx context.Context, c *metadata.ClusterMetadata, schemaName string, ...) (metadata.CreateTableResult, error)
- func CreateTableOnShard(ctx context.Context, c *metadata.ClusterMetadata, ...) error
- func DispatchDropTable(ctx context.Context, clusterMetadata *metadata.ClusterMetadata, ...) error
- func GetShardVersionByTableName(clusterMetadata *metadata.ClusterMetadata, schemaName, tableName string, ...) (storage.Table, metadata.ShardVersionUpdate, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildCreateTableRequest ¶
func BuildCreateTableRequest(table storage.Table, shardVersionUpdate metadata.ShardVersionUpdate, req *metaservicepb.CreateTableRequest) eventdispatch.CreateTableOnShardRequest
func CreateTableMetadata ¶
func CreateTableMetadata(ctx context.Context, c *metadata.ClusterMetadata, schemaName string, tableName string, shardID storage.ShardID, partitionInfo *clusterpb.PartitionInfo) (metadata.CreateTableResult, error)
func CreateTableOnShard ¶
func CreateTableOnShard(ctx context.Context, c *metadata.ClusterMetadata, dispatch eventdispatch.Dispatch, shardID storage.ShardID, request eventdispatch.CreateTableOnShardRequest) error
func DispatchDropTable ¶
func DispatchDropTable(ctx context.Context, clusterMetadata *metadata.ClusterMetadata, dispatch eventdispatch.Dispatch, schemaName string, table storage.Table, version metadata.ShardVersionUpdate) error
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.