cluster

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

type GetNodesResult struct {
	ClusterTopologyVersion uint64
	NodeShards             []*NodeShard
}

type Manager interface {
	// Start must be called before manager is used.
	Start(ctx context.Context) error
	// Stop must be called before manager is dropped.
	Stop(ctx context.Context) error

	CreateCluster(ctx context.Context, clusterName string, nodeCount, replicationFactor, shardTotal uint32) (*Cluster, error)
	AllocSchemaID(ctx context.Context, clusterName, schemaName string) (uint32, error)
	AllocTableID(ctx context.Context, clusterName, schemaName, tableName, nodeName string) (*Table, error)
	GetTables(ctx context.Context, clusterName, nodeName string, shardIDs []uint32) (map[uint32]*ShardTables, error)
	DropTable(ctx context.Context, clusterName, schemaName, tableName string, tableID uint64) error
	RegisterNode(ctx context.Context, clusterName string, nodeInfo *metaservicepb.NodeInfo) error
	GetShards(ctx context.Context, clusterName, nodeName string) ([]uint32, error)
	RouteTables(ctx context.Context, clusterName, schemaName string, tableNames []string) (*RouteTablesResult, error)
	GetNodes(ctx context.Context, clusterName string) (*GetNodesResult, error)
}

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

type NodeShard struct {
	Endpoint  string
	ShardInfo *ShardInfo
}

type RouteEntry struct {
	Table      *TableInfo
	NodeShards []*NodeShard
}

type RouteTablesResult struct {
	Version      uint64
	RouteEntries map[string]*RouteEntry
}

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

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

type ShardInfo struct {
	ShardID   uint32
	ShardRole clusterpb.ShardRole
	Version   uint64
}

type ShardTables struct {
	ShardRole clusterpb.ShardRole
	Tables    []*TableInfo
	Version   uint64
}

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

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

type TableInfo struct {
	ID         uint64
	Name       string
	SchemaID   uint32
	SchemaName string
}