Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetRPCTimeout ¶
SetRPCTimeout is the global timeout setting of RPC.
Types ¶
type Meta ¶
type Meta interface {
Close() error
// ListAvailableApps lists only available tables.
ListAvailableApps() ([]*admin.AppInfo, error)
ListApps(status admin.AppStatus) ([]*admin.AppInfo, error)
QueryConfig(tableName string) (*replication.QueryCfgResponse, error)
MetaControl(level admin.MetaFunctionLevel) (oldLevel admin.MetaFunctionLevel, err error)
QueryClusterInfo() (map[string]string, error)
UpdateAppEnvs(tableName string, envs map[string]string) error
ClearAppEnvs(tableName string, clearPrefix string) error
DelAppEnvs(tableName string, keys []string) error
CreateApp(tableName string, envs map[string]string, partitionCount int) (int32, error)
DropApp(tableName string, reserveSeconds int64) error
ModifyDuplication(tableName string, dupid int, status admin.DuplicationStatus) error
AddDuplication(tableName string, remoteCluster string, freezed bool) (*admin.DuplicationAddResponse, error)
QueryDuplication(tableName string) (*admin.DuplicationQueryResponse, error)
ListNodes() ([]*admin.NodeInfo, error)
RecallApp(originTableID int, newTableName string) (*admin.AppInfo, error)
}
Meta is a helper over pegasus-go-client's primitive session.MetaManager. It aims to provide an easy-to-use API that eliminates some boilerplate code, like context creation, request/response creation, etc.
func NewRPCBasedMeta ¶
NewRPCBasedMeta creates the connection to meta.
Click to show internal directories.
Click to hide internal directories.