cluster

package

Go to main page

Versions in this module

v1

v1.2.7

Oct 10, 2023

Changes in this version

type Cluster

+ func (c *Cluster) GetShardNodes() metadata.GetShardNodesResult

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

type Manager

+ GetTablesByIDs func(clusterName string, tableID []storage.TableID) ([]metadata.TableInfo, error)

+ GetTablesByShardIDs func(clusterName, nodeName string, shardIDs []storage.ShardID) (map[storage.ShardID]metadata.ShardTables, error)

+ ListRegisteredNodes func(ctx context.Context, clusterName string) ([]metadata.RegisteredNode, error)

v1.2.6

Sep 4, 2023

v1.2.5

Jul 27, 2023

v1.2.4

Jul 7, 2023

v1.2.2

May 31, 2023

v1.2.1

May 29, 2023

Changes in this version

type Manager

+ UpdateCluster func(ctx context.Context, clusterName string, opt metadata.UpdateClusterOpts) error

v1.2.0

May 6, 2023

Changes in this version

type Cluster

+ func (c *Cluster) GetMetadata() *metadata.ClusterMetadata

+ func (c *Cluster) GetProcedureFactory() *coordinator.Factory

+ func (c *Cluster) GetProcedureManager() procedure.Manager

+ func (c *Cluster) GetSchedulerManager() scheduler.Manager

+ func (c *Cluster) Start(ctx context.Context) error

+ func (c *Cluster) Stop(ctx context.Context) error

type Manager

+ ListRegisterNodes func(ctx context.Context, clusterName string) ([]metadata.RegisteredNode, error)

v1.1.0

Mar 27, 2023

v1.0.0

Feb 22, 2023

Changes in this version

+ const HeartbeatKeepAliveIntervalSec

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

+ type CloseTableRequest struct

+ NodeName string

+ SchemaName string

+ ShardID storage.ShardID

+ TableName string

type Cluster

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

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

+ func (c *Cluster) GetClusterViewVersion() uint64

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

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

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

+ func (c *Cluster) GetShardTables(shardIDs []storage.ShardID, nodeName string) map[storage.ShardID]ShardTables

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

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

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

+ type CreateClusterOpts struct

+ NodeCount uint32

+ ReplicationFactor uint32

+ ShardTotal uint32

+ type CreateShardView struct

+ ShardID storage.ShardID

+ Tables []storage.TableID

+ type CreateTableRequest struct

+ PartitionInfo storage.PartitionInfo

+ SchemaName string

+ ShardID storage.ShardID

+ TableName string

+ 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

+ Node storage.Node

+ ShardInfos []ShardInfo

type RouteTablesResult

+ ClusterViewVersion uint64

type ShardInfo

+ func ConvertShardsInfoPB(shard *metaservicepb.ShardInfo) ShardInfo

+ type ShardNodeWithVersion struct

+ ShardInfo ShardInfo

+ ShardNode storage.ShardNode

+ type ShardTableIDs struct

+ ShardNode storage.ShardNode

+ TableIDs []storage.TableID

+ Version uint64

type TableInfo

+ PartitionInfo storage.PartitionInfo

+ 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 TopologyManager interface

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

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

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

+ GetClusterState func() storage.ClusterState

+ GetShardNodes func() GetShardNodesResult

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

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

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

+ 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

+ 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) EvictTable(ctx context.Context, tableID storage.TableID) ([]ShardVersionUpdate, error)

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

+ 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, nodeName string) map[storage.ShardID]ShardTableIDs

+ 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

v1.0.0-test

Feb 10, 2023

v1.0.0-alpha02

Dec 30, 2022

v0

v0.4.0

Oct 27, 2022

Changes in this version

+ const MinShardID

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

+ var ErrNodeIsEmpty = coderr.NewCodeError(coderr.NotFound, "cluster nodes list is empty")

+ var ErrShardListIsEmpty = coderr.NewCodeError(coderr.NotFound, "cluster shard list is empty")

+ var ErrShardTopologyVersionNotMatch = coderr.NewCodeError(coderr.Internal, "shard topology version not match")

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

+ func ConvertNodeToPB(node *RegisteredNode) *clusterpb.Node

+ func ConvertShardsInfoToPB(shard *ShardInfo) *metaservicepb.ShardInfo

+ func ConvertTableInfoToPB(table *TableInfo) *metaservicepb.TableInfo

type Cluster

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

+ func (c *Cluster) CreateShardTopologies(ctx context.Context, state clusterpb.ClusterTopology_ClusterState, ...) error

+ func (c *Cluster) CreateTable(ctx context.Context, nodeName string, schemaName string, tableName string) (*CreateTableResult, error)

+ func (c *Cluster) GetClusterID() uint32

+ func (c *Cluster) GetClusterMinNodeCount() uint32

+ func (c *Cluster) GetClusterShardView() ([]*clusterpb.Shard, error)

+ func (c *Cluster) GetClusterState() clusterpb.ClusterTopology_ClusterState

+ func (c *Cluster) GetClusterVersion() uint64

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

+ func (c *Cluster) GetRegisteredNode(nodeName string) (*RegisteredNode, bool)

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

+ func (c *Cluster) GetShardByID(id uint32) (*Shard, error)

+ func (c *Cluster) GetShardIDsByNode(nodeName string) ([]uint32, error)

+ func (c *Cluster) GetTotalShardNum() uint32

+ type CreateTableResult struct

+ ShardVersionUpdate *ShardVersionUpdate

+ Table *Table

+ type DropTableResult struct

+ ShardVersionUpdate *ShardVersionUpdate

+ type GetNodeShardsResult struct

+ ClusterTopologyVersion uint64

+ NodeShards []*NodeShard

type Manager

+ GetCluster func(ctx context.Context, clusterName string) (*Cluster, error)

+ GetNodeShards func(ctx context.Context, clusterName string) (*GetNodeShardsResult, error)

+ GetRegisteredNode func(ctx context.Context, clusterName string, node string) (*metaservicepb.NodeInfo, error)

+ GetShardIDs func(ctx context.Context, clusterName, nodeName string) ([]uint32, error)

+ ListClusters func(ctx context.Context) ([]*Cluster, error)

+ type RegisteredNode struct

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

+ func (n *RegisteredNode) GetMeta() *clusterpb.Node

+ func (n *RegisteredNode) GetShardInfos() []*ShardInfo

+ func (n *RegisteredNode) IsOnline() bool

+ func (n RegisteredNode) IsExpired(now uint64, aliveThreshold uint64) bool

type Schema

+ func (s *Schema) GetName() string

type Shard

+ func (s *Shard) FindShardByNode(nodeName string) (*clusterpb.Shard, bool)

+ func (s *Shard) GetLeader() *clusterpb.Shard

+ func (s *Shard) GetVersion() uint64

type ShardInfo

+ ID uint32

+ Role clusterpb.ShardRole

type ShardTables

+ Shard *ShardInfo

+ type ShardVersionUpdate struct

+ CurrVersion uint64

+ PrevVersion uint64

+ ShardID uint32

+ type ShardsOfNode struct

+ Endpoint string

+ ShardIDs []uint32

type Table

+ func (t *Table) GetInfo() TableInfo

v0.3.0

Aug 29, 2022

Changes in this version

+ const AllocClusterIDPrefix

+ const AllocSchemaIDPrefix

+ const AllocTableIDPrefix

+ const DefaultHeartbeatInterval

+ var ErrClusterAlreadyExists = coderr.NewCodeError(coderr.Internal, "clusters already exists")

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

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

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

+ var ErrGetShardTopology = coderr.NewCodeError(coderr.Internal, "get shard topology")

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

+ var ErrNodeShardsIsEmpty = coderr.NewCodeError(coderr.Internal, "node's shard list is empty")

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

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

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

+ type Cluster struct

+ func NewCluster(meta *clusterpb.Cluster, storage storage.Storage, kv clientv3.KV, ...) *Cluster

+ func (c *Cluster) DropTable(ctx context.Context, schemaName, tableName string, tableID uint64) error

+ func (c *Cluster) GetNodes(_ context.Context) (*GetNodesResult, error)

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

+ func (c *Cluster) GetOrCreateTable(ctx context.Context, nodeName string, schemaName string, tableName string) (*Table, error)

+ func (c *Cluster) GetShardIDs(nodeName string) ([]uint32, error)

+ func (c *Cluster) GetTable(ctx context.Context, schemaName, tableName string) (*Table, bool, error)

+ func (c *Cluster) GetTables(_ context.Context, shardIDs []uint32, nodeName string) (map[uint32]*ShardTablesWithRole, error)

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

+ func (c *Cluster) Name() string

+ func (c *Cluster) RegisterNode(ctx context.Context, nodeInfo *metaservicepb.NodeInfo) error

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

+ type GetNodesResult struct

+ ClusterTopologyVersion uint64

+ NodeShards []*NodeShard

+ type Manager interface

+ AllocSchemaID func(ctx context.Context, clusterName, schemaName string) (uint32, error)

+ AllocTableID func(ctx context.Context, clusterName, schemaName, tableName, nodeName string) (*Table, error)

+ CreateCluster func(ctx context.Context, clusterName string, ...) (*Cluster, error)

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

+ GetNodes func(ctx context.Context, clusterName string) (*GetNodesResult, error)

+ GetShards func(ctx context.Context, clusterName, nodeName string) ([]uint32, error)

+ GetTables func(ctx context.Context, clusterName, nodeName string, shardIDs []uint32) (map[uint32]*ShardTables, error)

+ RegisterNode func(ctx context.Context, clusterName string, nodeInfo *metaservicepb.NodeInfo) error

+ RouteTables func(ctx context.Context, clusterName, schemaName string, tableNames []string) (*RouteTablesResult, error)

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ func NewManagerImpl(storage storage.Storage, kv clientv3.KV, hbstream *schedule.HeartbeatStreams, ...) (Manager, error)

+ type Node struct

+ type NodeShard struct

+ Endpoint string

+ ShardInfo *ShardInfo

+ type RouteEntry struct

+ NodeShards []*NodeShard

+ Table *TableInfo

+ type RouteTablesResult struct

+ RouteEntries map[string]*RouteEntry

+ Version uint64

+ type Schema struct

+ func (s *Schema) GetID() uint32

+ type Shard struct

+ type ShardInfo struct

+ ShardID uint32

+ ShardRole clusterpb.ShardRole

+ Version uint64

+ type ShardTables struct

+ ShardRole clusterpb.ShardRole

+ Tables []*TableInfo

+ Version uint64

+ type ShardTablesWithRole struct

+ type Table struct

+ func (t *Table) GetID() uint64

+ func (t *Table) GetName() string

+ func (t *Table) GetSchemaID() uint32

+ func (t *Table) GetSchemaName() string

+ func (t *Table) GetShardID() uint32

+ type TableInfo struct

+ ID uint64

+ Name string

+ SchemaID uint32

+ SchemaName string

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