admin

package
v0.0.0-...-596603c Latest Latest
Warning

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

 Go to latest Published: Jun 27, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 2 more Imports: 9 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BackupClearRequest_Pid_DEFAULT *base.Gpid
View Source 
var BackupRequest_BackupPath_DEFAULT string
View Source 
var BackupRequest_Pid_DEFAULT *base.Gpid
View Source 
var BackupResponse_Err_DEFAULT *base.ErrorCode
View Source 
var BackupResponse_Pid_DEFAULT *base.Gpid
View Source 
var BulkLoadRequest_HpPrimary_DEFAULT *base.HostPort
View Source 
var BulkLoadRequest_Pid_DEFAULT *base.Gpid
View Source 
var BulkLoadRequest_Primary_DEFAULT *base.RPCAddress
View Source 
var BulkLoadResponse_Err_DEFAULT *base.ErrorCode
View Source 
var BulkLoadResponse_HpGroupBulkLoadState_DEFAULT map[*base.HostPort]*PartitionBulkLoadState
View Source 
var BulkLoadResponse_IsGroupBulkLoadContextCleanedUp_DEFAULT bool
View Source 
var BulkLoadResponse_IsGroupBulkLoadPaused_DEFAULT bool
View Source 
var BulkLoadResponse_IsGroupIngestionFinished_DEFAULT bool
View Source 
var BulkLoadResponse_Pid_DEFAULT *base.Gpid
View Source 
var BulkLoadResponse_TotalDownloadProgress_DEFAULT int32
View Source 
var ClearBulkLoadStateResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationAddBackupPolicyResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationBalancerRequest_Force_DEFAULT bool = false
View Source 
var ConfigurationBalancerRequest_Gpid_DEFAULT *base.Gpid
View Source 
var ConfigurationBalancerResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationClusterInfoResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationCreateAppResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationDropAppResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationGetMaxReplicaCountResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationListAppsResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationListNodesResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationMetaControlResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationModifyBackupPolicyRequest_AddAppids_DEFAULT []int32
View Source 
var ConfigurationModifyBackupPolicyRequest_BackupHistoryCountToKeep_DEFAULT int32
View Source 
var ConfigurationModifyBackupPolicyRequest_IsDisable_DEFAULT bool
View Source 
var ConfigurationModifyBackupPolicyRequest_NewBackupIntervalSec__DEFAULT int64
View Source 
var ConfigurationModifyBackupPolicyRequest_RemovalAppids_DEFAULT []int32
View Source 
var ConfigurationModifyBackupPolicyRequest_StartTime_DEFAULT string
View Source 
var ConfigurationModifyBackupPolicyResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationProposalAction_HpNode_DEFAULT *base.HostPort
View Source 
var ConfigurationProposalAction_HpTarget_DEFAULT *base.HostPort
View Source 
var ConfigurationProposalAction_Node_DEFAULT *base.RPCAddress
View Source 
var ConfigurationProposalAction_Target_DEFAULT *base.RPCAddress
View Source 
var ConfigurationQueryBackupPolicyResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationQueryBackupPolicyResponse_HintMsg_DEFAULT string
View Source 
var ConfigurationQueryByNodeRequest_HpNode_DEFAULT *base.HostPort
View Source 
var ConfigurationQueryByNodeRequest_Node_DEFAULT *base.RPCAddress
View Source 
var ConfigurationQueryByNodeRequest_StoredReplicas_DEFAULT []*ReplicaInfo
View Source 
var ConfigurationQueryByNodeResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationQueryByNodeResponse_GcReplicas_DEFAULT []*ReplicaInfo
View Source 
var ConfigurationQueryRestoreResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationRecallAppResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationRecallAppResponse_Info_DEFAULT *replication.AppInfo
View Source 
var ConfigurationRecoveryRequest_HpRecoveryNodes_DEFAULT []*base.HostPort
View Source 
var ConfigurationRecoveryResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationRenameAppResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationReportRestoreStatusRequest_Pid_DEFAULT *base.Gpid
View Source 
var ConfigurationReportRestoreStatusRequest_Reason_DEFAULT string
View Source 
var ConfigurationReportRestoreStatusRequest_RestoreStatus_DEFAULT *base.ErrorCode
View Source 
var ConfigurationReportRestoreStatusResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationRestoreRequest_RestorePath_DEFAULT string
View Source 
var ConfigurationSetMaxReplicaCountResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationUpdateAppEnvRequest_ClearPrefix_DEFAULT string
View Source 
var ConfigurationUpdateAppEnvRequest_Keys_DEFAULT []string
View Source 
var ConfigurationUpdateAppEnvRequest_Values_DEFAULT []string
View Source 
var ConfigurationUpdateAppEnvResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ConfigurationUpdateRequest_Config_DEFAULT *replication.PartitionConfiguration
View Source 
var ConfigurationUpdateRequest_HostNode_DEFAULT *base.RPCAddress
View Source 
var ConfigurationUpdateRequest_HpNode_DEFAULT *base.HostPort
View Source 
var ConfigurationUpdateRequest_Info_DEFAULT *replication.AppInfo
View Source 
var ConfigurationUpdateRequest_Node_DEFAULT *base.RPCAddress
View Source 
var ConfigurationUpdateResponse_Config_DEFAULT *replication.PartitionConfiguration
View Source 
var ConfigurationUpdateResponse_Err_DEFAULT *base.ErrorCode
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 DddDiagnoseRequest_Pid_DEFAULT *base.Gpid
View Source 
var DddDiagnoseResponse_Err_DEFAULT *base.ErrorCode
View Source 
var DddNodeInfo_HpNode_DEFAULT *base.HostPort
View Source 
var DddNodeInfo_Node_DEFAULT *base.RPCAddress
View Source 
var DddPartitionInfo_Config_DEFAULT *replication.PartitionConfiguration
View Source 
var DropAppOptions_ReserveSeconds_DEFAULT int64
View Source 
var DuplicationAddRequest_IsDuplicatingCheckpoint_DEFAULT bool = true
View Source 
var DuplicationAddRequest_RemoteAppName_DEFAULT string
View Source 
var DuplicationAddRequest_RemoteReplicaCount_DEFAULT int32
View Source 
var DuplicationAddResponse_Err_DEFAULT *base.ErrorCode
View Source 
var DuplicationAddResponse_Hint_DEFAULT string
View Source 
var DuplicationAddResponse_RemoteAppName_DEFAULT string
View Source 
var DuplicationAddResponse_RemoteReplicaCount_DEFAULT int32
View Source 
var DuplicationConfirmEntry_CheckpointPrepared_DEFAULT bool = false
View Source 
var DuplicationEntry_Progress_DEFAULT map[int32]int64
View Source 
var DuplicationEntry_RemoteAppName_DEFAULT string
View Source 
var DuplicationEntry_RemoteReplicaCount_DEFAULT int32
View Source 
var DuplicationModifyResponse_Err_DEFAULT *base.ErrorCode
View Source 
var DuplicationQueryResponse_Err_DEFAULT *base.ErrorCode
View Source 
var DuplicationSyncRequest_HpNode_DEFAULT *base.HostPort
View Source 
var DuplicationSyncRequest_Node_DEFAULT *base.RPCAddress
View Source 
var DuplicationSyncResponse_Err_DEFAULT *base.ErrorCode
View Source 
var GoUnusedProtection__ int
View Source 
var GroupBulkLoadRequest_HpTarget_DEFAULT *base.HostPort
View Source 
var GroupBulkLoadRequest_Target_DEFAULT *base.RPCAddress
View Source 
var GroupBulkLoadResponse_Err_DEFAULT *base.ErrorCode
View Source 
var IngestionResponse_Err_DEFAULT *base.ErrorCode
View Source 
var NodeInfo_HpNode_DEFAULT *base.HostPort
View Source 
var NodeInfo_Node_DEFAULT *base.RPCAddress
View Source 
var NotifyCacthUpResponse_Err_DEFAULT *base.ErrorCode
View Source 
var NotifyCatchUpRequest_ChildGpid_DEFAULT *base.Gpid
View Source 
var NotifyCatchUpRequest_Child_DEFAULT *base.RPCAddress
View Source 
var NotifyCatchUpRequest_HpChild_DEFAULT *base.HostPort
View Source 
var NotifyCatchUpRequest_ParentGpid_DEFAULT *base.Gpid
View Source 
var NotifyStopSplitRequest_ParentGpid_DEFAULT *base.Gpid
View Source 
var NotifyStopSplitResponse_Err_DEFAULT *base.ErrorCode
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_HpMetaServer_DEFAULT *base.HostPort
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 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 QueryBulkLoadResponse_HpBulkLoadStates_DEFAULT []map[*base.HostPort]*PartitionBulkLoadState
View Source 
var QueryBulkLoadResponse_IsBulkLoading_DEFAULT bool
View Source 
var QueryChildStateRequest_Pid_DEFAULT *base.Gpid
View Source 
var QueryChildStateResponse_ChildConfig_DEFAULT *replication.PartitionConfiguration
View Source 
var QueryChildStateResponse_Err_DEFAULT *base.ErrorCode
View Source 
var QueryChildStateResponse_PartitionCount_DEFAULT int32
View Source 
var QuerySplitResponse_Err_DEFAULT *base.ErrorCode
View Source 
var QuerySplitResponse_HintMsg_DEFAULT string
View Source 
var RegisterChildRequest_App_DEFAULT *replication.AppInfo
View Source 
var RegisterChildRequest_ChildConfig_DEFAULT *replication.PartitionConfiguration
View Source 
var RegisterChildRequest_HpPrimary_DEFAULT *base.HostPort
View Source 
var RegisterChildRequest_ParentConfig_DEFAULT *replication.PartitionConfiguration
View Source 
var RegisterChildRequest_Primary_DEFAULT *base.RPCAddress
View Source 
var RegisterChildResponse_App_DEFAULT *replication.AppInfo
View Source 
var RegisterChildResponse_ChildConfig_DEFAULT *replication.PartitionConfiguration
View Source 
var RegisterChildResponse_Err_DEFAULT *base.ErrorCode
View Source 
var RegisterChildResponse_ParentConfig_DEFAULT *replication.PartitionConfiguration
View Source 
var ReplicaConfiguration_HpPrimary_DEFAULT *base.HostPort
View Source 
var ReplicaConfiguration_Pid_DEFAULT *base.Gpid
View Source 
var ReplicaConfiguration_PopAll_DEFAULT bool = false
View Source 
var ReplicaConfiguration_Primary_DEFAULT *base.RPCAddress
View Source 
var ReplicaConfiguration_SplitSyncToChild_DEFAULT bool = false
View Source 
var ReplicaInfo_Pid_DEFAULT *base.Gpid
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 UpdateChildGroupPartitionCountRequest_ChildPid_DEFAULT *base.Gpid
View Source 
var UpdateChildGroupPartitionCountRequest_HpTarget_DEFAULT *base.HostPort
View Source 
var UpdateChildGroupPartitionCountRequest_Target_DEFAULT *base.RPCAddress
View Source 
var UpdateChildGroupPartitionCountResponse_Err_DEFAULT *base.ErrorCode

Functions

This section is empty.

Types

type AdminClient 

type AdminClient interface {
	// Parameters:
	//  - Req
	CreateApp(ctx context.Context, req *ConfigurationCreateAppRequest) (r *ConfigurationCreateAppResponse, err error)
	// Parameters:
	//  - Req
	DropApp(ctx context.Context, req *ConfigurationDropAppRequest) (r *ConfigurationDropAppResponse, err error)
	// Parameters:
	//  - Req
	RecallApp(ctx context.Context, req *ConfigurationRecallAppRequest) (r *ConfigurationRecallAppResponse, err error)
	// Parameters:
	//  - Req
	ListApps(ctx context.Context, req *ConfigurationListAppsRequest) (r *ConfigurationListAppsResponse, 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 *ConfigurationUpdateAppEnvRequest) (r *ConfigurationUpdateAppEnvResponse, err error)
	// Parameters:
	//  - Req
	ListNodes(ctx context.Context, req *ConfigurationListNodesRequest) (r *ConfigurationListNodesResponse, err error)
	// Parameters:
	//  - Req
	QueryClusterInfo(ctx context.Context, req *ConfigurationClusterInfoRequest) (r *ConfigurationClusterInfoResponse, err error)
	// Parameters:
	//  - Req
	MetaControl(ctx context.Context, req *ConfigurationMetaControlRequest) (r *ConfigurationMetaControlResponse, err error)
	// Parameters:
	//  - Req
	QueryBackupPolicy(ctx context.Context, req *ConfigurationQueryBackupPolicyRequest) (r *ConfigurationQueryBackupPolicyResponse, err error)
	// Parameters:
	//  - Req
	Balance(ctx context.Context, req *ConfigurationBalancerRequest) (r *ConfigurationBalancerResponse, 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 *ConfigurationRestoreRequest) (r *ConfigurationCreateAppResponse, 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 *ConfigurationBalancerRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientBalanceArgs 

func NewAdminClientBalanceArgs() *AdminClientBalanceArgs

func (*AdminClientBalanceArgs) GetReq 

func (p *AdminClientBalanceArgs) GetReq() *ConfigurationBalancerRequest

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 *ConfigurationBalancerResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientBalanceResult 

func NewAdminClientBalanceResult() *AdminClientBalanceResult

func (*AdminClientBalanceResult) GetSuccess 

func (p *AdminClientBalanceResult) GetSuccess() *ConfigurationBalancerResponse

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 *ConfigurationBalancerRequest) (r *ConfigurationBalancerResponse, 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 *ConfigurationCreateAppRequest) (r *ConfigurationCreateAppResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) DropApp 

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

Parameters:

  • Req

func (*AdminClientClient) ListApps 

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

Parameters:

  • Req

func (*AdminClientClient) ListNodes 

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

Parameters:

  • Req

func (*AdminClientClient) MetaControl 

func (p *AdminClientClient) MetaControl(ctx context.Context, req *ConfigurationMetaControlRequest) (r *ConfigurationMetaControlResponse, 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 *ConfigurationQueryBackupPolicyRequest) (r *ConfigurationQueryBackupPolicyResponse, 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 *ConfigurationClusterInfoRequest) (r *ConfigurationClusterInfoResponse, 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 *ConfigurationRecallAppRequest) (r *ConfigurationRecallAppResponse, err error)

Parameters:

  • Req

func (*AdminClientClient) RestoreApp 

func (p *AdminClientClient) RestoreApp(ctx context.Context, req *ConfigurationRestoreRequest) (r *ConfigurationCreateAppResponse, 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 *ConfigurationUpdateAppEnvRequest) (r *ConfigurationUpdateAppEnvResponse, 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 *ConfigurationCreateAppRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientCreateAppArgs 

func NewAdminClientCreateAppArgs() *AdminClientCreateAppArgs

func (*AdminClientCreateAppArgs) GetReq 

func (p *AdminClientCreateAppArgs) GetReq() *ConfigurationCreateAppRequest

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 *ConfigurationCreateAppResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientCreateAppResult 

func NewAdminClientCreateAppResult() *AdminClientCreateAppResult

func (*AdminClientCreateAppResult) GetSuccess 

func (p *AdminClientCreateAppResult) GetSuccess() *ConfigurationCreateAppResponse

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 *ConfigurationDropAppRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientDropAppArgs 

func NewAdminClientDropAppArgs() *AdminClientDropAppArgs

func (*AdminClientDropAppArgs) GetReq 

func (p *AdminClientDropAppArgs) GetReq() *ConfigurationDropAppRequest

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 *ConfigurationDropAppResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientDropAppResult 

func NewAdminClientDropAppResult() *AdminClientDropAppResult

func (*AdminClientDropAppResult) GetSuccess 

func (p *AdminClientDropAppResult) GetSuccess() *ConfigurationDropAppResponse

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 *ConfigurationListAppsRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientListAppsArgs 

func NewAdminClientListAppsArgs() *AdminClientListAppsArgs

func (*AdminClientListAppsArgs) GetReq 

func (p *AdminClientListAppsArgs) GetReq() *ConfigurationListAppsRequest

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 *ConfigurationListAppsResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientListAppsResult 

func NewAdminClientListAppsResult() *AdminClientListAppsResult

func (*AdminClientListAppsResult) GetSuccess 

func (p *AdminClientListAppsResult) GetSuccess() *ConfigurationListAppsResponse

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 *ConfigurationListNodesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientListNodesArgs 

func NewAdminClientListNodesArgs() *AdminClientListNodesArgs

func (*AdminClientListNodesArgs) GetReq 

func (p *AdminClientListNodesArgs) GetReq() *ConfigurationListNodesRequest

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 *ConfigurationListNodesResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientListNodesResult 

func NewAdminClientListNodesResult() *AdminClientListNodesResult

func (*AdminClientListNodesResult) GetSuccess 

func (p *AdminClientListNodesResult) GetSuccess() *ConfigurationListNodesResponse

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 *ConfigurationMetaControlRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientMetaControlArgs 

func NewAdminClientMetaControlArgs() *AdminClientMetaControlArgs

func (*AdminClientMetaControlArgs) GetReq 

func (p *AdminClientMetaControlArgs) GetReq() *ConfigurationMetaControlRequest

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 *ConfigurationMetaControlResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientMetaControlResult 

func NewAdminClientMetaControlResult() *AdminClientMetaControlResult

func (*AdminClientMetaControlResult) GetSuccess 

func (p *AdminClientMetaControlResult) GetSuccess() *ConfigurationMetaControlResponse

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 *ConfigurationQueryBackupPolicyRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientQueryBackupPolicyArgs 

func NewAdminClientQueryBackupPolicyArgs() *AdminClientQueryBackupPolicyArgs

func (*AdminClientQueryBackupPolicyArgs) GetReq 

func (p *AdminClientQueryBackupPolicyArgs) GetReq() *ConfigurationQueryBackupPolicyRequest

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 *ConfigurationQueryBackupPolicyResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientQueryBackupPolicyResult 

func NewAdminClientQueryBackupPolicyResult() *AdminClientQueryBackupPolicyResult

func (*AdminClientQueryBackupPolicyResult) GetSuccess 

func (p *AdminClientQueryBackupPolicyResult) GetSuccess() *ConfigurationQueryBackupPolicyResponse

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 *ConfigurationClusterInfoRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientQueryClusterInfoArgs 

func NewAdminClientQueryClusterInfoArgs() *AdminClientQueryClusterInfoArgs

func (*AdminClientQueryClusterInfoArgs) GetReq 

func (p *AdminClientQueryClusterInfoArgs) GetReq() *ConfigurationClusterInfoRequest

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 *ConfigurationClusterInfoResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientQueryClusterInfoResult 

func NewAdminClientQueryClusterInfoResult() *AdminClientQueryClusterInfoResult

func (*AdminClientQueryClusterInfoResult) GetSuccess 

func (p *AdminClientQueryClusterInfoResult) GetSuccess() *ConfigurationClusterInfoResponse

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 *ConfigurationRecallAppRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientRecallAppArgs 

func NewAdminClientRecallAppArgs() *AdminClientRecallAppArgs

func (*AdminClientRecallAppArgs) GetReq 

func (p *AdminClientRecallAppArgs) GetReq() *ConfigurationRecallAppRequest

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 *ConfigurationRecallAppResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientRecallAppResult 

func NewAdminClientRecallAppResult() *AdminClientRecallAppResult

func (*AdminClientRecallAppResult) GetSuccess 

func (p *AdminClientRecallAppResult) GetSuccess() *ConfigurationRecallAppResponse

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 *ConfigurationRestoreRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientRestoreAppArgs 

func NewAdminClientRestoreAppArgs() *AdminClientRestoreAppArgs

func (*AdminClientRestoreAppArgs) GetReq 

func (p *AdminClientRestoreAppArgs) GetReq() *ConfigurationRestoreRequest

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 *ConfigurationCreateAppResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientRestoreAppResult 

func NewAdminClientRestoreAppResult() *AdminClientRestoreAppResult

func (*AdminClientRestoreAppResult) GetSuccess 

func (p *AdminClientRestoreAppResult) GetSuccess() *ConfigurationCreateAppResponse

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 *ConfigurationUpdateAppEnvRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewAdminClientUpdateAppEnvArgs 

func NewAdminClientUpdateAppEnvArgs() *AdminClientUpdateAppEnvArgs

func (*AdminClientUpdateAppEnvArgs) GetReq 

func (p *AdminClientUpdateAppEnvArgs) GetReq() *ConfigurationUpdateAppEnvRequest

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 *ConfigurationUpdateAppEnvResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewAdminClientUpdateAppEnvResult 

func NewAdminClientUpdateAppEnvResult() *AdminClientUpdateAppEnvResult

func (*AdminClientUpdateAppEnvResult) GetSuccess 

func (p *AdminClientUpdateAppEnvResult) GetSuccess() *ConfigurationUpdateAppEnvResponse

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 BackupClearRequest 

type BackupClearRequest struct {
	Pid        *base.Gpid `thrift:"pid,1" db:"pid" json:"pid"`
	PolicyName string     `thrift:"policy_name,2" db:"policy_name" json:"policy_name"`
}

Attributes:

  • Pid
  • PolicyName

func NewBackupClearRequest 

func NewBackupClearRequest() *BackupClearRequest

func (*BackupClearRequest) GetPid 

func (p *BackupClearRequest) GetPid() *base.Gpid

func (*BackupClearRequest) GetPolicyName 

func (p *BackupClearRequest) GetPolicyName() string

func (*BackupClearRequest) IsSetPid 

func (p *BackupClearRequest) IsSetPid() bool

func (*BackupClearRequest) Read 

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

func (*BackupClearRequest) ReadField1 

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

func (*BackupClearRequest) ReadField2 

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

func (*BackupClearRequest) String 

func (p *BackupClearRequest) String() string

func (*BackupClearRequest) Write 

func (p *BackupClearRequest) Write(oprot thrift.TProtocol) 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 BackupRequest 

type BackupRequest struct {
	Pid        *base.Gpid  `thrift:"pid,1" db:"pid" json:"pid"`
	Policy     *PolicyInfo `thrift:"policy,2" db:"policy" json:"policy"`
	AppName    string      `thrift:"app_name,3" db:"app_name" json:"app_name"`
	BackupID   int64       `thrift:"backup_id,4" db:"backup_id" json:"backup_id"`
	BackupPath *string     `thrift:"backup_path,5" db:"backup_path" json:"backup_path,omitempty"`
}

Attributes:

  • Pid
  • Policy
  • AppName
  • BackupID
  • BackupPath

func NewBackupRequest 

func NewBackupRequest() *BackupRequest

func (*BackupRequest) GetAppName 

func (p *BackupRequest) GetAppName() string

func (*BackupRequest) GetBackupID 

func (p *BackupRequest) GetBackupID() int64

func (*BackupRequest) GetBackupPath 

func (p *BackupRequest) GetBackupPath() string

func (*BackupRequest) GetPid 

func (p *BackupRequest) GetPid() *base.Gpid

func (*BackupRequest) GetPolicy 

func (p *BackupRequest) GetPolicy() *PolicyInfo

func (*BackupRequest) IsSetBackupPath 

func (p *BackupRequest) IsSetBackupPath() bool

func (*BackupRequest) IsSetPid 

func (p *BackupRequest) IsSetPid() bool

func (*BackupRequest) IsSetPolicy 

func (p *BackupRequest) IsSetPolicy() bool

func (*BackupRequest) Read 

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

func (*BackupRequest) ReadField1 

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

func (*BackupRequest) ReadField2 

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

func (*BackupRequest) ReadField3 

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

func (*BackupRequest) ReadField4 

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

func (*BackupRequest) ReadField5 

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

func (*BackupRequest) String 

func (p *BackupRequest) String() string

func (*BackupRequest) Write 

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

type BackupResponse 

type BackupResponse struct {
	Err                 *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	Pid                 *base.Gpid      `thrift:"pid,2" db:"pid" json:"pid"`
	Progress            int32           `thrift:"progress,3" db:"progress" json:"progress"`
	PolicyName          string          `thrift:"policy_name,4" db:"policy_name" json:"policy_name"`
	BackupID            int64           `thrift:"backup_id,5" db:"backup_id" json:"backup_id"`
	CheckpointTotalSize int64           `thrift:"checkpoint_total_size,6" db:"checkpoint_total_size" json:"checkpoint_total_size"`
}

Attributes:

  • Err
  • Pid
  • Progress
  • PolicyName
  • BackupID
  • CheckpointTotalSize

func NewBackupResponse 

func NewBackupResponse() *BackupResponse

func (*BackupResponse) GetBackupID 

func (p *BackupResponse) GetBackupID() int64

func (*BackupResponse) GetCheckpointTotalSize 

func (p *BackupResponse) GetCheckpointTotalSize() int64

func (*BackupResponse) GetErr 

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

func (*BackupResponse) GetPid 

func (p *BackupResponse) GetPid() *base.Gpid

func (*BackupResponse) GetPolicyName 

func (p *BackupResponse) GetPolicyName() string

func (*BackupResponse) GetProgress 

func (p *BackupResponse) GetProgress() int32

func (*BackupResponse) IsSetErr 

func (p *BackupResponse) IsSetErr() bool

func (*BackupResponse) IsSetPid 

func (p *BackupResponse) IsSetPid() bool

func (*BackupResponse) Read 

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

func (*BackupResponse) ReadField1 

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

func (*BackupResponse) ReadField2 

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

func (*BackupResponse) ReadField3 

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

func (*BackupResponse) ReadField4 

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

func (*BackupResponse) ReadField5 

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

func (*BackupResponse) ReadField6 

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

func (*BackupResponse) String 

func (p *BackupResponse) String() string

func (*BackupResponse) Write 

func (p *BackupResponse) 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 ConfigurationBalancerRequest_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 BulkLoadMetadata 

type BulkLoadMetadata struct {
	Files         []*FileMeta `thrift:"files,1" db:"files" json:"files"`
	FileTotalSize int64       `thrift:"file_total_size,2" db:"file_total_size" json:"file_total_size"`
}

Attributes:

  • Files
  • FileTotalSize
var BulkLoadResponse_Metadata_DEFAULT *BulkLoadMetadata
var IngestionRequest_Metadata_DEFAULT *BulkLoadMetadata

func NewBulkLoadMetadata 

func NewBulkLoadMetadata() *BulkLoadMetadata

func (*BulkLoadMetadata) GetFileTotalSize 

func (p *BulkLoadMetadata) GetFileTotalSize() int64

func (*BulkLoadMetadata) GetFiles 

func (p *BulkLoadMetadata) GetFiles() []*FileMeta

func (*BulkLoadMetadata) Read 

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

func (*BulkLoadMetadata) ReadField1 

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

func (*BulkLoadMetadata) ReadField2 

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

func (*BulkLoadMetadata) String 

func (p *BulkLoadMetadata) String() string

func (*BulkLoadMetadata) Write 

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

type BulkLoadRequest 

type BulkLoadRequest struct {
	Pid                   *base.Gpid       `thrift:"pid,1" db:"pid" json:"pid"`
	AppName               string           `thrift:"app_name,2" db:"app_name" json:"app_name"`
	Primary               *base.RPCAddress `thrift:"primary,3" db:"primary" json:"primary"`
	RemoteProviderName    string           `thrift:"remote_provider_name,4" db:"remote_provider_name" json:"remote_provider_name"`
	ClusterName           string           `thrift:"cluster_name,5" db:"cluster_name" json:"cluster_name"`
	Ballot                int64            `thrift:"ballot,6" db:"ballot" json:"ballot"`
	MetaBulkLoadStatus    BulkLoadStatus   `thrift:"meta_bulk_load_status,7" db:"meta_bulk_load_status" json:"meta_bulk_load_status"`
	QueryBulkLoadMetadata bool             `thrift:"query_bulk_load_metadata,8" db:"query_bulk_load_metadata" json:"query_bulk_load_metadata"`
	RemoteRootPath        string           `thrift:"remote_root_path,9" db:"remote_root_path" json:"remote_root_path"`
	HpPrimary             *base.HostPort   `thrift:"hp_primary,10" db:"hp_primary" json:"hp_primary,omitempty"`
}

Attributes:

  • Pid
  • AppName
  • Primary
  • RemoteProviderName
  • ClusterName
  • Ballot
  • MetaBulkLoadStatus
  • QueryBulkLoadMetadata
  • RemoteRootPath
  • HpPrimary

func NewBulkLoadRequest 

func NewBulkLoadRequest() *BulkLoadRequest

func (*BulkLoadRequest) GetAppName 

func (p *BulkLoadRequest) GetAppName() string

func (*BulkLoadRequest) GetBallot 

func (p *BulkLoadRequest) GetBallot() int64

func (*BulkLoadRequest) GetClusterName 

func (p *BulkLoadRequest) GetClusterName() string

func (*BulkLoadRequest) GetHpPrimary 

func (p *BulkLoadRequest) GetHpPrimary() *base.HostPort

func (*BulkLoadRequest) GetMetaBulkLoadStatus 

func (p *BulkLoadRequest) GetMetaBulkLoadStatus() BulkLoadStatus

func (*BulkLoadRequest) GetPid 

func (p *BulkLoadRequest) GetPid() *base.Gpid

func (*BulkLoadRequest) GetPrimary 

func (p *BulkLoadRequest) GetPrimary() *base.RPCAddress

func (*BulkLoadRequest) GetQueryBulkLoadMetadata 

func (p *BulkLoadRequest) GetQueryBulkLoadMetadata() bool

func (*BulkLoadRequest) GetRemoteProviderName 

func (p *BulkLoadRequest) GetRemoteProviderName() string

func (*BulkLoadRequest) GetRemoteRootPath 

func (p *BulkLoadRequest) GetRemoteRootPath() string

func (*BulkLoadRequest) IsSetHpPrimary 

func (p *BulkLoadRequest) IsSetHpPrimary() bool

func (*BulkLoadRequest) IsSetPid 

func (p *BulkLoadRequest) IsSetPid() bool

func (*BulkLoadRequest) IsSetPrimary 

func (p *BulkLoadRequest) IsSetPrimary() bool

func (*BulkLoadRequest) Read 

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

func (*BulkLoadRequest) ReadField1 

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

func (*BulkLoadRequest) ReadField10 

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

func (*BulkLoadRequest) ReadField2 

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

func (*BulkLoadRequest) ReadField3 

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

func (*BulkLoadRequest) ReadField4 

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

func (*BulkLoadRequest) ReadField5 

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

func (*BulkLoadRequest) ReadField6 

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

func (*BulkLoadRequest) ReadField7 

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

func (*BulkLoadRequest) ReadField8 

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

func (*BulkLoadRequest) ReadField9 

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

func (*BulkLoadRequest) String 

func (p *BulkLoadRequest) String() string

func (*BulkLoadRequest) Write 

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

type BulkLoadResponse 

type BulkLoadResponse struct {
	Err                             *base.ErrorCode                              `thrift:"err,1" db:"err" json:"err"`
	Pid                             *base.Gpid                                   `thrift:"pid,2" db:"pid" json:"pid"`
	AppName                         string                                       `thrift:"app_name,3" db:"app_name" json:"app_name"`
	PrimaryBulkLoadStatus           BulkLoadStatus                               `thrift:"primary_bulk_load_status,4" db:"primary_bulk_load_status" json:"primary_bulk_load_status"`
	GroupBulkLoadState              map[*base.RPCAddress]*PartitionBulkLoadState `thrift:"group_bulk_load_state,5" db:"group_bulk_load_state" json:"group_bulk_load_state"`
	Metadata                        *BulkLoadMetadata                            `thrift:"metadata,6" db:"metadata" json:"metadata,omitempty"`
	TotalDownloadProgress           *int32                                       `thrift:"total_download_progress,7" db:"total_download_progress" json:"total_download_progress,omitempty"`
	IsGroupIngestionFinished        *bool                                        `thrift:"is_group_ingestion_finished,8" db:"is_group_ingestion_finished" json:"is_group_ingestion_finished,omitempty"`
	IsGroupBulkLoadContextCleanedUp *bool                                        `` /* 146-byte string literal not displayed */
	IsGroupBulkLoadPaused           *bool                                        `thrift:"is_group_bulk_load_paused,10" db:"is_group_bulk_load_paused" json:"is_group_bulk_load_paused,omitempty"`
	HpGroupBulkLoadState            map[*base.HostPort]*PartitionBulkLoadState   `thrift:"hp_group_bulk_load_state,11" db:"hp_group_bulk_load_state" json:"hp_group_bulk_load_state,omitempty"`
}

Attributes:

  • Err
  • Pid
  • AppName
  • PrimaryBulkLoadStatus
  • GroupBulkLoadState
  • Metadata
  • TotalDownloadProgress
  • IsGroupIngestionFinished
  • IsGroupBulkLoadContextCleanedUp
  • IsGroupBulkLoadPaused
  • HpGroupBulkLoadState

func NewBulkLoadResponse 

func NewBulkLoadResponse() *BulkLoadResponse

func (*BulkLoadResponse) GetAppName 

func (p *BulkLoadResponse) GetAppName() string

func (*BulkLoadResponse) GetErr 

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

func (*BulkLoadResponse) GetGroupBulkLoadState 

func (p *BulkLoadResponse) GetGroupBulkLoadState() map[*base.RPCAddress]*PartitionBulkLoadState

func (*BulkLoadResponse) GetHpGroupBulkLoadState 

func (p *BulkLoadResponse) GetHpGroupBulkLoadState() map[*base.HostPort]*PartitionBulkLoadState

func (*BulkLoadResponse) GetIsGroupBulkLoadContextCleanedUp 

func (p *BulkLoadResponse) GetIsGroupBulkLoadContextCleanedUp() bool

func (*BulkLoadResponse) GetIsGroupBulkLoadPaused 

func (p *BulkLoadResponse) GetIsGroupBulkLoadPaused() bool

func (*BulkLoadResponse) GetIsGroupIngestionFinished 

func (p *BulkLoadResponse) GetIsGroupIngestionFinished() bool

func (*BulkLoadResponse) GetMetadata 

func (p *BulkLoadResponse) GetMetadata() *BulkLoadMetadata

func (*BulkLoadResponse) GetPid 

func (p *BulkLoadResponse) GetPid() *base.Gpid

func (*BulkLoadResponse) GetPrimaryBulkLoadStatus 

func (p *BulkLoadResponse) GetPrimaryBulkLoadStatus() BulkLoadStatus

func (*BulkLoadResponse) GetTotalDownloadProgress 

func (p *BulkLoadResponse) GetTotalDownloadProgress() int32

func (*BulkLoadResponse) IsSetErr 

func (p *BulkLoadResponse) IsSetErr() bool

func (*BulkLoadResponse) IsSetHpGroupBulkLoadState 

func (p *BulkLoadResponse) IsSetHpGroupBulkLoadState() bool

func (*BulkLoadResponse) IsSetIsGroupBulkLoadContextCleanedUp 

func (p *BulkLoadResponse) IsSetIsGroupBulkLoadContextCleanedUp() bool

func (*BulkLoadResponse) IsSetIsGroupBulkLoadPaused 

func (p *BulkLoadResponse) IsSetIsGroupBulkLoadPaused() bool

func (*BulkLoadResponse) IsSetIsGroupIngestionFinished 

func (p *BulkLoadResponse) IsSetIsGroupIngestionFinished() bool

func (*BulkLoadResponse) IsSetMetadata 

func (p *BulkLoadResponse) IsSetMetadata() bool

func (*BulkLoadResponse) IsSetPid 

func (p *BulkLoadResponse) IsSetPid() bool

func (*BulkLoadResponse) IsSetTotalDownloadProgress 

func (p *BulkLoadResponse) IsSetTotalDownloadProgress() bool

func (*BulkLoadResponse) Read 

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

func (*BulkLoadResponse) ReadField1 

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

func (*BulkLoadResponse) ReadField10 

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

func (*BulkLoadResponse) ReadField11 

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

func (*BulkLoadResponse) ReadField2 

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

func (*BulkLoadResponse) ReadField3 

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

func (*BulkLoadResponse) ReadField4 

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

func (*BulkLoadResponse) ReadField5 

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

func (*BulkLoadResponse) ReadField6 

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

func (*BulkLoadResponse) ReadField7 

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

func (*BulkLoadResponse) ReadField8 

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

func (*BulkLoadResponse) ReadField9 

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

func (*BulkLoadResponse) String 

func (p *BulkLoadResponse) String() string

func (*BulkLoadResponse) Write 

func (p *BulkLoadResponse) Write(oprot thrift.TProtocol) 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 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 ConfigurationAddBackupPolicyRequest 

type ConfigurationAddBackupPolicyRequest struct {
	BackupProviderType       string  `thrift:"backup_provider_type,1" db:"backup_provider_type" json:"backup_provider_type"`
	PolicyName               string  `thrift:"policy_name,2" db:"policy_name" json:"policy_name"`
	AppIds                   []int32 `thrift:"app_ids,3" db:"app_ids" json:"app_ids"`
	BackupIntervalSeconds    int64   `thrift:"backup_interval_seconds,4" db:"backup_interval_seconds" json:"backup_interval_seconds"`
	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"`
}

Attributes:

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

func NewConfigurationAddBackupPolicyRequest 

func NewConfigurationAddBackupPolicyRequest() *ConfigurationAddBackupPolicyRequest

func (*ConfigurationAddBackupPolicyRequest) GetAppIds 

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

func (*ConfigurationAddBackupPolicyRequest) GetBackupHistoryCountToKeep 

func (p *ConfigurationAddBackupPolicyRequest) GetBackupHistoryCountToKeep() int32

func (*ConfigurationAddBackupPolicyRequest) GetBackupIntervalSeconds 

func (p *ConfigurationAddBackupPolicyRequest) GetBackupIntervalSeconds() int64

func (*ConfigurationAddBackupPolicyRequest) GetBackupProviderType 

func (p *ConfigurationAddBackupPolicyRequest) GetBackupProviderType() string

func (*ConfigurationAddBackupPolicyRequest) GetPolicyName 

func (p *ConfigurationAddBackupPolicyRequest) GetPolicyName() string

func (*ConfigurationAddBackupPolicyRequest) GetStartTime 

func (p *ConfigurationAddBackupPolicyRequest) GetStartTime() string

func (*ConfigurationAddBackupPolicyRequest) Read 

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

func (*ConfigurationAddBackupPolicyRequest) ReadField1 

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

func (*ConfigurationAddBackupPolicyRequest) ReadField2 

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

func (*ConfigurationAddBackupPolicyRequest) ReadField3 

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

func (*ConfigurationAddBackupPolicyRequest) ReadField4 

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

func (*ConfigurationAddBackupPolicyRequest) ReadField5 

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

func (*ConfigurationAddBackupPolicyRequest) ReadField6 

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

func (*ConfigurationAddBackupPolicyRequest) String 

func (p *ConfigurationAddBackupPolicyRequest) String() string

func (*ConfigurationAddBackupPolicyRequest) Write 

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

type ConfigurationAddBackupPolicyResponse 

type ConfigurationAddBackupPolicyResponse 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

func NewConfigurationAddBackupPolicyResponse 

func NewConfigurationAddBackupPolicyResponse() *ConfigurationAddBackupPolicyResponse

func (*ConfigurationAddBackupPolicyResponse) GetErr 

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

func (*ConfigurationAddBackupPolicyResponse) GetHintMessage 

func (p *ConfigurationAddBackupPolicyResponse) GetHintMessage() string

func (*ConfigurationAddBackupPolicyResponse) IsSetErr 

func (p *ConfigurationAddBackupPolicyResponse) IsSetErr() bool

func (*ConfigurationAddBackupPolicyResponse) Read 

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

func (*ConfigurationAddBackupPolicyResponse) ReadField1 

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

func (*ConfigurationAddBackupPolicyResponse) ReadField2 

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

func (*ConfigurationAddBackupPolicyResponse) String 

func (p *ConfigurationAddBackupPolicyResponse) String() string

func (*ConfigurationAddBackupPolicyResponse) Write 

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

type ConfigurationBalancerRequest 

type ConfigurationBalancerRequest 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 *ConfigurationBalancerRequest

func NewConfigurationBalancerRequest 

func NewConfigurationBalancerRequest() *ConfigurationBalancerRequest

func (*ConfigurationBalancerRequest) GetActionList 

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

func (*ConfigurationBalancerRequest) GetBalanceType 

func (p *ConfigurationBalancerRequest) GetBalanceType() BalancerRequestType

func (*ConfigurationBalancerRequest) GetForce 

func (p *ConfigurationBalancerRequest) GetForce() bool

func (*ConfigurationBalancerRequest) GetGpid 

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

func (*ConfigurationBalancerRequest) IsSetBalanceType 

func (p *ConfigurationBalancerRequest) IsSetBalanceType() bool

func (*ConfigurationBalancerRequest) IsSetForce 

func (p *ConfigurationBalancerRequest) IsSetForce() bool

func (*ConfigurationBalancerRequest) IsSetGpid 

func (p *ConfigurationBalancerRequest) IsSetGpid() bool

func (*ConfigurationBalancerRequest) Read 

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

func (*ConfigurationBalancerRequest) ReadField1 

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

func (*ConfigurationBalancerRequest) ReadField2 

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

func (*ConfigurationBalancerRequest) ReadField3 

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

func (*ConfigurationBalancerRequest) ReadField4 

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

func (*ConfigurationBalancerRequest) String 

func (p *ConfigurationBalancerRequest) String() string

func (*ConfigurationBalancerRequest) Write 

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

type ConfigurationBalancerResponse 

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

Attributes:

  • Err
var AdminClientBalanceResult_Success_DEFAULT *ConfigurationBalancerResponse

func NewConfigurationBalancerResponse 

func NewConfigurationBalancerResponse() *ConfigurationBalancerResponse

func (*ConfigurationBalancerResponse) GetErr 

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

func (*ConfigurationBalancerResponse) IsSetErr 

func (p *ConfigurationBalancerResponse) IsSetErr() bool

func (*ConfigurationBalancerResponse) Read 

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

func (*ConfigurationBalancerResponse) ReadField1 

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

func (*ConfigurationBalancerResponse) String 

func (p *ConfigurationBalancerResponse) String() string

func (*ConfigurationBalancerResponse) Write 

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

type ConfigurationClusterInfoRequest 

type ConfigurationClusterInfoRequest struct {
}
var AdminClientQueryClusterInfoArgs_Req_DEFAULT *ConfigurationClusterInfoRequest

func NewConfigurationClusterInfoRequest 

func NewConfigurationClusterInfoRequest() *ConfigurationClusterInfoRequest

func (*ConfigurationClusterInfoRequest) Read 

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

func (*ConfigurationClusterInfoRequest) String 

func (p *ConfigurationClusterInfoRequest) String() string

func (*ConfigurationClusterInfoRequest) Write 

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

type ConfigurationClusterInfoResponse 

type ConfigurationClusterInfoResponse 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 *ConfigurationClusterInfoResponse

func NewConfigurationClusterInfoResponse 

func NewConfigurationClusterInfoResponse() *ConfigurationClusterInfoResponse

func (*ConfigurationClusterInfoResponse) GetErr 

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

func (*ConfigurationClusterInfoResponse) GetKeys 

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

func (*ConfigurationClusterInfoResponse) GetValues 

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

func (*ConfigurationClusterInfoResponse) IsSetErr 

func (p *ConfigurationClusterInfoResponse) IsSetErr() bool

func (*ConfigurationClusterInfoResponse) Read 

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

func (*ConfigurationClusterInfoResponse) ReadField1 

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

func (*ConfigurationClusterInfoResponse) ReadField2 

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

func (*ConfigurationClusterInfoResponse) ReadField3 

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

func (*ConfigurationClusterInfoResponse) String 

func (p *ConfigurationClusterInfoResponse) String() string

func (*ConfigurationClusterInfoResponse) Write 

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

type ConfigurationCreateAppRequest 

type ConfigurationCreateAppRequest 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 *ConfigurationCreateAppRequest

func NewConfigurationCreateAppRequest 

func NewConfigurationCreateAppRequest() *ConfigurationCreateAppRequest

func (*ConfigurationCreateAppRequest) GetAppName 

func (p *ConfigurationCreateAppRequest) GetAppName() string

func (*ConfigurationCreateAppRequest) GetOptions 

func (p *ConfigurationCreateAppRequest) GetOptions() *CreateAppOptions

func (*ConfigurationCreateAppRequest) IsSetOptions 

func (p *ConfigurationCreateAppRequest) IsSetOptions() bool

func (*ConfigurationCreateAppRequest) Read 

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

func (*ConfigurationCreateAppRequest) ReadField1 

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

func (*ConfigurationCreateAppRequest) ReadField2 

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

func (*ConfigurationCreateAppRequest) String 

func (p *ConfigurationCreateAppRequest) String() string

func (*ConfigurationCreateAppRequest) Write 

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

type ConfigurationCreateAppResponse 

type ConfigurationCreateAppResponse 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 *ConfigurationCreateAppResponse
var AdminClientRestoreAppResult_Success_DEFAULT *ConfigurationCreateAppResponse

func NewConfigurationCreateAppResponse 

func NewConfigurationCreateAppResponse() *ConfigurationCreateAppResponse

func (*ConfigurationCreateAppResponse) GetAppid 

func (p *ConfigurationCreateAppResponse) GetAppid() int32

func (*ConfigurationCreateAppResponse) GetErr 

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

func (*ConfigurationCreateAppResponse) IsSetErr 

func (p *ConfigurationCreateAppResponse) IsSetErr() bool

func (*ConfigurationCreateAppResponse) Read 

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

func (*ConfigurationCreateAppResponse) ReadField1 

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

func (*ConfigurationCreateAppResponse) ReadField2 

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

func (*ConfigurationCreateAppResponse) String 

func (p *ConfigurationCreateAppResponse) String() string

func (*ConfigurationCreateAppResponse) Write 

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

type ConfigurationDropAppRequest 

type ConfigurationDropAppRequest 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 *ConfigurationDropAppRequest

func NewConfigurationDropAppRequest 

func NewConfigurationDropAppRequest() *ConfigurationDropAppRequest

func (*ConfigurationDropAppRequest) GetAppName 

func (p *ConfigurationDropAppRequest) GetAppName() string

func (*ConfigurationDropAppRequest) GetOptions 

func (p *ConfigurationDropAppRequest) GetOptions() *DropAppOptions

func (*ConfigurationDropAppRequest) IsSetOptions 

func (p *ConfigurationDropAppRequest) IsSetOptions() bool

func (*ConfigurationDropAppRequest) Read 

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

func (*ConfigurationDropAppRequest) ReadField1 

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

func (*ConfigurationDropAppRequest) ReadField2 

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

func (*ConfigurationDropAppRequest) String 

func (p *ConfigurationDropAppRequest) String() string

func (*ConfigurationDropAppRequest) Write 

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

type ConfigurationDropAppResponse 

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

Attributes:

  • Err
var AdminClientDropAppResult_Success_DEFAULT *ConfigurationDropAppResponse

func NewConfigurationDropAppResponse 

func NewConfigurationDropAppResponse() *ConfigurationDropAppResponse

func (*ConfigurationDropAppResponse) GetErr 

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

func (*ConfigurationDropAppResponse) IsSetErr 

func (p *ConfigurationDropAppResponse) IsSetErr() bool

func (*ConfigurationDropAppResponse) Read 

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

func (*ConfigurationDropAppResponse) ReadField1 

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

func (*ConfigurationDropAppResponse) String 

func (p *ConfigurationDropAppResponse) String() string

func (*ConfigurationDropAppResponse) Write 

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

type ConfigurationGetMaxReplicaCountRequest 

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

Attributes:

  • AppName

func NewConfigurationGetMaxReplicaCountRequest 

func NewConfigurationGetMaxReplicaCountRequest() *ConfigurationGetMaxReplicaCountRequest

func (*ConfigurationGetMaxReplicaCountRequest) GetAppName 

func (p *ConfigurationGetMaxReplicaCountRequest) GetAppName() string

func (*ConfigurationGetMaxReplicaCountRequest) Read 

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

func (*ConfigurationGetMaxReplicaCountRequest) ReadField1 

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

func (*ConfigurationGetMaxReplicaCountRequest) String 

func (p *ConfigurationGetMaxReplicaCountRequest) String() string

func (*ConfigurationGetMaxReplicaCountRequest) Write 

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

type ConfigurationGetMaxReplicaCountResponse 

type ConfigurationGetMaxReplicaCountResponse struct {
	Err             *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	MaxReplicaCount int32           `thrift:"max_replica_count,2" db:"max_replica_count" json:"max_replica_count"`
	HintMessage     string          `thrift:"hint_message,3" db:"hint_message" json:"hint_message"`
}

Attributes:

  • Err
  • MaxReplicaCount
  • HintMessage

func NewConfigurationGetMaxReplicaCountResponse 

func NewConfigurationGetMaxReplicaCountResponse() *ConfigurationGetMaxReplicaCountResponse

func (*ConfigurationGetMaxReplicaCountResponse) GetErr 

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

func (*ConfigurationGetMaxReplicaCountResponse) GetHintMessage 

func (p *ConfigurationGetMaxReplicaCountResponse) GetHintMessage() string

func (*ConfigurationGetMaxReplicaCountResponse) GetMaxReplicaCount 

func (p *ConfigurationGetMaxReplicaCountResponse) GetMaxReplicaCount() int32

func (*ConfigurationGetMaxReplicaCountResponse) IsSetErr 

func (p *ConfigurationGetMaxReplicaCountResponse) IsSetErr() bool

func (*ConfigurationGetMaxReplicaCountResponse) Read 

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

func (*ConfigurationGetMaxReplicaCountResponse) ReadField1 

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

func (*ConfigurationGetMaxReplicaCountResponse) ReadField2 

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

func (*ConfigurationGetMaxReplicaCountResponse) ReadField3 

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

func (*ConfigurationGetMaxReplicaCountResponse) String 

func (p *ConfigurationGetMaxReplicaCountResponse) String() string

func (*ConfigurationGetMaxReplicaCountResponse) Write 

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

type ConfigurationListAppsRequest 

type ConfigurationListAppsRequest struct {
	Status replication.AppStatus `thrift:"status,1" db:"status" json:"status"`
}

Attributes:

  • Status
var AdminClientListAppsArgs_Req_DEFAULT *ConfigurationListAppsRequest

func NewConfigurationListAppsRequest 

func NewConfigurationListAppsRequest() *ConfigurationListAppsRequest

func (*ConfigurationListAppsRequest) GetStatus 

func (p *ConfigurationListAppsRequest) GetStatus() replication.AppStatus

func (*ConfigurationListAppsRequest) Read 

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

func (*ConfigurationListAppsRequest) ReadField1 

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

func (*ConfigurationListAppsRequest) String 

func (p *ConfigurationListAppsRequest) String() string

func (*ConfigurationListAppsRequest) Write 

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

type ConfigurationListAppsResponse 

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

Attributes:

  • Err
  • Infos
var AdminClientListAppsResult_Success_DEFAULT *ConfigurationListAppsResponse

func NewConfigurationListAppsResponse 

func NewConfigurationListAppsResponse() *ConfigurationListAppsResponse

func (*ConfigurationListAppsResponse) GetErr 

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

func (*ConfigurationListAppsResponse) GetInfos 

func (p *ConfigurationListAppsResponse) GetInfos() []*replication.AppInfo

func (*ConfigurationListAppsResponse) IsSetErr 

func (p *ConfigurationListAppsResponse) IsSetErr() bool

func (*ConfigurationListAppsResponse) Read 

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

func (*ConfigurationListAppsResponse) ReadField1 

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

func (*ConfigurationListAppsResponse) ReadField2 

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

func (*ConfigurationListAppsResponse) String 

func (p *ConfigurationListAppsResponse) String() string

func (*ConfigurationListAppsResponse) Write 

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

type ConfigurationListNodesRequest 

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

Attributes:

  • Status
var AdminClientListNodesArgs_Req_DEFAULT *ConfigurationListNodesRequest

func NewConfigurationListNodesRequest 

func NewConfigurationListNodesRequest() *ConfigurationListNodesRequest

func (*ConfigurationListNodesRequest) GetStatus 

func (p *ConfigurationListNodesRequest) GetStatus() NodeStatus

func (*ConfigurationListNodesRequest) Read 

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

func (*ConfigurationListNodesRequest) ReadField1 

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

func (*ConfigurationListNodesRequest) String 

func (p *ConfigurationListNodesRequest) String() string

func (*ConfigurationListNodesRequest) Write 

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

type ConfigurationListNodesResponse 

type ConfigurationListNodesResponse 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 *ConfigurationListNodesResponse

func NewConfigurationListNodesResponse 

func NewConfigurationListNodesResponse() *ConfigurationListNodesResponse

func (*ConfigurationListNodesResponse) GetErr 

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

func (*ConfigurationListNodesResponse) GetInfos 

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

func (*ConfigurationListNodesResponse) IsSetErr 

func (p *ConfigurationListNodesResponse) IsSetErr() bool

func (*ConfigurationListNodesResponse) Read 

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

func (*ConfigurationListNodesResponse) ReadField1 

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

func (*ConfigurationListNodesResponse) ReadField2 

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

func (*ConfigurationListNodesResponse) String 

func (p *ConfigurationListNodesResponse) String() string

func (*ConfigurationListNodesResponse) Write 

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

type ConfigurationMetaControlRequest 

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

Attributes:

  • Level
var AdminClientMetaControlArgs_Req_DEFAULT *ConfigurationMetaControlRequest

func NewConfigurationMetaControlRequest 

func NewConfigurationMetaControlRequest() *ConfigurationMetaControlRequest

func (*ConfigurationMetaControlRequest) GetLevel 

func (p *ConfigurationMetaControlRequest) GetLevel() MetaFunctionLevel

func (*ConfigurationMetaControlRequest) Read 

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

func (*ConfigurationMetaControlRequest) ReadField1 

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

func (*ConfigurationMetaControlRequest) String 

func (p *ConfigurationMetaControlRequest) String() string

func (*ConfigurationMetaControlRequest) Write 

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

type ConfigurationMetaControlResponse 

type ConfigurationMetaControlResponse 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 *ConfigurationMetaControlResponse

func NewConfigurationMetaControlResponse 

func NewConfigurationMetaControlResponse() *ConfigurationMetaControlResponse

func (*ConfigurationMetaControlResponse) GetErr 

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

func (*ConfigurationMetaControlResponse) GetOldLevel 

func (p *ConfigurationMetaControlResponse) GetOldLevel() MetaFunctionLevel

func (*ConfigurationMetaControlResponse) IsSetErr 

func (p *ConfigurationMetaControlResponse) IsSetErr() bool

func (*ConfigurationMetaControlResponse) Read 

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

func (*ConfigurationMetaControlResponse) ReadField1 

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

func (*ConfigurationMetaControlResponse) ReadField2 

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

func (*ConfigurationMetaControlResponse) String 

func (p *ConfigurationMetaControlResponse) String() string

func (*ConfigurationMetaControlResponse) Write 

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

type ConfigurationModifyBackupPolicyRequest 

type ConfigurationModifyBackupPolicyRequest struct {
	PolicyName               string  `thrift:"policy_name,1" db:"policy_name" json:"policy_name"`
	AddAppids                []int32 `thrift:"add_appids,2" db:"add_appids" json:"add_appids,omitempty"`
	RemovalAppids            []int32 `thrift:"removal_appids,3" db:"removal_appids" json:"removal_appids,omitempty"`
	NewBackupIntervalSec_    *int64  `thrift:"new_backup_interval_sec,4" db:"new_backup_interval_sec" json:"new_backup_interval_sec,omitempty"`
	BackupHistoryCountToKeep *int32  `thrift:"backup_history_count_to_keep,5" db:"backup_history_count_to_keep" json:"backup_history_count_to_keep,omitempty"`
	IsDisable                *bool   `thrift:"is_disable,6" db:"is_disable" json:"is_disable,omitempty"`
	StartTime                *string `thrift:"start_time,7" db:"start_time" json:"start_time,omitempty"`
}

Attributes:

  • PolicyName
  • AddAppids
  • RemovalAppids
  • NewBackupIntervalSec_
  • BackupHistoryCountToKeep
  • IsDisable
  • StartTime

func NewConfigurationModifyBackupPolicyRequest 

func NewConfigurationModifyBackupPolicyRequest() *ConfigurationModifyBackupPolicyRequest

func (*ConfigurationModifyBackupPolicyRequest) GetAddAppids 

func (p *ConfigurationModifyBackupPolicyRequest) GetAddAppids() []int32

func (*ConfigurationModifyBackupPolicyRequest) GetBackupHistoryCountToKeep 

func (p *ConfigurationModifyBackupPolicyRequest) GetBackupHistoryCountToKeep() int32

func (*ConfigurationModifyBackupPolicyRequest) GetIsDisable 

func (p *ConfigurationModifyBackupPolicyRequest) GetIsDisable() bool

func (*ConfigurationModifyBackupPolicyRequest) GetNewBackupIntervalSec_ 

func (p *ConfigurationModifyBackupPolicyRequest) GetNewBackupIntervalSec_() int64

func (*ConfigurationModifyBackupPolicyRequest) GetPolicyName 

func (p *ConfigurationModifyBackupPolicyRequest) GetPolicyName() string

func (*ConfigurationModifyBackupPolicyRequest) GetRemovalAppids 

func (p *ConfigurationModifyBackupPolicyRequest) GetRemovalAppids() []int32

func (*ConfigurationModifyBackupPolicyRequest) GetStartTime 

func (p *ConfigurationModifyBackupPolicyRequest) GetStartTime() string

func (*ConfigurationModifyBackupPolicyRequest) IsSetAddAppids 

func (p *ConfigurationModifyBackupPolicyRequest) IsSetAddAppids() bool

func (*ConfigurationModifyBackupPolicyRequest) IsSetBackupHistoryCountToKeep 

func (p *ConfigurationModifyBackupPolicyRequest) IsSetBackupHistoryCountToKeep() bool

func (*ConfigurationModifyBackupPolicyRequest) IsSetIsDisable 

func (p *ConfigurationModifyBackupPolicyRequest) IsSetIsDisable() bool

func (*ConfigurationModifyBackupPolicyRequest) IsSetNewBackupIntervalSec_ 

func (p *ConfigurationModifyBackupPolicyRequest) IsSetNewBackupIntervalSec_() bool

func (*ConfigurationModifyBackupPolicyRequest) IsSetRemovalAppids 

func (p *ConfigurationModifyBackupPolicyRequest) IsSetRemovalAppids() bool

func (*ConfigurationModifyBackupPolicyRequest) IsSetStartTime 

func (p *ConfigurationModifyBackupPolicyRequest) IsSetStartTime() bool

func (*ConfigurationModifyBackupPolicyRequest) Read 

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

func (*ConfigurationModifyBackupPolicyRequest) ReadField1 

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

func (*ConfigurationModifyBackupPolicyRequest) ReadField2 

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

func (*ConfigurationModifyBackupPolicyRequest) ReadField3 

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

func (*ConfigurationModifyBackupPolicyRequest) ReadField4 

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

func (*ConfigurationModifyBackupPolicyRequest) ReadField5 

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

func (*ConfigurationModifyBackupPolicyRequest) ReadField6 

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

func (*ConfigurationModifyBackupPolicyRequest) ReadField7 

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

func (*ConfigurationModifyBackupPolicyRequest) String 

func (p *ConfigurationModifyBackupPolicyRequest) String() string

func (*ConfigurationModifyBackupPolicyRequest) Write 

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

type ConfigurationModifyBackupPolicyResponse 

type ConfigurationModifyBackupPolicyResponse 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

func NewConfigurationModifyBackupPolicyResponse 

func NewConfigurationModifyBackupPolicyResponse() *ConfigurationModifyBackupPolicyResponse

func (*ConfigurationModifyBackupPolicyResponse) GetErr 

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

func (*ConfigurationModifyBackupPolicyResponse) GetHintMessage 

func (p *ConfigurationModifyBackupPolicyResponse) GetHintMessage() string

func (*ConfigurationModifyBackupPolicyResponse) IsSetErr 

func (p *ConfigurationModifyBackupPolicyResponse) IsSetErr() bool

func (*ConfigurationModifyBackupPolicyResponse) Read 

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

func (*ConfigurationModifyBackupPolicyResponse) ReadField1 

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

func (*ConfigurationModifyBackupPolicyResponse) ReadField2 

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

func (*ConfigurationModifyBackupPolicyResponse) String 

func (p *ConfigurationModifyBackupPolicyResponse) String() string

func (*ConfigurationModifyBackupPolicyResponse) Write 

func (p *ConfigurationModifyBackupPolicyResponse) Write(oprot thrift.TProtocol) 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"`
	// unused field # 4
	HpTarget *base.HostPort `thrift:"hp_target,5" db:"hp_target" json:"hp_target,omitempty"`
	HpNode   *base.HostPort `thrift:"hp_node,6" db:"hp_node" json:"hp_node,omitempty"`
}

Attributes:

  • Target
  • Node
  • Type
  • HpTarget
  • HpNode

func NewConfigurationProposalAction 

func NewConfigurationProposalAction() *ConfigurationProposalAction

func (*ConfigurationProposalAction) GetHpNode 

func (p *ConfigurationProposalAction) GetHpNode() *base.HostPort

func (*ConfigurationProposalAction) GetHpTarget 

func (p *ConfigurationProposalAction) GetHpTarget() *base.HostPort

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) IsSetHpNode 

func (p *ConfigurationProposalAction) IsSetHpNode() bool

func (*ConfigurationProposalAction) IsSetHpTarget 

func (p *ConfigurationProposalAction) IsSetHpTarget() bool

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) ReadField5 

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

func (*ConfigurationProposalAction) ReadField6 

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

func (*ConfigurationProposalAction) String 

func (p *ConfigurationProposalAction) String() string

func (*ConfigurationProposalAction) Write 

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

type ConfigurationQueryBackupPolicyRequest 

type ConfigurationQueryBackupPolicyRequest 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 *ConfigurationQueryBackupPolicyRequest

func NewConfigurationQueryBackupPolicyRequest 

func NewConfigurationQueryBackupPolicyRequest() *ConfigurationQueryBackupPolicyRequest

func (*ConfigurationQueryBackupPolicyRequest) GetBackupInfoCount 

func (p *ConfigurationQueryBackupPolicyRequest) GetBackupInfoCount() int32

func (*ConfigurationQueryBackupPolicyRequest) GetPolicyNames 

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

func (*ConfigurationQueryBackupPolicyRequest) Read 

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

func (*ConfigurationQueryBackupPolicyRequest) ReadField1 

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

func (*ConfigurationQueryBackupPolicyRequest) ReadField2 

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

func (*ConfigurationQueryBackupPolicyRequest) String 

func (p *ConfigurationQueryBackupPolicyRequest) String() string

func (*ConfigurationQueryBackupPolicyRequest) Write 

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

type ConfigurationQueryBackupPolicyResponse 

type ConfigurationQueryBackupPolicyResponse 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 *ConfigurationQueryBackupPolicyResponse

func NewConfigurationQueryBackupPolicyResponse 

func NewConfigurationQueryBackupPolicyResponse() *ConfigurationQueryBackupPolicyResponse

func (*ConfigurationQueryBackupPolicyResponse) GetBackupInfos 

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

func (*ConfigurationQueryBackupPolicyResponse) GetErr 

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

func (*ConfigurationQueryBackupPolicyResponse) GetHintMsg 

func (p *ConfigurationQueryBackupPolicyResponse) GetHintMsg() string

func (*ConfigurationQueryBackupPolicyResponse) GetPolicys 

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

func (*ConfigurationQueryBackupPolicyResponse) IsSetErr 

func (p *ConfigurationQueryBackupPolicyResponse) IsSetErr() bool

func (*ConfigurationQueryBackupPolicyResponse) IsSetHintMsg 

func (p *ConfigurationQueryBackupPolicyResponse) IsSetHintMsg() bool

func (*ConfigurationQueryBackupPolicyResponse) Read 

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

func (*ConfigurationQueryBackupPolicyResponse) ReadField1 

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

func (*ConfigurationQueryBackupPolicyResponse) ReadField2 

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

func (*ConfigurationQueryBackupPolicyResponse) ReadField3 

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

func (*ConfigurationQueryBackupPolicyResponse) ReadField4 

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

func (*ConfigurationQueryBackupPolicyResponse) String 

func (p *ConfigurationQueryBackupPolicyResponse) String() string

func (*ConfigurationQueryBackupPolicyResponse) Write 

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

type ConfigurationQueryByNodeRequest 

type ConfigurationQueryByNodeRequest struct {
	Node           *base.RPCAddress   `thrift:"node,1" db:"node" json:"node"`
	StoredReplicas []*ReplicaInfo     `thrift:"stored_replicas,2" db:"stored_replicas" json:"stored_replicas,omitempty"`
	Info           *ReplicaServerInfo `thrift:"info,3" db:"info" json:"info,omitempty"`
	HpNode         *base.HostPort     `thrift:"hp_node,4" db:"hp_node" json:"hp_node,omitempty"`
}

Attributes:

  • Node
  • StoredReplicas
  • Info
  • HpNode

func NewConfigurationQueryByNodeRequest 

func NewConfigurationQueryByNodeRequest() *ConfigurationQueryByNodeRequest

func (*ConfigurationQueryByNodeRequest) GetHpNode 

func (p *ConfigurationQueryByNodeRequest) GetHpNode() *base.HostPort

func (*ConfigurationQueryByNodeRequest) GetInfo 

func (p *ConfigurationQueryByNodeRequest) GetInfo() *ReplicaServerInfo

func (*ConfigurationQueryByNodeRequest) GetNode 

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

func (*ConfigurationQueryByNodeRequest) GetStoredReplicas 

func (p *ConfigurationQueryByNodeRequest) GetStoredReplicas() []*ReplicaInfo

func (*ConfigurationQueryByNodeRequest) IsSetHpNode 

func (p *ConfigurationQueryByNodeRequest) IsSetHpNode() bool

func (*ConfigurationQueryByNodeRequest) IsSetInfo 

func (p *ConfigurationQueryByNodeRequest) IsSetInfo() bool

func (*ConfigurationQueryByNodeRequest) IsSetNode 

func (p *ConfigurationQueryByNodeRequest) IsSetNode() bool

func (*ConfigurationQueryByNodeRequest) IsSetStoredReplicas 

func (p *ConfigurationQueryByNodeRequest) IsSetStoredReplicas() bool

func (*ConfigurationQueryByNodeRequest) Read 

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

func (*ConfigurationQueryByNodeRequest) ReadField1 

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

func (*ConfigurationQueryByNodeRequest) ReadField2 

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

func (*ConfigurationQueryByNodeRequest) ReadField3 

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

func (*ConfigurationQueryByNodeRequest) ReadField4 

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

func (*ConfigurationQueryByNodeRequest) String 

func (p *ConfigurationQueryByNodeRequest) String() string

func (*ConfigurationQueryByNodeRequest) Write 

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

type ConfigurationQueryByNodeResponse 

type ConfigurationQueryByNodeResponse struct {
	Err        *base.ErrorCode               `thrift:"err,1" db:"err" json:"err"`
	Partitions []*ConfigurationUpdateRequest `thrift:"partitions,2" db:"partitions" json:"partitions"`
	GcReplicas []*ReplicaInfo                `thrift:"gc_replicas,3" db:"gc_replicas" json:"gc_replicas,omitempty"`
}

Attributes:

  • Err
  • Partitions
  • GcReplicas

func NewConfigurationQueryByNodeResponse 

func NewConfigurationQueryByNodeResponse() *ConfigurationQueryByNodeResponse

func (*ConfigurationQueryByNodeResponse) GetErr 

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

func (*ConfigurationQueryByNodeResponse) GetGcReplicas 

func (p *ConfigurationQueryByNodeResponse) GetGcReplicas() []*ReplicaInfo

func (*ConfigurationQueryByNodeResponse) GetPartitions 

func (p *ConfigurationQueryByNodeResponse) GetPartitions() []*ConfigurationUpdateRequest

func (*ConfigurationQueryByNodeResponse) IsSetErr 

func (p *ConfigurationQueryByNodeResponse) IsSetErr() bool

func (*ConfigurationQueryByNodeResponse) IsSetGcReplicas 

func (p *ConfigurationQueryByNodeResponse) IsSetGcReplicas() bool

func (*ConfigurationQueryByNodeResponse) Read 

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

func (*ConfigurationQueryByNodeResponse) ReadField1 

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

func (*ConfigurationQueryByNodeResponse) ReadField2 

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

func (*ConfigurationQueryByNodeResponse) ReadField3 

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

func (*ConfigurationQueryByNodeResponse) String 

func (p *ConfigurationQueryByNodeResponse) String() string

func (*ConfigurationQueryByNodeResponse) Write 

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

type ConfigurationQueryRestoreRequest 

type ConfigurationQueryRestoreRequest struct {
	RestoreAppID int32 `thrift:"restore_app_id,1" db:"restore_app_id" json:"restore_app_id"`
}

Attributes:

  • RestoreAppID

func NewConfigurationQueryRestoreRequest 

func NewConfigurationQueryRestoreRequest() *ConfigurationQueryRestoreRequest

func (*ConfigurationQueryRestoreRequest) GetRestoreAppID 

func (p *ConfigurationQueryRestoreRequest) GetRestoreAppID() int32

func (*ConfigurationQueryRestoreRequest) Read 

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

func (*ConfigurationQueryRestoreRequest) ReadField1 

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

func (*ConfigurationQueryRestoreRequest) String 

func (p *ConfigurationQueryRestoreRequest) String() string

func (*ConfigurationQueryRestoreRequest) Write 

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

type ConfigurationQueryRestoreResponse 

type ConfigurationQueryRestoreResponse struct {
	Err             *base.ErrorCode   `thrift:"err,1" db:"err" json:"err"`
	RestoreStatus   []*base.ErrorCode `thrift:"restore_status,2" db:"restore_status" json:"restore_status"`
	RestoreProgress []int32           `thrift:"restore_progress,3" db:"restore_progress" json:"restore_progress"`
}

Attributes:

  • Err
  • RestoreStatus
  • RestoreProgress

func NewConfigurationQueryRestoreResponse 

func NewConfigurationQueryRestoreResponse() *ConfigurationQueryRestoreResponse

func (*ConfigurationQueryRestoreResponse) GetErr 

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

func (*ConfigurationQueryRestoreResponse) GetRestoreProgress 

func (p *ConfigurationQueryRestoreResponse) GetRestoreProgress() []int32

func (*ConfigurationQueryRestoreResponse) GetRestoreStatus 

func (p *ConfigurationQueryRestoreResponse) GetRestoreStatus() []*base.ErrorCode

func (*ConfigurationQueryRestoreResponse) IsSetErr 

func (p *ConfigurationQueryRestoreResponse) IsSetErr() bool

func (*ConfigurationQueryRestoreResponse) Read 

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

func (*ConfigurationQueryRestoreResponse) ReadField1 

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

func (*ConfigurationQueryRestoreResponse) ReadField2 

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

func (*ConfigurationQueryRestoreResponse) ReadField3 

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

func (*ConfigurationQueryRestoreResponse) String 

func (p *ConfigurationQueryRestoreResponse) String() string

func (*ConfigurationQueryRestoreResponse) Write 

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

type ConfigurationRecallAppRequest 

type ConfigurationRecallAppRequest 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 *ConfigurationRecallAppRequest

func NewConfigurationRecallAppRequest 

func NewConfigurationRecallAppRequest() *ConfigurationRecallAppRequest

func (*ConfigurationRecallAppRequest) GetAppID 

func (p *ConfigurationRecallAppRequest) GetAppID() int32

func (*ConfigurationRecallAppRequest) GetNewAppName_ 

func (p *ConfigurationRecallAppRequest) GetNewAppName_() string

func (*ConfigurationRecallAppRequest) Read 

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

func (*ConfigurationRecallAppRequest) ReadField1 

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

func (*ConfigurationRecallAppRequest) ReadField2 

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

func (*ConfigurationRecallAppRequest) String 

func (p *ConfigurationRecallAppRequest) String() string

func (*ConfigurationRecallAppRequest) Write 

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

type ConfigurationRecallAppResponse 

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

Attributes:

  • Err
  • Info
var AdminClientRecallAppResult_Success_DEFAULT *ConfigurationRecallAppResponse

func NewConfigurationRecallAppResponse 

func NewConfigurationRecallAppResponse() *ConfigurationRecallAppResponse

func (*ConfigurationRecallAppResponse) GetErr 

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

func (*ConfigurationRecallAppResponse) GetInfo 

func (p *ConfigurationRecallAppResponse) GetInfo() *replication.AppInfo

func (*ConfigurationRecallAppResponse) IsSetErr 

func (p *ConfigurationRecallAppResponse) IsSetErr() bool

func (*ConfigurationRecallAppResponse) IsSetInfo 

func (p *ConfigurationRecallAppResponse) IsSetInfo() bool

func (*ConfigurationRecallAppResponse) Read 

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

func (*ConfigurationRecallAppResponse) ReadField1 

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

func (*ConfigurationRecallAppResponse) ReadField2 

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

func (*ConfigurationRecallAppResponse) String 

func (p *ConfigurationRecallAppResponse) String() string

func (*ConfigurationRecallAppResponse) Write 

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

type ConfigurationRecoveryRequest 

type ConfigurationRecoveryRequest struct {
	RecoveryNodes      []*base.RPCAddress `thrift:"recovery_nodes,1" db:"recovery_nodes" json:"recovery_nodes"`
	SkipBadNodes       bool               `thrift:"skip_bad_nodes,2" db:"skip_bad_nodes" json:"skip_bad_nodes"`
	SkipLostPartitions bool               `thrift:"skip_lost_partitions,3" db:"skip_lost_partitions" json:"skip_lost_partitions"`
	HpRecoveryNodes    []*base.HostPort   `thrift:"hp_recovery_nodes,4" db:"hp_recovery_nodes" json:"hp_recovery_nodes,omitempty"`
}

Attributes:

  • RecoveryNodes
  • SkipBadNodes
  • SkipLostPartitions
  • HpRecoveryNodes

func NewConfigurationRecoveryRequest 

func NewConfigurationRecoveryRequest() *ConfigurationRecoveryRequest

func (*ConfigurationRecoveryRequest) GetHpRecoveryNodes 

func (p *ConfigurationRecoveryRequest) GetHpRecoveryNodes() []*base.HostPort

func (*ConfigurationRecoveryRequest) GetRecoveryNodes 

func (p *ConfigurationRecoveryRequest) GetRecoveryNodes() []*base.RPCAddress

func (*ConfigurationRecoveryRequest) GetSkipBadNodes 

func (p *ConfigurationRecoveryRequest) GetSkipBadNodes() bool

func (*ConfigurationRecoveryRequest) GetSkipLostPartitions 

func (p *ConfigurationRecoveryRequest) GetSkipLostPartitions() bool

func (*ConfigurationRecoveryRequest) IsSetHpRecoveryNodes 

func (p *ConfigurationRecoveryRequest) IsSetHpRecoveryNodes() bool

func (*ConfigurationRecoveryRequest) Read 

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

func (*ConfigurationRecoveryRequest) ReadField1 

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

func (*ConfigurationRecoveryRequest) ReadField2 

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

func (*ConfigurationRecoveryRequest) ReadField3 

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

func (*ConfigurationRecoveryRequest) ReadField4 

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

func (*ConfigurationRecoveryRequest) String 

func (p *ConfigurationRecoveryRequest) String() string

func (*ConfigurationRecoveryRequest) Write 

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

type ConfigurationRecoveryResponse 

type ConfigurationRecoveryResponse 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

func NewConfigurationRecoveryResponse 

func NewConfigurationRecoveryResponse() *ConfigurationRecoveryResponse

func (*ConfigurationRecoveryResponse) GetErr 

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

func (*ConfigurationRecoveryResponse) GetHintMessage 

func (p *ConfigurationRecoveryResponse) GetHintMessage() string

func (*ConfigurationRecoveryResponse) IsSetErr 

func (p *ConfigurationRecoveryResponse) IsSetErr() bool

func (*ConfigurationRecoveryResponse) Read 

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

func (*ConfigurationRecoveryResponse) ReadField1 

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

func (*ConfigurationRecoveryResponse) ReadField2 

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

func (*ConfigurationRecoveryResponse) String 

func (p *ConfigurationRecoveryResponse) String() string

func (*ConfigurationRecoveryResponse) Write 

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

type ConfigurationRenameAppRequest 

type ConfigurationRenameAppRequest struct {
	OldAppName  string `thrift:"old_app_name,1" db:"old_app_name" json:"old_app_name"`
	NewAppName_ string `thrift:"new_app_name,2" db:"new_app_name" json:"new_app_name"`
}

Attributes:

  • OldAppName
  • NewAppName_

func NewConfigurationRenameAppRequest 

func NewConfigurationRenameAppRequest() *ConfigurationRenameAppRequest

func (*ConfigurationRenameAppRequest) GetNewAppName_ 

func (p *ConfigurationRenameAppRequest) GetNewAppName_() string

func (*ConfigurationRenameAppRequest) GetOldAppName 

func (p *ConfigurationRenameAppRequest) GetOldAppName() string

func (*ConfigurationRenameAppRequest) Read 

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

func (*ConfigurationRenameAppRequest) ReadField1 

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

func (*ConfigurationRenameAppRequest) ReadField2 

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

func (*ConfigurationRenameAppRequest) String 

func (p *ConfigurationRenameAppRequest) String() string

func (*ConfigurationRenameAppRequest) Write 

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

type ConfigurationRenameAppResponse 

type ConfigurationRenameAppResponse 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

func NewConfigurationRenameAppResponse 

func NewConfigurationRenameAppResponse() *ConfigurationRenameAppResponse

func (*ConfigurationRenameAppResponse) GetErr 

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

func (*ConfigurationRenameAppResponse) GetHintMessage 

func (p *ConfigurationRenameAppResponse) GetHintMessage() string

func (*ConfigurationRenameAppResponse) IsSetErr 

func (p *ConfigurationRenameAppResponse) IsSetErr() bool

func (*ConfigurationRenameAppResponse) Read 

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

func (*ConfigurationRenameAppResponse) ReadField1 

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

func (*ConfigurationRenameAppResponse) ReadField2 

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

func (*ConfigurationRenameAppResponse) String 

func (p *ConfigurationRenameAppResponse) String() string

func (*ConfigurationRenameAppResponse) Write 

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

type ConfigurationReportRestoreStatusRequest 

type ConfigurationReportRestoreStatusRequest struct {
	Pid           *base.Gpid      `thrift:"pid,1" db:"pid" json:"pid"`
	RestoreStatus *base.ErrorCode `thrift:"restore_status,2" db:"restore_status" json:"restore_status"`
	Progress      int32           `thrift:"progress,3" db:"progress" json:"progress"`
	Reason        *string         `thrift:"reason,4" db:"reason" json:"reason,omitempty"`
}

Attributes:

  • Pid
  • RestoreStatus
  • Progress
  • Reason

func NewConfigurationReportRestoreStatusRequest 

func NewConfigurationReportRestoreStatusRequest() *ConfigurationReportRestoreStatusRequest

func (*ConfigurationReportRestoreStatusRequest) GetPid 

func (p *ConfigurationReportRestoreStatusRequest) GetPid() *base.Gpid

func (*ConfigurationReportRestoreStatusRequest) GetProgress 

func (p *ConfigurationReportRestoreStatusRequest) GetProgress() int32

func (*ConfigurationReportRestoreStatusRequest) GetReason 

func (p *ConfigurationReportRestoreStatusRequest) GetReason() string

func (*ConfigurationReportRestoreStatusRequest) GetRestoreStatus 

func (p *ConfigurationReportRestoreStatusRequest) GetRestoreStatus() *base.ErrorCode

func (*ConfigurationReportRestoreStatusRequest) IsSetPid 

func (p *ConfigurationReportRestoreStatusRequest) IsSetPid() bool

func (*ConfigurationReportRestoreStatusRequest) IsSetReason 

func (p *ConfigurationReportRestoreStatusRequest) IsSetReason() bool

func (*ConfigurationReportRestoreStatusRequest) IsSetRestoreStatus 

func (p *ConfigurationReportRestoreStatusRequest) IsSetRestoreStatus() bool

func (*ConfigurationReportRestoreStatusRequest) Read 

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

func (*ConfigurationReportRestoreStatusRequest) ReadField1 

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

func (*ConfigurationReportRestoreStatusRequest) ReadField2 

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

func (*ConfigurationReportRestoreStatusRequest) ReadField3 

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

func (*ConfigurationReportRestoreStatusRequest) ReadField4 

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

func (*ConfigurationReportRestoreStatusRequest) String 

func (p *ConfigurationReportRestoreStatusRequest) String() string

func (*ConfigurationReportRestoreStatusRequest) Write 

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

type ConfigurationReportRestoreStatusResponse 

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

Attributes:

  • Err

func NewConfigurationReportRestoreStatusResponse 

func NewConfigurationReportRestoreStatusResponse() *ConfigurationReportRestoreStatusResponse

func (*ConfigurationReportRestoreStatusResponse) GetErr 

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

func (*ConfigurationReportRestoreStatusResponse) IsSetErr 

func (p *ConfigurationReportRestoreStatusResponse) IsSetErr() bool

func (*ConfigurationReportRestoreStatusResponse) Read 

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

func (*ConfigurationReportRestoreStatusResponse) ReadField1 

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

func (*ConfigurationReportRestoreStatusResponse) String 

func (p *ConfigurationReportRestoreStatusResponse) String() string

func (*ConfigurationReportRestoreStatusResponse) Write 

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

type ConfigurationRestoreRequest 

type ConfigurationRestoreRequest 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 *ConfigurationRestoreRequest

func NewConfigurationRestoreRequest 

func NewConfigurationRestoreRequest() *ConfigurationRestoreRequest

func (*ConfigurationRestoreRequest) GetAppID 

func (p *ConfigurationRestoreRequest) GetAppID() int32

func (*ConfigurationRestoreRequest) GetAppName 

func (p *ConfigurationRestoreRequest) GetAppName() string

func (*ConfigurationRestoreRequest) GetBackupProviderName 

func (p *ConfigurationRestoreRequest) GetBackupProviderName() string

func (*ConfigurationRestoreRequest) GetClusterName 

func (p *ConfigurationRestoreRequest) GetClusterName() string

func (*ConfigurationRestoreRequest) GetNewAppName_ 

func (p *ConfigurationRestoreRequest) GetNewAppName_() string

func (*ConfigurationRestoreRequest) GetPolicyName 

func (p *ConfigurationRestoreRequest) GetPolicyName() string

func (*ConfigurationRestoreRequest) GetRestorePath 

func (p *ConfigurationRestoreRequest) GetRestorePath() string

func (*ConfigurationRestoreRequest) GetSkipBadPartition 

func (p *ConfigurationRestoreRequest) GetSkipBadPartition() bool

func (*ConfigurationRestoreRequest) GetTimeStamp 

func (p *ConfigurationRestoreRequest) GetTimeStamp() int64

func (*ConfigurationRestoreRequest) IsSetRestorePath 

func (p *ConfigurationRestoreRequest) IsSetRestorePath() bool

func (*ConfigurationRestoreRequest) Read 

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

func (*ConfigurationRestoreRequest) ReadField1 

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

func (*ConfigurationRestoreRequest) ReadField2 

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

func (*ConfigurationRestoreRequest) ReadField3 

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

func (*ConfigurationRestoreRequest) ReadField4 

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

func (*ConfigurationRestoreRequest) ReadField5 

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

func (*ConfigurationRestoreRequest) ReadField6 

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

func (*ConfigurationRestoreRequest) ReadField7 

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

func (*ConfigurationRestoreRequest) ReadField8 

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

func (*ConfigurationRestoreRequest) ReadField9 

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

func (*ConfigurationRestoreRequest) String 

func (p *ConfigurationRestoreRequest) String() string

func (*ConfigurationRestoreRequest) Write 

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

type ConfigurationSetMaxReplicaCountRequest 

type ConfigurationSetMaxReplicaCountRequest struct {
	AppName         string `thrift:"app_name,1" db:"app_name" json:"app_name"`
	MaxReplicaCount int32  `thrift:"max_replica_count,2" db:"max_replica_count" json:"max_replica_count"`
}

Attributes:

  • AppName
  • MaxReplicaCount

func NewConfigurationSetMaxReplicaCountRequest 

func NewConfigurationSetMaxReplicaCountRequest() *ConfigurationSetMaxReplicaCountRequest

func (*ConfigurationSetMaxReplicaCountRequest) GetAppName 

func (p *ConfigurationSetMaxReplicaCountRequest) GetAppName() string

func (*ConfigurationSetMaxReplicaCountRequest) GetMaxReplicaCount 

func (p *ConfigurationSetMaxReplicaCountRequest) GetMaxReplicaCount() int32

func (*ConfigurationSetMaxReplicaCountRequest) Read 

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

func (*ConfigurationSetMaxReplicaCountRequest) ReadField1 

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

func (*ConfigurationSetMaxReplicaCountRequest) ReadField2 

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

func (*ConfigurationSetMaxReplicaCountRequest) String 

func (p *ConfigurationSetMaxReplicaCountRequest) String() string

func (*ConfigurationSetMaxReplicaCountRequest) Write 

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

type ConfigurationSetMaxReplicaCountResponse 

type ConfigurationSetMaxReplicaCountResponse struct {
	Err                *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	OldMaxReplicaCount int32           `thrift:"old_max_replica_count,2" db:"old_max_replica_count" json:"old_max_replica_count"`
	HintMessage        string          `thrift:"hint_message,3" db:"hint_message" json:"hint_message"`
}

Attributes:

  • Err
  • OldMaxReplicaCount
  • HintMessage

func NewConfigurationSetMaxReplicaCountResponse 

func NewConfigurationSetMaxReplicaCountResponse() *ConfigurationSetMaxReplicaCountResponse

func (*ConfigurationSetMaxReplicaCountResponse) GetErr 

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

func (*ConfigurationSetMaxReplicaCountResponse) GetHintMessage 

func (p *ConfigurationSetMaxReplicaCountResponse) GetHintMessage() string

func (*ConfigurationSetMaxReplicaCountResponse) GetOldMaxReplicaCount 

func (p *ConfigurationSetMaxReplicaCountResponse) GetOldMaxReplicaCount() int32

func (*ConfigurationSetMaxReplicaCountResponse) IsSetErr 

func (p *ConfigurationSetMaxReplicaCountResponse) IsSetErr() bool

func (*ConfigurationSetMaxReplicaCountResponse) Read 

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

func (*ConfigurationSetMaxReplicaCountResponse) ReadField1 

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

func (*ConfigurationSetMaxReplicaCountResponse) ReadField2 

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

func (*ConfigurationSetMaxReplicaCountResponse) ReadField3 

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

func (*ConfigurationSetMaxReplicaCountResponse) String 

func (p *ConfigurationSetMaxReplicaCountResponse) String() string

func (*ConfigurationSetMaxReplicaCountResponse) Write 

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

type ConfigurationUpdateAppEnvRequest 

type ConfigurationUpdateAppEnvRequest 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 *ConfigurationUpdateAppEnvRequest

func NewConfigurationUpdateAppEnvRequest 

func NewConfigurationUpdateAppEnvRequest() *ConfigurationUpdateAppEnvRequest

func (*ConfigurationUpdateAppEnvRequest) GetAppName 

func (p *ConfigurationUpdateAppEnvRequest) GetAppName() string

func (*ConfigurationUpdateAppEnvRequest) GetClearPrefix 

func (p *ConfigurationUpdateAppEnvRequest) GetClearPrefix() string

func (*ConfigurationUpdateAppEnvRequest) GetKeys 

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

func (*ConfigurationUpdateAppEnvRequest) GetOp 

func (p *ConfigurationUpdateAppEnvRequest) GetOp() AppEnvOperation

func (*ConfigurationUpdateAppEnvRequest) GetValues 

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

func (*ConfigurationUpdateAppEnvRequest) IsSetClearPrefix 

func (p *ConfigurationUpdateAppEnvRequest) IsSetClearPrefix() bool

func (*ConfigurationUpdateAppEnvRequest) IsSetKeys 

func (p *ConfigurationUpdateAppEnvRequest) IsSetKeys() bool

func (*ConfigurationUpdateAppEnvRequest) IsSetValues 

func (p *ConfigurationUpdateAppEnvRequest) IsSetValues() bool

func (*ConfigurationUpdateAppEnvRequest) Read 

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

func (*ConfigurationUpdateAppEnvRequest) ReadField1 

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

func (*ConfigurationUpdateAppEnvRequest) ReadField2 

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

func (*ConfigurationUpdateAppEnvRequest) ReadField3 

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

func (*ConfigurationUpdateAppEnvRequest) ReadField4 

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

func (*ConfigurationUpdateAppEnvRequest) ReadField5 

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

func (*ConfigurationUpdateAppEnvRequest) String 

func (p *ConfigurationUpdateAppEnvRequest) String() string

func (*ConfigurationUpdateAppEnvRequest) Write 

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

type ConfigurationUpdateAppEnvResponse 

type ConfigurationUpdateAppEnvResponse 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 *ConfigurationUpdateAppEnvResponse

func NewConfigurationUpdateAppEnvResponse 

func NewConfigurationUpdateAppEnvResponse() *ConfigurationUpdateAppEnvResponse

func (*ConfigurationUpdateAppEnvResponse) GetErr 

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

func (*ConfigurationUpdateAppEnvResponse) GetHintMessage 

func (p *ConfigurationUpdateAppEnvResponse) GetHintMessage() string

func (*ConfigurationUpdateAppEnvResponse) IsSetErr 

func (p *ConfigurationUpdateAppEnvResponse) IsSetErr() bool

func (*ConfigurationUpdateAppEnvResponse) Read 

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

func (*ConfigurationUpdateAppEnvResponse) ReadField1 

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

func (*ConfigurationUpdateAppEnvResponse) ReadField2 

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

func (*ConfigurationUpdateAppEnvResponse) String 

func (p *ConfigurationUpdateAppEnvResponse) String() string

func (*ConfigurationUpdateAppEnvResponse) Write 

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

type ConfigurationUpdateRequest 

type ConfigurationUpdateRequest struct {
	Info            *replication.AppInfo                `thrift:"info,1" db:"info" json:"info"`
	Config          *replication.PartitionConfiguration `thrift:"config,2" db:"config" json:"config"`
	Type            ConfigType                          `thrift:"type,3" db:"type" json:"type"`
	Node            *base.RPCAddress                    `thrift:"node,4" db:"node" json:"node"`
	HostNode        *base.RPCAddress                    `thrift:"host_node,5" db:"host_node" json:"host_node"`
	MetaSplitStatus *SplitStatus                        `thrift:"meta_split_status,6" db:"meta_split_status" json:"meta_split_status,omitempty"`
	HpNode          *base.HostPort                      `thrift:"hp_node,7" db:"hp_node" json:"hp_node,omitempty"`
}

Attributes:

  • Info
  • Config
  • Type
  • Node
  • HostNode
  • MetaSplitStatus
  • HpNode

func NewConfigurationUpdateRequest 

func NewConfigurationUpdateRequest() *ConfigurationUpdateRequest

func (*ConfigurationUpdateRequest) GetConfig 

func (p *ConfigurationUpdateRequest) GetConfig() *replication.PartitionConfiguration

func (*ConfigurationUpdateRequest) GetHostNode 

func (p *ConfigurationUpdateRequest) GetHostNode() *base.RPCAddress

func (*ConfigurationUpdateRequest) GetHpNode 

func (p *ConfigurationUpdateRequest) GetHpNode() *base.HostPort

func (*ConfigurationUpdateRequest) GetInfo 

func (p *ConfigurationUpdateRequest) GetInfo() *replication.AppInfo

func (*ConfigurationUpdateRequest) GetMetaSplitStatus 

func (p *ConfigurationUpdateRequest) GetMetaSplitStatus() SplitStatus

func (*ConfigurationUpdateRequest) GetNode 

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

func (*ConfigurationUpdateRequest) GetType 

func (p *ConfigurationUpdateRequest) GetType() ConfigType

func (*ConfigurationUpdateRequest) IsSetConfig 

func (p *ConfigurationUpdateRequest) IsSetConfig() bool

func (*ConfigurationUpdateRequest) IsSetHostNode 

func (p *ConfigurationUpdateRequest) IsSetHostNode() bool

func (*ConfigurationUpdateRequest) IsSetHpNode 

func (p *ConfigurationUpdateRequest) IsSetHpNode() bool

func (*ConfigurationUpdateRequest) IsSetInfo 

func (p *ConfigurationUpdateRequest) IsSetInfo() bool

func (*ConfigurationUpdateRequest) IsSetMetaSplitStatus 

func (p *ConfigurationUpdateRequest) IsSetMetaSplitStatus() bool

func (*ConfigurationUpdateRequest) IsSetNode 

func (p *ConfigurationUpdateRequest) IsSetNode() bool

func (*ConfigurationUpdateRequest) Read 

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

func (*ConfigurationUpdateRequest) ReadField1 

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

func (*ConfigurationUpdateRequest) ReadField2 

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

func (*ConfigurationUpdateRequest) ReadField3 

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

func (*ConfigurationUpdateRequest) ReadField4 

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

func (*ConfigurationUpdateRequest) ReadField5 

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

func (*ConfigurationUpdateRequest) ReadField6 

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

func (*ConfigurationUpdateRequest) ReadField7 

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

func (*ConfigurationUpdateRequest) String 

func (p *ConfigurationUpdateRequest) String() string

func (*ConfigurationUpdateRequest) Write 

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

type ConfigurationUpdateResponse 

type ConfigurationUpdateResponse struct {
	Err    *base.ErrorCode                     `thrift:"err,1" db:"err" json:"err"`
	Config *replication.PartitionConfiguration `thrift:"config,2" db:"config" json:"config"`
}

Attributes:

  • Err
  • Config

func NewConfigurationUpdateResponse 

func NewConfigurationUpdateResponse() *ConfigurationUpdateResponse

func (*ConfigurationUpdateResponse) GetConfig 

func (p *ConfigurationUpdateResponse) GetConfig() *replication.PartitionConfiguration

func (*ConfigurationUpdateResponse) GetErr 

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

func (*ConfigurationUpdateResponse) IsSetConfig 

func (p *ConfigurationUpdateResponse) IsSetConfig() bool

func (*ConfigurationUpdateResponse) IsSetErr 

func (p *ConfigurationUpdateResponse) IsSetErr() bool

func (*ConfigurationUpdateResponse) Read 

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

func (*ConfigurationUpdateResponse) ReadField1 

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

func (*ConfigurationUpdateResponse) ReadField2 

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

func (*ConfigurationUpdateResponse) String 

func (p *ConfigurationUpdateResponse) String() string

func (*ConfigurationUpdateResponse) Write 

func (p *ConfigurationUpdateResponse) 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 ConfigurationCreateAppRequest_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 DddDiagnoseRequest 

type DddDiagnoseRequest struct {
	Pid *base.Gpid `thrift:"pid,1" db:"pid" json:"pid"`
}

Attributes:

  • Pid

func NewDddDiagnoseRequest 

func NewDddDiagnoseRequest() *DddDiagnoseRequest

func (*DddDiagnoseRequest) GetPid 

func (p *DddDiagnoseRequest) GetPid() *base.Gpid

func (*DddDiagnoseRequest) IsSetPid 

func (p *DddDiagnoseRequest) IsSetPid() bool

func (*DddDiagnoseRequest) Read 

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

func (*DddDiagnoseRequest) ReadField1 

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

func (*DddDiagnoseRequest) String 

func (p *DddDiagnoseRequest) String() string

func (*DddDiagnoseRequest) Write 

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

type DddDiagnoseResponse 

type DddDiagnoseResponse struct {
	Err        *base.ErrorCode     `thrift:"err,1" db:"err" json:"err"`
	Partitions []*DddPartitionInfo `thrift:"partitions,2" db:"partitions" json:"partitions"`
}

Attributes:

  • Err
  • Partitions

func NewDddDiagnoseResponse 

func NewDddDiagnoseResponse() *DddDiagnoseResponse

func (*DddDiagnoseResponse) GetErr 

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

func (*DddDiagnoseResponse) GetPartitions 

func (p *DddDiagnoseResponse) GetPartitions() []*DddPartitionInfo

func (*DddDiagnoseResponse) IsSetErr 

func (p *DddDiagnoseResponse) IsSetErr() bool

func (*DddDiagnoseResponse) Read 

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

func (*DddDiagnoseResponse) ReadField1 

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

func (*DddDiagnoseResponse) ReadField2 

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

func (*DddDiagnoseResponse) String 

func (p *DddDiagnoseResponse) String() string

func (*DddDiagnoseResponse) Write 

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

type DddNodeInfo 

type DddNodeInfo struct {
	Node                *base.RPCAddress `thrift:"node,1" db:"node" json:"node"`
	DropTimeMs          int64            `thrift:"drop_time_ms,2" db:"drop_time_ms" json:"drop_time_ms"`
	IsAlive             bool             `thrift:"is_alive,3" db:"is_alive" json:"is_alive"`
	IsCollected         bool             `thrift:"is_collected,4" db:"is_collected" json:"is_collected"`
	Ballot              int64            `thrift:"ballot,5" db:"ballot" json:"ballot"`
	LastCommittedDecree int64            `thrift:"last_committed_decree,6" db:"last_committed_decree" json:"last_committed_decree"`
	LastPreparedDecree  int64            `thrift:"last_prepared_decree,7" db:"last_prepared_decree" json:"last_prepared_decree"`
	HpNode              *base.HostPort   `thrift:"hp_node,8" db:"hp_node" json:"hp_node,omitempty"`
}

Attributes:

  • Node
  • DropTimeMs
  • IsAlive
  • IsCollected
  • Ballot
  • LastCommittedDecree
  • LastPreparedDecree
  • HpNode

func NewDddNodeInfo 

func NewDddNodeInfo() *DddNodeInfo

func (*DddNodeInfo) GetBallot 

func (p *DddNodeInfo) GetBallot() int64

func (*DddNodeInfo) GetDropTimeMs 

func (p *DddNodeInfo) GetDropTimeMs() int64

func (*DddNodeInfo) GetHpNode 

func (p *DddNodeInfo) GetHpNode() *base.HostPort

func (*DddNodeInfo) GetIsAlive 

func (p *DddNodeInfo) GetIsAlive() bool

func (*DddNodeInfo) GetIsCollected 

func (p *DddNodeInfo) GetIsCollected() bool

func (*DddNodeInfo) GetLastCommittedDecree 

func (p *DddNodeInfo) GetLastCommittedDecree() int64

func (*DddNodeInfo) GetLastPreparedDecree 

func (p *DddNodeInfo) GetLastPreparedDecree() int64

func (*DddNodeInfo) GetNode 

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

func (*DddNodeInfo) IsSetHpNode 

func (p *DddNodeInfo) IsSetHpNode() bool

func (*DddNodeInfo) IsSetNode 

func (p *DddNodeInfo) IsSetNode() bool

func (*DddNodeInfo) Read 

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

func (*DddNodeInfo) ReadField1 

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

func (*DddNodeInfo) ReadField2 

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

func (*DddNodeInfo) ReadField3 

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

func (*DddNodeInfo) ReadField4 

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

func (*DddNodeInfo) ReadField5 

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

func (*DddNodeInfo) ReadField6 

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

func (*DddNodeInfo) ReadField7 

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

func (*DddNodeInfo) ReadField8 

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

func (*DddNodeInfo) String 

func (p *DddNodeInfo) String() string

func (*DddNodeInfo) Write 

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

type DddPartitionInfo 

type DddPartitionInfo struct {
	Config  *replication.PartitionConfiguration `thrift:"config,1" db:"config" json:"config"`
	Dropped []*DddNodeInfo                      `thrift:"dropped,2" db:"dropped" json:"dropped"`
	Reason  string                              `thrift:"reason,3" db:"reason" json:"reason"`
}

Attributes:

  • Config
  • Dropped
  • Reason

func NewDddPartitionInfo 

func NewDddPartitionInfo() *DddPartitionInfo

func (*DddPartitionInfo) GetConfig 

func (p *DddPartitionInfo) GetConfig() *replication.PartitionConfiguration

func (*DddPartitionInfo) GetDropped 

func (p *DddPartitionInfo) GetDropped() []*DddNodeInfo

func (*DddPartitionInfo) GetReason 

func (p *DddPartitionInfo) GetReason() string

func (*DddPartitionInfo) IsSetConfig 

func (p *DddPartitionInfo) IsSetConfig() bool

func (*DddPartitionInfo) Read 

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

func (*DddPartitionInfo) ReadField1 

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

func (*DddPartitionInfo) ReadField2 

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

func (*DddPartitionInfo) ReadField3 

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

func (*DddPartitionInfo) String 

func (p *DddPartitionInfo) String() string

func (*DddPartitionInfo) Write 

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

type DiskStatus 

type DiskStatus int64
const (
	DiskStatus_NORMAL             DiskStatus = 0
	DiskStatus_SPACE_INSUFFICIENT DiskStatus = 1
	DiskStatus_IO_ERROR           DiskStatus = 2
)

func DiskStatusFromString 

func DiskStatusFromString(s string) (DiskStatus, error)

func DiskStatusPtr 

func DiskStatusPtr(v DiskStatus) *DiskStatus

func (DiskStatus) MarshalText 

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

func (*DiskStatus) Scan 

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

func (DiskStatus) String 

func (p DiskStatus) String() string

func (*DiskStatus) UnmarshalText 

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

func (*DiskStatus) Value 

func (p *DiskStatus) Value() (driver.Value, 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 ConfigurationDropAppRequest_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 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"`
	IsDuplicatingCheckpoint bool    `thrift:"is_duplicating_checkpoint,3" db:"is_duplicating_checkpoint" json:"is_duplicating_checkpoint"`
	RemoteAppName           *string `thrift:"remote_app_name,4" db:"remote_app_name" json:"remote_app_name,omitempty"`
	RemoteReplicaCount      *int32  `thrift:"remote_replica_count,5" db:"remote_replica_count" json:"remote_replica_count,omitempty"`
}

Attributes:

  • AppName
  • RemoteClusterName
  • IsDuplicatingCheckpoint
  • RemoteAppName
  • RemoteReplicaCount
var AdminClientAddDuplicationArgs_Req_DEFAULT *DuplicationAddRequest

func NewDuplicationAddRequest 

func NewDuplicationAddRequest() *DuplicationAddRequest

func (*DuplicationAddRequest) GetAppName 

func (p *DuplicationAddRequest) GetAppName() string

func (*DuplicationAddRequest) GetIsDuplicatingCheckpoint 

func (p *DuplicationAddRequest) GetIsDuplicatingCheckpoint() bool

func (*DuplicationAddRequest) GetRemoteAppName 

func (p *DuplicationAddRequest) GetRemoteAppName() string

func (*DuplicationAddRequest) GetRemoteClusterName 

func (p *DuplicationAddRequest) GetRemoteClusterName() string

func (*DuplicationAddRequest) GetRemoteReplicaCount 

func (p *DuplicationAddRequest) GetRemoteReplicaCount() int32

func (*DuplicationAddRequest) IsSetIsDuplicatingCheckpoint 

func (p *DuplicationAddRequest) IsSetIsDuplicatingCheckpoint() bool

func (*DuplicationAddRequest) IsSetRemoteAppName 

func (p *DuplicationAddRequest) IsSetRemoteAppName() bool

func (*DuplicationAddRequest) IsSetRemoteReplicaCount 

func (p *DuplicationAddRequest) IsSetRemoteReplicaCount() bool

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) ReadField4 

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

func (*DuplicationAddRequest) ReadField5 

func (p *DuplicationAddRequest) ReadField5(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"`
	RemoteAppName      *string         `thrift:"remote_app_name,5" db:"remote_app_name" json:"remote_app_name,omitempty"`
	RemoteReplicaCount *int32          `thrift:"remote_replica_count,6" db:"remote_replica_count" json:"remote_replica_count,omitempty"`
}

Attributes:

  • Err
  • Appid
  • Dupid
  • Hint
  • RemoteAppName
  • RemoteReplicaCount
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) GetRemoteAppName 

func (p *DuplicationAddResponse) GetRemoteAppName() string

func (*DuplicationAddResponse) GetRemoteReplicaCount 

func (p *DuplicationAddResponse) GetRemoteReplicaCount() int32

func (*DuplicationAddResponse) IsSetErr 

func (p *DuplicationAddResponse) IsSetErr() bool

func (*DuplicationAddResponse) IsSetHint 

func (p *DuplicationAddResponse) IsSetHint() bool

func (*DuplicationAddResponse) IsSetRemoteAppName 

func (p *DuplicationAddResponse) IsSetRemoteAppName() bool

func (*DuplicationAddResponse) IsSetRemoteReplicaCount 

func (p *DuplicationAddResponse) IsSetRemoteReplicaCount() 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) ReadField5 

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

func (*DuplicationAddResponse) ReadField6 

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

func (*DuplicationAddResponse) String 

func (p *DuplicationAddResponse) String() string

func (*DuplicationAddResponse) Write 

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

type DuplicationConfirmEntry 

type DuplicationConfirmEntry struct {
	Dupid              int32 `thrift:"dupid,1" db:"dupid" json:"dupid"`
	ConfirmedDecree    int64 `thrift:"confirmed_decree,2" db:"confirmed_decree" json:"confirmed_decree"`
	CheckpointPrepared bool  `thrift:"checkpoint_prepared,3" db:"checkpoint_prepared" json:"checkpoint_prepared"`
}

Attributes:

  • Dupid
  • ConfirmedDecree
  • CheckpointPrepared

func NewDuplicationConfirmEntry 

func NewDuplicationConfirmEntry() *DuplicationConfirmEntry

func (*DuplicationConfirmEntry) GetCheckpointPrepared 

func (p *DuplicationConfirmEntry) GetCheckpointPrepared() bool

func (*DuplicationConfirmEntry) GetConfirmedDecree 

func (p *DuplicationConfirmEntry) GetConfirmedDecree() int64

func (*DuplicationConfirmEntry) GetDupid 

func (p *DuplicationConfirmEntry) GetDupid() int32

func (*DuplicationConfirmEntry) IsSetCheckpointPrepared 

func (p *DuplicationConfirmEntry) IsSetCheckpointPrepared() bool

func (*DuplicationConfirmEntry) Read 

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

func (*DuplicationConfirmEntry) ReadField1 

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

func (*DuplicationConfirmEntry) ReadField2 

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

func (*DuplicationConfirmEntry) ReadField3 

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

func (*DuplicationConfirmEntry) String 

func (p *DuplicationConfirmEntry) String() string

func (*DuplicationConfirmEntry) Write 

func (p *DuplicationConfirmEntry) 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"`
	RemoteAppName      *string              `thrift:"remote_app_name,8" db:"remote_app_name" json:"remote_app_name,omitempty"`
	RemoteReplicaCount *int32               `thrift:"remote_replica_count,9" db:"remote_replica_count" json:"remote_replica_count,omitempty"`
}

Attributes:

  • Dupid
  • Status
  • Remote
  • CreateTs
  • Progress
  • FailMode
  • RemoteAppName
  • RemoteReplicaCount

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) GetRemoteAppName 

func (p *DuplicationEntry) GetRemoteAppName() string

func (*DuplicationEntry) GetRemoteReplicaCount 

func (p *DuplicationEntry) GetRemoteReplicaCount() int32

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) IsSetRemoteAppName 

func (p *DuplicationEntry) IsSetRemoteAppName() bool

func (*DuplicationEntry) IsSetRemoteReplicaCount 

func (p *DuplicationEntry) IsSetRemoteReplicaCount() 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) ReadField8 

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

func (*DuplicationEntry) ReadField9 

func (p *DuplicationEntry) ReadField9(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_PREPARE DuplicationStatus = 1
	DuplicationStatus_DS_APP     DuplicationStatus = 2
	DuplicationStatus_DS_LOG     DuplicationStatus = 3
	DuplicationStatus_DS_PAUSE   DuplicationStatus = 4
	DuplicationStatus_DS_REMOVED DuplicationStatus = 5
)
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 DuplicationSyncRequest 

type DuplicationSyncRequest struct {
	Node        *base.RPCAddress                          `thrift:"node,1" db:"node" json:"node"`
	ConfirmList map[*base.Gpid][]*DuplicationConfirmEntry `thrift:"confirm_list,2" db:"confirm_list" json:"confirm_list"`
	HpNode      *base.HostPort                            `thrift:"hp_node,3" db:"hp_node" json:"hp_node"`
}

Attributes:

  • Node
  • ConfirmList
  • HpNode

func NewDuplicationSyncRequest 

func NewDuplicationSyncRequest() *DuplicationSyncRequest

func (*DuplicationSyncRequest) GetConfirmList 

func (p *DuplicationSyncRequest) GetConfirmList() map[*base.Gpid][]*DuplicationConfirmEntry

func (*DuplicationSyncRequest) GetHpNode 

func (p *DuplicationSyncRequest) GetHpNode() *base.HostPort

func (*DuplicationSyncRequest) GetNode 

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

func (*DuplicationSyncRequest) IsSetHpNode 

func (p *DuplicationSyncRequest) IsSetHpNode() bool

func (*DuplicationSyncRequest) IsSetNode 

func (p *DuplicationSyncRequest) IsSetNode() bool

func (*DuplicationSyncRequest) Read 

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

func (*DuplicationSyncRequest) ReadField1 

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

func (*DuplicationSyncRequest) ReadField2 

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

func (*DuplicationSyncRequest) ReadField3 

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

func (*DuplicationSyncRequest) String 

func (p *DuplicationSyncRequest) String() string

func (*DuplicationSyncRequest) Write 

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

type DuplicationSyncResponse 

type DuplicationSyncResponse struct {
	Err    *base.ErrorCode                       `thrift:"err,1" db:"err" json:"err"`
	DupMap map[int32]map[int32]*DuplicationEntry `thrift:"dup_map,2" db:"dup_map" json:"dup_map"`
}

Attributes:

  • Err
  • DupMap

func NewDuplicationSyncResponse 

func NewDuplicationSyncResponse() *DuplicationSyncResponse

func (*DuplicationSyncResponse) GetDupMap 

func (p *DuplicationSyncResponse) GetDupMap() map[int32]map[int32]*DuplicationEntry

func (*DuplicationSyncResponse) GetErr 

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

func (*DuplicationSyncResponse) IsSetErr 

func (p *DuplicationSyncResponse) IsSetErr() bool

func (*DuplicationSyncResponse) Read 

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

func (*DuplicationSyncResponse) ReadField1 

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

func (*DuplicationSyncResponse) ReadField2 

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

func (*DuplicationSyncResponse) String 

func (p *DuplicationSyncResponse) String() string

func (*DuplicationSyncResponse) Write 

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

type FileMeta 

type FileMeta struct {
	Name string `thrift:"name,1" db:"name" json:"name"`
	Size int64  `thrift:"size,2" db:"size" json:"size"`
	Md5  string `thrift:"md5,3" db:"md5" json:"md5"`
}

Attributes:

  • Name
  • Size
  • Md5

func NewFileMeta 

func NewFileMeta() *FileMeta

func (*FileMeta) GetMd5 

func (p *FileMeta) GetMd5() string

func (*FileMeta) GetName 

func (p *FileMeta) GetName() string

func (*FileMeta) GetSize 

func (p *FileMeta) GetSize() int64

func (*FileMeta) Read 

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

func (*FileMeta) ReadField1 

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

func (*FileMeta) ReadField2 

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

func (*FileMeta) ReadField3 

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

func (*FileMeta) String 

func (p *FileMeta) String() string

func (*FileMeta) Write 

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

type GroupBulkLoadRequest 

type GroupBulkLoadRequest struct {
	AppName            string                `thrift:"app_name,1" db:"app_name" json:"app_name"`
	Target             *base.RPCAddress      `thrift:"target,2" db:"target" json:"target"`
	Config             *ReplicaConfiguration `thrift:"config,3" db:"config" json:"config"`
	ProviderName       string                `thrift:"provider_name,4" db:"provider_name" json:"provider_name"`
	ClusterName        string                `thrift:"cluster_name,5" db:"cluster_name" json:"cluster_name"`
	MetaBulkLoadStatus BulkLoadStatus        `thrift:"meta_bulk_load_status,6" db:"meta_bulk_load_status" json:"meta_bulk_load_status"`
	RemoteRootPath     string                `thrift:"remote_root_path,7" db:"remote_root_path" json:"remote_root_path"`
	HpTarget           *base.HostPort        `thrift:"hp_target,8" db:"hp_target" json:"hp_target,omitempty"`
}

Attributes:

  • AppName
  • Target
  • Config
  • ProviderName
  • ClusterName
  • MetaBulkLoadStatus
  • RemoteRootPath
  • HpTarget

func NewGroupBulkLoadRequest 

func NewGroupBulkLoadRequest() *GroupBulkLoadRequest

func (*GroupBulkLoadRequest) GetAppName 

func (p *GroupBulkLoadRequest) GetAppName() string

func (*GroupBulkLoadRequest) GetClusterName 

func (p *GroupBulkLoadRequest) GetClusterName() string

func (*GroupBulkLoadRequest) GetConfig 

func (p *GroupBulkLoadRequest) GetConfig() *ReplicaConfiguration

func (*GroupBulkLoadRequest) GetHpTarget 

func (p *GroupBulkLoadRequest) GetHpTarget() *base.HostPort

func (*GroupBulkLoadRequest) GetMetaBulkLoadStatus 

func (p *GroupBulkLoadRequest) GetMetaBulkLoadStatus() BulkLoadStatus

func (*GroupBulkLoadRequest) GetProviderName 

func (p *GroupBulkLoadRequest) GetProviderName() string

func (*GroupBulkLoadRequest) GetRemoteRootPath 

func (p *GroupBulkLoadRequest) GetRemoteRootPath() string

func (*GroupBulkLoadRequest) GetTarget 

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

func (*GroupBulkLoadRequest) IsSetConfig 

func (p *GroupBulkLoadRequest) IsSetConfig() bool

func (*GroupBulkLoadRequest) IsSetHpTarget 

func (p *GroupBulkLoadRequest) IsSetHpTarget() bool

func (*GroupBulkLoadRequest) IsSetTarget 

func (p *GroupBulkLoadRequest) IsSetTarget() bool

func (*GroupBulkLoadRequest) Read 

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

func (*GroupBulkLoadRequest) ReadField1 

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

func (*GroupBulkLoadRequest) ReadField2 

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

func (*GroupBulkLoadRequest) ReadField3 

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

func (*GroupBulkLoadRequest) ReadField4 

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

func (*GroupBulkLoadRequest) ReadField5 

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

func (*GroupBulkLoadRequest) ReadField6 

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

func (*GroupBulkLoadRequest) ReadField7 

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

func (*GroupBulkLoadRequest) ReadField8 

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

func (*GroupBulkLoadRequest) String 

func (p *GroupBulkLoadRequest) String() string

func (*GroupBulkLoadRequest) Write 

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

type GroupBulkLoadResponse 

type GroupBulkLoadResponse struct {
	Err           *base.ErrorCode         `thrift:"err,1" db:"err" json:"err"`
	Status        BulkLoadStatus          `thrift:"status,2" db:"status" json:"status"`
	BulkLoadState *PartitionBulkLoadState `thrift:"bulk_load_state,3" db:"bulk_load_state" json:"bulk_load_state"`
}

Attributes:

  • Err
  • Status
  • BulkLoadState

func NewGroupBulkLoadResponse 

func NewGroupBulkLoadResponse() *GroupBulkLoadResponse

func (*GroupBulkLoadResponse) GetBulkLoadState 

func (p *GroupBulkLoadResponse) GetBulkLoadState() *PartitionBulkLoadState

func (*GroupBulkLoadResponse) GetErr 

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

func (*GroupBulkLoadResponse) GetStatus 

func (p *GroupBulkLoadResponse) GetStatus() BulkLoadStatus

func (*GroupBulkLoadResponse) IsSetBulkLoadState 

func (p *GroupBulkLoadResponse) IsSetBulkLoadState() bool

func (*GroupBulkLoadResponse) IsSetErr 

func (p *GroupBulkLoadResponse) IsSetErr() bool

func (*GroupBulkLoadResponse) Read 

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

func (*GroupBulkLoadResponse) ReadField1 

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

func (*GroupBulkLoadResponse) ReadField2 

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

func (*GroupBulkLoadResponse) ReadField3 

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

func (*GroupBulkLoadResponse) String 

func (p *GroupBulkLoadResponse) String() string

func (*GroupBulkLoadResponse) Write 

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

type IngestionRequest 

type IngestionRequest struct {
	AppName            string            `thrift:"app_name,1" db:"app_name" json:"app_name"`
	Metadata           *BulkLoadMetadata `thrift:"metadata,2" db:"metadata" json:"metadata"`
	IngestBehind       bool              `thrift:"ingest_behind,3" db:"ingest_behind" json:"ingest_behind"`
	Ballot             int64             `thrift:"ballot,4" db:"ballot" json:"ballot"`
	VerifyBeforeIngest bool              `thrift:"verify_before_ingest,5" db:"verify_before_ingest" json:"verify_before_ingest"`
}

Attributes:

  • AppName
  • Metadata
  • IngestBehind
  • Ballot
  • VerifyBeforeIngest

func NewIngestionRequest 

func NewIngestionRequest() *IngestionRequest

func (*IngestionRequest) GetAppName 

func (p *IngestionRequest) GetAppName() string

func (*IngestionRequest) GetBallot 

func (p *IngestionRequest) GetBallot() int64

func (*IngestionRequest) GetIngestBehind 

func (p *IngestionRequest) GetIngestBehind() bool

func (*IngestionRequest) GetMetadata 

func (p *IngestionRequest) GetMetadata() *BulkLoadMetadata

func (*IngestionRequest) GetVerifyBeforeIngest 

func (p *IngestionRequest) GetVerifyBeforeIngest() bool

func (*IngestionRequest) IsSetMetadata 

func (p *IngestionRequest) IsSetMetadata() bool

func (*IngestionRequest) Read 

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

func (*IngestionRequest) ReadField1 

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

func (*IngestionRequest) ReadField2 

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

func (*IngestionRequest) ReadField3 

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

func (*IngestionRequest) ReadField4 

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

func (*IngestionRequest) ReadField5 

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

func (*IngestionRequest) String 

func (p *IngestionRequest) String() string

func (*IngestionRequest) Write 

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

type IngestionResponse 

type IngestionResponse struct {
	Err          *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	RocksdbError int32           `thrift:"rocksdb_error,2" db:"rocksdb_error" json:"rocksdb_error"`
}

Attributes:

  • Err
  • RocksdbError

func NewIngestionResponse 

func NewIngestionResponse() *IngestionResponse

func (*IngestionResponse) GetErr 

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

func (*IngestionResponse) GetRocksdbError 

func (p *IngestionResponse) GetRocksdbError() int32

func (*IngestionResponse) IsSetErr 

func (p *IngestionResponse) IsSetErr() bool

func (*IngestionResponse) Read 

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

func (*IngestionResponse) ReadField1 

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

func (*IngestionResponse) ReadField2 

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

func (*IngestionResponse) String 

func (p *IngestionResponse) String() string

func (*IngestionResponse) Write 

func (p *IngestionResponse) Write(oprot thrift.TProtocol) 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 ManualCompactionStatus 

type ManualCompactionStatus int64
const (
	ManualCompactionStatus_IDLE     ManualCompactionStatus = 0
	ManualCompactionStatus_QUEUING  ManualCompactionStatus = 1
	ManualCompactionStatus_RUNNING  ManualCompactionStatus = 2
	ManualCompactionStatus_FINISHED ManualCompactionStatus = 3
)
var ReplicaInfo_ManualCompactStatus_DEFAULT ManualCompactionStatus

func ManualCompactionStatusFromString 

func ManualCompactionStatusFromString(s string) (ManualCompactionStatus, error)

func ManualCompactionStatusPtr 

func ManualCompactionStatusPtr(v ManualCompactionStatus) *ManualCompactionStatus

func (ManualCompactionStatus) MarshalText 

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

func (*ManualCompactionStatus) Scan 

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

func (ManualCompactionStatus) String 

func (p ManualCompactionStatus) String() string

func (*ManualCompactionStatus) UnmarshalText 

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

func (*ManualCompactionStatus) Value 

func (p *ManualCompactionStatus) Value() (driver.Value, 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"`
	Node   *base.RPCAddress `thrift:"node,2" db:"node" json:"node"`
	HpNode *base.HostPort   `thrift:"hp_node,3" db:"hp_node" json:"hp_node,omitempty"`
}

Attributes:

  • Status
  • Node
  • HpNode

func NewNodeInfo 

func NewNodeInfo() *NodeInfo

func (*NodeInfo) GetHpNode 

func (p *NodeInfo) GetHpNode() *base.HostPort

func (*NodeInfo) GetNode 

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

func (*NodeInfo) GetStatus 

func (p *NodeInfo) GetStatus() NodeStatus

func (*NodeInfo) IsSetHpNode 

func (p *NodeInfo) IsSetHpNode() bool

func (*NodeInfo) IsSetNode 

func (p *NodeInfo) IsSetNode() 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) ReadField3 

func (p *NodeInfo) ReadField3(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 NotifyCacthUpResponse 

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

Attributes:

  • Err

func NewNotifyCacthUpResponse 

func NewNotifyCacthUpResponse() *NotifyCacthUpResponse

func (*NotifyCacthUpResponse) GetErr 

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

func (*NotifyCacthUpResponse) IsSetErr 

func (p *NotifyCacthUpResponse) IsSetErr() bool

func (*NotifyCacthUpResponse) Read 

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

func (*NotifyCacthUpResponse) ReadField1 

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

func (*NotifyCacthUpResponse) String 

func (p *NotifyCacthUpResponse) String() string

func (*NotifyCacthUpResponse) Write 

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

type NotifyCatchUpRequest 

type NotifyCatchUpRequest struct {
	ParentGpid  *base.Gpid       `thrift:"parent_gpid,1" db:"parent_gpid" json:"parent_gpid"`
	ChildGpid   *base.Gpid       `thrift:"child_gpid,2" db:"child_gpid" json:"child_gpid"`
	ChildBallot int64            `thrift:"child_ballot,3" db:"child_ballot" json:"child_ballot"`
	Child       *base.RPCAddress `thrift:"child,4" db:"child" json:"child"`
	HpChild     *base.HostPort   `thrift:"hp_child,5" db:"hp_child" json:"hp_child,omitempty"`
}

Attributes:

  • ParentGpid
  • ChildGpid
  • ChildBallot
  • Child
  • HpChild

func NewNotifyCatchUpRequest 

func NewNotifyCatchUpRequest() *NotifyCatchUpRequest

func (*NotifyCatchUpRequest) GetChild 

func (p *NotifyCatchUpRequest) GetChild() *base.RPCAddress

func (*NotifyCatchUpRequest) GetChildBallot 

func (p *NotifyCatchUpRequest) GetChildBallot() int64

func (*NotifyCatchUpRequest) GetChildGpid 

func (p *NotifyCatchUpRequest) GetChildGpid() *base.Gpid

func (*NotifyCatchUpRequest) GetHpChild 

func (p *NotifyCatchUpRequest) GetHpChild() *base.HostPort

func (*NotifyCatchUpRequest) GetParentGpid 

func (p *NotifyCatchUpRequest) GetParentGpid() *base.Gpid

func (*NotifyCatchUpRequest) IsSetChild 

func (p *NotifyCatchUpRequest) IsSetChild() bool

func (*NotifyCatchUpRequest) IsSetChildGpid 

func (p *NotifyCatchUpRequest) IsSetChildGpid() bool

func (*NotifyCatchUpRequest) IsSetHpChild 

func (p *NotifyCatchUpRequest) IsSetHpChild() bool

func (*NotifyCatchUpRequest) IsSetParentGpid 

func (p *NotifyCatchUpRequest) IsSetParentGpid() bool

func (*NotifyCatchUpRequest) Read 

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

func (*NotifyCatchUpRequest) ReadField1 

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

func (*NotifyCatchUpRequest) ReadField2 

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

func (*NotifyCatchUpRequest) ReadField3 

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

func (*NotifyCatchUpRequest) ReadField4 

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

func (*NotifyCatchUpRequest) ReadField5 

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

func (*NotifyCatchUpRequest) String 

func (p *NotifyCatchUpRequest) String() string

func (*NotifyCatchUpRequest) Write 

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

type NotifyStopSplitRequest 

type NotifyStopSplitRequest struct {
	AppName         string      `thrift:"app_name,1" db:"app_name" json:"app_name"`
	ParentGpid      *base.Gpid  `thrift:"parent_gpid,2" db:"parent_gpid" json:"parent_gpid"`
	MetaSplitStatus SplitStatus `thrift:"meta_split_status,3" db:"meta_split_status" json:"meta_split_status"`
	PartitionCount  int32       `thrift:"partition_count,4" db:"partition_count" json:"partition_count"`
}

Attributes:

  • AppName
  • ParentGpid
  • MetaSplitStatus
  • PartitionCount

func NewNotifyStopSplitRequest 

func NewNotifyStopSplitRequest() *NotifyStopSplitRequest

func (*NotifyStopSplitRequest) GetAppName 

func (p *NotifyStopSplitRequest) GetAppName() string

func (*NotifyStopSplitRequest) GetMetaSplitStatus 

func (p *NotifyStopSplitRequest) GetMetaSplitStatus() SplitStatus

func (*NotifyStopSplitRequest) GetParentGpid 

func (p *NotifyStopSplitRequest) GetParentGpid() *base.Gpid

func (*NotifyStopSplitRequest) GetPartitionCount 

func (p *NotifyStopSplitRequest) GetPartitionCount() int32

func (*NotifyStopSplitRequest) IsSetParentGpid 

func (p *NotifyStopSplitRequest) IsSetParentGpid() bool

func (*NotifyStopSplitRequest) Read 

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

func (*NotifyStopSplitRequest) ReadField1 

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

func (*NotifyStopSplitRequest) ReadField2 

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

func (*NotifyStopSplitRequest) ReadField3 

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

func (*NotifyStopSplitRequest) ReadField4 

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

func (*NotifyStopSplitRequest) String 

func (p *NotifyStopSplitRequest) String() string

func (*NotifyStopSplitRequest) Write 

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

type NotifyStopSplitResponse 

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

Attributes:

  • Err

func NewNotifyStopSplitResponse 

func NewNotifyStopSplitResponse() *NotifyStopSplitResponse

func (*NotifyStopSplitResponse) GetErr 

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

func (*NotifyStopSplitResponse) IsSetErr 

func (p *NotifyStopSplitResponse) IsSetErr() bool

func (*NotifyStopSplitResponse) Read 

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

func (*NotifyStopSplitResponse) ReadField1 

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

func (*NotifyStopSplitResponse) String 

func (p *NotifyStopSplitResponse) String() string

func (*NotifyStopSplitResponse) Write 

func (p *NotifyStopSplitResponse) Write(oprot thrift.TProtocol) 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
var GroupBulkLoadResponse_BulkLoadState_DEFAULT *PartitionBulkLoadState

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 PartitionStatus 

type PartitionStatus int64
const (
	PartitionStatus_PS_INVALID             PartitionStatus = 0
	PartitionStatus_PS_INACTIVE            PartitionStatus = 1
	PartitionStatus_PS_ERROR               PartitionStatus = 2
	PartitionStatus_PS_PRIMARY             PartitionStatus = 3
	PartitionStatus_PS_SECONDARY           PartitionStatus = 4
	PartitionStatus_PS_POTENTIAL_SECONDARY PartitionStatus = 5
	PartitionStatus_PS_PARTITION_SPLIT     PartitionStatus = 6
)

func PartitionStatusFromString 

func PartitionStatusFromString(s string) (PartitionStatus, error)

func PartitionStatusPtr 

func PartitionStatusPtr(v PartitionStatus) *PartitionStatus

func (PartitionStatus) MarshalText 

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

func (*PartitionStatus) Scan 

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

func (PartitionStatus) String 

func (p PartitionStatus) String() string

func (*PartitionStatus) UnmarshalText 

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

func (*PartitionStatus) Value 

func (p *PartitionStatus) Value() (driver.Value, 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 PolicyInfo 

type PolicyInfo 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"`
}

Attributes:

  • PolicyName
  • BackupProviderType
var BackupRequest_Policy_DEFAULT *PolicyInfo

func NewPolicyInfo 

func NewPolicyInfo() *PolicyInfo

func (*PolicyInfo) GetBackupProviderType 

func (p *PolicyInfo) GetBackupProviderType() string

func (*PolicyInfo) GetPolicyName 

func (p *PolicyInfo) GetPolicyName() string

func (*PolicyInfo) Read 

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

func (*PolicyInfo) ReadField1 

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

func (*PolicyInfo) ReadField2 

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

func (*PolicyInfo) String 

func (p *PolicyInfo) String() string

func (*PolicyInfo) Write 

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

type QueryAppInfoRequest 

type QueryAppInfoRequest struct {
	MetaServer   *base.RPCAddress `thrift:"meta_server,1" db:"meta_server" json:"meta_server"`
	HpMetaServer *base.HostPort   `thrift:"hp_meta_server,2" db:"hp_meta_server" json:"hp_meta_server,omitempty"`
}

Attributes:

  • MetaServer
  • HpMetaServer
var AdminClientQueryAppInfoArgs_Req_DEFAULT *QueryAppInfoRequest

func NewQueryAppInfoRequest 

func NewQueryAppInfoRequest() *QueryAppInfoRequest

func (*QueryAppInfoRequest) GetHpMetaServer 

func (p *QueryAppInfoRequest) GetHpMetaServer() *base.HostPort

func (*QueryAppInfoRequest) GetMetaServer 

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

func (*QueryAppInfoRequest) IsSetHpMetaServer 

func (p *QueryAppInfoRequest) IsSetHpMetaServer() bool

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) ReadField2 

func (p *QueryAppInfoRequest) ReadField2(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 []*replication.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() []*replication.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 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"`
	IsBulkLoading    *bool                                          `thrift:"is_bulk_loading,8" db:"is_bulk_loading" json:"is_bulk_loading,omitempty"`
	HpBulkLoadStates []map[*base.HostPort]*PartitionBulkLoadState   `thrift:"hp_bulk_load_states,9" db:"hp_bulk_load_states" json:"hp_bulk_load_states,omitempty"`
}

Attributes:

  • Err
  • AppName
  • AppStatus
  • PartitionsStatus
  • MaxReplicaCount
  • BulkLoadStates
  • HintMsg
  • IsBulkLoading
  • HpBulkLoadStates
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) GetHpBulkLoadStates 

func (p *QueryBulkLoadResponse) GetHpBulkLoadStates() []map[*base.HostPort]*PartitionBulkLoadState

func (*QueryBulkLoadResponse) GetIsBulkLoading 

func (p *QueryBulkLoadResponse) GetIsBulkLoading() bool

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) IsSetHpBulkLoadStates 

func (p *QueryBulkLoadResponse) IsSetHpBulkLoadStates() bool

func (*QueryBulkLoadResponse) IsSetIsBulkLoading 

func (p *QueryBulkLoadResponse) IsSetIsBulkLoading() 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) ReadField8 

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

func (*QueryBulkLoadResponse) ReadField9 

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

func (*QueryBulkLoadResponse) String 

func (p *QueryBulkLoadResponse) String() string

func (*QueryBulkLoadResponse) Write 

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

type QueryChildStateRequest 

type QueryChildStateRequest struct {
	AppName        string     `thrift:"app_name,1" db:"app_name" json:"app_name"`
	Pid            *base.Gpid `thrift:"pid,2" db:"pid" json:"pid"`
	PartitionCount int32      `thrift:"partition_count,3" db:"partition_count" json:"partition_count"`
}

Attributes:

  • AppName
  • Pid
  • PartitionCount

func NewQueryChildStateRequest 

func NewQueryChildStateRequest() *QueryChildStateRequest

func (*QueryChildStateRequest) GetAppName 

func (p *QueryChildStateRequest) GetAppName() string

func (*QueryChildStateRequest) GetPartitionCount 

func (p *QueryChildStateRequest) GetPartitionCount() int32

func (*QueryChildStateRequest) GetPid 

func (p *QueryChildStateRequest) GetPid() *base.Gpid

func (*QueryChildStateRequest) IsSetPid 

func (p *QueryChildStateRequest) IsSetPid() bool

func (*QueryChildStateRequest) Read 

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

func (*QueryChildStateRequest) ReadField1 

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

func (*QueryChildStateRequest) ReadField2 

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

func (*QueryChildStateRequest) ReadField3 

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

func (*QueryChildStateRequest) String 

func (p *QueryChildStateRequest) String() string

func (*QueryChildStateRequest) Write 

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

type QueryChildStateResponse 

type QueryChildStateResponse struct {
	Err            *base.ErrorCode                     `thrift:"err,1" db:"err" json:"err"`
	PartitionCount *int32                              `thrift:"partition_count,2" db:"partition_count" json:"partition_count,omitempty"`
	ChildConfig    *replication.PartitionConfiguration `thrift:"child_config,3" db:"child_config" json:"child_config,omitempty"`
}

Attributes:

  • Err
  • PartitionCount
  • ChildConfig

func NewQueryChildStateResponse 

func NewQueryChildStateResponse() *QueryChildStateResponse

func (*QueryChildStateResponse) GetChildConfig 

func (p *QueryChildStateResponse) GetChildConfig() *replication.PartitionConfiguration

func (*QueryChildStateResponse) GetErr 

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

func (*QueryChildStateResponse) GetPartitionCount 

func (p *QueryChildStateResponse) GetPartitionCount() int32

func (*QueryChildStateResponse) IsSetChildConfig 

func (p *QueryChildStateResponse) IsSetChildConfig() bool

func (*QueryChildStateResponse) IsSetErr 

func (p *QueryChildStateResponse) IsSetErr() bool

func (*QueryChildStateResponse) IsSetPartitionCount 

func (p *QueryChildStateResponse) IsSetPartitionCount() bool

func (*QueryChildStateResponse) Read 

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

func (*QueryChildStateResponse) ReadField1 

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

func (*QueryChildStateResponse) ReadField2 

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

func (*QueryChildStateResponse) ReadField3 

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

func (*QueryChildStateResponse) String 

func (p *QueryChildStateResponse) String() string

func (*QueryChildStateResponse) Write 

func (p *QueryChildStateResponse) 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 RegisterChildRequest 

type RegisterChildRequest struct {
	App          *replication.AppInfo                `thrift:"app,1" db:"app" json:"app"`
	ParentConfig *replication.PartitionConfiguration `thrift:"parent_config,2" db:"parent_config" json:"parent_config"`
	ChildConfig  *replication.PartitionConfiguration `thrift:"child_config,3" db:"child_config" json:"child_config"`
	Primary      *base.RPCAddress                    `thrift:"primary,4" db:"primary" json:"primary"`
	HpPrimary    *base.HostPort                      `thrift:"hp_primary,5" db:"hp_primary" json:"hp_primary,omitempty"`
}

Attributes:

  • App
  • ParentConfig
  • ChildConfig
  • Primary
  • HpPrimary

func NewRegisterChildRequest 

func NewRegisterChildRequest() *RegisterChildRequest

func (*RegisterChildRequest) GetApp 

func (p *RegisterChildRequest) GetApp() *replication.AppInfo

func (*RegisterChildRequest) GetChildConfig 

func (p *RegisterChildRequest) GetChildConfig() *replication.PartitionConfiguration

func (*RegisterChildRequest) GetHpPrimary 

func (p *RegisterChildRequest) GetHpPrimary() *base.HostPort

func (*RegisterChildRequest) GetParentConfig 

func (p *RegisterChildRequest) GetParentConfig() *replication.PartitionConfiguration

func (*RegisterChildRequest) GetPrimary 

func (p *RegisterChildRequest) GetPrimary() *base.RPCAddress

func (*RegisterChildRequest) IsSetApp 

func (p *RegisterChildRequest) IsSetApp() bool

func (*RegisterChildRequest) IsSetChildConfig 

func (p *RegisterChildRequest) IsSetChildConfig() bool

func (*RegisterChildRequest) IsSetHpPrimary 

func (p *RegisterChildRequest) IsSetHpPrimary() bool

func (*RegisterChildRequest) IsSetParentConfig 

func (p *RegisterChildRequest) IsSetParentConfig() bool

func (*RegisterChildRequest) IsSetPrimary 

func (p *RegisterChildRequest) IsSetPrimary() bool

func (*RegisterChildRequest) Read 

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

func (*RegisterChildRequest) ReadField1 

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

func (*RegisterChildRequest) ReadField2 

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

func (*RegisterChildRequest) ReadField3 

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

func (*RegisterChildRequest) ReadField4 

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

func (*RegisterChildRequest) ReadField5 

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

func (*RegisterChildRequest) String 

func (p *RegisterChildRequest) String() string

func (*RegisterChildRequest) Write 

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

type RegisterChildResponse 

type RegisterChildResponse struct {
	Err          *base.ErrorCode                     `thrift:"err,1" db:"err" json:"err"`
	App          *replication.AppInfo                `thrift:"app,2" db:"app" json:"app"`
	ParentConfig *replication.PartitionConfiguration `thrift:"parent_config,3" db:"parent_config" json:"parent_config"`
	ChildConfig  *replication.PartitionConfiguration `thrift:"child_config,4" db:"child_config" json:"child_config"`
}

Attributes:

  • Err
  • App
  • ParentConfig
  • ChildConfig

func NewRegisterChildResponse 

func NewRegisterChildResponse() *RegisterChildResponse

func (*RegisterChildResponse) GetApp 

func (p *RegisterChildResponse) GetApp() *replication.AppInfo

func (*RegisterChildResponse) GetChildConfig 

func (p *RegisterChildResponse) GetChildConfig() *replication.PartitionConfiguration

func (*RegisterChildResponse) GetErr 

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

func (*RegisterChildResponse) GetParentConfig 

func (p *RegisterChildResponse) GetParentConfig() *replication.PartitionConfiguration

func (*RegisterChildResponse) IsSetApp 

func (p *RegisterChildResponse) IsSetApp() bool

func (*RegisterChildResponse) IsSetChildConfig 

func (p *RegisterChildResponse) IsSetChildConfig() bool

func (*RegisterChildResponse) IsSetErr 

func (p *RegisterChildResponse) IsSetErr() bool

func (*RegisterChildResponse) IsSetParentConfig 

func (p *RegisterChildResponse) IsSetParentConfig() bool

func (*RegisterChildResponse) Read 

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

func (*RegisterChildResponse) ReadField1 

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

func (*RegisterChildResponse) ReadField2 

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

func (*RegisterChildResponse) ReadField3 

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

func (*RegisterChildResponse) ReadField4 

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

func (*RegisterChildResponse) String 

func (p *RegisterChildResponse) String() string

func (*RegisterChildResponse) Write 

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

type ReplicaConfiguration 

type ReplicaConfiguration struct {
	Pid              *base.Gpid       `thrift:"pid,1" db:"pid" json:"pid"`
	Ballot           int64            `thrift:"ballot,2" db:"ballot" json:"ballot"`
	Primary          *base.RPCAddress `thrift:"primary,3" db:"primary" json:"primary"`
	Status           PartitionStatus  `thrift:"status,4" db:"status" json:"status"`
	LearnerSignature int64            `thrift:"learner_signature,5" db:"learner_signature" json:"learner_signature"`
	PopAll           bool             `thrift:"pop_all,6" db:"pop_all" json:"pop_all"`
	SplitSyncToChild bool             `thrift:"split_sync_to_child,7" db:"split_sync_to_child" json:"split_sync_to_child"`
	HpPrimary        *base.HostPort   `thrift:"hp_primary,8" db:"hp_primary" json:"hp_primary,omitempty"`
}

Attributes:

  • Pid
  • Ballot
  • Primary
  • Status
  • LearnerSignature
  • PopAll
  • SplitSyncToChild
  • HpPrimary
var GroupBulkLoadRequest_Config_DEFAULT *ReplicaConfiguration

func NewReplicaConfiguration 

func NewReplicaConfiguration() *ReplicaConfiguration

func (*ReplicaConfiguration) GetBallot 

func (p *ReplicaConfiguration) GetBallot() int64

func (*ReplicaConfiguration) GetHpPrimary 

func (p *ReplicaConfiguration) GetHpPrimary() *base.HostPort

func (*ReplicaConfiguration) GetLearnerSignature 

func (p *ReplicaConfiguration) GetLearnerSignature() int64

func (*ReplicaConfiguration) GetPid 

func (p *ReplicaConfiguration) GetPid() *base.Gpid

func (*ReplicaConfiguration) GetPopAll 

func (p *ReplicaConfiguration) GetPopAll() bool

func (*ReplicaConfiguration) GetPrimary 

func (p *ReplicaConfiguration) GetPrimary() *base.RPCAddress

func (*ReplicaConfiguration) GetSplitSyncToChild 

func (p *ReplicaConfiguration) GetSplitSyncToChild() bool

func (*ReplicaConfiguration) GetStatus 

func (p *ReplicaConfiguration) GetStatus() PartitionStatus

func (*ReplicaConfiguration) IsSetHpPrimary 

func (p *ReplicaConfiguration) IsSetHpPrimary() bool

func (*ReplicaConfiguration) IsSetPid 

func (p *ReplicaConfiguration) IsSetPid() bool

func (*ReplicaConfiguration) IsSetPopAll 

func (p *ReplicaConfiguration) IsSetPopAll() bool

func (*ReplicaConfiguration) IsSetPrimary 

func (p *ReplicaConfiguration) IsSetPrimary() bool

func (*ReplicaConfiguration) IsSetSplitSyncToChild 

func (p *ReplicaConfiguration) IsSetSplitSyncToChild() bool

func (*ReplicaConfiguration) Read 

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

func (*ReplicaConfiguration) ReadField1 

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

func (*ReplicaConfiguration) ReadField2 

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

func (*ReplicaConfiguration) ReadField3 

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

func (*ReplicaConfiguration) ReadField4 

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

func (*ReplicaConfiguration) ReadField5 

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

func (*ReplicaConfiguration) ReadField6 

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

func (*ReplicaConfiguration) ReadField7 

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

func (*ReplicaConfiguration) ReadField8 

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

func (*ReplicaConfiguration) String 

func (p *ReplicaConfiguration) String() string

func (*ReplicaConfiguration) Write 

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

type ReplicaInfo 

type ReplicaInfo struct {
	Pid                 *base.Gpid              `thrift:"pid,1" db:"pid" json:"pid"`
	Ballot              int64                   `thrift:"ballot,2" db:"ballot" json:"ballot"`
	Status              PartitionStatus         `thrift:"status,3" db:"status" json:"status"`
	LastCommittedDecree int64                   `thrift:"last_committed_decree,4" db:"last_committed_decree" json:"last_committed_decree"`
	LastPreparedDecree  int64                   `thrift:"last_prepared_decree,5" db:"last_prepared_decree" json:"last_prepared_decree"`
	LastDurableDecree   int64                   `thrift:"last_durable_decree,6" db:"last_durable_decree" json:"last_durable_decree"`
	AppType             string                  `thrift:"app_type,7" db:"app_type" json:"app_type"`
	DiskTag             string                  `thrift:"disk_tag,8" db:"disk_tag" json:"disk_tag"`
	ManualCompactStatus *ManualCompactionStatus `thrift:"manual_compact_status,9" db:"manual_compact_status" json:"manual_compact_status,omitempty"`
}

Attributes:

  • Pid
  • Ballot
  • Status
  • LastCommittedDecree
  • LastPreparedDecree
  • LastDurableDecree
  • AppType
  • DiskTag
  • ManualCompactStatus

func NewReplicaInfo 

func NewReplicaInfo() *ReplicaInfo

func (*ReplicaInfo) GetAppType 

func (p *ReplicaInfo) GetAppType() string

func (*ReplicaInfo) GetBallot 

func (p *ReplicaInfo) GetBallot() int64

func (*ReplicaInfo) GetDiskTag 

func (p *ReplicaInfo) GetDiskTag() string

func (*ReplicaInfo) GetLastCommittedDecree 

func (p *ReplicaInfo) GetLastCommittedDecree() int64

func (*ReplicaInfo) GetLastDurableDecree 

func (p *ReplicaInfo) GetLastDurableDecree() int64

func (*ReplicaInfo) GetLastPreparedDecree 

func (p *ReplicaInfo) GetLastPreparedDecree() int64

func (*ReplicaInfo) GetManualCompactStatus 

func (p *ReplicaInfo) GetManualCompactStatus() ManualCompactionStatus

func (*ReplicaInfo) GetPid 

func (p *ReplicaInfo) GetPid() *base.Gpid

func (*ReplicaInfo) GetStatus 

func (p *ReplicaInfo) GetStatus() PartitionStatus

func (*ReplicaInfo) IsSetManualCompactStatus 

func (p *ReplicaInfo) IsSetManualCompactStatus() bool

func (*ReplicaInfo) IsSetPid 

func (p *ReplicaInfo) IsSetPid() bool

func (*ReplicaInfo) Read 

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

func (*ReplicaInfo) ReadField1 

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

func (*ReplicaInfo) ReadField2 

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

func (*ReplicaInfo) ReadField3 

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

func (*ReplicaInfo) ReadField4 

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

func (*ReplicaInfo) ReadField5 

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

func (*ReplicaInfo) ReadField6 

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

func (*ReplicaInfo) ReadField7 

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

func (*ReplicaInfo) ReadField8 

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

func (*ReplicaInfo) ReadField9 

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

func (*ReplicaInfo) String 

func (p *ReplicaInfo) String() string

func (*ReplicaInfo) Write 

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

type ReplicaServerInfo 

type ReplicaServerInfo struct {
	GeoTags         map[string]string `thrift:"geo_tags,1" db:"geo_tags" json:"geo_tags"`
	TotalCapacityMb int64             `thrift:"total_capacity_mb,2" db:"total_capacity_mb" json:"total_capacity_mb"`
}

Attributes:

  • GeoTags
  • TotalCapacityMb
var ConfigurationQueryByNodeRequest_Info_DEFAULT *ReplicaServerInfo

func NewReplicaServerInfo 

func NewReplicaServerInfo() *ReplicaServerInfo

func (*ReplicaServerInfo) GetGeoTags 

func (p *ReplicaServerInfo) GetGeoTags() map[string]string

func (*ReplicaServerInfo) GetTotalCapacityMb 

func (p *ReplicaServerInfo) GetTotalCapacityMb() int64

func (*ReplicaServerInfo) Read 

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

func (*ReplicaServerInfo) ReadField1 

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

func (*ReplicaServerInfo) ReadField2 

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

func (*ReplicaServerInfo) String 

func (p *ReplicaServerInfo) String() string

func (*ReplicaServerInfo) Write 

func (p *ReplicaServerInfo) 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
)
var ConfigurationUpdateRequest_MetaSplitStatus_DEFAULT SplitStatus

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"`
	IngestBehind     bool   `thrift:"ingest_behind,5" db:"ingest_behind" json:"ingest_behind"`
}

Attributes:

  • AppName
  • ClusterName
  • FileProviderType
  • RemoteRootPath
  • IngestBehind
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) GetIngestBehind 

func (p *StartBulkLoadRequest) GetIngestBehind() bool

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) ReadField5 

func (p *StartBulkLoadRequest) ReadField5(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 UpdateChildGroupPartitionCountRequest 

type UpdateChildGroupPartitionCountRequest struct {
	Target             *base.RPCAddress `thrift:"target,1" db:"target" json:"target"`
	NewPartitionCount_ int32            `thrift:"new_partition_count,2" db:"new_partition_count" json:"new_partition_count"`
	ChildPid           *base.Gpid       `thrift:"child_pid,3" db:"child_pid" json:"child_pid"`
	Ballot             int64            `thrift:"ballot,4" db:"ballot" json:"ballot"`
	HpTarget           *base.HostPort   `thrift:"hp_target,5" db:"hp_target" json:"hp_target,omitempty"`
}

Attributes:

  • Target
  • NewPartitionCount_
  • ChildPid
  • Ballot
  • HpTarget

func NewUpdateChildGroupPartitionCountRequest 

func NewUpdateChildGroupPartitionCountRequest() *UpdateChildGroupPartitionCountRequest

func (*UpdateChildGroupPartitionCountRequest) GetBallot 

func (p *UpdateChildGroupPartitionCountRequest) GetBallot() int64

func (*UpdateChildGroupPartitionCountRequest) GetChildPid 

func (p *UpdateChildGroupPartitionCountRequest) GetChildPid() *base.Gpid

func (*UpdateChildGroupPartitionCountRequest) GetHpTarget 

func (p *UpdateChildGroupPartitionCountRequest) GetHpTarget() *base.HostPort

func (*UpdateChildGroupPartitionCountRequest) GetNewPartitionCount_ 

func (p *UpdateChildGroupPartitionCountRequest) GetNewPartitionCount_() int32

func (*UpdateChildGroupPartitionCountRequest) GetTarget 

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

func (*UpdateChildGroupPartitionCountRequest) IsSetChildPid 

func (p *UpdateChildGroupPartitionCountRequest) IsSetChildPid() bool

func (*UpdateChildGroupPartitionCountRequest) IsSetHpTarget 

func (p *UpdateChildGroupPartitionCountRequest) IsSetHpTarget() bool

func (*UpdateChildGroupPartitionCountRequest) IsSetTarget 

func (p *UpdateChildGroupPartitionCountRequest) IsSetTarget() bool

func (*UpdateChildGroupPartitionCountRequest) Read 

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

func (*UpdateChildGroupPartitionCountRequest) ReadField1 

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

func (*UpdateChildGroupPartitionCountRequest) ReadField2 

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

func (*UpdateChildGroupPartitionCountRequest) ReadField3 

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

func (*UpdateChildGroupPartitionCountRequest) ReadField4 

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

func (*UpdateChildGroupPartitionCountRequest) ReadField5 

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

func (*UpdateChildGroupPartitionCountRequest) String 

func (p *UpdateChildGroupPartitionCountRequest) String() string

func (*UpdateChildGroupPartitionCountRequest) Write 

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

type UpdateChildGroupPartitionCountResponse 

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

Attributes:

  • Err

func NewUpdateChildGroupPartitionCountResponse 

func NewUpdateChildGroupPartitionCountResponse() *UpdateChildGroupPartitionCountResponse

func (*UpdateChildGroupPartitionCountResponse) GetErr 

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

func (*UpdateChildGroupPartitionCountResponse) IsSetErr 

func (p *UpdateChildGroupPartitionCountResponse) IsSetErr() bool

func (*UpdateChildGroupPartitionCountResponse) Read 

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

func (*UpdateChildGroupPartitionCountResponse) ReadField1 

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

func (*UpdateChildGroupPartitionCountResponse) String 

func (p *UpdateChildGroupPartitionCountResponse) String() string

func (*UpdateChildGroupPartitionCountResponse) Write 

func (p *UpdateChildGroupPartitionCountResponse) 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.