executor

package

v1.1.0 Latest Latest Go to latest Published: Jun 9, 2021 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pegasus-kv/admin-cli

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AddDuplication(c *Client, tableName string, remoteCluster string, freezed bool) error
func BackupTable(client *Client, tableID int, providerType string, backupPath string) error
func ClearAppEnv(c *Client, useTable string) error
func ClusterInfo(client *Client) error
func ConfigCommand(client *Client, nodeType session.NodeType, nodeAddr string, name string, ...) error
func CreateTable(c *Client, tableName string, partitionCount int, replicaCount int) error
func DelAppEnv(c *Client, useTable string, key string, deletePrefix bool) error
func DiskBalance(client *Client, replicaServer string, minSize int64, auto bool) error
func DiskMigrate(client *Client, replicaServer string, pidStr string, from string, to string) error
func DropTable(c *Client, tableName string, reservePeriod int64) error
func GetMetaLevel(c *Client) error
func ListAppEnvs(c *Client, useTable string) error
func ListNodes(client *Client) error
func ListTables(client *Client, showDropped bool) error
func ModifyDuplication(c *Client, tableName string, dupid int, status admin.DuplicationStatus) error
func QueryBackupStatus(client *Client, tableID int, backupID int64) error
func QueryDiskInfo(client *Client, infoType DiskInfoType, replicaServer string, tableName string, ...) error
func QueryDuplication(c *Client, tableName string) error
func RecallTable(client *Client, originTableID int, newTableName string) error
func RemoteCommand(c *Client, nodeType session.NodeType, nodeAddr string, cmd string, ...) error
func RestoreTable(client *Client, oldClusterName string, oldTableName string, oldTableID int, ...) error
func ServerInfo(c *Client) error
func SetAppEnv(c *Client, useTable string, key, value string) error
func SetMetaLevel(c *Client, lvlStr string) error
func ShowNodesStat(client *Client) error
func ShowPartitionsStats(client *Client, tableName string) error
func ShowTablePartitions(client *Client, tableName string) error
func TableStat(c *Client) error
func UseTable(client *Client, table string) error
type Client
- func NewClient(writer io.Writer, metaAddrs []string) *Client
type DiskCapacityStruct
type DiskInfoType
type DiskStats
type MigrateAction
type MigrateDisk
type ReplicaCapacityStruct

Constants ¶

View Source

const (
	WaitRunning  = time.Second * 10 // time for wait migrate complete
	WaitCleaning = time.Second * 90 // time for wait garbage replica to clean complete
)

Variables ¶

This section is empty.

Functions ¶

func BackupTable ¶ added in v1.1.0

func BackupTable(client *Client, tableID int, providerType string, backupPath string) error

func ConfigCommand ¶ added in v1.0.1

func ConfigCommand(client *Client, nodeType session.NodeType, nodeAddr string, name string, actionType string, value int64) error

TODO(jiashuo1) not support update collector config

func DelAppEnv ¶

func DelAppEnv(c *Client, useTable string, key string, deletePrefix bool) error

DelAppEnv command TODO(wutao): deleting a non-existed key returns "OK" now.

func DiskBalance ¶

func DiskBalance(client *Client, replicaServer string, minSize int64, auto bool) error

auto balance target node disk usage: -1. change the pegasus server disk cleaner internal for clean temp replica to free disk space in time -2. get the optimal migrate action to be ready to balance the disk until can't migrate base latest disk space stats -3. if current replica is `primary` status, force assign the replica to `secondary` status -4. migrate the replica base `getNextMigrateAction` result -5. loop query migrate progress using `DiskMigrate`, it will response `ERR_BUSY` if running -6. start next loop until can't allow to balance the node -7. recover disk cleaner internal if balance complete -8. set meta status to `lively` to balance primary and secondary // TODO(jiashuo1)

func DiskMigrate ¶

func DiskMigrate(client *Client, replicaServer string, pidStr string, from string, to string) error

func DropTable ¶

func DropTable(c *Client, tableName string, reservePeriod int64) error

DropTable command

func GetMetaLevel ¶

func GetMetaLevel(c *Client) error

GetMetaLevel command

func ListAppEnvs ¶

func ListAppEnvs(c *Client, useTable string) error

ListAppEnvs command

func ListNodes ¶

func ListNodes(client *Client) error

ListNodes is nodes command.

func ListTables ¶

func ListTables(client *Client, showDropped bool) error

ListTables command.

func ModifyDuplication ¶

func ModifyDuplication(c *Client, tableName string, dupid int, status admin.DuplicationStatus) error

ModifyDuplication command

func QueryBackupStatus ¶ added in v1.1.0

func QueryBackupStatus(client *Client, tableID int, backupID int64) error

func QueryDiskInfo ¶

func QueryDiskInfo(client *Client, infoType DiskInfoType, replicaServer string, tableName string, diskTag string) error

QueryDiskInfo command

func QueryDuplication ¶

func QueryDuplication(c *Client, tableName string) error

QueryDuplication command

func RecallTable ¶

func RecallTable(client *Client, originTableID int, newTableName string) error

func RemoteCommand ¶

func RemoteCommand(c *Client, nodeType session.NodeType, nodeAddr string, cmd string, args []string) error

RemoteCommand command.

func RestoreTable ¶ added in v1.1.0

func RestoreTable(client *Client, oldClusterName string, oldTableName string, oldTableID int,
	backupID int64, providerType string, newTableName string, restorePath string, skipBadPartition bool, policyName string) error

func ServerInfo ¶

func ServerInfo(c *Client) error

ServerInfo command

func SetAppEnv ¶

func SetAppEnv(c *Client, useTable string, key, value string) error

SetAppEnv command

func SetMetaLevel ¶

func SetMetaLevel(c *Client, lvlStr string) error

SetMetaLevel command

func ShowNodesStat ¶

func ShowNodesStat(client *Client) error

func ShowPartitionsStats ¶

func ShowPartitionsStats(client *Client, tableName string) error

ShowPartitionsStats is partition-stat command

func ShowTablePartitions ¶

func ShowTablePartitions(client *Client, tableName string) error

ShowTablePartitions is table-partitions command

func TableStat ¶

func TableStat(c *Client) error

TableStat is table-stat command.

func UseTable ¶

func UseTable(client *Client, table string) error

Types ¶

type Client ¶

type Client struct {
	// Every command should use Client as the fmt.Fprint's writer.
	io.Writer

	// to access administration APIs
	Meta client.Meta

	// to obtain perf-counters of ReplicaServers
	Perf *aggregate.PerfClient

	Nodes *util.PegasusNodeManager
}

Client represents as a manager of various SDKs that can access both Pegasus ReplicaServer and MetaServer.

func NewClient ¶

func NewClient(writer io.Writer, metaAddrs []string) *Client

NewClient creates a client for accessing Pegasus cluster for use of admin-cli.

type DiskCapacityStruct ¶ added in v1.1.0

type DiskCapacityStruct struct {
	Disk     string `json:"disk"`
	Capacity int64  `json:"capacity"`
	Usage    int64  `json:"usage"`
	Ratio    int64  `json:"ratio"`
}

type DiskInfoType ¶

type DiskInfoType string

const (
	CapacitySize DiskInfoType = "CapacitySize"
	ReplicaCount DiskInfoType = "ReplicaCount"
)

type DiskStats ¶ added in v1.1.0

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

type MigrateAction ¶ added in v1.1.0

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

type MigrateDisk ¶ added in v1.1.0

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

type ReplicaCapacityStruct ¶ added in v1.1.0

type ReplicaCapacityStruct struct {
	Gpid   string `json:"replica"`
	Status string `json:"status"`
	Size   int64  `json:"size"`
}

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