storage

package

Go to main page

Versions in this module

v1

v1.2.7

Oct 10, 2023

Changes in this version

+ func ConvertShardStatusToString(status ShardStatus) string

type ShardStatus

+ const ShardStatusPartialOpen

v1.2.6

Sep 4, 2023

v1.2.5

Jul 27, 2023

Changes in this version

+ const ShardStatusPartitionOpen

+ const ShardStatusReady

+ func ConvertShardStatusToPB(status ShardStatus) metaservicepb.ShardInfo_Status

+ type ShardStatus int

+ func ConvertShardStatusPB(status *metaservicepb.ShardInfo_Status) ShardStatus

v1.2.4

Jul 7, 2023

Changes in this version

type Cluster

+ ProcedureExecutingBatchSize uint32

v1.2.2

May 31, 2023

Changes in this version

+ const TopologyTypeUnknown

v1.2.1

May 29, 2023

Changes in this version

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

type Cluster

+ EnableSchedule bool

+ ModifiedAt uint64

+ TopologyType TopologyType

type ClusterState

+ const TopologyTypeDynamic

+ const TopologyTypeStatic

type Storage

+ GetCluster func(ctx context.Context, clusterID ClusterID) (Cluster, error)

+ UpdateCluster func(ctx context.Context, req UpdateClusterRequest) error

+ type TopologyType string

+ type UpdateClusterRequest struct

+ Cluster Cluster

v1.2.0

May 6, 2023

Changes in this version

type ClusterState

+ const ClusterStatePrepare

type ClusterView

+ func NewClusterView(clusterID ClusterID, version uint64, state ClusterState, ...) ClusterView

type ShardView

+ func NewShardView(shardID ShardID, version uint64, tableIDs []TableID) ShardView

v1.1.0

Mar 27, 2023

v1.0.0

Feb 22, 2023

Changes in this version

+ var ErrCreateClusterViewAgain = coderr.NewCodeError(coderr.Internal, "storage create cluster view")

+ var ErrCreateShardViewAgain = coderr.NewCodeError(coderr.Internal, "storage create shard view")

+ var ErrDecode = coderr.NewCodeError(coderr.Internal, "storage decode")

+ var ErrEncode = coderr.NewCodeError(coderr.Internal, "storage encode")

+ var ErrUpdateClusterViewConflict = coderr.NewCodeError(coderr.Internal, "storage update cluster view")

+ var ErrUpdateShardViewConflict = coderr.NewCodeError(coderr.Internal, "storage update shard view")

+ func ConvertShardRoleToPB(role ShardRole) clusterpb.ShardRole

+ type Cluster struct

+ CreatedAt uint64

+ ID ClusterID

+ MinNodeCount uint32

+ Name string

+ ReplicationFactor uint32

+ ShardTotal uint32

+ type ClusterID uint32

+ type ClusterState int

+ const ClusterStateEmpty

+ const ClusterStateStable

+ type ClusterView struct

+ ClusterID ClusterID

+ CreatedAt uint64

+ ShardNodes []ShardNode

+ State ClusterState

+ Version uint64

+ type CreateClusterRequest struct

+ Cluster Cluster

+ type CreateClusterViewRequest struct

+ ClusterView ClusterView

+ type CreateOrUpdateNodeRequest struct

+ ClusterID ClusterID

+ Node Node

+ type CreateSchemaRequest struct

+ ClusterID ClusterID

+ Schema Schema

+ type CreateShardViewsRequest struct

+ ClusterID ClusterID

+ ShardViews []ShardView

+ type CreateTableRequest struct

+ ClusterID ClusterID

+ SchemaID SchemaID

+ Table Table

+ type DeleteTableRequest struct

+ ClusterID ClusterID

+ SchemaID SchemaID

+ TableName string

+ type GetClusterViewRequest struct

+ ClusterID ClusterID

+ type GetClusterViewResult struct

+ ClusterView ClusterView

+ type GetTableRequest struct

+ ClusterID ClusterID

+ SchemaID SchemaID

+ TableName string

+ type GetTableResult struct

+ Exists bool

+ Table Table

+ type ListClustersResult struct

+ Clusters []Cluster

+ type ListNodesRequest struct

+ ClusterID ClusterID

+ type ListNodesResult struct

+ Nodes []Node

+ type ListSchemasRequest struct

+ ClusterID ClusterID

+ type ListSchemasResult struct

+ Schemas []Schema

+ type ListShardViewsRequest struct

+ ClusterID ClusterID

+ ShardIDs []ShardID

+ type ListShardViewsResult struct

+ ShardViews []ShardView

+ type ListTableRequest struct

+ ClusterID ClusterID

+ SchemaID SchemaID

+ type ListTablesResult struct

+ Tables []Table

+ type Node struct

+ LastTouchTime uint64

+ Name string

+ NodeStats NodeStats

+ State NodeState

+ type NodeState int

+ const NodeStateOffline

+ const NodeStateOnline

+ type NodeStats struct

+ Lease uint32

+ NodeVersion string

+ Zone string

+ type PartitionInfo struct

+ Info *clusterpb.PartitionInfo

+ type Schema struct

+ ClusterID ClusterID

+ CreatedAt uint64

+ ID SchemaID

+ Name string

+ type SchemaID uint32

+ type ShardID uint32

+ type ShardNode struct

+ ID ShardID

+ NodeName string

+ ShardRole ShardRole

+ type ShardRole int

+ const ShardRoleFollower

+ const ShardRoleLeader

+ func ConvertShardRolePB(role clusterpb.ShardRole) ShardRole

+ type ShardView struct

+ CreatedAt uint64

+ ShardID ShardID

+ TableIDs []TableID

+ Version uint64

type Storage

+ CreateCluster func(ctx context.Context, req CreateClusterRequest) error

+ CreateClusterView func(ctx context.Context, req CreateClusterViewRequest) error

+ CreateOrUpdateNode func(ctx context.Context, req CreateOrUpdateNodeRequest) error

+ CreateSchema func(ctx context.Context, req CreateSchemaRequest) error

+ CreateShardViews func(ctx context.Context, req CreateShardViewsRequest) error

+ CreateTable func(ctx context.Context, req CreateTableRequest) error

+ DeleteTable func(ctx context.Context, req DeleteTableRequest) error

+ GetClusterView func(ctx context.Context, req GetClusterViewRequest) (GetClusterViewResult, error)

+ GetTable func(ctx context.Context, req GetTableRequest) (GetTableResult, error)

+ ListClusters func(ctx context.Context) (ListClustersResult, error)

+ ListNodes func(ctx context.Context, req ListNodesRequest) (ListNodesResult, error)

+ ListSchemas func(ctx context.Context, req ListSchemasRequest) (ListSchemasResult, error)

+ ListShardViews func(ctx context.Context, req ListShardViewsRequest) (ListShardViewsResult, error)

+ ListTables func(ctx context.Context, req ListTableRequest) (ListTablesResult, error)

+ UpdateClusterView func(ctx context.Context, req UpdateClusterViewRequest) error

+ UpdateShardView func(ctx context.Context, req UpdateShardViewRequest) error

+ type Table struct

+ CreatedAt uint64

+ ID TableID

+ Name string

+ PartitionInfo PartitionInfo

+ SchemaID SchemaID

+ func (t Table) IsPartitioned() bool

+ type TableID uint64

+ type UpdateClusterViewRequest struct

+ ClusterID ClusterID

+ ClusterView ClusterView

+ LatestVersion uint64

+ type UpdateShardViewRequest struct

+ ClusterID ClusterID

+ LatestVersion uint64

+ ShardView ShardView

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

type MetaStorage

+ PutShardTopology func(ctx context.Context, clusterID uint32, latestVersion uint64, ...) error

v0.3.0

Aug 29, 2022

Changes in this version

+ var ErrCreateClusterAgain = coderr.NewCodeError(coderr.Internal, "meta storage create cluster")

+ var ErrCreateClusterTopologyAgain = coderr.NewCodeError(coderr.Internal, "meta storage create cluster topology")

+ var ErrCreateOrUpdateNode = coderr.NewCodeError(coderr.Internal, "meta storage create or update nodes")

+ var ErrCreateSchemaAgain = coderr.NewCodeError(coderr.Internal, "meta storage create schemas")

+ var ErrCreateShardTopologyAgain = coderr.NewCodeError(coderr.Internal, "meta storage create shard topology")

+ var ErrCreateTableAgain = coderr.NewCodeError(coderr.Internal, "meta storage create tables")

+ var ErrDecodeCluster = coderr.NewCodeError(coderr.Internal, "meta storage marshal cluster")

+ var ErrDecodeClusterTopology = coderr.NewCodeError(coderr.Internal, "meta storage marshal cluster topology")

+ var ErrDecodeNode = coderr.NewCodeError(coderr.Internal, "meta storage marshal node")

+ var ErrDecodeSchema = coderr.NewCodeError(coderr.Internal, "meta storage marshal schema")

+ var ErrDecodeShardTopology = coderr.NewCodeError(coderr.Internal, "meta storage marshal shard topology")

+ var ErrDecodeTable = coderr.NewCodeError(coderr.Internal, "meta storage marshal table")

+ var ErrDeleteTableAgain = coderr.NewCodeError(coderr.Internal, "meta storage delete table")

+ var ErrEncodeCluster = coderr.NewCodeError(coderr.Internal, "meta storage unmarshal cluster")

+ var ErrEncodeClusterTopology = coderr.NewCodeError(coderr.Internal, "meta storage unmarshal cluster topology")

+ var ErrEncodeNode = coderr.NewCodeError(coderr.Internal, "meta storage unmarshal node")

+ var ErrEncodeSchema = coderr.NewCodeError(coderr.Internal, "meta storage unmarshal schema")

+ var ErrEncodeShardTopology = coderr.NewCodeError(coderr.Internal, "meta storage unmarshal shard topology")

+ var ErrEncodeTable = coderr.NewCodeError(coderr.Internal, "meta storage unmarshal table")

+ var ErrPutClusterTopologyConflict = coderr.NewCodeError(coderr.Internal, "meta storage put cluster topology")

+ var ErrPutShardTopologyConflict = coderr.NewCodeError(coderr.Internal, "meta storage put shard topology")

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

+ type KV interface

+ Delete func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) (string, error)

+ Put func(ctx context.Context, key, value string) error

+ Scan func(ctx context.Context, key, endKey string, limit int) (keys []string, values []string, err error)

+ Txn func(ctx context.Context) clientv3.Txn

+ func NewEtcdKV(client *clientv3.Client, rootPath string) KV

+ type MetaStorage interface

+ CreateCluster func(ctx context.Context, cluster *clusterpb.Cluster) (*clusterpb.Cluster, error)

+ CreateClusterTopology func(ctx context.Context, clusterTopology *clusterpb.ClusterTopology) (*clusterpb.ClusterTopology, error)

+ CreateOrUpdateNode func(ctx context.Context, clusterID uint32, node *clusterpb.Node) (*clusterpb.Node, error)

+ CreateSchema func(ctx context.Context, clusterID uint32, schema *clusterpb.Schema) (*clusterpb.Schema, error)

+ CreateShardTopologies func(ctx context.Context, clusterID uint32, ...) ([]*clusterpb.ShardTopology, error)

+ CreateTable func(ctx context.Context, clusterID uint32, schemaID uint32, table *clusterpb.Table) (*clusterpb.Table, error)

+ DeleteTable func(ctx context.Context, clusterID uint32, schemaID uint32, tableName string) error

+ GetCluster func(ctx context.Context, clusterID uint32) (*clusterpb.Cluster, error)

+ GetClusterTopology func(ctx context.Context, clusterID uint32) (*clusterpb.ClusterTopology, error)

+ GetTable func(ctx context.Context, clusterID uint32, schemaID uint32, tableName string) (*clusterpb.Table, bool, error)

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

+ ListNodes func(ctx context.Context, clusterID uint32) ([]*clusterpb.Node, error)

+ ListSchemas func(ctx context.Context, clusterID uint32) ([]*clusterpb.Schema, error)

+ ListShardTopologies func(ctx context.Context, clusterID uint32, shardID []uint32) ([]*clusterpb.ShardTopology, error)

+ ListTables func(ctx context.Context, clusterID uint32, schemaID uint32) ([]*clusterpb.Table, error)

+ PutCluster func(ctx context.Context, clusterID uint32, cluster *clusterpb.Cluster) error

+ PutClusterTopology func(ctx context.Context, clusterID uint32, latestVersion uint64, ...) error

+ PutSchemas func(ctx context.Context, clusterID uint32, schemas []*clusterpb.Schema) error

+ PutShardTopologies func(ctx context.Context, clusterID uint32, shardIDs []uint32, latestVersion uint64, ...) error

+ PutTables func(ctx context.Context, clusterID uint32, schemaID uint32, ...) error

+ type Options struct

+ MaxScanLimit int

+ MinScanLimit int

+ type Storage interface

+ func NewMetaStorageImpl(kv KV, opts Options, rootPath string) Storage

+ func NewStorageWithEtcdBackend(client *clientv3.Client, rootPath string, opts Options) Storage

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