client

package

Versions in this module

v1

v1.2.0

Mar 25, 2022

Changes in this version

+ func ListPrimariesOnNode(meta Meta, node *util.PegasusNode, tableName string) ([]*replication.PartitionConfiguration, error)

type Meta

+ CancelBulkLoad func(tableName string, forced bool) error

+ CancelPartitionSplit func(tableName string, oldPartitionCount int) error

+ PauseBulkLoad func(tableName string) error

+ PausePartitionSplit func(tableName string, parentPidx int) error

+ QueryBulkLoad func(tableName string) (*admin.QueryBulkLoadResponse, error)

+ QueryManualCompaction func(tableName string) (*admin.QueryAppManualCompactResponse, error)

+ QuerySplitStatus func(tableName string) (*admin.QuerySplitResponse, error)

+ RestartBulkLoad func(tableName string) error

+ RestartPartitionSplit func(tableName string, parentPidx int) error

+ StartBulkLoad func(tableName string, clusterName string, providerType string, rootPath string) error

+ StartManualCompaction func(tableName string, targetLevel int, maxRunningCount int, bottommost bool) error

+ StartPartitionSplit func(tableName string, newPartitionCount int) error

v1.1.0

Jun 9, 2021

Changes in this version

+ func DowngradeNodeWithDetails(meta Meta, node *util.PegasusNode) ([]*base.Gpid, error)

type Meta

+ QueryBackupStatus func(tableID int, backupID int64) (*admin.QueryBackupStatusResponse, error)

+ RestoreApp func(oldClusterName string, oldTableName string, oldTableID int, backupID int64, ...) (*admin.CreateAppResponse, error)

+ StartBackupApp func(tableID int, providerType string, backupPath string) (*admin.StartBackupAppResponse, error)

v1.0.3

May 8, 2021

Changes in this version

+ func BatchCallCmd(nodes []*util.PegasusNode, cmd string, args []string) map[*util.PegasusNode]*CmdResult

+ type ClusterReplicaInfo struct

+ Nodes []*NodeState

+ Tables []*TableHealthInfo

+ func GetClusterReplicaInfo(meta Meta) (*ClusterReplicaInfo, error)

+ type CmdResult struct

+ func CallCmd(n *util.PegasusNode, cmd string, args []string) *CmdResult

+ func (c *CmdResult) Error() error

+ func (c *CmdResult) Failed() bool

+ func (c *CmdResult) RespBody() string

+ func (c *CmdResult) String() string

+ type NodeState struct

+ IPPort string

+ PrimariesNum int

+ ReplicaCount int

+ SecondariesNum int

+ Status admin.NodeStatus

+ func ListNodesReplicaInfo(meta Meta) ([]*NodeState, error)

v1.0.2

May 6, 2021

Changes in this version

+ func DowngradeNode(meta Meta, node *util.PegasusNode) error

+ func MigratePrimariesOut(meta Meta, node *util.PegasusNode) error

+ func SetMetaLevelLively(meta Meta) error

+ func SetMetaLevelSteady(meta Meta) error

+ type BalanceType int

+ const BalanceCopyPri

+ const BalanceCopySec

+ const BalanceMovePri

+ func (t BalanceType) String() string

type Meta

+ Balance func(gpid *base.Gpid, opType BalanceType, from *util.PegasusNode, ...) error

+ Propose func(gpid *base.Gpid, action admin.ConfigType, target *util.PegasusNode, ...) error

+ type TableHealthInfo struct

+ FullHealthy int32

+ PartitionCount int32

+ ReadUnhealthy int32

+ Unhealthy int32

+ WriteUnhealthy int32

+ func GetTableHealthInfo(meta Meta, tableName string) (*TableHealthInfo, error)

v1.0.1

Apr 26, 2021

Changes in this version

+ func SetRPCTimeout(d time.Duration)

+ type Meta interface

+ AddDuplication func(tableName string, remoteCluster string, freezed bool) (*admin.DuplicationAddResponse, error)

+ ClearAppEnvs func(tableName string, clearPrefix string) error

+ Close func() error

+ CreateApp func(tableName string, envs map[string]string, partitionCount int) (int32, error)

+ DelAppEnvs func(tableName string, keys []string) error

+ DropApp func(tableName string, reserveSeconds int64) error

+ ListApps func(status admin.AppStatus) ([]*admin.AppInfo, error)

+ ListAvailableApps func() ([]*admin.AppInfo, error)

+ ListNodes func() ([]*admin.NodeInfo, error)

+ MetaControl func(level admin.MetaFunctionLevel) (oldLevel admin.MetaFunctionLevel, err error)

+ ModifyDuplication func(tableName string, dupid int, status admin.DuplicationStatus) error

+ QueryClusterInfo func() (map[string]string, error)

+ QueryConfig func(tableName string) (*replication.QueryCfgResponse, error)

+ QueryDuplication func(tableName string) (*admin.DuplicationQueryResponse, error)

+ RecallApp func(originTableID int, newTableName string) (*admin.AppInfo, error)

+ UpdateAppEnvs func(tableName string, envs map[string]string) error

+ func NewRPCBasedMeta(metaAddrs []string) Meta

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