admin

package
v0.0.0-...-ba0e684 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 19, 2022 License: Apache-2.0 Imports: 8 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AppInfo_Duplicating_DEFAULT bool
View Source 
var AppInfo_IsBulkLoading_DEFAULT bool = false
View Source 
var BalanceRequest_Force_DEFAULT bool = false
View Source 
var BalanceRequest_Gpid_DEFAULT *base.Gpid
View Source 
var BalanceResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ClearBulkLoadStateResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ClusterInfoResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationProposalAction_Node_DEFAULT *base.RPCAddress
View Source 
var ConfigurationProposalAction_Target_DEFAULT *base.RPCAddress
View Source 
var ControlBulkLoadResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ControlBulkLoadResponse_HintMsg_DEFAULT string
View Source 
var ControlSplitRequest_OldPartitionCount_DEFAULT int32
View Source 
var ControlSplitResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ControlSplitResponse_HintMsg_DEFAULT string
View Source 
var CreateAppResponse_Err_DEFAULT *base.ErrorCode
View Source 
var DropAppOptions_ReserveSeconds_DEFAULT int64
View Source 
var DropAppResponse_Err_DEFAULT *base.ErrorCode
View Source 
var DuplicationAddResponse_Err_DEFAULT *base.ErrorCode
View Source 
var DuplicationAddResponse_Hint_DEFAULT string
View Source 
var DuplicationEntry_Progress_DEFAULT map[int32]int64
View Source 
var DuplicationModifyResponse_Err_DEFAULT *base.ErrorCode
View Source 
var DuplicationQueryResponse_Err_DEFAULT *base.ErrorCode
View Source 
var GoUnusedProtection__ int
View Source 
var ListAppsResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ListNodesResponse_Err_DEFAULT *base.ErrorCode
View Source 
var MetaControlResponse_Err_DEFAULT *base.ErrorCode
View Source 
var NodeInfo_Address_DEFAULT *base.RPCAddress
View Source 
var PartitionBulkLoadState_DownloadProgress_DEFAULT int32 = 0
View Source 
var PartitionBulkLoadState_DownloadStatus_DEFAULT *base.ErrorCode
View Source 
var PartitionBulkLoadState_IsCleanedUp_DEFAULT bool = false
View Source 
var PartitionBulkLoadState_IsPaused_DEFAULT bool = false
View Source 
var QueryAppInfoRequest_MetaServer_DEFAULT *base.RPCAddress
View Source 
var QueryAppInfoResponse_Err_DEFAULT *base.ErrorCode
View Source 
var QueryAppManualCompactResponse_Err_DEFAULT *base.ErrorCode
View Source 
var QueryAppManualCompactResponse_Progress_DEFAULT int32
View Source 
var QueryBackupPolicyResponse_Err_DEFAULT *base.ErrorCode
View Source 
var QueryBackupPolicyResponse_HintMsg_DEFAULT string
View Source 
var QueryBackupStatusRequest_BackupID_DEFAULT int64
View Source 
var QueryBackupStatusResponse_BackupItems_DEFAULT []*BackupItem
View Source 
var QueryBackupStatusResponse_Err_DEFAULT *base.ErrorCode
View Source 
var QueryBulkLoadResponse_Err_DEFAULT *base.ErrorCode
View Source 
var QueryBulkLoadResponse_HintMsg_DEFAULT string
View Source 
var QuerySplitResponse_Err_DEFAULT *base.ErrorCode
View Source 
var QuerySplitResponse_HintMsg_DEFAULT string
View Source 
var RecallAppResponse_Err_DEFAULT *base.ErrorCode
View Source 
var RestoreAppRequest_RestorePath_DEFAULT string
View Source 
var StartAppManualCompactRequest_Bottommost_DEFAULT bool
View Source 
var StartAppManualCompactRequest_MaxRunningCount_DEFAULT int32
View Source 
var StartAppManualCompactRequest_TargetLevel_DEFAULT int32
View Source 
var StartAppManualCompactRequest_TriggerTime_DEFAULT int64
View Source 
var StartAppManualCompactResponse_Err_DEFAULT *base.ErrorCode
View Source 
var StartBackupAppRequest_BackupPath_DEFAULT string
View Source 
var StartBackupAppResponse_BackupID_DEFAULT int64
View Source 
var StartBackupAppResponse_Err_DEFAULT *base.ErrorCode
View Source 
var StartBulkLoadResponse_Err_DEFAULT *base.ErrorCode
View Source 
var StartPartitionSplitResponse_Err_DEFAULT *base.ErrorCode
View Source 
var UpdateAppEnvRequest_ClearPrefix_DEFAULT string
View Source 
var UpdateAppEnvRequest_Keys_DEFAULT []string
View Source 
var UpdateAppEnvRequest_Values_DEFAULT []string
View Source 
var UpdateAppEnvResponse_Err_DEFAULT *base.ErrorCode

Functions

This section is empty.

Types

type AdminClient 

type AdminClient interface {
	// Parameters:
	//  - Req
	CreateApp(ctx context.Context, req *CreateAppRequest) (r *CreateAppResponse, err error)
	// Parameters:
	//  - Req
	DropApp(ctx context.Context, req *DropAppRequest) (r *DropAppResponse, err error)
	// Parameters:
	//  - Req
	RecallApp(ctx context.Context, req *RecallAppRequest) (r *RecallAppResponse, err error)
	// Parameters:
	//  - Req
	ListApps(ctx context.Context, req *ListAppsRequest) (r *ListAppsResponse, err error)
	// Parameters:
	//  - Req
	AddDuplication(ctx context.Context, req *DuplicationAddRequest) (r *DuplicationAddResponse, err error)
	// Parameters:
	//  - Req
	QueryDuplication(ctx context.Context, req *DuplicationQueryRequest) (r *DuplicationQueryResponse, err error)
	// Parameters:
	//  - Req
	ModifyDuplication(ctx context.Context, req *DuplicationModifyRequest) (r *DuplicationModifyResponse, err error)
	// Parameters:
	//  - Req
	QueryAppInfo(ctx context.Context, req *QueryAppInfoRequest) (r *QueryAppInfoResponse, err error)
	// Parameters:
	//  - Req
	UpdateAppEnv(ctx context.Context, req *UpdateAppEnvRequest) (r *UpdateAppEnvResponse, err error)
	// Parameters:
	//  - Req
	ListNodes(ctx context.Context, req *ListNodesRequest) (r *ListNodesResponse, err error)
	// Parameters:
	//  - Req
	QueryClusterInfo(ctx context.Context, req *ClusterInfoRequest) (r *ClusterInfoResponse, err error)
	// Parameters:
	//  - Req
	MetaControl(ctx context.Context, req *MetaControlRequest) (r *MetaControlResponse, err error)
	// Parameters:
	//  - Req
	QueryBackupPolicy(ctx context.Context, req *QueryBackupPolicyRequest) (r *QueryBackupPolicyResponse, err error)
	// Parameters:
	//  - Req
	Balance(ctx context.Context, req *BalanceRequest) (r *BalanceResponse, err error)
	// Parameters:
	//  - Req
	StartBackupApp(ctx context.Context, req *StartBackupAppRequest) (r *StartBackupAppResponse, err error)
	// Parameters:
	//  - Req
	QueryBackupStatus(ctx context.Context, req *QueryBackupStatusRequest) (r *QueryBackupStatusResponse, err error)
	// Parameters:
	//  - Req
	RestoreApp(ctx context.Context, req *RestoreAppRequest) (r *CreateAppResponse, err error)
	// Parameters:
	//  - Req
	StartPartitionSplit(ctx context.Context, req *StartPartitionSplitRequest) (r *StartPartitionSplitResponse, err error)
	// Parameters:
	//  - Req
	QuerySplitStatus(ctx context.Context, req *QuerySplitRequest) (r *QuerySplitResponse, err error)
	// Parameters:
	//  - Req
	ControlPartitionSplit(ctx context.Context, req *ControlSplitRequest) (r *ControlSplitResponse, err error)
	// Parameters:
	//  - Req
	StartBulkLoad(ctx context.Context, req *StartBulkLoadRequest) (r *StartBulkLoadResponse, err error)
	// Parameters:
	//  - Req
	QueryBulkLoadStatus(ctx context.Context, req *QueryBulkLoadRequest) (r *QueryBulkLoadResponse, err error)
	// Parameters:
	//  - Req
	ControlBulkLoad(ctx context.Context, req *ControlBulkLoadRequest) (r *ControlBulkLoadResponse, err error)
	// Parameters:
	//  - Req
	ClearBulkLoad(ctx context.Context, req *ClearBulkLoadStateRequest) (r *ClearBulkLoadStateResponse, err error)
	// Parameters:
	//  - Req
	StartManualCompact(ctx context.Context, req *StartAppManualCompactRequest) (r *StartAppManualCompactResponse, err error)
	// Parameters:
	//  - Req
	QueryManualCompact(ctx context.Context, req *QueryAppManualCompactRequest) (r *QueryAppManualCompactResponse, err error)
}

type AdminClientAddDuplicationArgs 

type AdminClientAddDuplicationArgs struct {
	Req *DuplicationAddRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientAddDuplicationArgs 

func NewAdminClientAddDuplicationArgs() *AdminClientAddDuplicationArgs

func (*AdminClientAddDuplicationArgs) GetReq 

func (p *AdminClientAddDuplicationArgs) GetReq() *DuplicationAddRequest

func (*AdminClientAddDuplicationArgs) IsSetReq 

func (p *AdminClientAddDuplicationArgs) IsSetReq() bool

func (*AdminClientAddDuplicationArgs) Read 

func (p *AdminClientAddDuplicationArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientAddDuplicationArgs) ReadField1 

func (p *AdminClientAddDuplicationArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientAddDuplicationArgs) String 

func (p *AdminClientAddDuplicationArgs) String() string

func (*AdminClientAddDuplicationArgs) Write 

func (p *AdminClientAddDuplicationArgs) Write(oprot thrift.TProtocol) error

type AdminClientAddDuplicationResult 

type AdminClientAddDuplicationResult struct {
	Success *DuplicationAddResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientAddDuplicationResult 

func NewAdminClientAddDuplicationResult() *AdminClientAddDuplicationResult

func (*AdminClientAddDuplicationResult) GetSuccess 

func (p *AdminClientAddDuplicationResult) GetSuccess() *DuplicationAddResponse

func (*AdminClientAddDuplicationResult) IsSetSuccess 

func (p *AdminClientAddDuplicationResult) IsSetSuccess() bool

func (*AdminClientAddDuplicationResult) Read 

func (p *AdminClientAddDuplicationResult) Read(iprot thrift.TProtocol) error

func (*AdminClientAddDuplicationResult) ReadField0 

func (p *AdminClientAddDuplicationResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientAddDuplicationResult) String 

func (p *AdminClientAddDuplicationResult) String() string

func (*AdminClientAddDuplicationResult) Write 

func (p *AdminClientAddDuplicationResult) Write(oprot thrift.TProtocol) error

type AdminClientBalanceArgs 

type AdminClientBalanceArgs struct {
	Req *BalanceRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientBalanceArgs 

func NewAdminClientBalanceArgs() *AdminClientBalanceArgs

func (*AdminClientBalanceArgs) GetReq 

func (p *AdminClientBalanceArgs) GetReq() *BalanceRequest

func (*AdminClientBalanceArgs) IsSetReq 

func (p *AdminClientBalanceArgs) IsSetReq() bool

func (*AdminClientBalanceArgs) Read 

func (p *AdminClientBalanceArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientBalanceArgs) ReadField1 

func (p *AdminClientBalanceArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientBalanceArgs) String 

func (p *AdminClientBalanceArgs) String() string

func (*AdminClientBalanceArgs) Write 

func (p *AdminClientBalanceArgs) Write(oprot thrift.TProtocol) error

type AdminClientBalanceResult 

type AdminClientBalanceResult struct {
	Success *BalanceResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientBalanceResult 

func NewAdminClientBalanceResult() *AdminClientBalanceResult

func (*AdminClientBalanceResult) GetSuccess 

func (p *AdminClientBalanceResult) GetSuccess() *BalanceResponse

func (*AdminClientBalanceResult) IsSetSuccess 

func (p *AdminClientBalanceResult) IsSetSuccess() bool

func (*AdminClientBalanceResult) Read 

func (p *AdminClientBalanceResult) Read(iprot thrift.TProtocol) error

func (*AdminClientBalanceResult) ReadField0 

func (p *AdminClientBalanceResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientBalanceResult) String 

func (p *AdminClientBalanceResult) String() string

func (*AdminClientBalanceResult) Write 

func (p *AdminClientBalanceResult) Write(oprot thrift.TProtocol) error

type AdminClientClearBulkLoadArgs 

type AdminClientClearBulkLoadArgs struct {
	Req *ClearBulkLoadStateRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientClearBulkLoadArgs 

func NewAdminClientClearBulkLoadArgs() *AdminClientClearBulkLoadArgs

func (*AdminClientClearBulkLoadArgs) GetReq 

func (p *AdminClientClearBulkLoadArgs) GetReq() *ClearBulkLoadStateRequest

func (*AdminClientClearBulkLoadArgs) IsSetReq 

func (p *AdminClientClearBulkLoadArgs) IsSetReq() bool

func (*AdminClientClearBulkLoadArgs) Read 

func (p *AdminClientClearBulkLoadArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientClearBulkLoadArgs) ReadField1 

func (p *AdminClientClearBulkLoadArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientClearBulkLoadArgs) String 

func (p *AdminClientClearBulkLoadArgs) String() string

func (*AdminClientClearBulkLoadArgs) Write 

func (p *AdminClientClearBulkLoadArgs) Write(oprot thrift.TProtocol) error

type AdminClientClearBulkLoadResult 

type AdminClientClearBulkLoadResult struct {
	Success *ClearBulkLoadStateResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientClearBulkLoadResult 

func NewAdminClientClearBulkLoadResult() *AdminClientClearBulkLoadResult

func (*AdminClientClearBulkLoadResult) GetSuccess 

func (p *AdminClientClearBulkLoadResult) GetSuccess() *ClearBulkLoadStateResponse

func (*AdminClientClearBulkLoadResult) IsSetSuccess 

func (p *AdminClientClearBulkLoadResult) IsSetSuccess() bool

func (*AdminClientClearBulkLoadResult) Read 

func (p *AdminClientClearBulkLoadResult) Read(iprot thrift.TProtocol) error

func (*AdminClientClearBulkLoadResult) ReadField0 

func (p *AdminClientClearBulkLoadResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientClearBulkLoadResult) String 

func (p *AdminClientClearBulkLoadResult) String() string

func (*AdminClientClearBulkLoadResult) Write 

func (p *AdminClientClearBulkLoadResult) Write(oprot thrift.TProtocol) error

type AdminClientClient 

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

func NewAdminClientClient 

func NewAdminClientClient(c thrift.TClient) *AdminClientClient

func NewAdminClientClientFactory 

func NewAdminClientClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *AdminClientClient

func NewAdminClientClientProtocol 

func NewAdminClientClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *AdminClientClient

func (*AdminClientClient) AddDuplication 

func (p *AdminClientClient) AddDuplication(ctx context.Context, req *DuplicationAddRequest) (r *DuplicationAddResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) Balance 

func (p *AdminClientClient) Balance(ctx context.Context, req *BalanceRequest) (r *BalanceResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) ClearBulkLoad 

func (p *AdminClientClient) ClearBulkLoad(ctx context.Context, req *ClearBulkLoadStateRequest) (r *ClearBulkLoadStateResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) Client_ 

func (p *AdminClientClient) Client_() thrift.TClient

func (*AdminClientClient) ControlBulkLoad 

func (p *AdminClientClient) ControlBulkLoad(ctx context.Context, req *ControlBulkLoadRequest) (r *ControlBulkLoadResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) ControlPartitionSplit 

func (p *AdminClientClient) ControlPartitionSplit(ctx context.Context, req *ControlSplitRequest) (r *ControlSplitResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) CreateApp 

func (p *AdminClientClient) CreateApp(ctx context.Context, req *CreateAppRequest) (r *CreateAppResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) DropApp 

func (p *AdminClientClient) DropApp(ctx context.Context, req *DropAppRequest) (r *DropAppResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) ListApps 

func (p *AdminClientClient) ListApps(ctx context.Context, req *ListAppsRequest) (r *ListAppsResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) ListNodes 

func (p *AdminClientClient) ListNodes(ctx context.Context, req *ListNodesRequest) (r *ListNodesResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) MetaControl 

func (p *AdminClientClient) MetaControl(ctx context.Context, req *MetaControlRequest) (r *MetaControlResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) ModifyDuplication 

func (p *AdminClientClient) ModifyDuplication(ctx context.Context, req *DuplicationModifyRequest) (r *DuplicationModifyResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) QueryAppInfo 

func (p *AdminClientClient) QueryAppInfo(ctx context.Context, req *QueryAppInfoRequest) (r *QueryAppInfoResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) QueryBackupPolicy 

func (p *AdminClientClient) QueryBackupPolicy(ctx context.Context, req *QueryBackupPolicyRequest) (r *QueryBackupPolicyResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) QueryBackupStatus 

func (p *AdminClientClient) QueryBackupStatus(ctx context.Context, req *QueryBackupStatusRequest) (r *QueryBackupStatusResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) QueryBulkLoadStatus 

func (p *AdminClientClient) QueryBulkLoadStatus(ctx context.Context, req *QueryBulkLoadRequest) (r *QueryBulkLoadResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) QueryClusterInfo 

func (p *AdminClientClient) QueryClusterInfo(ctx context.Context, req *ClusterInfoRequest) (r *ClusterInfoResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) QueryDuplication 

func (p *AdminClientClient) QueryDuplication(ctx context.Context, req *DuplicationQueryRequest) (r *DuplicationQueryResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) QueryManualCompact 

func (p *AdminClientClient) QueryManualCompact(ctx context.Context, req *QueryAppManualCompactRequest) (r *QueryAppManualCompactResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) QuerySplitStatus 

func (p *AdminClientClient) QuerySplitStatus(ctx context.Context, req *QuerySplitRequest) (r *QuerySplitResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) RecallApp 

func (p *AdminClientClient) RecallApp(ctx context.Context, req *RecallAppRequest) (r *RecallAppResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) RestoreApp 

func (p *AdminClientClient) RestoreApp(ctx context.Context, req *RestoreAppRequest) (r *CreateAppResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) StartBackupApp 

func (p *AdminClientClient) StartBackupApp(ctx context.Context, req *StartBackupAppRequest) (r *StartBackupAppResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) StartBulkLoad 

func (p *AdminClientClient) StartBulkLoad(ctx context.Context, req *StartBulkLoadRequest) (r *StartBulkLoadResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) StartManualCompact 

func (p *AdminClientClient) StartManualCompact(ctx context.Context, req *StartAppManualCompactRequest) (r *StartAppManualCompactResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) StartPartitionSplit 

func (p *AdminClientClient) StartPartitionSplit(ctx context.Context, req *StartPartitionSplitRequest) (r *StartPartitionSplitResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) UpdateAppEnv 

func (p *AdminClientClient) UpdateAppEnv(ctx context.Context, req *UpdateAppEnvRequest) (r *UpdateAppEnvResponse, err error)

Parameters:

  • Req

type AdminClientControlBulkLoadArgs 

type AdminClientControlBulkLoadArgs struct {
	Req *ControlBulkLoadRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientControlBulkLoadArgs 

func NewAdminClientControlBulkLoadArgs() *AdminClientControlBulkLoadArgs

func (*AdminClientControlBulkLoadArgs) GetReq 

func (p *AdminClientControlBulkLoadArgs) GetReq() *ControlBulkLoadRequest

func (*AdminClientControlBulkLoadArgs) IsSetReq 

func (p *AdminClientControlBulkLoadArgs) IsSetReq() bool

func (*AdminClientControlBulkLoadArgs) Read 

func (p *AdminClientControlBulkLoadArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientControlBulkLoadArgs) ReadField1 

func (p *AdminClientControlBulkLoadArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientControlBulkLoadArgs) String 

func (p *AdminClientControlBulkLoadArgs) String() string

func (*AdminClientControlBulkLoadArgs) Write 

func (p *AdminClientControlBulkLoadArgs) Write(oprot thrift.TProtocol) error

type AdminClientControlBulkLoadResult 

type AdminClientControlBulkLoadResult struct {
	Success *ControlBulkLoadResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientControlBulkLoadResult 

func NewAdminClientControlBulkLoadResult() *AdminClientControlBulkLoadResult

func (*AdminClientControlBulkLoadResult) GetSuccess 

func (p *AdminClientControlBulkLoadResult) GetSuccess() *ControlBulkLoadResponse

func (*AdminClientControlBulkLoadResult) IsSetSuccess 

func (p *AdminClientControlBulkLoadResult) IsSetSuccess() bool

func (*AdminClientControlBulkLoadResult) Read 

func (p *AdminClientControlBulkLoadResult) Read(iprot thrift.TProtocol) error

func (*AdminClientControlBulkLoadResult) ReadField0 

func (p *AdminClientControlBulkLoadResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientControlBulkLoadResult) String 

func (p *AdminClientControlBulkLoadResult) String() string

func (*AdminClientControlBulkLoadResult) Write 

func (p *AdminClientControlBulkLoadResult) Write(oprot thrift.TProtocol) error

type AdminClientControlPartitionSplitArgs 

type AdminClientControlPartitionSplitArgs struct {
	Req *ControlSplitRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientControlPartitionSplitArgs 

func NewAdminClientControlPartitionSplitArgs() *AdminClientControlPartitionSplitArgs

func (*AdminClientControlPartitionSplitArgs) GetReq 

func (p *AdminClientControlPartitionSplitArgs) GetReq() *ControlSplitRequest

func (*AdminClientControlPartitionSplitArgs) IsSetReq 

func (p *AdminClientControlPartitionSplitArgs) IsSetReq() bool

func (*AdminClientControlPartitionSplitArgs) Read 

func (p *AdminClientControlPartitionSplitArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientControlPartitionSplitArgs) ReadField1 

func (p *AdminClientControlPartitionSplitArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientControlPartitionSplitArgs) String 

func (p *AdminClientControlPartitionSplitArgs) String() string

func (*AdminClientControlPartitionSplitArgs) Write 

func (p *AdminClientControlPartitionSplitArgs) Write(oprot thrift.TProtocol) error

type AdminClientControlPartitionSplitResult 

type AdminClientControlPartitionSplitResult struct {
	Success *ControlSplitResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientControlPartitionSplitResult 

func NewAdminClientControlPartitionSplitResult() *AdminClientControlPartitionSplitResult

func (*AdminClientControlPartitionSplitResult) GetSuccess 

func (p *AdminClientControlPartitionSplitResult) GetSuccess() *ControlSplitResponse

func (*AdminClientControlPartitionSplitResult) IsSetSuccess 

func (p *AdminClientControlPartitionSplitResult) IsSetSuccess() bool

func (*AdminClientControlPartitionSplitResult) Read 

func (p *AdminClientControlPartitionSplitResult) Read(iprot thrift.TProtocol) error

func (*AdminClientControlPartitionSplitResult) ReadField0 

func (p *AdminClientControlPartitionSplitResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientControlPartitionSplitResult) String 

func (p *AdminClientControlPartitionSplitResult) String() string

func (*AdminClientControlPartitionSplitResult) Write 

func (p *AdminClientControlPartitionSplitResult) Write(oprot thrift.TProtocol) error

type AdminClientCreateAppArgs 

type AdminClientCreateAppArgs struct {
	Req *CreateAppRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientCreateAppArgs 

func NewAdminClientCreateAppArgs() *AdminClientCreateAppArgs

func (*AdminClientCreateAppArgs) GetReq 

func (p *AdminClientCreateAppArgs) GetReq() *CreateAppRequest

func (*AdminClientCreateAppArgs) IsSetReq 

func (p *AdminClientCreateAppArgs) IsSetReq() bool

func (*AdminClientCreateAppArgs) Read 

func (p *AdminClientCreateAppArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientCreateAppArgs) ReadField1 

func (p *AdminClientCreateAppArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientCreateAppArgs) String 

func (p *AdminClientCreateAppArgs) String() string

func (*AdminClientCreateAppArgs) Write 

func (p *AdminClientCreateAppArgs) Write(oprot thrift.TProtocol) error

type AdminClientCreateAppResult 

type AdminClientCreateAppResult struct {
	Success *CreateAppResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientCreateAppResult 

func NewAdminClientCreateAppResult() *AdminClientCreateAppResult

func (*AdminClientCreateAppResult) GetSuccess 

func (p *AdminClientCreateAppResult) GetSuccess() *CreateAppResponse

func (*AdminClientCreateAppResult) IsSetSuccess 

func (p *AdminClientCreateAppResult) IsSetSuccess() bool

func (*AdminClientCreateAppResult) Read 

func (p *AdminClientCreateAppResult) Read(iprot thrift.TProtocol) error

func (*AdminClientCreateAppResult) ReadField0 

func (p *AdminClientCreateAppResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientCreateAppResult) String 

func (p *AdminClientCreateAppResult) String() string

func (*AdminClientCreateAppResult) Write 

func (p *AdminClientCreateAppResult) Write(oprot thrift.TProtocol) error

type AdminClientDropAppArgs 

type AdminClientDropAppArgs struct {
	Req *DropAppRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientDropAppArgs 

func NewAdminClientDropAppArgs() *AdminClientDropAppArgs

func (*AdminClientDropAppArgs) GetReq 

func (p *AdminClientDropAppArgs) GetReq() *DropAppRequest

func (*AdminClientDropAppArgs) IsSetReq 

func (p *AdminClientDropAppArgs) IsSetReq() bool

func (*AdminClientDropAppArgs) Read 

func (p *AdminClientDropAppArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientDropAppArgs) ReadField1 

func (p *AdminClientDropAppArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientDropAppArgs) String 

func (p *AdminClientDropAppArgs) String() string

func (*AdminClientDropAppArgs) Write 

func (p *AdminClientDropAppArgs) Write(oprot thrift.TProtocol) error

type AdminClientDropAppResult 

type AdminClientDropAppResult struct {
	Success *DropAppResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientDropAppResult 

func NewAdminClientDropAppResult() *AdminClientDropAppResult

func (*AdminClientDropAppResult) GetSuccess 

func (p *AdminClientDropAppResult) GetSuccess() *DropAppResponse

func (*AdminClientDropAppResult) IsSetSuccess 

func (p *AdminClientDropAppResult) IsSetSuccess() bool

func (*AdminClientDropAppResult) Read 

func (p *AdminClientDropAppResult) Read(iprot thrift.TProtocol) error

func (*AdminClientDropAppResult) ReadField0 

func (p *AdminClientDropAppResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientDropAppResult) String 

func (p *AdminClientDropAppResult) String() string

func (*AdminClientDropAppResult) Write 

func (p *AdminClientDropAppResult) Write(oprot thrift.TProtocol) error

type AdminClientListAppsArgs 

type AdminClientListAppsArgs struct {
	Req *ListAppsRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientListAppsArgs 

func NewAdminClientListAppsArgs() *AdminClientListAppsArgs

func (*AdminClientListAppsArgs) GetReq 

func (p *AdminClientListAppsArgs) GetReq() *ListAppsRequest

func (*AdminClientListAppsArgs) IsSetReq 

func (p *AdminClientListAppsArgs) IsSetReq() bool

func (*AdminClientListAppsArgs) Read 

func (p *AdminClientListAppsArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientListAppsArgs) ReadField1 

func (p *AdminClientListAppsArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientListAppsArgs) String 

func (p *AdminClientListAppsArgs) String() string

func (*AdminClientListAppsArgs) Write 

func (p *AdminClientListAppsArgs) Write(oprot thrift.TProtocol) error

type AdminClientListAppsResult 

type AdminClientListAppsResult struct {
	Success *ListAppsResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientListAppsResult 

func NewAdminClientListAppsResult() *AdminClientListAppsResult

func (*AdminClientListAppsResult) GetSuccess 

func (p *AdminClientListAppsResult) GetSuccess() *ListAppsResponse

func (*AdminClientListAppsResult) IsSetSuccess 

func (p *AdminClientListAppsResult) IsSetSuccess() bool

func (*AdminClientListAppsResult) Read 

func (p *AdminClientListAppsResult) Read(iprot thrift.TProtocol) error

func (*AdminClientListAppsResult) ReadField0 

func (p *AdminClientListAppsResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientListAppsResult) String 

func (p *AdminClientListAppsResult) String() string

func (*AdminClientListAppsResult) Write 

func (p *AdminClientListAppsResult) Write(oprot thrift.TProtocol) error

type AdminClientListNodesArgs 

type AdminClientListNodesArgs struct {
	Req *ListNodesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientListNodesArgs 

func NewAdminClientListNodesArgs() *AdminClientListNodesArgs

func (*AdminClientListNodesArgs) GetReq 

func (p *AdminClientListNodesArgs) GetReq() *ListNodesRequest

func (*AdminClientListNodesArgs) IsSetReq 

func (p *AdminClientListNodesArgs) IsSetReq() bool

func (*AdminClientListNodesArgs) Read 

func (p *AdminClientListNodesArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientListNodesArgs) ReadField1 

func (p *AdminClientListNodesArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientListNodesArgs) String 

func (p *AdminClientListNodesArgs) String() string

func (*AdminClientListNodesArgs) Write 

func (p *AdminClientListNodesArgs) Write(oprot thrift.TProtocol) error

type AdminClientListNodesResult 

type AdminClientListNodesResult struct {
	Success *ListNodesResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientListNodesResult 

func NewAdminClientListNodesResult() *AdminClientListNodesResult

func (*AdminClientListNodesResult) GetSuccess 

func (p *AdminClientListNodesResult) GetSuccess() *ListNodesResponse

func (*AdminClientListNodesResult) IsSetSuccess 

func (p *AdminClientListNodesResult) IsSetSuccess() bool

func (*AdminClientListNodesResult) Read 

func (p *AdminClientListNodesResult) Read(iprot thrift.TProtocol) error

func (*AdminClientListNodesResult) ReadField0 

func (p *AdminClientListNodesResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientListNodesResult) String 

func (p *AdminClientListNodesResult) String() string

func (*AdminClientListNodesResult) Write 

func (p *AdminClientListNodesResult) Write(oprot thrift.TProtocol) error

type AdminClientMetaControlArgs 

type AdminClientMetaControlArgs struct {
	Req *MetaControlRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientMetaControlArgs 

func NewAdminClientMetaControlArgs() *AdminClientMetaControlArgs

func (*AdminClientMetaControlArgs) GetReq 

func (p *AdminClientMetaControlArgs) GetReq() *MetaControlRequest

func (*AdminClientMetaControlArgs) IsSetReq 

func (p *AdminClientMetaControlArgs) IsSetReq() bool

func (*AdminClientMetaControlArgs) Read 

func (p *AdminClientMetaControlArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientMetaControlArgs) ReadField1 

func (p *AdminClientMetaControlArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientMetaControlArgs) String 

func (p *AdminClientMetaControlArgs) String() string

func (*AdminClientMetaControlArgs) Write 

func (p *AdminClientMetaControlArgs) Write(oprot thrift.TProtocol) error

type AdminClientMetaControlResult 

type AdminClientMetaControlResult struct {
	Success *MetaControlResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientMetaControlResult 

func NewAdminClientMetaControlResult() *AdminClientMetaControlResult

func (*AdminClientMetaControlResult) GetSuccess 

func (p *AdminClientMetaControlResult) GetSuccess() *MetaControlResponse

func (*AdminClientMetaControlResult) IsSetSuccess 

func (p *AdminClientMetaControlResult) IsSetSuccess() bool

func (*AdminClientMetaControlResult) Read 

func (p *AdminClientMetaControlResult) Read(iprot thrift.TProtocol) error

func (*AdminClientMetaControlResult) ReadField0 

func (p *AdminClientMetaControlResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientMetaControlResult) String 

func (p *AdminClientMetaControlResult) String() string

func (*AdminClientMetaControlResult) Write 

func (p *AdminClientMetaControlResult) Write(oprot thrift.TProtocol) error

type AdminClientModifyDuplicationArgs 

type AdminClientModifyDuplicationArgs struct {
	Req *DuplicationModifyRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientModifyDuplicationArgs 

func NewAdminClientModifyDuplicationArgs() *AdminClientModifyDuplicationArgs

func (*AdminClientModifyDuplicationArgs) GetReq 

func (p *AdminClientModifyDuplicationArgs) GetReq() *DuplicationModifyRequest

func (*AdminClientModifyDuplicationArgs) IsSetReq 

func (p *AdminClientModifyDuplicationArgs) IsSetReq() bool

func (*AdminClientModifyDuplicationArgs) Read 

func (p *AdminClientModifyDuplicationArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientModifyDuplicationArgs) ReadField1 

func (p *AdminClientModifyDuplicationArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientModifyDuplicationArgs) String 

func (p *AdminClientModifyDuplicationArgs) String() string

func (*AdminClientModifyDuplicationArgs) Write 

func (p *AdminClientModifyDuplicationArgs) Write(oprot thrift.TProtocol) error

type AdminClientModifyDuplicationResult 

type AdminClientModifyDuplicationResult struct {
	Success *DuplicationModifyResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientModifyDuplicationResult 

func NewAdminClientModifyDuplicationResult() *AdminClientModifyDuplicationResult

func (*AdminClientModifyDuplicationResult) GetSuccess 

func (p *AdminClientModifyDuplicationResult) GetSuccess() *DuplicationModifyResponse

func (*AdminClientModifyDuplicationResult) IsSetSuccess 

func (p *AdminClientModifyDuplicationResult) IsSetSuccess() bool

func (*AdminClientModifyDuplicationResult) Read 

func (p *AdminClientModifyDuplicationResult) Read(iprot thrift.TProtocol) error

func (*AdminClientModifyDuplicationResult) ReadField0 

func (p *AdminClientModifyDuplicationResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientModifyDuplicationResult) String 

func (p *AdminClientModifyDuplicationResult) String() string

func (*AdminClientModifyDuplicationResult) Write 

func (p *AdminClientModifyDuplicationResult) Write(oprot thrift.TProtocol) error

type AdminClientProcessor 

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

func NewAdminClientProcessor 

func NewAdminClientProcessor(handler AdminClient) *AdminClientProcessor

func (*AdminClientProcessor) AddToProcessorMap 

func (p *AdminClientProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*AdminClientProcessor) GetProcessorFunction 

func (p *AdminClientProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*AdminClientProcessor) Process 

func (p *AdminClientProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*AdminClientProcessor) ProcessorMap 

func (p *AdminClientProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type AdminClientQueryAppInfoArgs 

type AdminClientQueryAppInfoArgs struct {
	Req *QueryAppInfoRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientQueryAppInfoArgs 

func NewAdminClientQueryAppInfoArgs() *AdminClientQueryAppInfoArgs

func (*AdminClientQueryAppInfoArgs) GetReq 

func (p *AdminClientQueryAppInfoArgs) GetReq() *QueryAppInfoRequest

func (*AdminClientQueryAppInfoArgs) IsSetReq 

func (p *AdminClientQueryAppInfoArgs) IsSetReq() bool

func (*AdminClientQueryAppInfoArgs) Read 

func (p *AdminClientQueryAppInfoArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryAppInfoArgs) ReadField1 

func (p *AdminClientQueryAppInfoArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientQueryAppInfoArgs) String 

func (p *AdminClientQueryAppInfoArgs) String() string

func (*AdminClientQueryAppInfoArgs) Write 

func (p *AdminClientQueryAppInfoArgs) Write(oprot thrift.TProtocol) error

type AdminClientQueryAppInfoResult 

type AdminClientQueryAppInfoResult struct {
	Success *QueryAppInfoResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientQueryAppInfoResult 

func NewAdminClientQueryAppInfoResult() *AdminClientQueryAppInfoResult

func (*AdminClientQueryAppInfoResult) GetSuccess 

func (p *AdminClientQueryAppInfoResult) GetSuccess() *QueryAppInfoResponse

func (*AdminClientQueryAppInfoResult) IsSetSuccess 

func (p *AdminClientQueryAppInfoResult) IsSetSuccess() bool

func (*AdminClientQueryAppInfoResult) Read 

func (p *AdminClientQueryAppInfoResult) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryAppInfoResult) ReadField0 

func (p *AdminClientQueryAppInfoResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientQueryAppInfoResult) String 

func (p *AdminClientQueryAppInfoResult) String() string

func (*AdminClientQueryAppInfoResult) Write 

func (p *AdminClientQueryAppInfoResult) Write(oprot thrift.TProtocol) error

type AdminClientQueryBackupPolicyArgs 

type AdminClientQueryBackupPolicyArgs struct {
	Req *QueryBackupPolicyRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientQueryBackupPolicyArgs 

func NewAdminClientQueryBackupPolicyArgs() *AdminClientQueryBackupPolicyArgs

func (*AdminClientQueryBackupPolicyArgs) GetReq 

func (p *AdminClientQueryBackupPolicyArgs) GetReq() *QueryBackupPolicyRequest

func (*AdminClientQueryBackupPolicyArgs) IsSetReq 

func (p *AdminClientQueryBackupPolicyArgs) IsSetReq() bool

func (*AdminClientQueryBackupPolicyArgs) Read 

func (p *AdminClientQueryBackupPolicyArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryBackupPolicyArgs) ReadField1 

func (p *AdminClientQueryBackupPolicyArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientQueryBackupPolicyArgs) String 

func (p *AdminClientQueryBackupPolicyArgs) String() string

func (*AdminClientQueryBackupPolicyArgs) Write 

func (p *AdminClientQueryBackupPolicyArgs) Write(oprot thrift.TProtocol) error

type AdminClientQueryBackupPolicyResult 

type AdminClientQueryBackupPolicyResult struct {
	Success *QueryBackupPolicyResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientQueryBackupPolicyResult 

func NewAdminClientQueryBackupPolicyResult() *AdminClientQueryBackupPolicyResult

func (*AdminClientQueryBackupPolicyResult) GetSuccess 

func (p *AdminClientQueryBackupPolicyResult) GetSuccess() *QueryBackupPolicyResponse

func (*AdminClientQueryBackupPolicyResult) IsSetSuccess 

func (p *AdminClientQueryBackupPolicyResult) IsSetSuccess() bool

func (*AdminClientQueryBackupPolicyResult) Read 

func (p *AdminClientQueryBackupPolicyResult) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryBackupPolicyResult) ReadField0 

func (p *AdminClientQueryBackupPolicyResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientQueryBackupPolicyResult) String 

func (p *AdminClientQueryBackupPolicyResult) String() string

func (*AdminClientQueryBackupPolicyResult) Write 

func (p *AdminClientQueryBackupPolicyResult) Write(oprot thrift.TProtocol) error

type AdminClientQueryBackupStatusArgs 

type AdminClientQueryBackupStatusArgs struct {
	Req *QueryBackupStatusRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientQueryBackupStatusArgs 

func NewAdminClientQueryBackupStatusArgs() *AdminClientQueryBackupStatusArgs

func (*AdminClientQueryBackupStatusArgs) GetReq 

func (p *AdminClientQueryBackupStatusArgs) GetReq() *QueryBackupStatusRequest

func (*AdminClientQueryBackupStatusArgs) IsSetReq 

func (p *AdminClientQueryBackupStatusArgs) IsSetReq() bool

func (*AdminClientQueryBackupStatusArgs) Read 

func (p *AdminClientQueryBackupStatusArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryBackupStatusArgs) ReadField1 

func (p *AdminClientQueryBackupStatusArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientQueryBackupStatusArgs) String 

func (p *AdminClientQueryBackupStatusArgs) String() string

func (*AdminClientQueryBackupStatusArgs) Write 

func (p *AdminClientQueryBackupStatusArgs) Write(oprot thrift.TProtocol) error

type AdminClientQueryBackupStatusResult 

type AdminClientQueryBackupStatusResult struct {
	Success *QueryBackupStatusResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientQueryBackupStatusResult 

func NewAdminClientQueryBackupStatusResult() *AdminClientQueryBackupStatusResult

func (*AdminClientQueryBackupStatusResult) GetSuccess 

func (p *AdminClientQueryBackupStatusResult) GetSuccess() *QueryBackupStatusResponse

func (*AdminClientQueryBackupStatusResult) IsSetSuccess 

func (p *AdminClientQueryBackupStatusResult) IsSetSuccess() bool

func (*AdminClientQueryBackupStatusResult) Read 

func (p *AdminClientQueryBackupStatusResult) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryBackupStatusResult) ReadField0 

func (p *AdminClientQueryBackupStatusResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientQueryBackupStatusResult) String 

func (p *AdminClientQueryBackupStatusResult) String() string

func (*AdminClientQueryBackupStatusResult) Write 

func (p *AdminClientQueryBackupStatusResult) Write(oprot thrift.TProtocol) error

type AdminClientQueryBulkLoadStatusArgs 

type AdminClientQueryBulkLoadStatusArgs struct {
	Req *QueryBulkLoadRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientQueryBulkLoadStatusArgs 

func NewAdminClientQueryBulkLoadStatusArgs() *AdminClientQueryBulkLoadStatusArgs

func (*AdminClientQueryBulkLoadStatusArgs) GetReq 

func (p *AdminClientQueryBulkLoadStatusArgs) GetReq() *QueryBulkLoadRequest

func (*AdminClientQueryBulkLoadStatusArgs) IsSetReq 

func (p *AdminClientQueryBulkLoadStatusArgs) IsSetReq() bool

func (*AdminClientQueryBulkLoadStatusArgs) Read 

func (p *AdminClientQueryBulkLoadStatusArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryBulkLoadStatusArgs) ReadField1 

func (p *AdminClientQueryBulkLoadStatusArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientQueryBulkLoadStatusArgs) String 

func (p *AdminClientQueryBulkLoadStatusArgs) String() string

func (*AdminClientQueryBulkLoadStatusArgs) Write 

func (p *AdminClientQueryBulkLoadStatusArgs) Write(oprot thrift.TProtocol) error

type AdminClientQueryBulkLoadStatusResult 

type AdminClientQueryBulkLoadStatusResult struct {
	Success *QueryBulkLoadResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientQueryBulkLoadStatusResult 

func NewAdminClientQueryBulkLoadStatusResult() *AdminClientQueryBulkLoadStatusResult

func (*AdminClientQueryBulkLoadStatusResult) GetSuccess 

func (p *AdminClientQueryBulkLoadStatusResult) GetSuccess() *QueryBulkLoadResponse

func (*AdminClientQueryBulkLoadStatusResult) IsSetSuccess 

func (p *AdminClientQueryBulkLoadStatusResult) IsSetSuccess() bool

func (*AdminClientQueryBulkLoadStatusResult) Read 

func (p *AdminClientQueryBulkLoadStatusResult) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryBulkLoadStatusResult) ReadField0 

func (p *AdminClientQueryBulkLoadStatusResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientQueryBulkLoadStatusResult) String 

func (p *AdminClientQueryBulkLoadStatusResult) String() string

func (*AdminClientQueryBulkLoadStatusResult) Write 

func (p *AdminClientQueryBulkLoadStatusResult) Write(oprot thrift.TProtocol) error

type AdminClientQueryClusterInfoArgs 

type AdminClientQueryClusterInfoArgs struct {
	Req *ClusterInfoRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientQueryClusterInfoArgs 

func NewAdminClientQueryClusterInfoArgs() *AdminClientQueryClusterInfoArgs

func (*AdminClientQueryClusterInfoArgs) GetReq 

func (p *AdminClientQueryClusterInfoArgs) GetReq() *ClusterInfoRequest

func (*AdminClientQueryClusterInfoArgs) IsSetReq 

func (p *AdminClientQueryClusterInfoArgs) IsSetReq() bool

func (*AdminClientQueryClusterInfoArgs) Read 

func (p *AdminClientQueryClusterInfoArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryClusterInfoArgs) ReadField1 

func (p *AdminClientQueryClusterInfoArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientQueryClusterInfoArgs) String 

func (p *AdminClientQueryClusterInfoArgs) String() string

func (*AdminClientQueryClusterInfoArgs) Write 

func (p *AdminClientQueryClusterInfoArgs) Write(oprot thrift.TProtocol) error

type AdminClientQueryClusterInfoResult 

type AdminClientQueryClusterInfoResult struct {
	Success *ClusterInfoResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientQueryClusterInfoResult 

func NewAdminClientQueryClusterInfoResult() *AdminClientQueryClusterInfoResult

func (*AdminClientQueryClusterInfoResult) GetSuccess 

func (p *AdminClientQueryClusterInfoResult) GetSuccess() *ClusterInfoResponse

func (*AdminClientQueryClusterInfoResult) IsSetSuccess 

func (p *AdminClientQueryClusterInfoResult) IsSetSuccess() bool

func (*AdminClientQueryClusterInfoResult) Read 

func (p *AdminClientQueryClusterInfoResult) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryClusterInfoResult) ReadField0 

func (p *AdminClientQueryClusterInfoResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientQueryClusterInfoResult) String 

func (p *AdminClientQueryClusterInfoResult) String() string

func (*AdminClientQueryClusterInfoResult) Write 

func (p *AdminClientQueryClusterInfoResult) Write(oprot thrift.TProtocol) error

type AdminClientQueryDuplicationArgs 

type AdminClientQueryDuplicationArgs struct {
	Req *DuplicationQueryRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientQueryDuplicationArgs 

func NewAdminClientQueryDuplicationArgs() *AdminClientQueryDuplicationArgs

func (*AdminClientQueryDuplicationArgs) GetReq 

func (p *AdminClientQueryDuplicationArgs) GetReq() *DuplicationQueryRequest

func (*AdminClientQueryDuplicationArgs) IsSetReq 

func (p *AdminClientQueryDuplicationArgs) IsSetReq() bool

func (*AdminClientQueryDuplicationArgs) Read 

func (p *AdminClientQueryDuplicationArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryDuplicationArgs) ReadField1 

func (p *AdminClientQueryDuplicationArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientQueryDuplicationArgs) String 

func (p *AdminClientQueryDuplicationArgs) String() string

func (*AdminClientQueryDuplicationArgs) Write 

func (p *AdminClientQueryDuplicationArgs) Write(oprot thrift.TProtocol) error

type AdminClientQueryDuplicationResult 

type AdminClientQueryDuplicationResult struct {
	Success *DuplicationQueryResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientQueryDuplicationResult 

func NewAdminClientQueryDuplicationResult() *AdminClientQueryDuplicationResult

func (*AdminClientQueryDuplicationResult) GetSuccess 

func (p *AdminClientQueryDuplicationResult) GetSuccess() *DuplicationQueryResponse

func (*AdminClientQueryDuplicationResult) IsSetSuccess 

func (p *AdminClientQueryDuplicationResult) IsSetSuccess() bool

func (*AdminClientQueryDuplicationResult) Read 

func (p *AdminClientQueryDuplicationResult) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryDuplicationResult) ReadField0 

func (p *AdminClientQueryDuplicationResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientQueryDuplicationResult) String 

func (p *AdminClientQueryDuplicationResult) String() string

func (*AdminClientQueryDuplicationResult) Write 

func (p *AdminClientQueryDuplicationResult) Write(oprot thrift.TProtocol) error

type AdminClientQueryManualCompactArgs 

type AdminClientQueryManualCompactArgs struct {
	Req *QueryAppManualCompactRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientQueryManualCompactArgs 

func NewAdminClientQueryManualCompactArgs() *AdminClientQueryManualCompactArgs

func (*AdminClientQueryManualCompactArgs) GetReq 

func (p *AdminClientQueryManualCompactArgs) GetReq() *QueryAppManualCompactRequest

func (*AdminClientQueryManualCompactArgs) IsSetReq 

func (p *AdminClientQueryManualCompactArgs) IsSetReq() bool

func (*AdminClientQueryManualCompactArgs) Read 

func (p *AdminClientQueryManualCompactArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryManualCompactArgs) ReadField1 

func (p *AdminClientQueryManualCompactArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientQueryManualCompactArgs) String 

func (p *AdminClientQueryManualCompactArgs) String() string

func (*AdminClientQueryManualCompactArgs) Write 

func (p *AdminClientQueryManualCompactArgs) Write(oprot thrift.TProtocol) error

type AdminClientQueryManualCompactResult 

type AdminClientQueryManualCompactResult struct {
	Success *QueryAppManualCompactResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientQueryManualCompactResult 

func NewAdminClientQueryManualCompactResult() *AdminClientQueryManualCompactResult

func (*AdminClientQueryManualCompactResult) GetSuccess 

func (p *AdminClientQueryManualCompactResult) GetSuccess() *QueryAppManualCompactResponse

func (*AdminClientQueryManualCompactResult) IsSetSuccess 

func (p *AdminClientQueryManualCompactResult) IsSetSuccess() bool

func (*AdminClientQueryManualCompactResult) Read 

func (p *AdminClientQueryManualCompactResult) Read(iprot thrift.TProtocol) error

func (*AdminClientQueryManualCompactResult) ReadField0 

func (p *AdminClientQueryManualCompactResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientQueryManualCompactResult) String 

func (p *AdminClientQueryManualCompactResult) String() string

func (*AdminClientQueryManualCompactResult) Write 

func (p *AdminClientQueryManualCompactResult) Write(oprot thrift.TProtocol) error

type AdminClientQuerySplitStatusArgs 

type AdminClientQuerySplitStatusArgs struct {
	Req *QuerySplitRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientQuerySplitStatusArgs 

func NewAdminClientQuerySplitStatusArgs() *AdminClientQuerySplitStatusArgs

func (*AdminClientQuerySplitStatusArgs) GetReq 

func (p *AdminClientQuerySplitStatusArgs) GetReq() *QuerySplitRequest

func (*AdminClientQuerySplitStatusArgs) IsSetReq 

func (p *AdminClientQuerySplitStatusArgs) IsSetReq() bool

func (*AdminClientQuerySplitStatusArgs) Read 

func (p *AdminClientQuerySplitStatusArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientQuerySplitStatusArgs) ReadField1 

func (p *AdminClientQuerySplitStatusArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientQuerySplitStatusArgs) String 

func (p *AdminClientQuerySplitStatusArgs) String() string

func (*AdminClientQuerySplitStatusArgs) Write 

func (p *AdminClientQuerySplitStatusArgs) Write(oprot thrift.TProtocol) error

type AdminClientQuerySplitStatusResult 

type AdminClientQuerySplitStatusResult struct {
	Success *QuerySplitResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientQuerySplitStatusResult 

func NewAdminClientQuerySplitStatusResult() *AdminClientQuerySplitStatusResult

func (*AdminClientQuerySplitStatusResult) GetSuccess 

func (p *AdminClientQuerySplitStatusResult) GetSuccess() *QuerySplitResponse

func (*AdminClientQuerySplitStatusResult) IsSetSuccess 

func (p *AdminClientQuerySplitStatusResult) IsSetSuccess() bool

func (*AdminClientQuerySplitStatusResult) Read 

func (p *AdminClientQuerySplitStatusResult) Read(iprot thrift.TProtocol) error

func (*AdminClientQuerySplitStatusResult) ReadField0 

func (p *AdminClientQuerySplitStatusResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientQuerySplitStatusResult) String 

func (p *AdminClientQuerySplitStatusResult) String() string

func (*AdminClientQuerySplitStatusResult) Write 

func (p *AdminClientQuerySplitStatusResult) Write(oprot thrift.TProtocol) error

type AdminClientRecallAppArgs 

type AdminClientRecallAppArgs struct {
	Req *RecallAppRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientRecallAppArgs 

func NewAdminClientRecallAppArgs() *AdminClientRecallAppArgs

func (*AdminClientRecallAppArgs) GetReq 

func (p *AdminClientRecallAppArgs) GetReq() *RecallAppRequest

func (*AdminClientRecallAppArgs) IsSetReq 

func (p *AdminClientRecallAppArgs) IsSetReq() bool

func (*AdminClientRecallAppArgs) Read 

func (p *AdminClientRecallAppArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientRecallAppArgs) ReadField1 

func (p *AdminClientRecallAppArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientRecallAppArgs) String 

func (p *AdminClientRecallAppArgs) String() string

func (*AdminClientRecallAppArgs) Write 

func (p *AdminClientRecallAppArgs) Write(oprot thrift.TProtocol) error

type AdminClientRecallAppResult 

type AdminClientRecallAppResult struct {
	Success *RecallAppResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientRecallAppResult 

func NewAdminClientRecallAppResult() *AdminClientRecallAppResult

func (*AdminClientRecallAppResult) GetSuccess 

func (p *AdminClientRecallAppResult) GetSuccess() *RecallAppResponse

func (*AdminClientRecallAppResult) IsSetSuccess 

func (p *AdminClientRecallAppResult) IsSetSuccess() bool

func (*AdminClientRecallAppResult) Read 

func (p *AdminClientRecallAppResult) Read(iprot thrift.TProtocol) error

func (*AdminClientRecallAppResult) ReadField0 

func (p *AdminClientRecallAppResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientRecallAppResult) String 

func (p *AdminClientRecallAppResult) String() string

func (*AdminClientRecallAppResult) Write 

func (p *AdminClientRecallAppResult) Write(oprot thrift.TProtocol) error

type AdminClientRestoreAppArgs 

type AdminClientRestoreAppArgs struct {
	Req *RestoreAppRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientRestoreAppArgs 

func NewAdminClientRestoreAppArgs() *AdminClientRestoreAppArgs

func (*AdminClientRestoreAppArgs) GetReq 

func (p *AdminClientRestoreAppArgs) GetReq() *RestoreAppRequest

func (*AdminClientRestoreAppArgs) IsSetReq 

func (p *AdminClientRestoreAppArgs) IsSetReq() bool

func (*AdminClientRestoreAppArgs) Read 

func (p *AdminClientRestoreAppArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientRestoreAppArgs) ReadField1 

func (p *AdminClientRestoreAppArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientRestoreAppArgs) String 

func (p *AdminClientRestoreAppArgs) String() string

func (*AdminClientRestoreAppArgs) Write 

func (p *AdminClientRestoreAppArgs) Write(oprot thrift.TProtocol) error

type AdminClientRestoreAppResult 

type AdminClientRestoreAppResult struct {
	Success *CreateAppResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientRestoreAppResult 

func NewAdminClientRestoreAppResult() *AdminClientRestoreAppResult

func (*AdminClientRestoreAppResult) GetSuccess 

func (p *AdminClientRestoreAppResult) GetSuccess() *CreateAppResponse

func (*AdminClientRestoreAppResult) IsSetSuccess 

func (p *AdminClientRestoreAppResult) IsSetSuccess() bool

func (*AdminClientRestoreAppResult) Read 

func (p *AdminClientRestoreAppResult) Read(iprot thrift.TProtocol) error

func (*AdminClientRestoreAppResult) ReadField0 

func (p *AdminClientRestoreAppResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientRestoreAppResult) String 

func (p *AdminClientRestoreAppResult) String() string

func (*AdminClientRestoreAppResult) Write 

func (p *AdminClientRestoreAppResult) Write(oprot thrift.TProtocol) error

type AdminClientStartBackupAppArgs 

type AdminClientStartBackupAppArgs struct {
	Req *StartBackupAppRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientStartBackupAppArgs 

func NewAdminClientStartBackupAppArgs() *AdminClientStartBackupAppArgs

func (*AdminClientStartBackupAppArgs) GetReq 

func (p *AdminClientStartBackupAppArgs) GetReq() *StartBackupAppRequest

func (*AdminClientStartBackupAppArgs) IsSetReq 

func (p *AdminClientStartBackupAppArgs) IsSetReq() bool

func (*AdminClientStartBackupAppArgs) Read 

func (p *AdminClientStartBackupAppArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientStartBackupAppArgs) ReadField1 

func (p *AdminClientStartBackupAppArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientStartBackupAppArgs) String 

func (p *AdminClientStartBackupAppArgs) String() string

func (*AdminClientStartBackupAppArgs) Write 

func (p *AdminClientStartBackupAppArgs) Write(oprot thrift.TProtocol) error

type AdminClientStartBackupAppResult 

type AdminClientStartBackupAppResult struct {
	Success *StartBackupAppResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientStartBackupAppResult 

func NewAdminClientStartBackupAppResult() *AdminClientStartBackupAppResult

func (*AdminClientStartBackupAppResult) GetSuccess 

func (p *AdminClientStartBackupAppResult) GetSuccess() *StartBackupAppResponse

func (*AdminClientStartBackupAppResult) IsSetSuccess 

func (p *AdminClientStartBackupAppResult) IsSetSuccess() bool

func (*AdminClientStartBackupAppResult) Read 

func (p *AdminClientStartBackupAppResult) Read(iprot thrift.TProtocol) error

func (*AdminClientStartBackupAppResult) ReadField0 

func (p *AdminClientStartBackupAppResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientStartBackupAppResult) String 

func (p *AdminClientStartBackupAppResult) String() string

func (*AdminClientStartBackupAppResult) Write 

func (p *AdminClientStartBackupAppResult) Write(oprot thrift.TProtocol) error

type AdminClientStartBulkLoadArgs 

type AdminClientStartBulkLoadArgs struct {
	Req *StartBulkLoadRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientStartBulkLoadArgs 

func NewAdminClientStartBulkLoadArgs() *AdminClientStartBulkLoadArgs

func (*AdminClientStartBulkLoadArgs) GetReq 

func (p *AdminClientStartBulkLoadArgs) GetReq() *StartBulkLoadRequest

func (*AdminClientStartBulkLoadArgs) IsSetReq 

func (p *AdminClientStartBulkLoadArgs) IsSetReq() bool

func (*AdminClientStartBulkLoadArgs) Read 

func (p *AdminClientStartBulkLoadArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientStartBulkLoadArgs) ReadField1 

func (p *AdminClientStartBulkLoadArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientStartBulkLoadArgs) String 

func (p *AdminClientStartBulkLoadArgs) String() string

func (*AdminClientStartBulkLoadArgs) Write 

func (p *AdminClientStartBulkLoadArgs) Write(oprot thrift.TProtocol) error

type AdminClientStartBulkLoadResult 

type AdminClientStartBulkLoadResult struct {
	Success *StartBulkLoadResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientStartBulkLoadResult 

func NewAdminClientStartBulkLoadResult() *AdminClientStartBulkLoadResult

func (*AdminClientStartBulkLoadResult) GetSuccess 

func (p *AdminClientStartBulkLoadResult) GetSuccess() *StartBulkLoadResponse

func (*AdminClientStartBulkLoadResult) IsSetSuccess 

func (p *AdminClientStartBulkLoadResult) IsSetSuccess() bool

func (*AdminClientStartBulkLoadResult) Read 

func (p *AdminClientStartBulkLoadResult) Read(iprot thrift.TProtocol) error

func (*AdminClientStartBulkLoadResult) ReadField0 

func (p *AdminClientStartBulkLoadResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientStartBulkLoadResult) String 

func (p *AdminClientStartBulkLoadResult) String() string

func (*AdminClientStartBulkLoadResult) Write 

func (p *AdminClientStartBulkLoadResult) Write(oprot thrift.TProtocol) error

type AdminClientStartManualCompactArgs 

type AdminClientStartManualCompactArgs struct {
	Req *StartAppManualCompactRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientStartManualCompactArgs 

func NewAdminClientStartManualCompactArgs() *AdminClientStartManualCompactArgs

func (*AdminClientStartManualCompactArgs) GetReq 

func (p *AdminClientStartManualCompactArgs) GetReq() *StartAppManualCompactRequest

func (*AdminClientStartManualCompactArgs) IsSetReq 

func (p *AdminClientStartManualCompactArgs) IsSetReq() bool

func (*AdminClientStartManualCompactArgs) Read 

func (p *AdminClientStartManualCompactArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientStartManualCompactArgs) ReadField1 

func (p *AdminClientStartManualCompactArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientStartManualCompactArgs) String 

func (p *AdminClientStartManualCompactArgs) String() string

func (*AdminClientStartManualCompactArgs) Write 

func (p *AdminClientStartManualCompactArgs) Write(oprot thrift.TProtocol) error

type AdminClientStartManualCompactResult 

type AdminClientStartManualCompactResult struct {
	Success *StartAppManualCompactResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientStartManualCompactResult 

func NewAdminClientStartManualCompactResult() *AdminClientStartManualCompactResult

func (*AdminClientStartManualCompactResult) GetSuccess 

func (p *AdminClientStartManualCompactResult) GetSuccess() *StartAppManualCompactResponse

func (*AdminClientStartManualCompactResult) IsSetSuccess 

func (p *AdminClientStartManualCompactResult) IsSetSuccess() bool

func (*AdminClientStartManualCompactResult) Read 

func (p *AdminClientStartManualCompactResult) Read(iprot thrift.TProtocol) error

func (*AdminClientStartManualCompactResult) ReadField0 

func (p *AdminClientStartManualCompactResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientStartManualCompactResult) String 

func (p *AdminClientStartManualCompactResult) String() string

func (*AdminClientStartManualCompactResult) Write 

func (p *AdminClientStartManualCompactResult) Write(oprot thrift.TProtocol) error

type AdminClientStartPartitionSplitArgs 

type AdminClientStartPartitionSplitArgs struct {
	Req *StartPartitionSplitRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientStartPartitionSplitArgs 

func NewAdminClientStartPartitionSplitArgs() *AdminClientStartPartitionSplitArgs

func (*AdminClientStartPartitionSplitArgs) GetReq 

func (p *AdminClientStartPartitionSplitArgs) GetReq() *StartPartitionSplitRequest

func (*AdminClientStartPartitionSplitArgs) IsSetReq 

func (p *AdminClientStartPartitionSplitArgs) IsSetReq() bool

func (*AdminClientStartPartitionSplitArgs) Read 

func (p *AdminClientStartPartitionSplitArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientStartPartitionSplitArgs) ReadField1 

func (p *AdminClientStartPartitionSplitArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientStartPartitionSplitArgs) String 

func (p *AdminClientStartPartitionSplitArgs) String() string

func (*AdminClientStartPartitionSplitArgs) Write 

func (p *AdminClientStartPartitionSplitArgs) Write(oprot thrift.TProtocol) error

type AdminClientStartPartitionSplitResult 

type AdminClientStartPartitionSplitResult struct {
	Success *StartPartitionSplitResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientStartPartitionSplitResult 

func NewAdminClientStartPartitionSplitResult() *AdminClientStartPartitionSplitResult

func (*AdminClientStartPartitionSplitResult) GetSuccess 

func (p *AdminClientStartPartitionSplitResult) GetSuccess() *StartPartitionSplitResponse

func (*AdminClientStartPartitionSplitResult) IsSetSuccess 

func (p *AdminClientStartPartitionSplitResult) IsSetSuccess() bool

func (*AdminClientStartPartitionSplitResult) Read 

func (p *AdminClientStartPartitionSplitResult) Read(iprot thrift.TProtocol) error

func (*AdminClientStartPartitionSplitResult) ReadField0 

func (p *AdminClientStartPartitionSplitResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientStartPartitionSplitResult) String 

func (p *AdminClientStartPartitionSplitResult) String() string

func (*AdminClientStartPartitionSplitResult) Write 

func (p *AdminClientStartPartitionSplitResult) Write(oprot thrift.TProtocol) error

type AdminClientUpdateAppEnvArgs 

type AdminClientUpdateAppEnvArgs struct {
	Req *UpdateAppEnvRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientUpdateAppEnvArgs 

func NewAdminClientUpdateAppEnvArgs() *AdminClientUpdateAppEnvArgs

func (*AdminClientUpdateAppEnvArgs) GetReq 

func (p *AdminClientUpdateAppEnvArgs) GetReq() *UpdateAppEnvRequest

func (*AdminClientUpdateAppEnvArgs) IsSetReq 

func (p *AdminClientUpdateAppEnvArgs) IsSetReq() bool

func (*AdminClientUpdateAppEnvArgs) Read 

func (p *AdminClientUpdateAppEnvArgs) Read(iprot thrift.TProtocol) error

func (*AdminClientUpdateAppEnvArgs) ReadField1 

func (p *AdminClientUpdateAppEnvArgs) ReadField1(iprot thrift.TProtocol) error

func (*AdminClientUpdateAppEnvArgs) String 

func (p *AdminClientUpdateAppEnvArgs) String() string

func (*AdminClientUpdateAppEnvArgs) Write 

func (p *AdminClientUpdateAppEnvArgs) Write(oprot thrift.TProtocol) error

type AdminClientUpdateAppEnvResult 

type AdminClientUpdateAppEnvResult struct {
	Success *UpdateAppEnvResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientUpdateAppEnvResult 

func NewAdminClientUpdateAppEnvResult() *AdminClientUpdateAppEnvResult

func (*AdminClientUpdateAppEnvResult) GetSuccess 

func (p *AdminClientUpdateAppEnvResult) GetSuccess() *UpdateAppEnvResponse

func (*AdminClientUpdateAppEnvResult) IsSetSuccess 

func (p *AdminClientUpdateAppEnvResult) IsSetSuccess() bool

func (*AdminClientUpdateAppEnvResult) Read 

func (p *AdminClientUpdateAppEnvResult) Read(iprot thrift.TProtocol) error

func (*AdminClientUpdateAppEnvResult) ReadField0 

func (p *AdminClientUpdateAppEnvResult) ReadField0(iprot thrift.TProtocol) error

func (*AdminClientUpdateAppEnvResult) String 

func (p *AdminClientUpdateAppEnvResult) String() string

func (*AdminClientUpdateAppEnvResult) Write 

func (p *AdminClientUpdateAppEnvResult) Write(oprot thrift.TProtocol) error

type AppEnvOperation 

type AppEnvOperation int64
const (
	AppEnvOperation_APP_ENV_OP_INVALID AppEnvOperation = 0
	AppEnvOperation_APP_ENV_OP_SET     AppEnvOperation = 1
	AppEnvOperation_APP_ENV_OP_DEL     AppEnvOperation = 2
	AppEnvOperation_APP_ENV_OP_CLEAR   AppEnvOperation = 3
)

func AppEnvOperationFromString 

func AppEnvOperationFromString(s string) (AppEnvOperation, error)

func AppEnvOperationPtr 

func AppEnvOperationPtr(v AppEnvOperation) *AppEnvOperation

func (AppEnvOperation) MarshalText 

func (p AppEnvOperation) MarshalText() ([]byte, error)

func (*AppEnvOperation) Scan 

func (p *AppEnvOperation) Scan(value interface{}) error

func (AppEnvOperation) String 

func (p AppEnvOperation) String() string

func (*AppEnvOperation) UnmarshalText 

func (p *AppEnvOperation) UnmarshalText(text []byte) error

func (*AppEnvOperation) Value 

func (p *AppEnvOperation) Value() (driver.Value, error)

type AppInfo 

type AppInfo struct {
	Status             AppStatus         `thrift:"status,1" db:"status" json:"status"`
	AppType            string            `thrift:"app_type,2" db:"app_type" json:"app_type"`
	AppName            string            `thrift:"app_name,3" db:"app_name" json:"app_name"`
	AppID              int32             `thrift:"app_id,4" db:"app_id" json:"app_id"`
	PartitionCount     int32             `thrift:"partition_count,5" db:"partition_count" json:"partition_count"`
	Envs               map[string]string `thrift:"envs,6" db:"envs" json:"envs"`
	IsStateful         bool              `thrift:"is_stateful,7" db:"is_stateful" json:"is_stateful"`
	MaxReplicaCount    int32             `thrift:"max_replica_count,8" db:"max_replica_count" json:"max_replica_count"`
	ExpireSecond       int64             `thrift:"expire_second,9" db:"expire_second" json:"expire_second"`
	CreateSecond       int64             `thrift:"create_second,10" db:"create_second" json:"create_second"`
	DropSecond         int64             `thrift:"drop_second,11" db:"drop_second" json:"drop_second"`
	Duplicating        *bool             `thrift:"duplicating,12" db:"duplicating" json:"duplicating,omitempty"`
	InitPartitionCount int32             `thrift:"init_partition_count,13" db:"init_partition_count" json:"init_partition_count"`
	IsBulkLoading      bool              `thrift:"is_bulk_loading,14" db:"is_bulk_loading" json:"is_bulk_loading"`
}

Attributes:

  • Status
  • AppType
  • AppName
  • AppID
  • PartitionCount
  • Envs
  • IsStateful
  • MaxReplicaCount
  • ExpireSecond
  • CreateSecond
  • DropSecond
  • Duplicating
  • InitPartitionCount
  • IsBulkLoading
var RecallAppResponse_Info_DEFAULT *AppInfo

func NewAppInfo 

func NewAppInfo() *AppInfo

func (*AppInfo) GetAppID 

func (p *AppInfo) GetAppID() int32

func (*AppInfo) GetAppName 

func (p *AppInfo) GetAppName() string

func (*AppInfo) GetAppType 

func (p *AppInfo) GetAppType() string

func (*AppInfo) GetCreateSecond 

func (p *AppInfo) GetCreateSecond() int64

func (*AppInfo) GetDropSecond 

func (p *AppInfo) GetDropSecond() int64

func (*AppInfo) GetDuplicating 

func (p *AppInfo) GetDuplicating() bool

func (*AppInfo) GetEnvs 

func (p *AppInfo) GetEnvs() map[string]string

func (*AppInfo) GetExpireSecond 

func (p *AppInfo) GetExpireSecond() int64

func (*AppInfo) GetInitPartitionCount 

func (p *AppInfo) GetInitPartitionCount() int32

func (*AppInfo) GetIsBulkLoading 

func (p *AppInfo) GetIsBulkLoading() bool

func (*AppInfo) GetIsStateful 

func (p *AppInfo) GetIsStateful() bool

func (*AppInfo) GetMaxReplicaCount 

func (p *AppInfo) GetMaxReplicaCount() int32

func (*AppInfo) GetPartitionCount 

func (p *AppInfo) GetPartitionCount() int32

func (*AppInfo) GetStatus 

func (p *AppInfo) GetStatus() AppStatus

func (*AppInfo) IsSetDuplicating 

func (p *AppInfo) IsSetDuplicating() bool

func (*AppInfo) IsSetIsBulkLoading 

func (p *AppInfo) IsSetIsBulkLoading() bool

func (*AppInfo) Read 

func (p *AppInfo) Read(iprot thrift.TProtocol) error

func (*AppInfo) ReadField1 

func (p *AppInfo) ReadField1(iprot thrift.TProtocol) error

func (*AppInfo) ReadField10 

func (p *AppInfo) ReadField10(iprot thrift.TProtocol) error

func (*AppInfo) ReadField11 

func (p *AppInfo) ReadField11(iprot thrift.TProtocol) error

func (*AppInfo) ReadField12 

func (p *AppInfo) ReadField12(iprot thrift.TProtocol) error

func (*AppInfo) ReadField13 

func (p *AppInfo) ReadField13(iprot thrift.TProtocol) error

func (*AppInfo) ReadField14 

func (p *AppInfo) ReadField14(iprot thrift.TProtocol) error

func (*AppInfo) ReadField2 

func (p *AppInfo) ReadField2(iprot thrift.TProtocol) error

func (*AppInfo) ReadField3 

func (p *AppInfo) ReadField3(iprot thrift.TProtocol) error

func (*AppInfo) ReadField4 

func (p *AppInfo) ReadField4(iprot thrift.TProtocol) error

func (*AppInfo) ReadField5 

func (p *AppInfo) ReadField5(iprot thrift.TProtocol) error

func (*AppInfo) ReadField6 

func (p *AppInfo) ReadField6(iprot thrift.TProtocol) error

func (*AppInfo) ReadField7 

func (p *AppInfo) ReadField7(iprot thrift.TProtocol) error

func (*AppInfo) ReadField8 

func (p *AppInfo) ReadField8(iprot thrift.TProtocol) error

func (*AppInfo) ReadField9 

func (p *AppInfo) ReadField9(iprot thrift.TProtocol) error

func (*AppInfo) String 

func (p *AppInfo) String() string

func (*AppInfo) Write 

func (p *AppInfo) Write(oprot thrift.TProtocol) error

type AppStatus 

type AppStatus int64
const (
	AppStatus_AS_INVALID       AppStatus = 0
	AppStatus_AS_AVAILABLE     AppStatus = 1
	AppStatus_AS_CREATING      AppStatus = 2
	AppStatus_AS_CREATE_FAILED AppStatus = 3
	AppStatus_AS_DROPPING      AppStatus = 4
	AppStatus_AS_DROP_FAILED   AppStatus = 5
	AppStatus_AS_DROPPED       AppStatus = 6
	AppStatus_AS_RECALLING     AppStatus = 7
)

func AppStatusFromString 

func AppStatusFromString(s string) (AppStatus, error)

func AppStatusPtr 

func AppStatusPtr(v AppStatus) *AppStatus

func (AppStatus) MarshalText 

func (p AppStatus) MarshalText() ([]byte, error)

func (*AppStatus) Scan 

func (p *AppStatus) Scan(value interface{}) error

func (AppStatus) String 

func (p AppStatus) String() string

func (*AppStatus) UnmarshalText 

func (p *AppStatus) UnmarshalText(text []byte) error

func (*AppStatus) Value 

func (p *AppStatus) Value() (driver.Value, error)

type BackupEntry 

type BackupEntry struct {
	BackupID    int64   `thrift:"backup_id,1" db:"backup_id" json:"backup_id"`
	StartTimeMs int64   `thrift:"start_time_ms,2" db:"start_time_ms" json:"start_time_ms"`
	EndTimeMs   int64   `thrift:"end_time_ms,3" db:"end_time_ms" json:"end_time_ms"`
	AppIds      []int32 `thrift:"app_ids,4" db:"app_ids" json:"app_ids"`
}

Attributes:

  • BackupID
  • StartTimeMs
  • EndTimeMs
  • AppIds

func NewBackupEntry 

func NewBackupEntry() *BackupEntry

func (*BackupEntry) GetAppIds 

func (p *BackupEntry) GetAppIds() []int32

func (*BackupEntry) GetBackupID 

func (p *BackupEntry) GetBackupID() int64

func (*BackupEntry) GetEndTimeMs 

func (p *BackupEntry) GetEndTimeMs() int64

func (*BackupEntry) GetStartTimeMs 

func (p *BackupEntry) GetStartTimeMs() int64

func (*BackupEntry) Read 

func (p *BackupEntry) Read(iprot thrift.TProtocol) error

func (*BackupEntry) ReadField1 

func (p *BackupEntry) ReadField1(iprot thrift.TProtocol) error

func (*BackupEntry) ReadField2 

func (p *BackupEntry) ReadField2(iprot thrift.TProtocol) error

func (*BackupEntry) ReadField3 

func (p *BackupEntry) ReadField3(iprot thrift.TProtocol) error

func (*BackupEntry) ReadField4 

func (p *BackupEntry) ReadField4(iprot thrift.TProtocol) error

func (*BackupEntry) String 

func (p *BackupEntry) String() string

func (*BackupEntry) Write 

func (p *BackupEntry) Write(oprot thrift.TProtocol) error

type BackupItem 

type BackupItem struct {
	BackupID           int64  `thrift:"backup_id,1" db:"backup_id" json:"backup_id"`
	AppName            string `thrift:"app_name,2" db:"app_name" json:"app_name"`
	BackupProviderType string `thrift:"backup_provider_type,3" db:"backup_provider_type" json:"backup_provider_type"`
	BackupPath         string `thrift:"backup_path,4" db:"backup_path" json:"backup_path"`
	StartTimeMs        int64  `thrift:"start_time_ms,5" db:"start_time_ms" json:"start_time_ms"`
	EndTimeMs          int64  `thrift:"end_time_ms,6" db:"end_time_ms" json:"end_time_ms"`
	IsBackupFailed     bool   `thrift:"is_backup_failed,7" db:"is_backup_failed" json:"is_backup_failed"`
}

Attributes:

  • BackupID
  • AppName
  • BackupProviderType
  • BackupPath
  • StartTimeMs
  • EndTimeMs
  • IsBackupFailed

func NewBackupItem 

func NewBackupItem() *BackupItem

func (*BackupItem) GetAppName 

func (p *BackupItem) GetAppName() string

func (*BackupItem) GetBackupID 

func (p *BackupItem) GetBackupID() int64

func (*BackupItem) GetBackupPath 

func (p *BackupItem) GetBackupPath() string

func (*BackupItem) GetBackupProviderType 

func (p *BackupItem) GetBackupProviderType() string

func (*BackupItem) GetEndTimeMs 

func (p *BackupItem) GetEndTimeMs() int64

func (*BackupItem) GetIsBackupFailed 

func (p *BackupItem) GetIsBackupFailed() bool

func (*BackupItem) GetStartTimeMs 

func (p *BackupItem) GetStartTimeMs() int64

func (*BackupItem) Read 

func (p *BackupItem) Read(iprot thrift.TProtocol) error

func (*BackupItem) ReadField1 

func (p *BackupItem) ReadField1(iprot thrift.TProtocol) error

func (*BackupItem) ReadField2 

func (p *BackupItem) ReadField2(iprot thrift.TProtocol) error

func (*BackupItem) ReadField3 

func (p *BackupItem) ReadField3(iprot thrift.TProtocol) error

func (*BackupItem) ReadField4 

func (p *BackupItem) ReadField4(iprot thrift.TProtocol) error

func (*BackupItem) ReadField5 

func (p *BackupItem) ReadField5(iprot thrift.TProtocol) error

func (*BackupItem) ReadField6 

func (p *BackupItem) ReadField6(iprot thrift.TProtocol) error

func (*BackupItem) ReadField7 

func (p *BackupItem) ReadField7(iprot thrift.TProtocol) error

func (*BackupItem) String 

func (p *BackupItem) String() string

func (*BackupItem) Write 

func (p *BackupItem) Write(oprot thrift.TProtocol) error

type BalanceRequest 

type BalanceRequest struct {
	Gpid        *base.Gpid                     `thrift:"gpid,1" db:"gpid" json:"gpid"`
	ActionList  []*ConfigurationProposalAction `thrift:"action_list,2" db:"action_list" json:"action_list"`
	Force       bool                           `thrift:"force,3" db:"force" json:"force"`
	BalanceType *BalancerRequestType           `thrift:"balance_type,4" db:"balance_type" json:"balance_type,omitempty"`
}

Attributes:

  • Gpid
  • ActionList
  • Force
  • BalanceType
var AdminClientBalanceArgs_Req_DEFAULT *BalanceRequest

func NewBalanceRequest 

func NewBalanceRequest() *BalanceRequest

func (*BalanceRequest) GetActionList 

func (p *BalanceRequest) GetActionList() []*ConfigurationProposalAction

func (*BalanceRequest) GetBalanceType 

func (p *BalanceRequest) GetBalanceType() BalancerRequestType

func (*BalanceRequest) GetForce 

func (p *BalanceRequest) GetForce() bool

func (*BalanceRequest) GetGpid 

func (p *BalanceRequest) GetGpid() *base.Gpid

func (*BalanceRequest) IsSetBalanceType 

func (p *BalanceRequest) IsSetBalanceType() bool

func (*BalanceRequest) IsSetForce 

func (p *BalanceRequest) IsSetForce() bool

func (*BalanceRequest) IsSetGpid 

func (p *BalanceRequest) IsSetGpid() bool

func (*BalanceRequest) Read 

func (p *BalanceRequest) Read(iprot thrift.TProtocol) error

func (*BalanceRequest) ReadField1 

func (p *BalanceRequest) ReadField1(iprot thrift.TProtocol) error

func (*BalanceRequest) ReadField2 

func (p *BalanceRequest) ReadField2(iprot thrift.TProtocol) error

func (*BalanceRequest) ReadField3 

func (p *BalanceRequest) ReadField3(iprot thrift.TProtocol) error

func (*BalanceRequest) ReadField4 

func (p *BalanceRequest) ReadField4(iprot thrift.TProtocol) error

func (*BalanceRequest) String 

func (p *BalanceRequest) String() string

func (*BalanceRequest) Write 

func (p *BalanceRequest) Write(oprot thrift.TProtocol) error

type BalanceResponse 

type BalanceResponse struct {
	Err *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
}

Attributes:

  • Err
var AdminClientBalanceResult_Success_DEFAULT *BalanceResponse

func NewBalanceResponse 

func NewBalanceResponse() *BalanceResponse

func (*BalanceResponse) GetErr 

func (p *BalanceResponse) GetErr() *base.ErrorCode

func (*BalanceResponse) IsSetErr 

func (p *BalanceResponse) IsSetErr() bool

func (*BalanceResponse) Read 

func (p *BalanceResponse) Read(iprot thrift.TProtocol) error

func (*BalanceResponse) ReadField1 

func (p *BalanceResponse) ReadField1(iprot thrift.TProtocol) error

func (*BalanceResponse) String 

func (p *BalanceResponse) String() string

func (*BalanceResponse) Write 

func (p *BalanceResponse) Write(oprot thrift.TProtocol) error

type BalancerRequestType 

type BalancerRequestType int64
const (
	BalancerRequestType_move_primary   BalancerRequestType = 0
	BalancerRequestType_copy_primary   BalancerRequestType = 1
	BalancerRequestType_copy_secondary BalancerRequestType = 2
)
var BalanceRequest_BalanceType_DEFAULT BalancerRequestType

func BalancerRequestTypeFromString 

func BalancerRequestTypeFromString(s string) (BalancerRequestType, error)

func BalancerRequestTypePtr 

func BalancerRequestTypePtr(v BalancerRequestType) *BalancerRequestType

func (BalancerRequestType) MarshalText 

func (p BalancerRequestType) MarshalText() ([]byte, error)

func (*BalancerRequestType) Scan 

func (p *BalancerRequestType) Scan(value interface{}) error

func (BalancerRequestType) String 

func (p BalancerRequestType) String() string

func (*BalancerRequestType) UnmarshalText 

func (p *BalancerRequestType) UnmarshalText(text []byte) error

func (*BalancerRequestType) Value 

func (p *BalancerRequestType) Value() (driver.Value, error)

type BulkLoadControlType 

type BulkLoadControlType int64
const (
	BulkLoadControlType_BLC_PAUSE        BulkLoadControlType = 0
	BulkLoadControlType_BLC_RESTART      BulkLoadControlType = 1
	BulkLoadControlType_BLC_CANCEL       BulkLoadControlType = 2
	BulkLoadControlType_BLC_FORCE_CANCEL BulkLoadControlType = 3
)

func BulkLoadControlTypeFromString 

func BulkLoadControlTypeFromString(s string) (BulkLoadControlType, error)

func BulkLoadControlTypePtr 

func BulkLoadControlTypePtr(v BulkLoadControlType) *BulkLoadControlType

func (BulkLoadControlType) MarshalText 

func (p BulkLoadControlType) MarshalText() ([]byte, error)

func (*BulkLoadControlType) Scan 

func (p *BulkLoadControlType) Scan(value interface{}) error

func (BulkLoadControlType) String 

func (p BulkLoadControlType) String() string

func (*BulkLoadControlType) UnmarshalText 

func (p *BulkLoadControlType) UnmarshalText(text []byte) error

func (*BulkLoadControlType) Value 

func (p *BulkLoadControlType) Value() (driver.Value, error)

type BulkLoadStatus 

type BulkLoadStatus int64
const (
	BulkLoadStatus_BLS_INVALID     BulkLoadStatus = 0
	BulkLoadStatus_BLS_DOWNLOADING BulkLoadStatus = 1
	BulkLoadStatus_BLS_DOWNLOADED  BulkLoadStatus = 2
	BulkLoadStatus_BLS_INGESTING   BulkLoadStatus = 3
	BulkLoadStatus_BLS_SUCCEED     BulkLoadStatus = 4
	BulkLoadStatus_BLS_FAILED      BulkLoadStatus = 5
	BulkLoadStatus_BLS_PAUSING     BulkLoadStatus = 6
	BulkLoadStatus_BLS_PAUSED      BulkLoadStatus = 7
	BulkLoadStatus_BLS_CANCELED    BulkLoadStatus = 8
)

func BulkLoadStatusFromString 

func BulkLoadStatusFromString(s string) (BulkLoadStatus, error)

func BulkLoadStatusPtr 

func BulkLoadStatusPtr(v BulkLoadStatus) *BulkLoadStatus

func (BulkLoadStatus) MarshalText 

func (p BulkLoadStatus) MarshalText() ([]byte, error)

func (*BulkLoadStatus) Scan 

func (p *BulkLoadStatus) Scan(value interface{}) error

func (BulkLoadStatus) String 

func (p BulkLoadStatus) String() string

func (*BulkLoadStatus) UnmarshalText 

func (p *BulkLoadStatus) UnmarshalText(text []byte) error

func (*BulkLoadStatus) Value 

func (p *BulkLoadStatus) Value() (driver.Value, error)

type ClearBulkLoadStateRequest 

type ClearBulkLoadStateRequest struct {
	AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"`
}

Attributes:

  • AppName
var AdminClientClearBulkLoadArgs_Req_DEFAULT *ClearBulkLoadStateRequest

func NewClearBulkLoadStateRequest 

func NewClearBulkLoadStateRequest() *ClearBulkLoadStateRequest

func (*ClearBulkLoadStateRequest) GetAppName 

func (p *ClearBulkLoadStateRequest) GetAppName() string

func (*ClearBulkLoadStateRequest) Read 

func (p *ClearBulkLoadStateRequest) Read(iprot thrift.TProtocol) error

func (*ClearBulkLoadStateRequest) ReadField1 

func (p *ClearBulkLoadStateRequest) ReadField1(iprot thrift.TProtocol) error

func (*ClearBulkLoadStateRequest) String 

func (p *ClearBulkLoadStateRequest) String() string

func (*ClearBulkLoadStateRequest) Write 

func (p *ClearBulkLoadStateRequest) Write(oprot thrift.TProtocol) error

type ClearBulkLoadStateResponse 

type ClearBulkLoadStateResponse struct {
	Err     *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	HintMsg string          `thrift:"hint_msg,2" db:"hint_msg" json:"hint_msg"`
}

Attributes:

  • Err
  • HintMsg
var AdminClientClearBulkLoadResult_Success_DEFAULT *ClearBulkLoadStateResponse

func NewClearBulkLoadStateResponse 

func NewClearBulkLoadStateResponse() *ClearBulkLoadStateResponse

func (*ClearBulkLoadStateResponse) GetErr 

func (p *ClearBulkLoadStateResponse) GetErr() *base.ErrorCode

func (*ClearBulkLoadStateResponse) GetHintMsg 

func (p *ClearBulkLoadStateResponse) GetHintMsg() string

func (*ClearBulkLoadStateResponse) IsSetErr 

func (p *ClearBulkLoadStateResponse) IsSetErr() bool

func (*ClearBulkLoadStateResponse) Read 

func (p *ClearBulkLoadStateResponse) Read(iprot thrift.TProtocol) error

func (*ClearBulkLoadStateResponse) ReadField1 

func (p *ClearBulkLoadStateResponse) ReadField1(iprot thrift.TProtocol) error

func (*ClearBulkLoadStateResponse) ReadField2 

func (p *ClearBulkLoadStateResponse) ReadField2(iprot thrift.TProtocol) error

func (*ClearBulkLoadStateResponse) String 

func (p *ClearBulkLoadStateResponse) String() string

func (*ClearBulkLoadStateResponse) Write 

func (p *ClearBulkLoadStateResponse) Write(oprot thrift.TProtocol) error

type ClusterInfoRequest 

type ClusterInfoRequest struct {
}
var AdminClientQueryClusterInfoArgs_Req_DEFAULT *ClusterInfoRequest

func NewClusterInfoRequest 

func NewClusterInfoRequest() *ClusterInfoRequest

func (*ClusterInfoRequest) Read 

func (p *ClusterInfoRequest) Read(iprot thrift.TProtocol) error

func (*ClusterInfoRequest) String 

func (p *ClusterInfoRequest) String() string

func (*ClusterInfoRequest) Write 

func (p *ClusterInfoRequest) Write(oprot thrift.TProtocol) error

type ClusterInfoResponse 

type ClusterInfoResponse struct {
	Err    *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	Keys   []string        `thrift:"keys,2" db:"keys" json:"keys"`
	Values []string        `thrift:"values,3" db:"values" json:"values"`
}

Attributes:

  • Err
  • Keys
  • Values
var AdminClientQueryClusterInfoResult_Success_DEFAULT *ClusterInfoResponse

func NewClusterInfoResponse 

func NewClusterInfoResponse() *ClusterInfoResponse

func (*ClusterInfoResponse) GetErr 

func (p *ClusterInfoResponse) GetErr() *base.ErrorCode

func (*ClusterInfoResponse) GetKeys 

func (p *ClusterInfoResponse) GetKeys() []string

func (*ClusterInfoResponse) GetValues 

func (p *ClusterInfoResponse) GetValues() []string

func (*ClusterInfoResponse) IsSetErr 

func (p *ClusterInfoResponse) IsSetErr() bool

func (*ClusterInfoResponse) Read 

func (p *ClusterInfoResponse) Read(iprot thrift.TProtocol) error

func (*ClusterInfoResponse) ReadField1 

func (p *ClusterInfoResponse) ReadField1(iprot thrift.TProtocol) error

func (*ClusterInfoResponse) ReadField2 

func (p *ClusterInfoResponse) ReadField2(iprot thrift.TProtocol) error

func (*ClusterInfoResponse) ReadField3 

func (p *ClusterInfoResponse) ReadField3(iprot thrift.TProtocol) error

func (*ClusterInfoResponse) String 

func (p *ClusterInfoResponse) String() string

func (*ClusterInfoResponse) Write 

func (p *ClusterInfoResponse) Write(oprot thrift.TProtocol) error

type ConfigType 

type ConfigType int64
const (
	ConfigType_CT_INVALID                     ConfigType = 0
	ConfigType_CT_ASSIGN_PRIMARY              ConfigType = 1
	ConfigType_CT_UPGRADE_TO_PRIMARY          ConfigType = 2
	ConfigType_CT_ADD_SECONDARY               ConfigType = 3
	ConfigType_CT_UPGRADE_TO_SECONDARY        ConfigType = 4
	ConfigType_CT_DOWNGRADE_TO_SECONDARY      ConfigType = 5
	ConfigType_CT_DOWNGRADE_TO_INACTIVE       ConfigType = 6
	ConfigType_CT_REMOVE                      ConfigType = 7
	ConfigType_CT_ADD_SECONDARY_FOR_LB        ConfigType = 8
	ConfigType_CT_PRIMARY_FORCE_UPDATE_BALLOT ConfigType = 9
	ConfigType_CT_DROP_PARTITION              ConfigType = 10
	ConfigType_CT_REGISTER_CHILD              ConfigType = 11
)

func ConfigTypeFromString 

func ConfigTypeFromString(s string) (ConfigType, error)

func ConfigTypePtr 

func ConfigTypePtr(v ConfigType) *ConfigType

func (ConfigType) MarshalText 

func (p ConfigType) MarshalText() ([]byte, error)

func (*ConfigType) Scan 

func (p *ConfigType) Scan(value interface{}) error

func (ConfigType) String 

func (p ConfigType) String() string

func (*ConfigType) UnmarshalText 

func (p *ConfigType) UnmarshalText(text []byte) error

func (*ConfigType) Value 

func (p *ConfigType) Value() (driver.Value, error)

type ConfigurationProposalAction 

type ConfigurationProposalAction struct {
	Target *base.RPCAddress `thrift:"target,1" db:"target" json:"target"`
	Node   *base.RPCAddress `thrift:"node,2" db:"node" json:"node"`
	Type   ConfigType       `thrift:"type,3" db:"type" json:"type"`
}

Attributes:

  • Target
  • Node
  • Type

func NewConfigurationProposalAction 

func NewConfigurationProposalAction() *ConfigurationProposalAction

func (*ConfigurationProposalAction) GetNode 

func (p *ConfigurationProposalAction) GetNode() *base.RPCAddress

func (*ConfigurationProposalAction) GetTarget 

func (p *ConfigurationProposalAction) GetTarget() *base.RPCAddress

func (*ConfigurationProposalAction) GetType 

func (p *ConfigurationProposalAction) GetType() ConfigType

func (*ConfigurationProposalAction) IsSetNode 

func (p *ConfigurationProposalAction) IsSetNode() bool

func (*ConfigurationProposalAction) IsSetTarget 

func (p *ConfigurationProposalAction) IsSetTarget() bool

func (*ConfigurationProposalAction) Read 

func (p *ConfigurationProposalAction) Read(iprot thrift.TProtocol) error

func (*ConfigurationProposalAction) ReadField1 

func (p *ConfigurationProposalAction) ReadField1(iprot thrift.TProtocol) error

func (*ConfigurationProposalAction) ReadField2 

func (p *ConfigurationProposalAction) ReadField2(iprot thrift.TProtocol) error

func (*ConfigurationProposalAction) ReadField3 

func (p *ConfigurationProposalAction) ReadField3(iprot thrift.TProtocol) error

func (*ConfigurationProposalAction) String 

func (p *ConfigurationProposalAction) String() string

func (*ConfigurationProposalAction) Write 

func (p *ConfigurationProposalAction) Write(oprot thrift.TProtocol) error

type ControlBulkLoadRequest 

type ControlBulkLoadRequest struct {
	AppName string              `thrift:"app_name,1" db:"app_name" json:"app_name"`
	Type    BulkLoadControlType `thrift:"type,2" db:"type" json:"type"`
}

Attributes:

  • AppName
  • Type
var AdminClientControlBulkLoadArgs_Req_DEFAULT *ControlBulkLoadRequest

func NewControlBulkLoadRequest 

func NewControlBulkLoadRequest() *ControlBulkLoadRequest

func (*ControlBulkLoadRequest) GetAppName 

func (p *ControlBulkLoadRequest) GetAppName() string

func (*ControlBulkLoadRequest) GetType 

func (p *ControlBulkLoadRequest) GetType() BulkLoadControlType

func (*ControlBulkLoadRequest) Read 

func (p *ControlBulkLoadRequest) Read(iprot thrift.TProtocol) error

func (*ControlBulkLoadRequest) ReadField1 

func (p *ControlBulkLoadRequest) ReadField1(iprot thrift.TProtocol) error

func (*ControlBulkLoadRequest) ReadField2 

func (p *ControlBulkLoadRequest) ReadField2(iprot thrift.TProtocol) error

func (*ControlBulkLoadRequest) String 

func (p *ControlBulkLoadRequest) String() string

func (*ControlBulkLoadRequest) Write 

func (p *ControlBulkLoadRequest) Write(oprot thrift.TProtocol) error

type ControlBulkLoadResponse 

type ControlBulkLoadResponse struct {
	Err     *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	HintMsg *string         `thrift:"hint_msg,2" db:"hint_msg" json:"hint_msg,omitempty"`
}

Attributes:

  • Err
  • HintMsg
var AdminClientControlBulkLoadResult_Success_DEFAULT *ControlBulkLoadResponse

func NewControlBulkLoadResponse 

func NewControlBulkLoadResponse() *ControlBulkLoadResponse

func (*ControlBulkLoadResponse) GetErr 

func (p *ControlBulkLoadResponse) GetErr() *base.ErrorCode

func (*ControlBulkLoadResponse) GetHintMsg 

func (p *ControlBulkLoadResponse) GetHintMsg() string

func (*ControlBulkLoadResponse) IsSetErr 

func (p *ControlBulkLoadResponse) IsSetErr() bool

func (*ControlBulkLoadResponse) IsSetHintMsg 

func (p *ControlBulkLoadResponse) IsSetHintMsg() bool

func (*ControlBulkLoadResponse) Read 

func (p *ControlBulkLoadResponse) Read(iprot thrift.TProtocol) error

func (*ControlBulkLoadResponse) ReadField1 

func (p *ControlBulkLoadResponse) ReadField1(iprot thrift.TProtocol) error

func (*ControlBulkLoadResponse) ReadField2 

func (p *ControlBulkLoadResponse) ReadField2(iprot thrift.TProtocol) error

func (*ControlBulkLoadResponse) String 

func (p *ControlBulkLoadResponse) String() string

func (*ControlBulkLoadResponse) Write 

func (p *ControlBulkLoadResponse) Write(oprot thrift.TProtocol) error

type ControlSplitRequest 

type ControlSplitRequest struct {
	AppName           string           `thrift:"app_name,1" db:"app_name" json:"app_name"`
	ControlType       SplitControlType `thrift:"control_type,2" db:"control_type" json:"control_type"`
	ParentPidx        int32            `thrift:"parent_pidx,3" db:"parent_pidx" json:"parent_pidx"`
	OldPartitionCount *int32           `thrift:"old_partition_count,4" db:"old_partition_count" json:"old_partition_count,omitempty"`
}

Attributes:

  • AppName
  • ControlType
  • ParentPidx
  • OldPartitionCount
var AdminClientControlPartitionSplitArgs_Req_DEFAULT *ControlSplitRequest

func NewControlSplitRequest 

func NewControlSplitRequest() *ControlSplitRequest

func (*ControlSplitRequest) GetAppName 

func (p *ControlSplitRequest) GetAppName() string

func (*ControlSplitRequest) GetControlType 

func (p *ControlSplitRequest) GetControlType() SplitControlType

func (*ControlSplitRequest) GetOldPartitionCount 

func (p *ControlSplitRequest) GetOldPartitionCount() int32

func (*ControlSplitRequest) GetParentPidx 

func (p *ControlSplitRequest) GetParentPidx() int32

func (*ControlSplitRequest) IsSetOldPartitionCount 

func (p *ControlSplitRequest) IsSetOldPartitionCount() bool

func (*ControlSplitRequest) Read 

func (p *ControlSplitRequest) Read(iprot thrift.TProtocol) error

func (*ControlSplitRequest) ReadField1 

func (p *ControlSplitRequest) ReadField1(iprot thrift.TProtocol) error

func (*ControlSplitRequest) ReadField2 

func (p *ControlSplitRequest) ReadField2(iprot thrift.TProtocol) error

func (*ControlSplitRequest) ReadField3 

func (p *ControlSplitRequest) ReadField3(iprot thrift.TProtocol) error

func (*ControlSplitRequest) ReadField4 

func (p *ControlSplitRequest) ReadField4(iprot thrift.TProtocol) error

func (*ControlSplitRequest) String 

func (p *ControlSplitRequest) String() string

func (*ControlSplitRequest) Write 

func (p *ControlSplitRequest) Write(oprot thrift.TProtocol) error

type ControlSplitResponse 

type ControlSplitResponse struct {
	Err     *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	HintMsg *string         `thrift:"hint_msg,2" db:"hint_msg" json:"hint_msg,omitempty"`
}

Attributes:

  • Err
  • HintMsg
var AdminClientControlPartitionSplitResult_Success_DEFAULT *ControlSplitResponse

func NewControlSplitResponse 

func NewControlSplitResponse() *ControlSplitResponse

func (*ControlSplitResponse) GetErr 

func (p *ControlSplitResponse) GetErr() *base.ErrorCode

func (*ControlSplitResponse) GetHintMsg 

func (p *ControlSplitResponse) GetHintMsg() string

func (*ControlSplitResponse) IsSetErr 

func (p *ControlSplitResponse) IsSetErr() bool

func (*ControlSplitResponse) IsSetHintMsg 

func (p *ControlSplitResponse) IsSetHintMsg() bool

func (*ControlSplitResponse) Read 

func (p *ControlSplitResponse) Read(iprot thrift.TProtocol) error

func (*ControlSplitResponse) ReadField1 

func (p *ControlSplitResponse) ReadField1(iprot thrift.TProtocol) error

func (*ControlSplitResponse) ReadField2 

func (p *ControlSplitResponse) ReadField2(iprot thrift.TProtocol) error

func (*ControlSplitResponse) String 

func (p *ControlSplitResponse) String() string

func (*ControlSplitResponse) Write 

func (p *ControlSplitResponse) Write(oprot thrift.TProtocol) error

type CreateAppOptions 

type CreateAppOptions struct {
	PartitionCount int32             `thrift:"partition_count,1" db:"partition_count" json:"partition_count"`
	ReplicaCount   int32             `thrift:"replica_count,2" db:"replica_count" json:"replica_count"`
	SuccessIfExist bool              `thrift:"success_if_exist,3" db:"success_if_exist" json:"success_if_exist"`
	AppType        string            `thrift:"app_type,4" db:"app_type" json:"app_type"`
	IsStateful     bool              `thrift:"is_stateful,5" db:"is_stateful" json:"is_stateful"`
	Envs           map[string]string `thrift:"envs,6" db:"envs" json:"envs"`
}

Attributes:

  • PartitionCount
  • ReplicaCount
  • SuccessIfExist
  • AppType
  • IsStateful
  • Envs
var CreateAppRequest_Options_DEFAULT *CreateAppOptions

func NewCreateAppOptions 

func NewCreateAppOptions() *CreateAppOptions

func (*CreateAppOptions) GetAppType 

func (p *CreateAppOptions) GetAppType() string

func (*CreateAppOptions) GetEnvs 

func (p *CreateAppOptions) GetEnvs() map[string]string

func (*CreateAppOptions) GetIsStateful 

func (p *CreateAppOptions) GetIsStateful() bool

func (*CreateAppOptions) GetPartitionCount 

func (p *CreateAppOptions) GetPartitionCount() int32

func (*CreateAppOptions) GetReplicaCount 

func (p *CreateAppOptions) GetReplicaCount() int32

func (*CreateAppOptions) GetSuccessIfExist 

func (p *CreateAppOptions) GetSuccessIfExist() bool

func (*CreateAppOptions) Read 

func (p *CreateAppOptions) Read(iprot thrift.TProtocol) error

func (*CreateAppOptions) ReadField1 

func (p *CreateAppOptions) ReadField1(iprot thrift.TProtocol) error

func (*CreateAppOptions) ReadField2 

func (p *CreateAppOptions) ReadField2(iprot thrift.TProtocol) error

func (*CreateAppOptions) ReadField3 

func (p *CreateAppOptions) ReadField3(iprot thrift.TProtocol) error

func (*CreateAppOptions) ReadField4 

func (p *CreateAppOptions) ReadField4(iprot thrift.TProtocol) error

func (*CreateAppOptions) ReadField5 

func (p *CreateAppOptions) ReadField5(iprot thrift.TProtocol) error

func (*CreateAppOptions) ReadField6 

func (p *CreateAppOptions) ReadField6(iprot thrift.TProtocol) error

func (*CreateAppOptions) String 

func (p *CreateAppOptions) String() string

func (*CreateAppOptions) Write 

func (p *CreateAppOptions) Write(oprot thrift.TProtocol) error

type CreateAppRequest 

type CreateAppRequest struct {
	AppName string            `thrift:"app_name,1" db:"app_name" json:"app_name"`
	Options *CreateAppOptions `thrift:"options,2" db:"options" json:"options"`
}

Attributes:

  • AppName
  • Options
var AdminClientCreateAppArgs_Req_DEFAULT *CreateAppRequest

func NewCreateAppRequest 

func NewCreateAppRequest() *CreateAppRequest

func (*CreateAppRequest) GetAppName 

func (p *CreateAppRequest) GetAppName() string

func (*CreateAppRequest) GetOptions 

func (p *CreateAppRequest) GetOptions() *CreateAppOptions

func (*CreateAppRequest) IsSetOptions 

func (p *CreateAppRequest) IsSetOptions() bool

func (*CreateAppRequest) Read 

func (p *CreateAppRequest) Read(iprot thrift.TProtocol) error

func (*CreateAppRequest) ReadField1 

func (p *CreateAppRequest) ReadField1(iprot thrift.TProtocol) error

func (*CreateAppRequest) ReadField2 

func (p *CreateAppRequest) ReadField2(iprot thrift.TProtocol) error

func (*CreateAppRequest) String 

func (p *CreateAppRequest) String() string

func (*CreateAppRequest) Write 

func (p *CreateAppRequest) Write(oprot thrift.TProtocol) error

type CreateAppResponse 

type CreateAppResponse struct {
	Err   *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	Appid int32           `thrift:"appid,2" db:"appid" json:"appid"`
}

Attributes:

  • Err
  • Appid
var AdminClientCreateAppResult_Success_DEFAULT *CreateAppResponse
var AdminClientRestoreAppResult_Success_DEFAULT *CreateAppResponse

func NewCreateAppResponse 

func NewCreateAppResponse() *CreateAppResponse

func (*CreateAppResponse) GetAppid 

func (p *CreateAppResponse) GetAppid() int32

func (*CreateAppResponse) GetErr 

func (p *CreateAppResponse) GetErr() *base.ErrorCode

func (*CreateAppResponse) IsSetErr 

func (p *CreateAppResponse) IsSetErr() bool

func (*CreateAppResponse) Read 

func (p *CreateAppResponse) Read(iprot thrift.TProtocol) error

func (*CreateAppResponse) ReadField1 

func (p *CreateAppResponse) ReadField1(iprot thrift.TProtocol) error

func (*CreateAppResponse) ReadField2 

func (p *CreateAppResponse) ReadField2(iprot thrift.TProtocol) error

func (*CreateAppResponse) String 

func (p *CreateAppResponse) String() string

func (*CreateAppResponse) Write 

func (p *CreateAppResponse) Write(oprot thrift.TProtocol) error

type DropAppOptions 

type DropAppOptions struct {
	SuccessIfNotExist bool   `thrift:"success_if_not_exist,1" db:"success_if_not_exist" json:"success_if_not_exist"`
	ReserveSeconds    *int64 `thrift:"reserve_seconds,2" db:"reserve_seconds" json:"reserve_seconds,omitempty"`
}

Attributes:

  • SuccessIfNotExist
  • ReserveSeconds
var DropAppRequest_Options_DEFAULT *DropAppOptions

func NewDropAppOptions 

func NewDropAppOptions() *DropAppOptions

func (*DropAppOptions) GetReserveSeconds 

func (p *DropAppOptions) GetReserveSeconds() int64

func (*DropAppOptions) GetSuccessIfNotExist 

func (p *DropAppOptions) GetSuccessIfNotExist() bool

func (*DropAppOptions) IsSetReserveSeconds 

func (p *DropAppOptions) IsSetReserveSeconds() bool

func (*DropAppOptions) Read 

func (p *DropAppOptions) Read(iprot thrift.TProtocol) error

func (*DropAppOptions) ReadField1 

func (p *DropAppOptions) ReadField1(iprot thrift.TProtocol) error

func (*DropAppOptions) ReadField2 

func (p *DropAppOptions) ReadField2(iprot thrift.TProtocol) error

func (*DropAppOptions) String 

func (p *DropAppOptions) String() string

func (*DropAppOptions) Write 

func (p *DropAppOptions) Write(oprot thrift.TProtocol) error

type DropAppRequest 

type DropAppRequest struct {
	AppName string          `thrift:"app_name,1" db:"app_name" json:"app_name"`
	Options *DropAppOptions `thrift:"options,2" db:"options" json:"options"`
}

Attributes:

  • AppName
  • Options
var AdminClientDropAppArgs_Req_DEFAULT *DropAppRequest

func NewDropAppRequest 

func NewDropAppRequest() *DropAppRequest

func (*DropAppRequest) GetAppName 

func (p *DropAppRequest) GetAppName() string

func (*DropAppRequest) GetOptions 

func (p *DropAppRequest) GetOptions() *DropAppOptions

func (*DropAppRequest) IsSetOptions 

func (p *DropAppRequest) IsSetOptions() bool

func (*DropAppRequest) Read 

func (p *DropAppRequest) Read(iprot thrift.TProtocol) error

func (*DropAppRequest) ReadField1 

func (p *DropAppRequest) ReadField1(iprot thrift.TProtocol) error

func (*DropAppRequest) ReadField2 

func (p *DropAppRequest) ReadField2(iprot thrift.TProtocol) error

func (*DropAppRequest) String 

func (p *DropAppRequest) String() string

func (*DropAppRequest) Write 

func (p *DropAppRequest) Write(oprot thrift.TProtocol) error

type DropAppResponse 

type DropAppResponse struct {
	Err *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
}

Attributes:

  • Err
var AdminClientDropAppResult_Success_DEFAULT *DropAppResponse

func NewDropAppResponse 

func NewDropAppResponse() *DropAppResponse

func (*DropAppResponse) GetErr 

func (p *DropAppResponse) GetErr() *base.ErrorCode

func (*DropAppResponse) IsSetErr 

func (p *DropAppResponse) IsSetErr() bool

func (*DropAppResponse) Read 

func (p *DropAppResponse) Read(iprot thrift.TProtocol) error

func (*DropAppResponse) ReadField1 

func (p *DropAppResponse) ReadField1(iprot thrift.TProtocol) error

func (*DropAppResponse) String 

func (p *DropAppResponse) String() string

func (*DropAppResponse) Write 

func (p *DropAppResponse) Write(oprot thrift.TProtocol) error

type DuplicationAddRequest 

type DuplicationAddRequest struct {
	AppName           string `thrift:"app_name,1" db:"app_name" json:"app_name"`
	RemoteClusterName string `thrift:"remote_cluster_name,2" db:"remote_cluster_name" json:"remote_cluster_name"`
	Freezed           bool   `thrift:"freezed,3" db:"freezed" json:"freezed"`
}

Attributes:

  • AppName
  • RemoteClusterName
  • Freezed
var AdminClientAddDuplicationArgs_Req_DEFAULT *DuplicationAddRequest

func NewDuplicationAddRequest 

func NewDuplicationAddRequest() *DuplicationAddRequest

func (*DuplicationAddRequest) GetAppName 

func (p *DuplicationAddRequest) GetAppName() string

func (*DuplicationAddRequest) GetFreezed 

func (p *DuplicationAddRequest) GetFreezed() bool

func (*DuplicationAddRequest) GetRemoteClusterName 

func (p *DuplicationAddRequest) GetRemoteClusterName() string

func (*DuplicationAddRequest) Read 

func (p *DuplicationAddRequest) Read(iprot thrift.TProtocol) error

func (*DuplicationAddRequest) ReadField1 

func (p *DuplicationAddRequest) ReadField1(iprot thrift.TProtocol) error

func (*DuplicationAddRequest) ReadField2 

func (p *DuplicationAddRequest) ReadField2(iprot thrift.TProtocol) error

func (*DuplicationAddRequest) ReadField3 

func (p *DuplicationAddRequest) ReadField3(iprot thrift.TProtocol) error

func (*DuplicationAddRequest) String 

func (p *DuplicationAddRequest) String() string

func (*DuplicationAddRequest) Write 

func (p *DuplicationAddRequest) Write(oprot thrift.TProtocol) error

type DuplicationAddResponse 

type DuplicationAddResponse struct {
	Err   *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	Appid int32           `thrift:"appid,2" db:"appid" json:"appid"`
	Dupid int32           `thrift:"dupid,3" db:"dupid" json:"dupid"`
	Hint  *string         `thrift:"hint,4" db:"hint" json:"hint,omitempty"`
}

Attributes:

  • Err
  • Appid
  • Dupid
  • Hint
var AdminClientAddDuplicationResult_Success_DEFAULT *DuplicationAddResponse

func NewDuplicationAddResponse 

func NewDuplicationAddResponse() *DuplicationAddResponse

func (*DuplicationAddResponse) GetAppid 

func (p *DuplicationAddResponse) GetAppid() int32

func (*DuplicationAddResponse) GetDupid 

func (p *DuplicationAddResponse) GetDupid() int32

func (*DuplicationAddResponse) GetErr 

func (p *DuplicationAddResponse) GetErr() *base.ErrorCode

func (*DuplicationAddResponse) GetHint 

func (p *DuplicationAddResponse) GetHint() string

func (*DuplicationAddResponse) IsSetErr 

func (p *DuplicationAddResponse) IsSetErr() bool

func (*DuplicationAddResponse) IsSetHint 

func (p *DuplicationAddResponse) IsSetHint() bool

func (*DuplicationAddResponse) Read 

func (p *DuplicationAddResponse) Read(iprot thrift.TProtocol) error

func (*DuplicationAddResponse) ReadField1 

func (p *DuplicationAddResponse) ReadField1(iprot thrift.TProtocol) error

func (*DuplicationAddResponse) ReadField2 

func (p *DuplicationAddResponse) ReadField2(iprot thrift.TProtocol) error

func (*DuplicationAddResponse) ReadField3 

func (p *DuplicationAddResponse) ReadField3(iprot thrift.TProtocol) error

func (*DuplicationAddResponse) ReadField4 

func (p *DuplicationAddResponse) ReadField4(iprot thrift.TProtocol) error

func (*DuplicationAddResponse) String 

func (p *DuplicationAddResponse) String() string

func (*DuplicationAddResponse) Write 

func (p *DuplicationAddResponse) Write(oprot thrift.TProtocol) error

type DuplicationEntry 

type DuplicationEntry struct {
	Dupid    int32             `thrift:"dupid,1" db:"dupid" json:"dupid"`
	Status   DuplicationStatus `thrift:"status,2" db:"status" json:"status"`
	Remote   string            `thrift:"remote,3" db:"remote" json:"remote"`
	CreateTs int64             `thrift:"create_ts,4" db:"create_ts" json:"create_ts"`
	Progress map[int32]int64   `thrift:"progress,5" db:"progress" json:"progress,omitempty"`
	// unused field # 6
	FailMode *DuplicationFailMode `thrift:"fail_mode,7" db:"fail_mode" json:"fail_mode,omitempty"`
}

Attributes:

  • Dupid
  • Status
  • Remote
  • CreateTs
  • Progress
  • FailMode

func NewDuplicationEntry 

func NewDuplicationEntry() *DuplicationEntry

func (*DuplicationEntry) GetCreateTs 

func (p *DuplicationEntry) GetCreateTs() int64

func (*DuplicationEntry) GetDupid 

func (p *DuplicationEntry) GetDupid() int32

func (*DuplicationEntry) GetFailMode 

func (p *DuplicationEntry) GetFailMode() DuplicationFailMode

func (*DuplicationEntry) GetProgress 

func (p *DuplicationEntry) GetProgress() map[int32]int64

func (*DuplicationEntry) GetRemote 

func (p *DuplicationEntry) GetRemote() string

func (*DuplicationEntry) GetStatus 

func (p *DuplicationEntry) GetStatus() DuplicationStatus

func (*DuplicationEntry) IsSetFailMode 

func (p *DuplicationEntry) IsSetFailMode() bool

func (*DuplicationEntry) IsSetProgress 

func (p *DuplicationEntry) IsSetProgress() bool

func (*DuplicationEntry) Read 

func (p *DuplicationEntry) Read(iprot thrift.TProtocol) error

func (*DuplicationEntry) ReadField1 

func (p *DuplicationEntry) ReadField1(iprot thrift.TProtocol) error

func (*DuplicationEntry) ReadField2 

func (p *DuplicationEntry) ReadField2(iprot thrift.TProtocol) error

func (*DuplicationEntry) ReadField3 

func (p *DuplicationEntry) ReadField3(iprot thrift.TProtocol) error

func (*DuplicationEntry) ReadField4 

func (p *DuplicationEntry) ReadField4(iprot thrift.TProtocol) error

func (*DuplicationEntry) ReadField5 

func (p *DuplicationEntry) ReadField5(iprot thrift.TProtocol) error

func (*DuplicationEntry) ReadField7 

func (p *DuplicationEntry) ReadField7(iprot thrift.TProtocol) error

func (*DuplicationEntry) String 

func (p *DuplicationEntry) String() string

func (*DuplicationEntry) Write 

func (p *DuplicationEntry) Write(oprot thrift.TProtocol) error

type DuplicationFailMode 

type DuplicationFailMode int64
const (
	DuplicationFailMode_FAIL_SLOW DuplicationFailMode = 0
	DuplicationFailMode_FAIL_SKIP DuplicationFailMode = 1
	DuplicationFailMode_FAIL_FAST DuplicationFailMode = 2
)
var DuplicationEntry_FailMode_DEFAULT DuplicationFailMode
var DuplicationModifyRequest_FailMode_DEFAULT DuplicationFailMode

func DuplicationFailModeFromString 

func DuplicationFailModeFromString(s string) (DuplicationFailMode, error)

func DuplicationFailModePtr 

func DuplicationFailModePtr(v DuplicationFailMode) *DuplicationFailMode

func (DuplicationFailMode) MarshalText 

func (p DuplicationFailMode) MarshalText() ([]byte, error)

func (*DuplicationFailMode) Scan 

func (p *DuplicationFailMode) Scan(value interface{}) error

func (DuplicationFailMode) String 

func (p DuplicationFailMode) String() string

func (*DuplicationFailMode) UnmarshalText 

func (p *DuplicationFailMode) UnmarshalText(text []byte) error

func (*DuplicationFailMode) Value 

func (p *DuplicationFailMode) Value() (driver.Value, error)

type DuplicationModifyRequest 

type DuplicationModifyRequest struct {
	AppName  string               `thrift:"app_name,1" db:"app_name" json:"app_name"`
	Dupid    int32                `thrift:"dupid,2" db:"dupid" json:"dupid"`
	Status   *DuplicationStatus   `thrift:"status,3" db:"status" json:"status,omitempty"`
	FailMode *DuplicationFailMode `thrift:"fail_mode,4" db:"fail_mode" json:"fail_mode,omitempty"`
}

Attributes:

  • AppName
  • Dupid
  • Status
  • FailMode
var AdminClientModifyDuplicationArgs_Req_DEFAULT *DuplicationModifyRequest

func NewDuplicationModifyRequest 

func NewDuplicationModifyRequest() *DuplicationModifyRequest

func (*DuplicationModifyRequest) GetAppName 

func (p *DuplicationModifyRequest) GetAppName() string

func (*DuplicationModifyRequest) GetDupid 

func (p *DuplicationModifyRequest) GetDupid() int32

func (*DuplicationModifyRequest) GetFailMode 

func (p *DuplicationModifyRequest) GetFailMode() DuplicationFailMode

func (*DuplicationModifyRequest) GetStatus 

func (p *DuplicationModifyRequest) GetStatus() DuplicationStatus

func (*DuplicationModifyRequest) IsSetFailMode 

func (p *DuplicationModifyRequest) IsSetFailMode() bool

func (*DuplicationModifyRequest) IsSetStatus 

func (p *DuplicationModifyRequest) IsSetStatus() bool

func (*DuplicationModifyRequest) Read 

func (p *DuplicationModifyRequest) Read(iprot thrift.TProtocol) error

func (*DuplicationModifyRequest) ReadField1 

func (p *DuplicationModifyRequest) ReadField1(iprot thrift.TProtocol) error

func (*DuplicationModifyRequest) ReadField2 

func (p *DuplicationModifyRequest) ReadField2(iprot thrift.TProtocol) error

func (*DuplicationModifyRequest) ReadField3 

func (p *DuplicationModifyRequest) ReadField3(iprot thrift.TProtocol) error

func (*DuplicationModifyRequest) ReadField4 

func (p *DuplicationModifyRequest) ReadField4(iprot thrift.TProtocol) error

func (*DuplicationModifyRequest) String 

func (p *DuplicationModifyRequest) String() string

func (*DuplicationModifyRequest) Write 

func (p *DuplicationModifyRequest) Write(oprot thrift.TProtocol) error

type DuplicationModifyResponse 

type DuplicationModifyResponse struct {
	Err   *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	Appid int32           `thrift:"appid,2" db:"appid" json:"appid"`
}

Attributes:

  • Err
  • Appid
var AdminClientModifyDuplicationResult_Success_DEFAULT *DuplicationModifyResponse

func NewDuplicationModifyResponse 

func NewDuplicationModifyResponse() *DuplicationModifyResponse

func (*DuplicationModifyResponse) GetAppid 

func (p *DuplicationModifyResponse) GetAppid() int32

func (*DuplicationModifyResponse) GetErr 

func (p *DuplicationModifyResponse) GetErr() *base.ErrorCode

func (*DuplicationModifyResponse) IsSetErr 

func (p *DuplicationModifyResponse) IsSetErr() bool

func (*DuplicationModifyResponse) Read 

func (p *DuplicationModifyResponse) Read(iprot thrift.TProtocol) error

func (*DuplicationModifyResponse) ReadField1 

func (p *DuplicationModifyResponse) ReadField1(iprot thrift.TProtocol) error

func (*DuplicationModifyResponse) ReadField2 

func (p *DuplicationModifyResponse) ReadField2(iprot thrift.TProtocol) error

func (*DuplicationModifyResponse) String 

func (p *DuplicationModifyResponse) String() string

func (*DuplicationModifyResponse) Write 

func (p *DuplicationModifyResponse) Write(oprot thrift.TProtocol) error

type DuplicationQueryRequest 

type DuplicationQueryRequest struct {
	AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"`
}

Attributes:

  • AppName
var AdminClientQueryDuplicationArgs_Req_DEFAULT *DuplicationQueryRequest

func NewDuplicationQueryRequest 

func NewDuplicationQueryRequest() *DuplicationQueryRequest

func (*DuplicationQueryRequest) GetAppName 

func (p *DuplicationQueryRequest) GetAppName() string

func (*DuplicationQueryRequest) Read 

func (p *DuplicationQueryRequest) Read(iprot thrift.TProtocol) error

func (*DuplicationQueryRequest) ReadField1 

func (p *DuplicationQueryRequest) ReadField1(iprot thrift.TProtocol) error

func (*DuplicationQueryRequest) String 

func (p *DuplicationQueryRequest) String() string

func (*DuplicationQueryRequest) Write 

func (p *DuplicationQueryRequest) Write(oprot thrift.TProtocol) error

type DuplicationQueryResponse 

type DuplicationQueryResponse struct {
	Err *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	// unused field # 2
	Appid     int32               `thrift:"appid,3" db:"appid" json:"appid"`
	EntryList []*DuplicationEntry `thrift:"entry_list,4" db:"entry_list" json:"entry_list"`
}

Attributes:

  • Err
  • Appid
  • EntryList
var AdminClientQueryDuplicationResult_Success_DEFAULT *DuplicationQueryResponse

func NewDuplicationQueryResponse 

func NewDuplicationQueryResponse() *DuplicationQueryResponse

func (*DuplicationQueryResponse) GetAppid 

func (p *DuplicationQueryResponse) GetAppid() int32

func (*DuplicationQueryResponse) GetEntryList 

func (p *DuplicationQueryResponse) GetEntryList() []*DuplicationEntry

func (*DuplicationQueryResponse) GetErr 

func (p *DuplicationQueryResponse) GetErr() *base.ErrorCode

func (*DuplicationQueryResponse) IsSetErr 

func (p *DuplicationQueryResponse) IsSetErr() bool

func (*DuplicationQueryResponse) Read 

func (p *DuplicationQueryResponse) Read(iprot thrift.TProtocol) error

func (*DuplicationQueryResponse) ReadField1 

func (p *DuplicationQueryResponse) ReadField1(iprot thrift.TProtocol) error

func (*DuplicationQueryResponse) ReadField3 

func (p *DuplicationQueryResponse) ReadField3(iprot thrift.TProtocol) error

func (*DuplicationQueryResponse) ReadField4 

func (p *DuplicationQueryResponse) ReadField4(iprot thrift.TProtocol) error

func (*DuplicationQueryResponse) String 

func (p *DuplicationQueryResponse) String() string

func (*DuplicationQueryResponse) Write 

func (p *DuplicationQueryResponse) Write(oprot thrift.TProtocol) error

type DuplicationStatus 

type DuplicationStatus int64
const (
	DuplicationStatus_DS_INIT    DuplicationStatus = 0
	DuplicationStatus_DS_START   DuplicationStatus = 1
	DuplicationStatus_DS_PAUSE   DuplicationStatus = 2
	DuplicationStatus_DS_REMOVED DuplicationStatus = 3
)
var DuplicationModifyRequest_Status_DEFAULT DuplicationStatus

func DuplicationStatusFromString 

func DuplicationStatusFromString(s string) (DuplicationStatus, error)

func DuplicationStatusPtr 

func DuplicationStatusPtr(v DuplicationStatus) *DuplicationStatus

func (DuplicationStatus) MarshalText 

func (p DuplicationStatus) MarshalText() ([]byte, error)

func (*DuplicationStatus) Scan 

func (p *DuplicationStatus) Scan(value interface{}) error

func (DuplicationStatus) String 

func (p DuplicationStatus) String() string

func (*DuplicationStatus) UnmarshalText 

func (p *DuplicationStatus) UnmarshalText(text []byte) error

func (*DuplicationStatus) Value 

func (p *DuplicationStatus) Value() (driver.Value, error)

type IngestionStatus 

type IngestionStatus int64
const (
	IngestionStatus_IS_INVALID IngestionStatus = 0
	IngestionStatus_IS_RUNNING IngestionStatus = 1
	IngestionStatus_IS_SUCCEED IngestionStatus = 2
	IngestionStatus_IS_FAILED  IngestionStatus = 3
)
var PartitionBulkLoadState_IngestStatus_DEFAULT IngestionStatus = 0

func IngestionStatusFromString 

func IngestionStatusFromString(s string) (IngestionStatus, error)

func IngestionStatusPtr 

func IngestionStatusPtr(v IngestionStatus) *IngestionStatus

func (IngestionStatus) MarshalText 

func (p IngestionStatus) MarshalText() ([]byte, error)

func (*IngestionStatus) Scan 

func (p *IngestionStatus) Scan(value interface{}) error

func (IngestionStatus) String 

func (p IngestionStatus) String() string

func (*IngestionStatus) UnmarshalText 

func (p *IngestionStatus) UnmarshalText(text []byte) error

func (*IngestionStatus) Value 

func (p *IngestionStatus) Value() (driver.Value, error)

type ListAppsRequest 

type ListAppsRequest struct {
	Status AppStatus `thrift:"status,1" db:"status" json:"status"`
}

Attributes:

  • Status
var AdminClientListAppsArgs_Req_DEFAULT *ListAppsRequest

func NewListAppsRequest 

func NewListAppsRequest() *ListAppsRequest

func (*ListAppsRequest) GetStatus 

func (p *ListAppsRequest) GetStatus() AppStatus

func (*ListAppsRequest) Read 

func (p *ListAppsRequest) Read(iprot thrift.TProtocol) error

func (*ListAppsRequest) ReadField1 

func (p *ListAppsRequest) ReadField1(iprot thrift.TProtocol) error

func (*ListAppsRequest) String 

func (p *ListAppsRequest) String() string

func (*ListAppsRequest) Write 

func (p *ListAppsRequest) Write(oprot thrift.TProtocol) error

type ListAppsResponse 

type ListAppsResponse struct {
	Err   *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	Infos []*AppInfo      `thrift:"infos,2" db:"infos" json:"infos"`
}

Attributes:

  • Err
  • Infos
var AdminClientListAppsResult_Success_DEFAULT *ListAppsResponse

func NewListAppsResponse 

func NewListAppsResponse() *ListAppsResponse

func (*ListAppsResponse) GetErr 

func (p *ListAppsResponse) GetErr() *base.ErrorCode

func (*ListAppsResponse) GetInfos 

func (p *ListAppsResponse) GetInfos() []*AppInfo

func (*ListAppsResponse) IsSetErr 

func (p *ListAppsResponse) IsSetErr() bool

func (*ListAppsResponse) Read 

func (p *ListAppsResponse) Read(iprot thrift.TProtocol) error

func (*ListAppsResponse) ReadField1 

func (p *ListAppsResponse) ReadField1(iprot thrift.TProtocol) error

func (*ListAppsResponse) ReadField2 

func (p *ListAppsResponse) ReadField2(iprot thrift.TProtocol) error

func (*ListAppsResponse) String 

func (p *ListAppsResponse) String() string

func (*ListAppsResponse) Write 

func (p *ListAppsResponse) Write(oprot thrift.TProtocol) error

type ListNodesRequest 

type ListNodesRequest struct {
	Status NodeStatus `thrift:"status,1" db:"status" json:"status"`
}

Attributes:

  • Status
var AdminClientListNodesArgs_Req_DEFAULT *ListNodesRequest

func NewListNodesRequest 

func NewListNodesRequest() *ListNodesRequest

func (*ListNodesRequest) GetStatus 

func (p *ListNodesRequest) GetStatus() NodeStatus

func (*ListNodesRequest) Read 

func (p *ListNodesRequest) Read(iprot thrift.TProtocol) error

func (*ListNodesRequest) ReadField1 

func (p *ListNodesRequest) ReadField1(iprot thrift.TProtocol) error

func (*ListNodesRequest) String 

func (p *ListNodesRequest) String() string

func (*ListNodesRequest) Write 

func (p *ListNodesRequest) Write(oprot thrift.TProtocol) error

type ListNodesResponse 

type ListNodesResponse struct {
	Err   *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	Infos []*NodeInfo     `thrift:"infos,2" db:"infos" json:"infos"`
}

Attributes:

  • Err
  • Infos
var AdminClientListNodesResult_Success_DEFAULT *ListNodesResponse

func NewListNodesResponse 

func NewListNodesResponse() *ListNodesResponse

func (*ListNodesResponse) GetErr 

func (p *ListNodesResponse) GetErr() *base.ErrorCode

func (*ListNodesResponse) GetInfos 

func (p *ListNodesResponse) GetInfos() []*NodeInfo

func (*ListNodesResponse) IsSetErr 

func (p *ListNodesResponse) IsSetErr() bool

func (*ListNodesResponse) Read 

func (p *ListNodesResponse) Read(iprot thrift.TProtocol) error

func (*ListNodesResponse) ReadField1 

func (p *ListNodesResponse) ReadField1(iprot thrift.TProtocol) error

func (*ListNodesResponse) ReadField2 

func (p *ListNodesResponse) ReadField2(iprot thrift.TProtocol) error

func (*ListNodesResponse) String 

func (p *ListNodesResponse) String() string

func (*ListNodesResponse) Write 

func (p *ListNodesResponse) Write(oprot thrift.TProtocol) error

type MetaControlRequest 

type MetaControlRequest struct {
	Level MetaFunctionLevel `thrift:"level,1" db:"level" json:"level"`
}

Attributes:

  • Level
var AdminClientMetaControlArgs_Req_DEFAULT *MetaControlRequest

func NewMetaControlRequest 

func NewMetaControlRequest() *MetaControlRequest

func (*MetaControlRequest) GetLevel 

func (p *MetaControlRequest) GetLevel() MetaFunctionLevel

func (*MetaControlRequest) Read 

func (p *MetaControlRequest) Read(iprot thrift.TProtocol) error

func (*MetaControlRequest) ReadField1 

func (p *MetaControlRequest) ReadField1(iprot thrift.TProtocol) error

func (*MetaControlRequest) String 

func (p *MetaControlRequest) String() string

func (*MetaControlRequest) Write 

func (p *MetaControlRequest) Write(oprot thrift.TProtocol) error

type MetaControlResponse 

type MetaControlResponse struct {
	Err      *base.ErrorCode   `thrift:"err,1" db:"err" json:"err"`
	OldLevel MetaFunctionLevel `thrift:"old_level,2" db:"old_level" json:"old_level"`
}

Attributes:

  • Err
  • OldLevel
var AdminClientMetaControlResult_Success_DEFAULT *MetaControlResponse

func NewMetaControlResponse 

func NewMetaControlResponse() *MetaControlResponse

func (*MetaControlResponse) GetErr 

func (p *MetaControlResponse) GetErr() *base.ErrorCode

func (*MetaControlResponse) GetOldLevel 

func (p *MetaControlResponse) GetOldLevel() MetaFunctionLevel

func (*MetaControlResponse) IsSetErr 

func (p *MetaControlResponse) IsSetErr() bool

func (*MetaControlResponse) Read 

func (p *MetaControlResponse) Read(iprot thrift.TProtocol) error

func (*MetaControlResponse) ReadField1 

func (p *MetaControlResponse) ReadField1(iprot thrift.TProtocol) error

func (*MetaControlResponse) ReadField2 

func (p *MetaControlResponse) ReadField2(iprot thrift.TProtocol) error

func (*MetaControlResponse) String 

func (p *MetaControlResponse) String() string

func (*MetaControlResponse) Write 

func (p *MetaControlResponse) Write(oprot thrift.TProtocol) error

type MetaFunctionLevel 

type MetaFunctionLevel int64
const (
	MetaFunctionLevel_fl_stopped MetaFunctionLevel = 100
	MetaFunctionLevel_fl_blind   MetaFunctionLevel = 200
	MetaFunctionLevel_fl_freezed MetaFunctionLevel = 300
	MetaFunctionLevel_fl_steady  MetaFunctionLevel = 400
	MetaFunctionLevel_fl_lively  MetaFunctionLevel = 500
	MetaFunctionLevel_fl_invalid MetaFunctionLevel = 10000
)

func MetaFunctionLevelFromString 

func MetaFunctionLevelFromString(s string) (MetaFunctionLevel, error)

func MetaFunctionLevelPtr 

func MetaFunctionLevelPtr(v MetaFunctionLevel) *MetaFunctionLevel

func (MetaFunctionLevel) MarshalText 

func (p MetaFunctionLevel) MarshalText() ([]byte, error)

func (*MetaFunctionLevel) Scan 

func (p *MetaFunctionLevel) Scan(value interface{}) error

func (MetaFunctionLevel) String 

func (p MetaFunctionLevel) String() string

func (*MetaFunctionLevel) UnmarshalText 

func (p *MetaFunctionLevel) UnmarshalText(text []byte) error

func (*MetaFunctionLevel) Value 

func (p *MetaFunctionLevel) Value() (driver.Value, error)

type NodeInfo 

type NodeInfo struct {
	Status  NodeStatus       `thrift:"status,1" db:"status" json:"status"`
	Address *base.RPCAddress `thrift:"address,2" db:"address" json:"address"`
}

Attributes:

  • Status
  • Address

func NewNodeInfo 

func NewNodeInfo() *NodeInfo

func (*NodeInfo) GetAddress 

func (p *NodeInfo) GetAddress() *base.RPCAddress

func (*NodeInfo) GetStatus 

func (p *NodeInfo) GetStatus() NodeStatus

func (*NodeInfo) IsSetAddress 

func (p *NodeInfo) IsSetAddress() bool

func (*NodeInfo) Read 

func (p *NodeInfo) Read(iprot thrift.TProtocol) error

func (*NodeInfo) ReadField1 

func (p *NodeInfo) ReadField1(iprot thrift.TProtocol) error

func (*NodeInfo) ReadField2 

func (p *NodeInfo) ReadField2(iprot thrift.TProtocol) error

func (*NodeInfo) String 

func (p *NodeInfo) String() string

func (*NodeInfo) Write 

func (p *NodeInfo) Write(oprot thrift.TProtocol) error

type NodeStatus 

type NodeStatus int64
const (
	NodeStatus_NS_INVALID NodeStatus = 0
	NodeStatus_NS_ALIVE   NodeStatus = 1
	NodeStatus_NS_UNALIVE NodeStatus = 2
)

func NodeStatusFromString 

func NodeStatusFromString(s string) (NodeStatus, error)

func NodeStatusPtr 

func NodeStatusPtr(v NodeStatus) *NodeStatus

func (NodeStatus) MarshalText 

func (p NodeStatus) MarshalText() ([]byte, error)

func (*NodeStatus) Scan 

func (p *NodeStatus) Scan(value interface{}) error

func (NodeStatus) String 

func (p NodeStatus) String() string

func (*NodeStatus) UnmarshalText 

func (p *NodeStatus) UnmarshalText(text []byte) error

func (*NodeStatus) Value 

func (p *NodeStatus) Value() (driver.Value, error)

type PartitionBulkLoadState 

type PartitionBulkLoadState struct {
	DownloadProgress int32           `thrift:"download_progress,1" db:"download_progress" json:"download_progress"`
	DownloadStatus   *base.ErrorCode `thrift:"download_status,2" db:"download_status" json:"download_status,omitempty"`
	IngestStatus     IngestionStatus `thrift:"ingest_status,3" db:"ingest_status" json:"ingest_status"`
	IsCleanedUp      bool            `thrift:"is_cleaned_up,4" db:"is_cleaned_up" json:"is_cleaned_up"`
	IsPaused         bool            `thrift:"is_paused,5" db:"is_paused" json:"is_paused"`
}

Attributes:

  • DownloadProgress
  • DownloadStatus
  • IngestStatus
  • IsCleanedUp
  • IsPaused

func NewPartitionBulkLoadState 

func NewPartitionBulkLoadState() *PartitionBulkLoadState

func (*PartitionBulkLoadState) GetDownloadProgress 

func (p *PartitionBulkLoadState) GetDownloadProgress() int32

func (*PartitionBulkLoadState) GetDownloadStatus 

func (p *PartitionBulkLoadState) GetDownloadStatus() *base.ErrorCode

func (*PartitionBulkLoadState) GetIngestStatus 

func (p *PartitionBulkLoadState) GetIngestStatus() IngestionStatus

func (*PartitionBulkLoadState) GetIsCleanedUp 

func (p *PartitionBulkLoadState) GetIsCleanedUp() bool

func (*PartitionBulkLoadState) GetIsPaused 

func (p *PartitionBulkLoadState) GetIsPaused() bool

func (*PartitionBulkLoadState) IsSetDownloadProgress 

func (p *PartitionBulkLoadState) IsSetDownloadProgress() bool

func (*PartitionBulkLoadState) IsSetDownloadStatus 

func (p *PartitionBulkLoadState) IsSetDownloadStatus() bool

func (*PartitionBulkLoadState) IsSetIngestStatus 

func (p *PartitionBulkLoadState) IsSetIngestStatus() bool

func (*PartitionBulkLoadState) IsSetIsCleanedUp 

func (p *PartitionBulkLoadState) IsSetIsCleanedUp() bool

func (*PartitionBulkLoadState) IsSetIsPaused 

func (p *PartitionBulkLoadState) IsSetIsPaused() bool

func (*PartitionBulkLoadState) Read 

func (p *PartitionBulkLoadState) Read(iprot thrift.TProtocol) error

func (*PartitionBulkLoadState) ReadField1 

func (p *PartitionBulkLoadState) ReadField1(iprot thrift.TProtocol) error

func (*PartitionBulkLoadState) ReadField2 

func (p *PartitionBulkLoadState) ReadField2(iprot thrift.TProtocol) error

func (*PartitionBulkLoadState) ReadField3 

func (p *PartitionBulkLoadState) ReadField3(iprot thrift.TProtocol) error

func (*PartitionBulkLoadState) ReadField4 

func (p *PartitionBulkLoadState) ReadField4(iprot thrift.TProtocol) error

func (*PartitionBulkLoadState) ReadField5 

func (p *PartitionBulkLoadState) ReadField5(iprot thrift.TProtocol) error

func (*PartitionBulkLoadState) String 

func (p *PartitionBulkLoadState) String() string

func (*PartitionBulkLoadState) Write 

func (p *PartitionBulkLoadState) Write(oprot thrift.TProtocol) error

type PolicyEntry 

type PolicyEntry struct {
	PolicyName               string  `thrift:"policy_name,1" db:"policy_name" json:"policy_name"`
	BackupProviderType       string  `thrift:"backup_provider_type,2" db:"backup_provider_type" json:"backup_provider_type"`
	BackupIntervalSeconds    string  `thrift:"backup_interval_seconds,3" db:"backup_interval_seconds" json:"backup_interval_seconds"`
	AppIds                   []int32 `thrift:"app_ids,4" db:"app_ids" json:"app_ids"`
	BackupHistoryCountToKeep int32   `thrift:"backup_history_count_to_keep,5" db:"backup_history_count_to_keep" json:"backup_history_count_to_keep"`
	StartTime                string  `thrift:"start_time,6" db:"start_time" json:"start_time"`
	IsDisable                bool    `thrift:"is_disable,7" db:"is_disable" json:"is_disable"`
}

Attributes:

  • PolicyName
  • BackupProviderType
  • BackupIntervalSeconds
  • AppIds
  • BackupHistoryCountToKeep
  • StartTime
  • IsDisable

func NewPolicyEntry 

func NewPolicyEntry() *PolicyEntry

func (*PolicyEntry) GetAppIds 

func (p *PolicyEntry) GetAppIds() []int32

func (*PolicyEntry) GetBackupHistoryCountToKeep 

func (p *PolicyEntry) GetBackupHistoryCountToKeep() int32

func (*PolicyEntry) GetBackupIntervalSeconds 

func (p *PolicyEntry) GetBackupIntervalSeconds() string

func (*PolicyEntry) GetBackupProviderType 

func (p *PolicyEntry) GetBackupProviderType() string

func (*PolicyEntry) GetIsDisable 

func (p *PolicyEntry) GetIsDisable() bool

func (*PolicyEntry) GetPolicyName 

func (p *PolicyEntry) GetPolicyName() string

func (*PolicyEntry) GetStartTime 

func (p *PolicyEntry) GetStartTime() string

func (*PolicyEntry) Read 

func (p *PolicyEntry) Read(iprot thrift.TProtocol) error

func (*PolicyEntry) ReadField1 

func (p *PolicyEntry) ReadField1(iprot thrift.TProtocol) error

func (*PolicyEntry) ReadField2 

func (p *PolicyEntry) ReadField2(iprot thrift.TProtocol) error

func (*PolicyEntry) ReadField3 

func (p *PolicyEntry) ReadField3(iprot thrift.TProtocol) error

func (*PolicyEntry) ReadField4 

func (p *PolicyEntry) ReadField4(iprot thrift.TProtocol) error

func (*PolicyEntry) ReadField5 

func (p *PolicyEntry) ReadField5(iprot thrift.TProtocol) error

func (*PolicyEntry) ReadField6 

func (p *PolicyEntry) ReadField6(iprot thrift.TProtocol) error

func (*PolicyEntry) ReadField7 

func (p *PolicyEntry) ReadField7(iprot thrift.TProtocol) error

func (*PolicyEntry) String 

func (p *PolicyEntry) String() string

func (*PolicyEntry) Write 

func (p *PolicyEntry) Write(oprot thrift.TProtocol) error

type QueryAppInfoRequest 

type QueryAppInfoRequest struct {
	MetaServer *base.RPCAddress `thrift:"meta_server,1" db:"meta_server" json:"meta_server"`
}

Attributes:

  • MetaServer
var AdminClientQueryAppInfoArgs_Req_DEFAULT *QueryAppInfoRequest

func NewQueryAppInfoRequest 

func NewQueryAppInfoRequest() *QueryAppInfoRequest

func (*QueryAppInfoRequest) GetMetaServer 

func (p *QueryAppInfoRequest) GetMetaServer() *base.RPCAddress

func (*QueryAppInfoRequest) IsSetMetaServer 

func (p *QueryAppInfoRequest) IsSetMetaServer() bool

func (*QueryAppInfoRequest) Read 

func (p *QueryAppInfoRequest) Read(iprot thrift.TProtocol) error

func (*QueryAppInfoRequest) ReadField1 

func (p *QueryAppInfoRequest) ReadField1(iprot thrift.TProtocol) error

func (*QueryAppInfoRequest) String 

func (p *QueryAppInfoRequest) String() string

func (*QueryAppInfoRequest) Write 

func (p *QueryAppInfoRequest) Write(oprot thrift.TProtocol) error

type QueryAppInfoResponse 

type QueryAppInfoResponse struct {
	Err  *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	Apps []*AppInfo      `thrift:"apps,2" db:"apps" json:"apps"`
}

Attributes:

  • Err
  • Apps
var AdminClientQueryAppInfoResult_Success_DEFAULT *QueryAppInfoResponse

func NewQueryAppInfoResponse 

func NewQueryAppInfoResponse() *QueryAppInfoResponse

func (*QueryAppInfoResponse) GetApps 

func (p *QueryAppInfoResponse) GetApps() []*AppInfo

func (*QueryAppInfoResponse) GetErr 

func (p *QueryAppInfoResponse) GetErr() *base.ErrorCode

func (*QueryAppInfoResponse) IsSetErr 

func (p *QueryAppInfoResponse) IsSetErr() bool

func (*QueryAppInfoResponse) Read 

func (p *QueryAppInfoResponse) Read(iprot thrift.TProtocol) error

func (*QueryAppInfoResponse) ReadField1 

func (p *QueryAppInfoResponse) ReadField1(iprot thrift.TProtocol) error

func (*QueryAppInfoResponse) ReadField2 

func (p *QueryAppInfoResponse) ReadField2(iprot thrift.TProtocol) error

func (*QueryAppInfoResponse) String 

func (p *QueryAppInfoResponse) String() string

func (*QueryAppInfoResponse) Write 

func (p *QueryAppInfoResponse) Write(oprot thrift.TProtocol) error

type QueryAppManualCompactRequest 

type QueryAppManualCompactRequest struct {
	AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"`
}

Attributes:

  • AppName
var AdminClientQueryManualCompactArgs_Req_DEFAULT *QueryAppManualCompactRequest

func NewQueryAppManualCompactRequest 

func NewQueryAppManualCompactRequest() *QueryAppManualCompactRequest

func (*QueryAppManualCompactRequest) GetAppName 

func (p *QueryAppManualCompactRequest) GetAppName() string

func (*QueryAppManualCompactRequest) Read 

func (p *QueryAppManualCompactRequest) Read(iprot thrift.TProtocol) error

func (*QueryAppManualCompactRequest) ReadField1 

func (p *QueryAppManualCompactRequest) ReadField1(iprot thrift.TProtocol) error

func (*QueryAppManualCompactRequest) String 

func (p *QueryAppManualCompactRequest) String() string

func (*QueryAppManualCompactRequest) Write 

func (p *QueryAppManualCompactRequest) Write(oprot thrift.TProtocol) error

type QueryAppManualCompactResponse 

type QueryAppManualCompactResponse struct {
	Err      *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	HintMsg  string          `thrift:"hint_msg,2" db:"hint_msg" json:"hint_msg"`
	Progress *int32          `thrift:"progress,3" db:"progress" json:"progress,omitempty"`
}

Attributes:

  • Err
  • HintMsg
  • Progress
var AdminClientQueryManualCompactResult_Success_DEFAULT *QueryAppManualCompactResponse

func NewQueryAppManualCompactResponse 

func NewQueryAppManualCompactResponse() *QueryAppManualCompactResponse

func (*QueryAppManualCompactResponse) GetErr 

func (p *QueryAppManualCompactResponse) GetErr() *base.ErrorCode

func (*QueryAppManualCompactResponse) GetHintMsg 

func (p *QueryAppManualCompactResponse) GetHintMsg() string

func (*QueryAppManualCompactResponse) GetProgress 

func (p *QueryAppManualCompactResponse) GetProgress() int32

func (*QueryAppManualCompactResponse) IsSetErr 

func (p *QueryAppManualCompactResponse) IsSetErr() bool

func (*QueryAppManualCompactResponse) IsSetProgress 

func (p *QueryAppManualCompactResponse) IsSetProgress() bool

func (*QueryAppManualCompactResponse) Read 

func (p *QueryAppManualCompactResponse) Read(iprot thrift.TProtocol) error

func (*QueryAppManualCompactResponse) ReadField1 

func (p *QueryAppManualCompactResponse) ReadField1(iprot thrift.TProtocol) error

func (*QueryAppManualCompactResponse) ReadField2 

func (p *QueryAppManualCompactResponse) ReadField2(iprot thrift.TProtocol) error

func (*QueryAppManualCompactResponse) ReadField3 

func (p *QueryAppManualCompactResponse) ReadField3(iprot thrift.TProtocol) error

func (*QueryAppManualCompactResponse) String 

func (p *QueryAppManualCompactResponse) String() string

func (*QueryAppManualCompactResponse) Write 

func (p *QueryAppManualCompactResponse) Write(oprot thrift.TProtocol) error

type QueryBackupPolicyRequest 

type QueryBackupPolicyRequest struct {
	PolicyNames     []string `thrift:"policy_names,1" db:"policy_names" json:"policy_names"`
	BackupInfoCount int32    `thrift:"backup_info_count,2" db:"backup_info_count" json:"backup_info_count"`
}

Attributes:

  • PolicyNames
  • BackupInfoCount
var AdminClientQueryBackupPolicyArgs_Req_DEFAULT *QueryBackupPolicyRequest

func NewQueryBackupPolicyRequest 

func NewQueryBackupPolicyRequest() *QueryBackupPolicyRequest

func (*QueryBackupPolicyRequest) GetBackupInfoCount 

func (p *QueryBackupPolicyRequest) GetBackupInfoCount() int32

func (*QueryBackupPolicyRequest) GetPolicyNames 

func (p *QueryBackupPolicyRequest) GetPolicyNames() []string

func (*QueryBackupPolicyRequest) Read 

func (p *QueryBackupPolicyRequest) Read(iprot thrift.TProtocol) error

func (*QueryBackupPolicyRequest) ReadField1 

func (p *QueryBackupPolicyRequest) ReadField1(iprot thrift.TProtocol) error

func (*QueryBackupPolicyRequest) ReadField2 

func (p *QueryBackupPolicyRequest) ReadField2(iprot thrift.TProtocol) error

func (*QueryBackupPolicyRequest) String 

func (p *QueryBackupPolicyRequest) String() string

func (*QueryBackupPolicyRequest) Write 

func (p *QueryBackupPolicyRequest) Write(oprot thrift.TProtocol) error

type QueryBackupPolicyResponse 

type QueryBackupPolicyResponse struct {
	Err         *base.ErrorCode  `thrift:"err,1" db:"err" json:"err"`
	Policys     []*PolicyEntry   `thrift:"policys,2" db:"policys" json:"policys"`
	BackupInfos [][]*BackupEntry `thrift:"backup_infos,3" db:"backup_infos" json:"backup_infos"`
	HintMsg     *string          `thrift:"hint_msg,4" db:"hint_msg" json:"hint_msg,omitempty"`
}

Attributes:

  • Err
  • Policys
  • BackupInfos
  • HintMsg
var AdminClientQueryBackupPolicyResult_Success_DEFAULT *QueryBackupPolicyResponse

func NewQueryBackupPolicyResponse 

func NewQueryBackupPolicyResponse() *QueryBackupPolicyResponse

func (*QueryBackupPolicyResponse) GetBackupInfos 

func (p *QueryBackupPolicyResponse) GetBackupInfos() [][]*BackupEntry

func (*QueryBackupPolicyResponse) GetErr 

func (p *QueryBackupPolicyResponse) GetErr() *base.ErrorCode

func (*QueryBackupPolicyResponse) GetHintMsg 

func (p *QueryBackupPolicyResponse) GetHintMsg() string

func (*QueryBackupPolicyResponse) GetPolicys 

func (p *QueryBackupPolicyResponse) GetPolicys() []*PolicyEntry

func (*QueryBackupPolicyResponse) IsSetErr 

func (p *QueryBackupPolicyResponse) IsSetErr() bool

func (*QueryBackupPolicyResponse) IsSetHintMsg 

func (p *QueryBackupPolicyResponse) IsSetHintMsg() bool

func (*QueryBackupPolicyResponse) Read 

func (p *QueryBackupPolicyResponse) Read(iprot thrift.TProtocol) error

func (*QueryBackupPolicyResponse) ReadField1 

func (p *QueryBackupPolicyResponse) ReadField1(iprot thrift.TProtocol) error

func (*QueryBackupPolicyResponse) ReadField2 

func (p *QueryBackupPolicyResponse) ReadField2(iprot thrift.TProtocol) error

func (*QueryBackupPolicyResponse) ReadField3 

func (p *QueryBackupPolicyResponse) ReadField3(iprot thrift.TProtocol) error

func (*QueryBackupPolicyResponse) ReadField4 

func (p *QueryBackupPolicyResponse) ReadField4(iprot thrift.TProtocol) error

func (*QueryBackupPolicyResponse) String 

func (p *QueryBackupPolicyResponse) String() string

func (*QueryBackupPolicyResponse) Write 

func (p *QueryBackupPolicyResponse) Write(oprot thrift.TProtocol) error

type QueryBackupStatusRequest 

type QueryBackupStatusRequest struct {
	AppID    int32  `thrift:"app_id,1" db:"app_id" json:"app_id"`
	BackupID *int64 `thrift:"backup_id,2" db:"backup_id" json:"backup_id,omitempty"`
}

Attributes:

  • AppID
  • BackupID
var AdminClientQueryBackupStatusArgs_Req_DEFAULT *QueryBackupStatusRequest

func NewQueryBackupStatusRequest 

func NewQueryBackupStatusRequest() *QueryBackupStatusRequest

func (*QueryBackupStatusRequest) GetAppID 

func (p *QueryBackupStatusRequest) GetAppID() int32

func (*QueryBackupStatusRequest) GetBackupID 

func (p *QueryBackupStatusRequest) GetBackupID() int64

func (*QueryBackupStatusRequest) IsSetBackupID 

func (p *QueryBackupStatusRequest) IsSetBackupID() bool

func (*QueryBackupStatusRequest) Read 

func (p *QueryBackupStatusRequest) Read(iprot thrift.TProtocol) error

func (*QueryBackupStatusRequest) ReadField1 

func (p *QueryBackupStatusRequest) ReadField1(iprot thrift.TProtocol) error

func (*QueryBackupStatusRequest) ReadField2 

func (p *QueryBackupStatusRequest) ReadField2(iprot thrift.TProtocol) error

func (*QueryBackupStatusRequest) String 

func (p *QueryBackupStatusRequest) String() string

func (*QueryBackupStatusRequest) Write 

func (p *QueryBackupStatusRequest) Write(oprot thrift.TProtocol) error

type QueryBackupStatusResponse 

type QueryBackupStatusResponse struct {
	Err         *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	HintMessage string          `thrift:"hint_message,2" db:"hint_message" json:"hint_message"`
	BackupItems []*BackupItem   `thrift:"backup_items,3" db:"backup_items" json:"backup_items,omitempty"`
}

Attributes:

  • Err
  • HintMessage
  • BackupItems
var AdminClientQueryBackupStatusResult_Success_DEFAULT *QueryBackupStatusResponse

func NewQueryBackupStatusResponse 

func NewQueryBackupStatusResponse() *QueryBackupStatusResponse

func (*QueryBackupStatusResponse) GetBackupItems 

func (p *QueryBackupStatusResponse) GetBackupItems() []*BackupItem

func (*QueryBackupStatusResponse) GetErr 

func (p *QueryBackupStatusResponse) GetErr() *base.ErrorCode

func (*QueryBackupStatusResponse) GetHintMessage 

func (p *QueryBackupStatusResponse) GetHintMessage() string

func (*QueryBackupStatusResponse) IsSetBackupItems 

func (p *QueryBackupStatusResponse) IsSetBackupItems() bool

func (*QueryBackupStatusResponse) IsSetErr 

func (p *QueryBackupStatusResponse) IsSetErr() bool

func (*QueryBackupStatusResponse) Read 

func (p *QueryBackupStatusResponse) Read(iprot thrift.TProtocol) error

func (*QueryBackupStatusResponse) ReadField1 

func (p *QueryBackupStatusResponse) ReadField1(iprot thrift.TProtocol) error

func (*QueryBackupStatusResponse) ReadField2 

func (p *QueryBackupStatusResponse) ReadField2(iprot thrift.TProtocol) error

func (*QueryBackupStatusResponse) ReadField3 

func (p *QueryBackupStatusResponse) ReadField3(iprot thrift.TProtocol) error

func (*QueryBackupStatusResponse) String 

func (p *QueryBackupStatusResponse) String() string

func (*QueryBackupStatusResponse) Write 

func (p *QueryBackupStatusResponse) Write(oprot thrift.TProtocol) error

type QueryBulkLoadRequest 

type QueryBulkLoadRequest struct {
	AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"`
}

Attributes:

  • AppName
var AdminClientQueryBulkLoadStatusArgs_Req_DEFAULT *QueryBulkLoadRequest

func NewQueryBulkLoadRequest 

func NewQueryBulkLoadRequest() *QueryBulkLoadRequest

func (*QueryBulkLoadRequest) GetAppName 

func (p *QueryBulkLoadRequest) GetAppName() string

func (*QueryBulkLoadRequest) Read 

func (p *QueryBulkLoadRequest) Read(iprot thrift.TProtocol) error

func (*QueryBulkLoadRequest) ReadField1 

func (p *QueryBulkLoadRequest) ReadField1(iprot thrift.TProtocol) error

func (*QueryBulkLoadRequest) String 

func (p *QueryBulkLoadRequest) String() string

func (*QueryBulkLoadRequest) Write 

func (p *QueryBulkLoadRequest) Write(oprot thrift.TProtocol) error

type QueryBulkLoadResponse 

type QueryBulkLoadResponse struct {
	Err              *base.ErrorCode                                `thrift:"err,1" db:"err" json:"err"`
	AppName          string                                         `thrift:"app_name,2" db:"app_name" json:"app_name"`
	AppStatus        BulkLoadStatus                                 `thrift:"app_status,3" db:"app_status" json:"app_status"`
	PartitionsStatus []BulkLoadStatus                               `thrift:"partitions_status,4" db:"partitions_status" json:"partitions_status"`
	MaxReplicaCount  int32                                          `thrift:"max_replica_count,5" db:"max_replica_count" json:"max_replica_count"`
	BulkLoadStates   []map[*base.RPCAddress]*PartitionBulkLoadState `thrift:"bulk_load_states,6" db:"bulk_load_states" json:"bulk_load_states"`
	HintMsg          *string                                        `thrift:"hint_msg,7" db:"hint_msg" json:"hint_msg,omitempty"`
}

Attributes:

  • Err
  • AppName
  • AppStatus
  • PartitionsStatus
  • MaxReplicaCount
  • BulkLoadStates
  • HintMsg
var AdminClientQueryBulkLoadStatusResult_Success_DEFAULT *QueryBulkLoadResponse

func NewQueryBulkLoadResponse 

func NewQueryBulkLoadResponse() *QueryBulkLoadResponse

func (*QueryBulkLoadResponse) GetAppName 

func (p *QueryBulkLoadResponse) GetAppName() string

func (*QueryBulkLoadResponse) GetAppStatus 

func (p *QueryBulkLoadResponse) GetAppStatus() BulkLoadStatus

func (*QueryBulkLoadResponse) GetBulkLoadStates 

func (p *QueryBulkLoadResponse) GetBulkLoadStates() []map[*base.RPCAddress]*PartitionBulkLoadState

func (*QueryBulkLoadResponse) GetErr 

func (p *QueryBulkLoadResponse) GetErr() *base.ErrorCode

func (*QueryBulkLoadResponse) GetHintMsg 

func (p *QueryBulkLoadResponse) GetHintMsg() string

func (*QueryBulkLoadResponse) GetMaxReplicaCount 

func (p *QueryBulkLoadResponse) GetMaxReplicaCount() int32

func (*QueryBulkLoadResponse) GetPartitionsStatus 

func (p *QueryBulkLoadResponse) GetPartitionsStatus() []BulkLoadStatus

func (*QueryBulkLoadResponse) IsSetErr 

func (p *QueryBulkLoadResponse) IsSetErr() bool

func (*QueryBulkLoadResponse) IsSetHintMsg 

func (p *QueryBulkLoadResponse) IsSetHintMsg() bool

func (*QueryBulkLoadResponse) Read 

func (p *QueryBulkLoadResponse) Read(iprot thrift.TProtocol) error

func (*QueryBulkLoadResponse) ReadField1 

func (p *QueryBulkLoadResponse) ReadField1(iprot thrift.TProtocol) error

func (*QueryBulkLoadResponse) ReadField2 

func (p *QueryBulkLoadResponse) ReadField2(iprot thrift.TProtocol) error

func (*QueryBulkLoadResponse) ReadField3 

func (p *QueryBulkLoadResponse) ReadField3(iprot thrift.TProtocol) error

func (*QueryBulkLoadResponse) ReadField4 

func (p *QueryBulkLoadResponse) ReadField4(iprot thrift.TProtocol) error

func (*QueryBulkLoadResponse) ReadField5 

func (p *QueryBulkLoadResponse) ReadField5(iprot thrift.TProtocol) error

func (*QueryBulkLoadResponse) ReadField6 

func (p *QueryBulkLoadResponse) ReadField6(iprot thrift.TProtocol) error

func (*QueryBulkLoadResponse) ReadField7 

func (p *QueryBulkLoadResponse) ReadField7(iprot thrift.TProtocol) error

func (*QueryBulkLoadResponse) String 

func (p *QueryBulkLoadResponse) String() string

func (*QueryBulkLoadResponse) Write 

func (p *QueryBulkLoadResponse) Write(oprot thrift.TProtocol) error

type QuerySplitRequest 

type QuerySplitRequest struct {
	AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"`
}

Attributes:

  • AppName
var AdminClientQuerySplitStatusArgs_Req_DEFAULT *QuerySplitRequest

func NewQuerySplitRequest 

func NewQuerySplitRequest() *QuerySplitRequest

func (*QuerySplitRequest) GetAppName 

func (p *QuerySplitRequest) GetAppName() string

func (*QuerySplitRequest) Read 

func (p *QuerySplitRequest) Read(iprot thrift.TProtocol) error

func (*QuerySplitRequest) ReadField1 

func (p *QuerySplitRequest) ReadField1(iprot thrift.TProtocol) error

func (*QuerySplitRequest) String 

func (p *QuerySplitRequest) String() string

func (*QuerySplitRequest) Write 

func (p *QuerySplitRequest) Write(oprot thrift.TProtocol) error

type QuerySplitResponse 

type QuerySplitResponse struct {
	Err                *base.ErrorCode       `thrift:"err,1" db:"err" json:"err"`
	NewPartitionCount_ int32                 `thrift:"new_partition_count,2" db:"new_partition_count" json:"new_partition_count"`
	Status             map[int32]SplitStatus `thrift:"status,3" db:"status" json:"status"`
	HintMsg            *string               `thrift:"hint_msg,4" db:"hint_msg" json:"hint_msg,omitempty"`
}

Attributes:

  • Err
  • NewPartitionCount_
  • Status
  • HintMsg
var AdminClientQuerySplitStatusResult_Success_DEFAULT *QuerySplitResponse

func NewQuerySplitResponse 

func NewQuerySplitResponse() *QuerySplitResponse

func (*QuerySplitResponse) GetErr 

func (p *QuerySplitResponse) GetErr() *base.ErrorCode

func (*QuerySplitResponse) GetHintMsg 

func (p *QuerySplitResponse) GetHintMsg() string

func (*QuerySplitResponse) GetNewPartitionCount_ 

func (p *QuerySplitResponse) GetNewPartitionCount_() int32

func (*QuerySplitResponse) GetStatus 

func (p *QuerySplitResponse) GetStatus() map[int32]SplitStatus

func (*QuerySplitResponse) IsSetErr 

func (p *QuerySplitResponse) IsSetErr() bool

func (*QuerySplitResponse) IsSetHintMsg 

func (p *QuerySplitResponse) IsSetHintMsg() bool

func (*QuerySplitResponse) Read 

func (p *QuerySplitResponse) Read(iprot thrift.TProtocol) error

func (*QuerySplitResponse) ReadField1 

func (p *QuerySplitResponse) ReadField1(iprot thrift.TProtocol) error

func (*QuerySplitResponse) ReadField2 

func (p *QuerySplitResponse) ReadField2(iprot thrift.TProtocol) error

func (*QuerySplitResponse) ReadField3 

func (p *QuerySplitResponse) ReadField3(iprot thrift.TProtocol) error

func (*QuerySplitResponse) ReadField4 

func (p *QuerySplitResponse) ReadField4(iprot thrift.TProtocol) error

func (*QuerySplitResponse) String 

func (p *QuerySplitResponse) String() string

func (*QuerySplitResponse) Write 

func (p *QuerySplitResponse) Write(oprot thrift.TProtocol) error

type RecallAppRequest 

type RecallAppRequest struct {
	AppID       int32  `thrift:"app_id,1" db:"app_id" json:"app_id"`
	NewAppName_ string `thrift:"new_app_name,2" db:"new_app_name" json:"new_app_name"`
}

Attributes:

  • AppID
  • NewAppName_
var AdminClientRecallAppArgs_Req_DEFAULT *RecallAppRequest

func NewRecallAppRequest 

func NewRecallAppRequest() *RecallAppRequest

func (*RecallAppRequest) GetAppID 

func (p *RecallAppRequest) GetAppID() int32

func (*RecallAppRequest) GetNewAppName_ 

func (p *RecallAppRequest) GetNewAppName_() string

func (*RecallAppRequest) Read 

func (p *RecallAppRequest) Read(iprot thrift.TProtocol) error

func (*RecallAppRequest) ReadField1 

func (p *RecallAppRequest) ReadField1(iprot thrift.TProtocol) error

func (*RecallAppRequest) ReadField2 

func (p *RecallAppRequest) ReadField2(iprot thrift.TProtocol) error

func (*RecallAppRequest) String 

func (p *RecallAppRequest) String() string

func (*RecallAppRequest) Write 

func (p *RecallAppRequest) Write(oprot thrift.TProtocol) error

type RecallAppResponse 

type RecallAppResponse struct {
	Err  *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	Info *AppInfo        `thrift:"info,2" db:"info" json:"info"`
}

Attributes:

  • Err
  • Info
var AdminClientRecallAppResult_Success_DEFAULT *RecallAppResponse

func NewRecallAppResponse 

func NewRecallAppResponse() *RecallAppResponse

func (*RecallAppResponse) GetErr 

func (p *RecallAppResponse) GetErr() *base.ErrorCode

func (*RecallAppResponse) GetInfo 

func (p *RecallAppResponse) GetInfo() *AppInfo

func (*RecallAppResponse) IsSetErr 

func (p *RecallAppResponse) IsSetErr() bool

func (*RecallAppResponse) IsSetInfo 

func (p *RecallAppResponse) IsSetInfo() bool

func (*RecallAppResponse) Read 

func (p *RecallAppResponse) Read(iprot thrift.TProtocol) error

func (*RecallAppResponse) ReadField1 

func (p *RecallAppResponse) ReadField1(iprot thrift.TProtocol) error

func (*RecallAppResponse) ReadField2 

func (p *RecallAppResponse) ReadField2(iprot thrift.TProtocol) error

func (*RecallAppResponse) String 

func (p *RecallAppResponse) String() string

func (*RecallAppResponse) Write 

func (p *RecallAppResponse) Write(oprot thrift.TProtocol) error

type RestoreAppRequest 

type RestoreAppRequest struct {
	ClusterName        string  `thrift:"cluster_name,1" db:"cluster_name" json:"cluster_name"`
	PolicyName         string  `thrift:"policy_name,2" db:"policy_name" json:"policy_name"`
	TimeStamp          int64   `thrift:"time_stamp,3" db:"time_stamp" json:"time_stamp"`
	AppName            string  `thrift:"app_name,4" db:"app_name" json:"app_name"`
	AppID              int32   `thrift:"app_id,5" db:"app_id" json:"app_id"`
	NewAppName_        string  `thrift:"new_app_name,6" db:"new_app_name" json:"new_app_name"`
	BackupProviderName string  `thrift:"backup_provider_name,7" db:"backup_provider_name" json:"backup_provider_name"`
	SkipBadPartition   bool    `thrift:"skip_bad_partition,8" db:"skip_bad_partition" json:"skip_bad_partition"`
	RestorePath        *string `thrift:"restore_path,9" db:"restore_path" json:"restore_path,omitempty"`
}

Attributes:

  • ClusterName
  • PolicyName
  • TimeStamp
  • AppName
  • AppID
  • NewAppName_
  • BackupProviderName
  • SkipBadPartition
  • RestorePath
var AdminClientRestoreAppArgs_Req_DEFAULT *RestoreAppRequest

func NewRestoreAppRequest 

func NewRestoreAppRequest() *RestoreAppRequest

func (*RestoreAppRequest) GetAppID 

func (p *RestoreAppRequest) GetAppID() int32

func (*RestoreAppRequest) GetAppName 

func (p *RestoreAppRequest) GetAppName() string

func (*RestoreAppRequest) GetBackupProviderName 

func (p *RestoreAppRequest) GetBackupProviderName() string

func (*RestoreAppRequest) GetClusterName 

func (p *RestoreAppRequest) GetClusterName() string

func (*RestoreAppRequest) GetNewAppName_ 

func (p *RestoreAppRequest) GetNewAppName_() string

func (*RestoreAppRequest) GetPolicyName 

func (p *RestoreAppRequest) GetPolicyName() string

func (*RestoreAppRequest) GetRestorePath 

func (p *RestoreAppRequest) GetRestorePath() string

func (*RestoreAppRequest) GetSkipBadPartition 

func (p *RestoreAppRequest) GetSkipBadPartition() bool

func (*RestoreAppRequest) GetTimeStamp 

func (p *RestoreAppRequest) GetTimeStamp() int64

func (*RestoreAppRequest) IsSetRestorePath 

func (p *RestoreAppRequest) IsSetRestorePath() bool

func (*RestoreAppRequest) Read 

func (p *RestoreAppRequest) Read(iprot thrift.TProtocol) error

func (*RestoreAppRequest) ReadField1 

func (p *RestoreAppRequest) ReadField1(iprot thrift.TProtocol) error

func (*RestoreAppRequest) ReadField2 

func (p *RestoreAppRequest) ReadField2(iprot thrift.TProtocol) error

func (*RestoreAppRequest) ReadField3 

func (p *RestoreAppRequest) ReadField3(iprot thrift.TProtocol) error

func (*RestoreAppRequest) ReadField4 

func (p *RestoreAppRequest) ReadField4(iprot thrift.TProtocol) error

func (*RestoreAppRequest) ReadField5 

func (p *RestoreAppRequest) ReadField5(iprot thrift.TProtocol) error

func (*RestoreAppRequest) ReadField6 

func (p *RestoreAppRequest) ReadField6(iprot thrift.TProtocol) error

func (*RestoreAppRequest) ReadField7 

func (p *RestoreAppRequest) ReadField7(iprot thrift.TProtocol) error

func (*RestoreAppRequest) ReadField8 

func (p *RestoreAppRequest) ReadField8(iprot thrift.TProtocol) error

func (*RestoreAppRequest) ReadField9 

func (p *RestoreAppRequest) ReadField9(iprot thrift.TProtocol) error

func (*RestoreAppRequest) String 

func (p *RestoreAppRequest) String() string

func (*RestoreAppRequest) Write 

func (p *RestoreAppRequest) Write(oprot thrift.TProtocol) error

type SplitControlType 

type SplitControlType int64
const (
	SplitControlType_PAUSE   SplitControlType = 0
	SplitControlType_RESTART SplitControlType = 1
	SplitControlType_CANCEL  SplitControlType = 2
)

func SplitControlTypeFromString 

func SplitControlTypeFromString(s string) (SplitControlType, error)

func SplitControlTypePtr 

func SplitControlTypePtr(v SplitControlType) *SplitControlType

func (SplitControlType) MarshalText 

func (p SplitControlType) MarshalText() ([]byte, error)

func (*SplitControlType) Scan 

func (p *SplitControlType) Scan(value interface{}) error

func (SplitControlType) String 

func (p SplitControlType) String() string

func (*SplitControlType) UnmarshalText 

func (p *SplitControlType) UnmarshalText(text []byte) error

func (*SplitControlType) Value 

func (p *SplitControlType) Value() (driver.Value, error)

type SplitStatus 

type SplitStatus int64
const (
	SplitStatus_NOT_SPLIT SplitStatus = 0
	SplitStatus_SPLITTING SplitStatus = 1
	SplitStatus_PAUSING   SplitStatus = 2
	SplitStatus_PAUSED    SplitStatus = 3
	SplitStatus_CANCELING SplitStatus = 4
)

func SplitStatusFromString 

func SplitStatusFromString(s string) (SplitStatus, error)

func SplitStatusPtr 

func SplitStatusPtr(v SplitStatus) *SplitStatus

func (SplitStatus) MarshalText 

func (p SplitStatus) MarshalText() ([]byte, error)

func (*SplitStatus) Scan 

func (p *SplitStatus) Scan(value interface{}) error

func (SplitStatus) String 

func (p SplitStatus) String() string

func (*SplitStatus) UnmarshalText 

func (p *SplitStatus) UnmarshalText(text []byte) error

func (*SplitStatus) Value 

func (p *SplitStatus) Value() (driver.Value, error)

type StartAppManualCompactRequest 

type StartAppManualCompactRequest struct {
	AppName         string `thrift:"app_name,1" db:"app_name" json:"app_name"`
	TriggerTime     *int64 `thrift:"trigger_time,2" db:"trigger_time" json:"trigger_time,omitempty"`
	TargetLevel     *int32 `thrift:"target_level,3" db:"target_level" json:"target_level,omitempty"`
	Bottommost      *bool  `thrift:"bottommost,4" db:"bottommost" json:"bottommost,omitempty"`
	MaxRunningCount *int32 `thrift:"max_running_count,5" db:"max_running_count" json:"max_running_count,omitempty"`
}

Attributes:

  • AppName
  • TriggerTime
  • TargetLevel
  • Bottommost
  • MaxRunningCount
var AdminClientStartManualCompactArgs_Req_DEFAULT *StartAppManualCompactRequest

func NewStartAppManualCompactRequest 

func NewStartAppManualCompactRequest() *StartAppManualCompactRequest

func (*StartAppManualCompactRequest) GetAppName 

func (p *StartAppManualCompactRequest) GetAppName() string

func (*StartAppManualCompactRequest) GetBottommost 

func (p *StartAppManualCompactRequest) GetBottommost() bool

func (*StartAppManualCompactRequest) GetMaxRunningCount 

func (p *StartAppManualCompactRequest) GetMaxRunningCount() int32

func (*StartAppManualCompactRequest) GetTargetLevel 

func (p *StartAppManualCompactRequest) GetTargetLevel() int32

func (*StartAppManualCompactRequest) GetTriggerTime 

func (p *StartAppManualCompactRequest) GetTriggerTime() int64

func (*StartAppManualCompactRequest) IsSetBottommost 

func (p *StartAppManualCompactRequest) IsSetBottommost() bool

func (*StartAppManualCompactRequest) IsSetMaxRunningCount 

func (p *StartAppManualCompactRequest) IsSetMaxRunningCount() bool

func (*StartAppManualCompactRequest) IsSetTargetLevel 

func (p *StartAppManualCompactRequest) IsSetTargetLevel() bool

func (*StartAppManualCompactRequest) IsSetTriggerTime 

func (p *StartAppManualCompactRequest) IsSetTriggerTime() bool

func (*StartAppManualCompactRequest) Read 

func (p *StartAppManualCompactRequest) Read(iprot thrift.TProtocol) error

func (*StartAppManualCompactRequest) ReadField1 

func (p *StartAppManualCompactRequest) ReadField1(iprot thrift.TProtocol) error

func (*StartAppManualCompactRequest) ReadField2 

func (p *StartAppManualCompactRequest) ReadField2(iprot thrift.TProtocol) error

func (*StartAppManualCompactRequest) ReadField3 

func (p *StartAppManualCompactRequest) ReadField3(iprot thrift.TProtocol) error

func (*StartAppManualCompactRequest) ReadField4 

func (p *StartAppManualCompactRequest) ReadField4(iprot thrift.TProtocol) error

func (*StartAppManualCompactRequest) ReadField5 

func (p *StartAppManualCompactRequest) ReadField5(iprot thrift.TProtocol) error

func (*StartAppManualCompactRequest) String 

func (p *StartAppManualCompactRequest) String() string

func (*StartAppManualCompactRequest) Write 

func (p *StartAppManualCompactRequest) Write(oprot thrift.TProtocol) error

type StartAppManualCompactResponse 

type StartAppManualCompactResponse struct {
	Err     *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	HintMsg string          `thrift:"hint_msg,2" db:"hint_msg" json:"hint_msg"`
}

Attributes:

  • Err
  • HintMsg
var AdminClientStartManualCompactResult_Success_DEFAULT *StartAppManualCompactResponse

func NewStartAppManualCompactResponse 

func NewStartAppManualCompactResponse() *StartAppManualCompactResponse

func (*StartAppManualCompactResponse) GetErr 

func (p *StartAppManualCompactResponse) GetErr() *base.ErrorCode

func (*StartAppManualCompactResponse) GetHintMsg 

func (p *StartAppManualCompactResponse) GetHintMsg() string

func (*StartAppManualCompactResponse) IsSetErr 

func (p *StartAppManualCompactResponse) IsSetErr() bool

func (*StartAppManualCompactResponse) Read 

func (p *StartAppManualCompactResponse) Read(iprot thrift.TProtocol) error

func (*StartAppManualCompactResponse) ReadField1 

func (p *StartAppManualCompactResponse) ReadField1(iprot thrift.TProtocol) error

func (*StartAppManualCompactResponse) ReadField2 

func (p *StartAppManualCompactResponse) ReadField2(iprot thrift.TProtocol) error

func (*StartAppManualCompactResponse) String 

func (p *StartAppManualCompactResponse) String() string

func (*StartAppManualCompactResponse) Write 

func (p *StartAppManualCompactResponse) Write(oprot thrift.TProtocol) error

type StartBackupAppRequest 

type StartBackupAppRequest struct {
	BackupProviderType string  `thrift:"backup_provider_type,1" db:"backup_provider_type" json:"backup_provider_type"`
	AppID              int32   `thrift:"app_id,2" db:"app_id" json:"app_id"`
	BackupPath         *string `thrift:"backup_path,3" db:"backup_path" json:"backup_path,omitempty"`
}

Attributes:

  • BackupProviderType
  • AppID
  • BackupPath
var AdminClientStartBackupAppArgs_Req_DEFAULT *StartBackupAppRequest

func NewStartBackupAppRequest 

func NewStartBackupAppRequest() *StartBackupAppRequest

func (*StartBackupAppRequest) GetAppID 

func (p *StartBackupAppRequest) GetAppID() int32

func (*StartBackupAppRequest) GetBackupPath 

func (p *StartBackupAppRequest) GetBackupPath() string

func (*StartBackupAppRequest) GetBackupProviderType 

func (p *StartBackupAppRequest) GetBackupProviderType() string

func (*StartBackupAppRequest) IsSetBackupPath 

func (p *StartBackupAppRequest) IsSetBackupPath() bool

func (*StartBackupAppRequest) Read 

func (p *StartBackupAppRequest) Read(iprot thrift.TProtocol) error

func (*StartBackupAppRequest) ReadField1 

func (p *StartBackupAppRequest) ReadField1(iprot thrift.TProtocol) error

func (*StartBackupAppRequest) ReadField2 

func (p *StartBackupAppRequest) ReadField2(iprot thrift.TProtocol) error

func (*StartBackupAppRequest) ReadField3 

func (p *StartBackupAppRequest) ReadField3(iprot thrift.TProtocol) error

func (*StartBackupAppRequest) String 

func (p *StartBackupAppRequest) String() string

func (*StartBackupAppRequest) Write 

func (p *StartBackupAppRequest) Write(oprot thrift.TProtocol) error

type StartBackupAppResponse 

type StartBackupAppResponse struct {
	Err         *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	HintMessage string          `thrift:"hint_message,2" db:"hint_message" json:"hint_message"`
	BackupID    *int64          `thrift:"backup_id,3" db:"backup_id" json:"backup_id,omitempty"`
}

Attributes:

  • Err
  • HintMessage
  • BackupID
var AdminClientStartBackupAppResult_Success_DEFAULT *StartBackupAppResponse

func NewStartBackupAppResponse 

func NewStartBackupAppResponse() *StartBackupAppResponse

func (*StartBackupAppResponse) GetBackupID 

func (p *StartBackupAppResponse) GetBackupID() int64

func (*StartBackupAppResponse) GetErr 

func (p *StartBackupAppResponse) GetErr() *base.ErrorCode

func (*StartBackupAppResponse) GetHintMessage 

func (p *StartBackupAppResponse) GetHintMessage() string

func (*StartBackupAppResponse) IsSetBackupID 

func (p *StartBackupAppResponse) IsSetBackupID() bool

func (*StartBackupAppResponse) IsSetErr 

func (p *StartBackupAppResponse) IsSetErr() bool

func (*StartBackupAppResponse) Read 

func (p *StartBackupAppResponse) Read(iprot thrift.TProtocol) error

func (*StartBackupAppResponse) ReadField1 

func (p *StartBackupAppResponse) ReadField1(iprot thrift.TProtocol) error

func (*StartBackupAppResponse) ReadField2 

func (p *StartBackupAppResponse) ReadField2(iprot thrift.TProtocol) error

func (*StartBackupAppResponse) ReadField3 

func (p *StartBackupAppResponse) ReadField3(iprot thrift.TProtocol) error

func (*StartBackupAppResponse) String 

func (p *StartBackupAppResponse) String() string

func (*StartBackupAppResponse) Write 

func (p *StartBackupAppResponse) Write(oprot thrift.TProtocol) error

type StartBulkLoadRequest 

type StartBulkLoadRequest struct {
	AppName          string `thrift:"app_name,1" db:"app_name" json:"app_name"`
	ClusterName      string `thrift:"cluster_name,2" db:"cluster_name" json:"cluster_name"`
	FileProviderType string `thrift:"file_provider_type,3" db:"file_provider_type" json:"file_provider_type"`
	RemoteRootPath   string `thrift:"remote_root_path,4" db:"remote_root_path" json:"remote_root_path"`
}

Attributes:

  • AppName
  • ClusterName
  • FileProviderType
  • RemoteRootPath
var AdminClientStartBulkLoadArgs_Req_DEFAULT *StartBulkLoadRequest

func NewStartBulkLoadRequest 

func NewStartBulkLoadRequest() *StartBulkLoadRequest

func (*StartBulkLoadRequest) GetAppName 

func (p *StartBulkLoadRequest) GetAppName() string

func (*StartBulkLoadRequest) GetClusterName 

func (p *StartBulkLoadRequest) GetClusterName() string

func (*StartBulkLoadRequest) GetFileProviderType 

func (p *StartBulkLoadRequest) GetFileProviderType() string

func (*StartBulkLoadRequest) GetRemoteRootPath 

func (p *StartBulkLoadRequest) GetRemoteRootPath() string

func (*StartBulkLoadRequest) Read 

func (p *StartBulkLoadRequest) Read(iprot thrift.TProtocol) error

func (*StartBulkLoadRequest) ReadField1 

func (p *StartBulkLoadRequest) ReadField1(iprot thrift.TProtocol) error

func (*StartBulkLoadRequest) ReadField2 

func (p *StartBulkLoadRequest) ReadField2(iprot thrift.TProtocol) error

func (*StartBulkLoadRequest) ReadField3 

func (p *StartBulkLoadRequest) ReadField3(iprot thrift.TProtocol) error

func (*StartBulkLoadRequest) ReadField4 

func (p *StartBulkLoadRequest) ReadField4(iprot thrift.TProtocol) error

func (*StartBulkLoadRequest) String 

func (p *StartBulkLoadRequest) String() string

func (*StartBulkLoadRequest) Write 

func (p *StartBulkLoadRequest) Write(oprot thrift.TProtocol) error

type StartBulkLoadResponse 

type StartBulkLoadResponse struct {
	Err     *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	HintMsg string          `thrift:"hint_msg,2" db:"hint_msg" json:"hint_msg"`
}

Attributes:

  • Err
  • HintMsg
var AdminClientStartBulkLoadResult_Success_DEFAULT *StartBulkLoadResponse

func NewStartBulkLoadResponse 

func NewStartBulkLoadResponse() *StartBulkLoadResponse

func (*StartBulkLoadResponse) GetErr 

func (p *StartBulkLoadResponse) GetErr() *base.ErrorCode

func (*StartBulkLoadResponse) GetHintMsg 

func (p *StartBulkLoadResponse) GetHintMsg() string

func (*StartBulkLoadResponse) IsSetErr 

func (p *StartBulkLoadResponse) IsSetErr() bool

func (*StartBulkLoadResponse) Read 

func (p *StartBulkLoadResponse) Read(iprot thrift.TProtocol) error

func (*StartBulkLoadResponse) ReadField1 

func (p *StartBulkLoadResponse) ReadField1(iprot thrift.TProtocol) error

func (*StartBulkLoadResponse) ReadField2 

func (p *StartBulkLoadResponse) ReadField2(iprot thrift.TProtocol) error

func (*StartBulkLoadResponse) String 

func (p *StartBulkLoadResponse) String() string

func (*StartBulkLoadResponse) Write 

func (p *StartBulkLoadResponse) Write(oprot thrift.TProtocol) error

type StartPartitionSplitRequest 

type StartPartitionSplitRequest struct {
	AppName            string `thrift:"app_name,1" db:"app_name" json:"app_name"`
	NewPartitionCount_ int32  `thrift:"new_partition_count,2" db:"new_partition_count" json:"new_partition_count"`
}

Attributes:

  • AppName
  • NewPartitionCount_
var AdminClientStartPartitionSplitArgs_Req_DEFAULT *StartPartitionSplitRequest

func NewStartPartitionSplitRequest 

func NewStartPartitionSplitRequest() *StartPartitionSplitRequest

func (*StartPartitionSplitRequest) GetAppName 

func (p *StartPartitionSplitRequest) GetAppName() string

func (*StartPartitionSplitRequest) GetNewPartitionCount_ 

func (p *StartPartitionSplitRequest) GetNewPartitionCount_() int32

func (*StartPartitionSplitRequest) Read 

func (p *StartPartitionSplitRequest) Read(iprot thrift.TProtocol) error

func (*StartPartitionSplitRequest) ReadField1 

func (p *StartPartitionSplitRequest) ReadField1(iprot thrift.TProtocol) error

func (*StartPartitionSplitRequest) ReadField2 

func (p *StartPartitionSplitRequest) ReadField2(iprot thrift.TProtocol) error

func (*StartPartitionSplitRequest) String 

func (p *StartPartitionSplitRequest) String() string

func (*StartPartitionSplitRequest) Write 

func (p *StartPartitionSplitRequest) Write(oprot thrift.TProtocol) error

type StartPartitionSplitResponse 

type StartPartitionSplitResponse struct {
	Err     *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	HintMsg string          `thrift:"hint_msg,2" db:"hint_msg" json:"hint_msg"`
}

Attributes:

  • Err
  • HintMsg
var AdminClientStartPartitionSplitResult_Success_DEFAULT *StartPartitionSplitResponse

func NewStartPartitionSplitResponse 

func NewStartPartitionSplitResponse() *StartPartitionSplitResponse

func (*StartPartitionSplitResponse) GetErr 

func (p *StartPartitionSplitResponse) GetErr() *base.ErrorCode

func (*StartPartitionSplitResponse) GetHintMsg 

func (p *StartPartitionSplitResponse) GetHintMsg() string

func (*StartPartitionSplitResponse) IsSetErr 

func (p *StartPartitionSplitResponse) IsSetErr() bool

func (*StartPartitionSplitResponse) Read 

func (p *StartPartitionSplitResponse) Read(iprot thrift.TProtocol) error

func (*StartPartitionSplitResponse) ReadField1 

func (p *StartPartitionSplitResponse) ReadField1(iprot thrift.TProtocol) error

func (*StartPartitionSplitResponse) ReadField2 

func (p *StartPartitionSplitResponse) ReadField2(iprot thrift.TProtocol) error

func (*StartPartitionSplitResponse) String 

func (p *StartPartitionSplitResponse) String() string

func (*StartPartitionSplitResponse) Write 

func (p *StartPartitionSplitResponse) Write(oprot thrift.TProtocol) error

type UpdateAppEnvRequest 

type UpdateAppEnvRequest struct {
	AppName     string          `thrift:"app_name,1" db:"app_name" json:"app_name"`
	Op          AppEnvOperation `thrift:"op,2" db:"op" json:"op"`
	Keys        []string        `thrift:"keys,3" db:"keys" json:"keys,omitempty"`
	Values      []string        `thrift:"values,4" db:"values" json:"values,omitempty"`
	ClearPrefix *string         `thrift:"clear_prefix,5" db:"clear_prefix" json:"clear_prefix,omitempty"`
}

Attributes:

  • AppName
  • Op
  • Keys
  • Values
  • ClearPrefix
var AdminClientUpdateAppEnvArgs_Req_DEFAULT *UpdateAppEnvRequest

func NewUpdateAppEnvRequest 

func NewUpdateAppEnvRequest() *UpdateAppEnvRequest

func (*UpdateAppEnvRequest) GetAppName 

func (p *UpdateAppEnvRequest) GetAppName() string

func (*UpdateAppEnvRequest) GetClearPrefix 

func (p *UpdateAppEnvRequest) GetClearPrefix() string

func (*UpdateAppEnvRequest) GetKeys 

func (p *UpdateAppEnvRequest) GetKeys() []string

func (*UpdateAppEnvRequest) GetOp 

func (p *UpdateAppEnvRequest) GetOp() AppEnvOperation

func (*UpdateAppEnvRequest) GetValues 

func (p *UpdateAppEnvRequest) GetValues() []string

func (*UpdateAppEnvRequest) IsSetClearPrefix 

func (p *UpdateAppEnvRequest) IsSetClearPrefix() bool

func (*UpdateAppEnvRequest) IsSetKeys 

func (p *UpdateAppEnvRequest) IsSetKeys() bool

func (*UpdateAppEnvRequest) IsSetValues 

func (p *UpdateAppEnvRequest) IsSetValues() bool

func (*UpdateAppEnvRequest) Read 

func (p *UpdateAppEnvRequest) Read(iprot thrift.TProtocol) error

func (*UpdateAppEnvRequest) ReadField1 

func (p *UpdateAppEnvRequest) ReadField1(iprot thrift.TProtocol) error

func (*UpdateAppEnvRequest) ReadField2 

func (p *UpdateAppEnvRequest) ReadField2(iprot thrift.TProtocol) error

func (*UpdateAppEnvRequest) ReadField3 

func (p *UpdateAppEnvRequest) ReadField3(iprot thrift.TProtocol) error

func (*UpdateAppEnvRequest) ReadField4 

func (p *UpdateAppEnvRequest) ReadField4(iprot thrift.TProtocol) error

func (*UpdateAppEnvRequest) ReadField5 

func (p *UpdateAppEnvRequest) ReadField5(iprot thrift.TProtocol) error

func (*UpdateAppEnvRequest) String 

func (p *UpdateAppEnvRequest) String() string

func (*UpdateAppEnvRequest) Write 

func (p *UpdateAppEnvRequest) Write(oprot thrift.TProtocol) error

type UpdateAppEnvResponse 

type UpdateAppEnvResponse struct {
	Err         *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	HintMessage string          `thrift:"hint_message,2" db:"hint_message" json:"hint_message"`
}

Attributes:

  • Err
  • HintMessage
var AdminClientUpdateAppEnvResult_Success_DEFAULT *UpdateAppEnvResponse

func NewUpdateAppEnvResponse 

func NewUpdateAppEnvResponse() *UpdateAppEnvResponse

func (*UpdateAppEnvResponse) GetErr 

func (p *UpdateAppEnvResponse) GetErr() *base.ErrorCode

func (*UpdateAppEnvResponse) GetHintMessage 

func (p *UpdateAppEnvResponse) GetHintMessage() string

func (*UpdateAppEnvResponse) IsSetErr 

func (p *UpdateAppEnvResponse) IsSetErr() bool

func (*UpdateAppEnvResponse) Read 

func (p *UpdateAppEnvResponse) Read(iprot thrift.TProtocol) error

func (*UpdateAppEnvResponse) ReadField1 

func (p *UpdateAppEnvResponse) ReadField1(iprot thrift.TProtocol) error

func (*UpdateAppEnvResponse) ReadField2 

func (p *UpdateAppEnvResponse) ReadField2(iprot thrift.TProtocol) error

func (*UpdateAppEnvResponse) String 

func (p *UpdateAppEnvResponse) String() string

func (*UpdateAppEnvResponse) Write 

func (p *UpdateAppEnvResponse) Write(oprot thrift.TProtocol) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.