executor

package

Go to main page

Versions in this module

v1

v1.2.0

Mar 25, 2022

Changes in this version

+ func AddDisk(client *Client, replicaServer string, diskStr string) error

+ func CancelBulkLoad(client *Client, tableName string, forced bool) error

+ func CancelPartitionSplit(client *Client, tableName string, oldPartitionCount int) error

+ func DiskBeforeSplit(client *Client, tableName string) error

+ func GetAppEnv(c *Client, useTable string, envName string) (string, error)

+ func PauseBulkLoad(client *Client, tableName string) error

+ func PausePartitionSplit(client *Client, tableName string, parentPidx int) error

+ func PrintAllCleanupFlag(client *Client, resp *admin.QueryBulkLoadResponse, detailed bool)

+ func PrintAllDownloading(client *Client, resp *admin.QueryBulkLoadResponse, detailed bool)

+ func PrintAllOthers(client *Client, resp *admin.QueryBulkLoadResponse, detailed bool)

+ func PrintAllSummary(client *Client, tableName string, tableStatus admin.BulkLoadStatus)

+ func PrintSingleCleanupFlag(client *Client, resp *admin.QueryBulkLoadResponse, partitionIndex int, ...)

+ func PrintSingleDownloading(client *Client, resp *admin.QueryBulkLoadResponse, partitionIndex int, ...)

+ func PrintSingleIngesting(client *Client, resp *admin.QueryBulkLoadResponse, partitionIndex int, ...)

+ func PrintSinglePausing(client *Client, resp *admin.QueryBulkLoadResponse, partitionIndex int, ...)

+ func PrintSingleSummary(client *Client, tableName string, pidx int32, ...)

+ func QueryAllNodesDiskInfo(client *Client, tableName string) (map[string]*radmin.QueryDiskInfoResponse, error)

+ func QueryBulkLoad(client *Client, tableName string, partitionIndex int, detailed bool) error

+ func QueryManualCompaction(client *Client, tableName string) error

+ func QuerySplitStatus(client *Client, tableName string) error

+ func RestartBulkLoad(client *Client, tableName string) error

+ func RestartPartitionSplit(client *Client, tableName string, parentPidx int) error

+ func SetCompaction(client *Client, tableName string, params *CompactionParams) error

+ func ShowPartitionCount(client *Client, tableName string) error

+ func StartBulkLoad(client *Client, tableName string, clusterName string, providerType string, ...) error

+ func StartManualCompaction(client *Client, tableName string, targetLevel int, maxRunningCount int, ...) error

+ func StartPartitionSplit(client *Client, tableName string, newPartitionCount int) error

+ type CompactionParams struct

+ HashkeyMatch string

+ HashkeyPattern string

+ OperationType string

+ SortkeyMatch string

+ SortkeyPattern string

+ StartTTL int64

+ StopTTL int64

+ TimeValue uint

+ UpdateTTLType string

+ type NodeDiskStats struct

+ DiskAvailable int64

+ DiskCapacity int64

+ DiskTag string

+ NodeAddress string

+ ReplicaCapacity []ReplicaCapacityStruct

+ type PartitionStruct struct

+ Pidx int32

+ PrimaryAddr string

+ SecondariesAddr string

+ func GetTablePartition(client *Client, tableName string, partitionIndex int32) (*PartitionStruct, error)

+ func GetTablePartitions(client *Client, tableName string) (partitions []PartitionStruct, err error)

v1.1.0

Jun 9, 2021

Changes in this version

+ const WaitCleaning

+ const WaitRunning

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

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

+ func RestoreTable(client *Client, oldClusterName string, oldTableName string, oldTableID int, ...) error

+ type DiskCapacityStruct struct

+ Capacity int64

+ Disk string

+ Ratio int64

+ Usage int64

+ type DiskStats struct

+ type MigrateAction struct

+ type MigrateDisk struct

+ type ReplicaCapacityStruct struct

+ Gpid string

+ Size int64

+ Status string

v1.0.3

May 8, 2021

v1.0.2

May 6, 2021

v1.0.1

Apr 26, 2021

Changes in this version

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

v1.0.0

Dec 9, 2020

Changes in this version

+ func AddDuplication(c *Client, tableName string, remoteCluster string, freezed bool) error

+ func ClearAppEnv(c *Client, useTable string) error

+ func ClusterInfo(client *Client) 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() 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 QueryDiskInfo(client *Client, infoType DiskInfoType, replicaServer string, tableName string, ...) error

+ func QueryDuplication(c *Client, tableName string) error

+ func RecallTable(client *Client, originTableId string, newTableName string) error

+ func RemoteCommand(client *Client, nodeType session.NodeType, nodeAddr string, cmd string, ...) error

+ func ServerInfo(client *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 struct

+ Meta *session.MetaManager

+ Nodes *util.PegasusNodeManager

+ Perf *aggregate.PerfClient

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

+ type DiskInfoType int32

+ const CapacitySize

+ const ReplicaCount

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