metadata

package

Go to main page

Versions in this module

v1

v1.2.7

Oct 10, 2023

Changes in this version

type ClusterMetadata

+ func (c *ClusterMetadata) GetShardNodes() GetShardNodesResult

+ func (c *ClusterMetadata) GetShards() []storage.ShardID

+ func (c *ClusterMetadata) GetTables(schemaName string, tableNames []string) ([]storage.Table, error)

+ func (c *ClusterMetadata) GetTablesByIDs(tableIDs []storage.TableID) []storage.Table

type GetShardNodesResult

+ ShardNodes []storage.ShardNode

+ Versions map[storage.ShardID]uint64

type TableInfo

+ CreatedAt uint64

type TableManager

+ GetSchema func(schemaName string) (storage.Schema, bool)

+ GetSchemaByID func(schemaID storage.SchemaID) (storage.Schema, bool)

+ GetTables func(schemaName string, tableNames []string) ([]storage.Table, error)

type TableManagerImpl

+ func (m *TableManagerImpl) GetSchema(schemaName string) (storage.Schema, bool)

+ func (m *TableManagerImpl) GetSchemaByID(schemaID storage.SchemaID) (storage.Schema, bool)

+ func (m *TableManagerImpl) GetTables(schemaName string, tableNames []string) ([]storage.Table, error)

type TopologyManager

+ GetShards func() []storage.ShardID

type TopologyManagerImpl

+ func (m *TopologyManagerImpl) GetShards() []storage.ShardID

v1.2.6

Sep 4, 2023

v1.2.5

Jul 27, 2023

Changes in this version

type ShardInfo

+ Status storage.ShardStatus

v1.2.4

Jul 7, 2023

Changes in this version

type ClusterMetadata

+ func (c *ClusterMetadata) GetProcedureExecutingBatchSize() uint32

type CreateClusterOpts

+ ProcedureExecutingBatchSize uint32

type UpdateClusterOpts

+ ProcedureExecutingBatchSize uint32

v1.2.2

May 31, 2023

v1.2.1

May 29, 2023

Changes in this version

+ var ErrStartCluster = coderr.NewCodeError(coderr.Internal, "start cluster")

+ var ErrUpdateCluster = coderr.NewCodeError(coderr.Internal, "update cluster")

type ClusterMetadata

+ func (c *ClusterMetadata) GetCreateTime() uint64

+ func (c *ClusterMetadata) GetEnableSchedule() bool

+ func (c *ClusterMetadata) GetStorageMetadata() storage.Cluster

+ func (c *ClusterMetadata) GetTopologyType() storage.TopologyType

+ func (c *ClusterMetadata) LoadMetadata(ctx context.Context) error

type CreateClusterOpts

+ EnableSchedule bool

+ TopologyType storage.TopologyType

+ type UpdateClusterOpts struct

+ EnableSchedule bool

+ TopologyType storage.TopologyType

v1.2.0

May 6, 2023

Changes in this version

+ const AllocSchemaIDPrefix

+ const AllocTableIDPrefix

+ const HeartbeatKeepAliveIntervalSec

+ const MinShardID

+ const TopologyTypeDynamic

+ const TopologyTypeStatic

+ var ErrClusterAlreadyExists = coderr.NewCodeError(coderr.ClusterAlreadyExists, "cluster already exists")

+ var ErrClusterNotFound = coderr.NewCodeError(coderr.NotFound, "cluster not found")

+ var ErrClusterStateInvalid = coderr.NewCodeError(coderr.Internal, "cluster state invalid")

+ var ErrCreateCluster = coderr.NewCodeError(coderr.BadRequest, "create cluster")

+ var ErrNodeNotFound = coderr.NewCodeError(coderr.NotFound, "NodeName not found")

+ var ErrOpenTable = coderr.NewCodeError(coderr.Internal, "open table")

+ var ErrParseTopologyType = coderr.NewCodeError(coderr.Internal, "parse topology type")

+ var ErrSchemaNotFound = coderr.NewCodeError(coderr.NotFound, "schema not found")

+ var ErrShardNotFound = coderr.NewCodeError(coderr.NotFound, "shard not found")

+ var ErrTableAlreadyExists = coderr.NewCodeError(coderr.Internal, "table already exists")

+ var ErrTableNotFound = coderr.NewCodeError(coderr.NotFound, "table not found")

+ func ConvertShardsInfoToPB(shard ShardInfo) *metaservicepb.ShardInfo

+ func ConvertTableInfoToPB(table TableInfo) *metaservicepb.TableInfo

+ type CloseTableRequest struct

+ NodeName string

+ SchemaName string

+ ShardID storage.ShardID

+ TableName string

+ type ClusterMetadata struct

+ func NewClusterMetadata(meta storage.Cluster, storage storage.Storage, kv clientv3.KV, rootPath string, ...) *ClusterMetadata

+ func (c *ClusterMetadata) AddTableTopology(ctx context.Context, shardID storage.ShardID, table storage.Table) (CreateTableResult, error)

+ func (c *ClusterMetadata) AllocShardID(ctx context.Context) (uint32, error)

+ func (c *ClusterMetadata) CloseTable(ctx context.Context, request CloseTableRequest) (ShardVersionUpdate, error)

+ func (c *ClusterMetadata) CreateShardViews(ctx context.Context, views []CreateShardView) error

+ func (c *ClusterMetadata) CreateTable(ctx context.Context, request CreateTableRequest) (CreateTableResult, error)

+ func (c *ClusterMetadata) CreateTableMetadata(ctx context.Context, request CreateTableMetadataRequest) (CreateTableMetadataResult, error)

+ func (c *ClusterMetadata) DropShardNode(ctx context.Context, shardNodes []storage.ShardNode) error

+ func (c *ClusterMetadata) DropTable(ctx context.Context, schemaName, tableName string) (DropTableResult, error)

+ func (c *ClusterMetadata) DropTableMetadata(ctx context.Context, schemaName, tableName string) (DropTableMetadataResult, error)

+ func (c *ClusterMetadata) GetClusterID() storage.ClusterID

+ func (c *ClusterMetadata) GetClusterMinNodeCount() uint32

+ func (c *ClusterMetadata) GetClusterSnapshot() Snapshot

+ func (c *ClusterMetadata) GetClusterState() storage.ClusterState

+ func (c *ClusterMetadata) GetClusterView() storage.ClusterView

+ func (c *ClusterMetadata) GetClusterViewVersion() uint64

+ func (c *ClusterMetadata) GetNodeShards(_ context.Context) (GetNodeShardsResult, error)

+ func (c *ClusterMetadata) GetOrCreateSchema(ctx context.Context, schemaName string) (storage.Schema, bool, error)

+ func (c *ClusterMetadata) GetRegisteredNodeByName(nodeName string) (RegisteredNode, bool)

+ func (c *ClusterMetadata) GetRegisteredNodes() []RegisteredNode

+ func (c *ClusterMetadata) GetShardNodeByTableIDs(tableIDs []storage.TableID) (GetShardNodesByTableIDsResult, error)

+ func (c *ClusterMetadata) GetShardNodesByShardID(id storage.ShardID) ([]storage.ShardNode, error)

+ func (c *ClusterMetadata) GetShardTables(shardIDs []storage.ShardID) map[storage.ShardID]ShardTables

+ func (c *ClusterMetadata) GetTable(schemaName, tableName string) (storage.Table, bool, error)

+ func (c *ClusterMetadata) GetTotalShardNum() uint32

+ func (c *ClusterMetadata) Init(ctx context.Context) error

+ func (c *ClusterMetadata) Load(ctx context.Context) error

+ func (c *ClusterMetadata) MigrateTable(ctx context.Context, request MigrateTableRequest) error

+ func (c *ClusterMetadata) Name() string

+ func (c *ClusterMetadata) OpenTable(ctx context.Context, request OpenTableRequest) (ShardVersionUpdate, error)

+ func (c *ClusterMetadata) RegisterNode(ctx context.Context, registeredNode RegisteredNode) error

+ func (c *ClusterMetadata) RouteTables(_ context.Context, schemaName string, tableNames []string) (RouteTablesResult, error)

+ func (c *ClusterMetadata) UpdateClusterView(ctx context.Context, state storage.ClusterState, ...) error

+ func (c *ClusterMetadata) UpdateClusterViewByNode(ctx context.Context, shardNodes map[string][]storage.ShardNode) error

+ type CreateClusterOpts struct

+ NodeCount uint32

+ ReplicationFactor uint32

+ ShardTotal uint32

+ type CreateShardView struct

+ ShardID storage.ShardID

+ Tables []storage.TableID

+ type CreateTableMetadataRequest struct

+ PartitionInfo storage.PartitionInfo

+ SchemaName string

+ TableName string

+ type CreateTableMetadataResult struct

+ Table storage.Table

+ type CreateTableRequest struct

+ PartitionInfo storage.PartitionInfo

+ SchemaName string

+ ShardID storage.ShardID

+ TableName string

+ type CreateTableResult struct

+ ShardVersionUpdate ShardVersionUpdate

+ Table storage.Table

+ type DropTableMetadataResult struct

+ Table storage.Table

+ type DropTableResult struct

+ ShardVersionUpdate []ShardVersionUpdate

+ type GetNodeShardsResult struct

+ ClusterTopologyVersion uint64

+ NodeShards []ShardNodeWithVersion

+ type GetShardNodesByTableIDsResult struct

+ ShardNodes map[storage.TableID][]storage.ShardNode

+ Version map[storage.ShardID]uint64

+ type GetShardNodesResult struct

+ type GetShardTablesByNodeResult struct

+ ShardTableIDs map[storage.ShardID]ShardTableIDs

+ type MigrateTableRequest struct

+ NewShardID storage.ShardID

+ OldShardID storage.ShardID

+ SchemaName string

+ TableNames []string

+ type OpenTableRequest struct

+ NodeName string

+ SchemaName string

+ ShardID storage.ShardID

+ TableName string

+ type RegisteredNode struct

+ Node storage.Node

+ ShardInfos []ShardInfo

+ func NewRegisteredNode(meta storage.Node, shardInfos []ShardInfo) RegisteredNode

+ func (n RegisteredNode) IsExpired(now time.Time) bool

+ type RouteEntry struct

+ NodeShards []ShardNodeWithVersion

+ Table TableInfo

+ type RouteTablesResult struct

+ ClusterViewVersion uint64

+ RouteEntries map[string]RouteEntry

+ type ShardInfo struct

+ ID storage.ShardID

+ Role storage.ShardRole

+ Version uint64

+ func ConvertShardsInfoPB(shard *metaservicepb.ShardInfo) ShardInfo

+ type ShardNodeWithVersion struct

+ ShardInfo ShardInfo

+ ShardNode storage.ShardNode

+ type ShardTableIDs struct

+ TableIDs []storage.TableID

+ Version uint64

+ type ShardTables struct

+ Shard ShardInfo

+ Tables []TableInfo

+ type ShardVersionUpdate struct

+ CurrVersion uint64

+ PrevVersion uint64

+ ShardID storage.ShardID

+ type Snapshot struct

+ RegisteredNodes []RegisteredNode

+ Topology Topology

+ type TableInfo struct

+ ID storage.TableID

+ Name string

+ PartitionInfo storage.PartitionInfo

+ SchemaID storage.SchemaID

+ SchemaName string

+ type TableManager interface

+ CreateTable func(ctx context.Context, schemaName string, tableName string, ...) (storage.Table, error)

+ DropTable func(ctx context.Context, schemaName string, tableName string) error

+ GetOrCreateSchema func(ctx context.Context, schemaName string) (storage.Schema, bool, error)

+ GetSchemaByName func(schemaName string) (storage.Schema, bool)

+ GetSchemas func() []storage.Schema

+ GetTable func(schemaName string, tableName string) (storage.Table, bool, error)

+ GetTablesByIDs func(tableIDs []storage.TableID) []storage.Table

+ Load func(ctx context.Context) error

+ func NewTableManagerImpl(storage storage.Storage, clusterID storage.ClusterID, ...) TableManager

+ type TableManagerImpl struct

+ func (m *TableManagerImpl) CreateTable(ctx context.Context, schemaName string, tableName string, ...) (storage.Table, error)

+ func (m *TableManagerImpl) DropTable(ctx context.Context, schemaName string, tableName string) error

+ func (m *TableManagerImpl) GetOrCreateSchema(ctx context.Context, schemaName string) (storage.Schema, bool, error)

+ func (m *TableManagerImpl) GetSchemaByName(schemaName string) (storage.Schema, bool)

+ func (m *TableManagerImpl) GetSchemas() []storage.Schema

+ func (m *TableManagerImpl) GetTable(schemaName, tableName string) (storage.Table, bool, error)

+ func (m *TableManagerImpl) GetTablesByIDs(tableIDs []storage.TableID) []storage.Table

+ func (m *TableManagerImpl) Load(ctx context.Context) error

+ type Tables struct

+ type Topology struct

+ ClusterView storage.ClusterView

+ ShardViewsMapping map[storage.ShardID]storage.ShardView

+ func (t *Topology) IsPrepareFinished() bool

+ func (t *Topology) IsStable() bool

+ type TopologyManager interface

+ AddTable func(ctx context.Context, shardID storage.ShardID, tables []storage.Table) (ShardVersionUpdate, error)

+ CreateShardViews func(ctx context.Context, shardViews []CreateShardView) error

+ DropShardNodes func(ctx context.Context, shardNodes []storage.ShardNode) error

+ EvictTable func(ctx context.Context, tableID storage.TableID) ([]ShardVersionUpdate, error)

+ GetClusterState func() storage.ClusterState

+ GetClusterView func() storage.ClusterView

+ GetShardNodes func() GetShardNodesResult

+ GetShardNodesByID func(shardID storage.ShardID) ([]storage.ShardNode, error)

+ GetShardNodesByTableIDs func(tableID []storage.TableID) (GetShardNodesByTableIDsResult, error)

+ GetTableIDs func(shardIDs []storage.ShardID) map[storage.ShardID]ShardTableIDs

+ GetTopology func() Topology

+ GetVersion func() uint64

+ InitClusterView func(ctx context.Context) error

+ Load func(ctx context.Context) error

+ RemoveTable func(ctx context.Context, shardID storage.ShardID, tableIDs []storage.TableID) (ShardVersionUpdate, error)

+ UpdateClusterView func(ctx context.Context, state storage.ClusterState, ...) error

+ UpdateClusterViewByNode func(ctx context.Context, shardNodes map[string][]storage.ShardNode) error

+ func NewTopologyManagerImpl(storage storage.Storage, clusterID storage.ClusterID, ...) TopologyManager

+ type TopologyManagerImpl struct

+ func (m *TopologyManagerImpl) AddTable(ctx context.Context, shardID storage.ShardID, tables []storage.Table) (ShardVersionUpdate, error)

+ func (m *TopologyManagerImpl) CreateShardViews(ctx context.Context, createShardViews []CreateShardView) error

+ func (m *TopologyManagerImpl) DropShardNodes(ctx context.Context, shardNodes []storage.ShardNode) error

+ func (m *TopologyManagerImpl) EvictTable(ctx context.Context, tableID storage.TableID) ([]ShardVersionUpdate, error)

+ func (m *TopologyManagerImpl) GetClusterState() storage.ClusterState

+ func (m *TopologyManagerImpl) GetClusterView() storage.ClusterView

+ func (m *TopologyManagerImpl) GetShardNodes() GetShardNodesResult

+ func (m *TopologyManagerImpl) GetShardNodesByID(shardID storage.ShardID) ([]storage.ShardNode, error)

+ func (m *TopologyManagerImpl) GetShardNodesByTableIDs(tableIDs []storage.TableID) (GetShardNodesByTableIDsResult, error)

+ func (m *TopologyManagerImpl) GetTableIDs(shardIDs []storage.ShardID) map[storage.ShardID]ShardTableIDs

+ func (m *TopologyManagerImpl) GetTopology() Topology

+ func (m *TopologyManagerImpl) GetVersion() uint64

+ func (m *TopologyManagerImpl) InitClusterView(ctx context.Context) error

+ func (m *TopologyManagerImpl) Load(ctx context.Context) error

+ func (m *TopologyManagerImpl) RemoveTable(ctx context.Context, shardID storage.ShardID, tableIDs []storage.TableID) (ShardVersionUpdate, error)

+ func (m *TopologyManagerImpl) UpdateClusterView(ctx context.Context, state storage.ClusterState, ...) error

+ func (m *TopologyManagerImpl) UpdateClusterViewByNode(ctx context.Context, shardNodes map[string][]storage.ShardNode) error

+ type TopologyType string

+ func ParseTopologyType(rawString string) (TopologyType, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL