radmin

package
v0.0.0-...-1091da5 Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2025 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 2 more Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AddNewDiskResponse_ErrHint_DEFAULT string
View Source 
var AddNewDiskResponse_Err_DEFAULT *base.ErrorCode
View Source 
var DetectHotkeyRequest_Pid_DEFAULT *base.Gpid
View Source 
var DetectHotkeyResponse_ErrHint_DEFAULT string
View Source 
var DetectHotkeyResponse_Err_DEFAULT *base.ErrorCode
View Source 
var DetectHotkeyResponse_HotkeyResult__DEFAULT string
View Source 
var GoUnusedProtection__ int
View Source 
var QueryDiskInfoRequest_HpNode1_DEFAULT *base.HostPort
View Source 
var QueryDiskInfoRequest_Node1_DEFAULT *base.RPCAddress
View Source 
var QueryDiskInfoResponse_Err_DEFAULT *base.ErrorCode
View Source 
var QueryReplicaDecreeRequest_HpNode1_DEFAULT *base.HostPort
View Source 
var QueryReplicaDecreeRequest_Node1_DEFAULT *base.RPCAddress
View Source 
var QueryReplicaDecreeRequest_Pid_DEFAULT *base.Gpid
View Source 
var QueryReplicaDecreeResponse_Err_DEFAULT *base.ErrorCode
View Source 
var QueryReplicaInfoRequest_HpNode1_DEFAULT *base.HostPort
View Source 
var QueryReplicaInfoRequest_Node1_DEFAULT *base.RPCAddress
View Source 
var QueryReplicaInfoResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ReplicaDiskMigrateRequest_Pid_DEFAULT *base.Gpid
View Source 
var ReplicaDiskMigrateResponse_Err_DEFAULT *base.ErrorCode
View Source 
var ReplicaDiskMigrateResponse_Hint_DEFAULT string

Functions

This section is empty.

Types

type AddNewDiskRequest 

type AddNewDiskRequest struct {
	DiskStr string `thrift:"disk_str,1" db:"disk_str" json:"disk_str"`
}

Attributes:

  • DiskStr
var ReplicaClientAddDiskArgs_Req_DEFAULT *AddNewDiskRequest

func NewAddNewDiskRequest 

func NewAddNewDiskRequest() *AddNewDiskRequest

func (*AddNewDiskRequest) GetDiskStr 

func (p *AddNewDiskRequest) GetDiskStr() string

func (*AddNewDiskRequest) Read 

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

func (*AddNewDiskRequest) ReadField1 

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

func (*AddNewDiskRequest) String 

func (p *AddNewDiskRequest) String() string

func (*AddNewDiskRequest) Write 

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

type AddNewDiskResponse 

type AddNewDiskResponse struct {
	Err     *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	ErrHint *string         `thrift:"err_hint,2" db:"err_hint" json:"err_hint,omitempty"`
}

Attributes:

  • Err
  • ErrHint
var ReplicaClientAddDiskResult_Success_DEFAULT *AddNewDiskResponse

func NewAddNewDiskResponse 

func NewAddNewDiskResponse() *AddNewDiskResponse

func (*AddNewDiskResponse) GetErr 

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

func (*AddNewDiskResponse) GetErrHint 

func (p *AddNewDiskResponse) GetErrHint() string

func (*AddNewDiskResponse) IsSetErr 

func (p *AddNewDiskResponse) IsSetErr() bool

func (*AddNewDiskResponse) IsSetErrHint 

func (p *AddNewDiskResponse) IsSetErrHint() bool

func (*AddNewDiskResponse) Read 

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

func (*AddNewDiskResponse) ReadField1 

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

func (*AddNewDiskResponse) ReadField2 

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

func (*AddNewDiskResponse) String 

func (p *AddNewDiskResponse) String() string

func (*AddNewDiskResponse) Write 

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

type DetectAction 

type DetectAction int64
const (
	DetectAction_START DetectAction = 0
	DetectAction_STOP  DetectAction = 1
	DetectAction_QUERY DetectAction = 2
)

func DetectActionFromString 

func DetectActionFromString(s string) (DetectAction, error)

func DetectActionPtr 

func DetectActionPtr(v DetectAction) *DetectAction

func (DetectAction) MarshalText 

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

func (*DetectAction) Scan 

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

func (DetectAction) String 

func (p DetectAction) String() string

func (*DetectAction) UnmarshalText 

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

func (*DetectAction) Value 

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

type DetectHotkeyRequest 

type DetectHotkeyRequest struct {
	Type   HotkeyType   `thrift:"type,1" db:"type" json:"type"`
	Action DetectAction `thrift:"action,2" db:"action" json:"action"`
	Pid    *base.Gpid   `thrift:"pid,3" db:"pid" json:"pid"`
}

Attributes:

  • Type
  • Action
  • Pid

func NewDetectHotkeyRequest 

func NewDetectHotkeyRequest() *DetectHotkeyRequest

func (*DetectHotkeyRequest) GetAction 

func (p *DetectHotkeyRequest) GetAction() DetectAction

func (*DetectHotkeyRequest) GetPid 

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

func (*DetectHotkeyRequest) GetType 

func (p *DetectHotkeyRequest) GetType() HotkeyType

func (*DetectHotkeyRequest) IsSetPid 

func (p *DetectHotkeyRequest) IsSetPid() bool

func (*DetectHotkeyRequest) Read 

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

func (*DetectHotkeyRequest) ReadField1 

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

func (*DetectHotkeyRequest) ReadField2 

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

func (*DetectHotkeyRequest) ReadField3 

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

func (*DetectHotkeyRequest) String 

func (p *DetectHotkeyRequest) String() string

func (*DetectHotkeyRequest) Write 

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

type DetectHotkeyResponse 

type DetectHotkeyResponse struct {
	Err           *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	ErrHint       *string         `thrift:"err_hint,2" db:"err_hint" json:"err_hint,omitempty"`
	HotkeyResult_ *string         `thrift:"hotkey_result,3" db:"hotkey_result" json:"hotkey_result,omitempty"`
}

Attributes:

  • Err
  • ErrHint
  • HotkeyResult_

func NewDetectHotkeyResponse 

func NewDetectHotkeyResponse() *DetectHotkeyResponse

func (*DetectHotkeyResponse) GetErr 

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

func (*DetectHotkeyResponse) GetErrHint 

func (p *DetectHotkeyResponse) GetErrHint() string

func (*DetectHotkeyResponse) GetHotkeyResult_ 

func (p *DetectHotkeyResponse) GetHotkeyResult_() string

func (*DetectHotkeyResponse) IsSetErr 

func (p *DetectHotkeyResponse) IsSetErr() bool

func (*DetectHotkeyResponse) IsSetErrHint 

func (p *DetectHotkeyResponse) IsSetErrHint() bool

func (*DetectHotkeyResponse) IsSetHotkeyResult_ 

func (p *DetectHotkeyResponse) IsSetHotkeyResult_() bool

func (*DetectHotkeyResponse) Read 

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

func (*DetectHotkeyResponse) ReadField1 

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

func (*DetectHotkeyResponse) ReadField2 

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

func (*DetectHotkeyResponse) ReadField3 

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

func (*DetectHotkeyResponse) String 

func (p *DetectHotkeyResponse) String() string

func (*DetectHotkeyResponse) Write 

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

type DiskInfo 

type DiskInfo struct {
	Tag                      string                 `thrift:"tag,1" db:"tag" json:"tag"`
	FullDir                  string                 `thrift:"full_dir,2" db:"full_dir" json:"full_dir"`
	DiskCapacityMb           int64                  `thrift:"disk_capacity_mb,3" db:"disk_capacity_mb" json:"disk_capacity_mb"`
	DiskAvailableMb          int64                  `thrift:"disk_available_mb,4" db:"disk_available_mb" json:"disk_available_mb"`
	HoldingPrimaryReplicas   map[int32][]*base.Gpid `thrift:"holding_primary_replicas,5" db:"holding_primary_replicas" json:"holding_primary_replicas"`
	HoldingSecondaryReplicas map[int32][]*base.Gpid `thrift:"holding_secondary_replicas,6" db:"holding_secondary_replicas" json:"holding_secondary_replicas"`
}

Attributes:

  • Tag
  • FullDir
  • DiskCapacityMb
  • DiskAvailableMb
  • HoldingPrimaryReplicas
  • HoldingSecondaryReplicas

func NewDiskInfo 

func NewDiskInfo() *DiskInfo

func (*DiskInfo) GetDiskAvailableMb 

func (p *DiskInfo) GetDiskAvailableMb() int64

func (*DiskInfo) GetDiskCapacityMb 

func (p *DiskInfo) GetDiskCapacityMb() int64

func (*DiskInfo) GetFullDir 

func (p *DiskInfo) GetFullDir() string

func (*DiskInfo) GetHoldingPrimaryReplicas 

func (p *DiskInfo) GetHoldingPrimaryReplicas() map[int32][]*base.Gpid

func (*DiskInfo) GetHoldingSecondaryReplicas 

func (p *DiskInfo) GetHoldingSecondaryReplicas() map[int32][]*base.Gpid

func (*DiskInfo) GetTag 

func (p *DiskInfo) GetTag() string

func (*DiskInfo) Read 

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

func (*DiskInfo) ReadField1 

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

func (*DiskInfo) ReadField2 

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

func (*DiskInfo) ReadField3 

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

func (*DiskInfo) ReadField4 

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

func (*DiskInfo) ReadField5 

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

func (*DiskInfo) ReadField6 

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

func (*DiskInfo) String 

func (p *DiskInfo) String() string

func (*DiskInfo) Write 

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

type DiskMigrationStatus 

type DiskMigrationStatus int64
const (
	DiskMigrationStatus_IDLE   DiskMigrationStatus = 0
	DiskMigrationStatus_MOVING DiskMigrationStatus = 1
	DiskMigrationStatus_MOVED  DiskMigrationStatus = 2
	DiskMigrationStatus_CLOSED DiskMigrationStatus = 3
)

func DiskMigrationStatusFromString 

func DiskMigrationStatusFromString(s string) (DiskMigrationStatus, error)

func DiskMigrationStatusPtr 

func DiskMigrationStatusPtr(v DiskMigrationStatus) *DiskMigrationStatus

func (DiskMigrationStatus) MarshalText 

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

func (*DiskMigrationStatus) Scan 

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

func (DiskMigrationStatus) String 

func (p DiskMigrationStatus) String() string

func (*DiskMigrationStatus) UnmarshalText 

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

func (*DiskMigrationStatus) Value 

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

type HotkeyType 

type HotkeyType int64
const (
	HotkeyType_READ  HotkeyType = 0
	HotkeyType_WRITE HotkeyType = 1
)

func HotkeyTypeFromString 

func HotkeyTypeFromString(s string) (HotkeyType, error)

func HotkeyTypePtr 

func HotkeyTypePtr(v HotkeyType) *HotkeyType

func (HotkeyType) MarshalText 

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

func (*HotkeyType) Scan 

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

func (HotkeyType) String 

func (p HotkeyType) String() string

func (*HotkeyType) UnmarshalText 

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

func (*HotkeyType) Value 

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

type QueryDiskInfoRequest 

type QueryDiskInfoRequest struct {
	Node1   *base.RPCAddress `thrift:"node1,1" db:"node1" json:"node1"`
	AppName string           `thrift:"app_name,2" db:"app_name" json:"app_name"`
	HpNode1 *base.HostPort   `thrift:"hp_node1,3" db:"hp_node1" json:"hp_node1,omitempty"`
}

Attributes:

  • Node1
  • AppName
  • HpNode1
var ReplicaClientQueryDiskInfoArgs_Req_DEFAULT *QueryDiskInfoRequest

func NewQueryDiskInfoRequest 

func NewQueryDiskInfoRequest() *QueryDiskInfoRequest

func (*QueryDiskInfoRequest) GetAppName 

func (p *QueryDiskInfoRequest) GetAppName() string

func (*QueryDiskInfoRequest) GetHpNode1 

func (p *QueryDiskInfoRequest) GetHpNode1() *base.HostPort

func (*QueryDiskInfoRequest) GetNode1 

func (p *QueryDiskInfoRequest) GetNode1() *base.RPCAddress

func (*QueryDiskInfoRequest) IsSetHpNode1 

func (p *QueryDiskInfoRequest) IsSetHpNode1() bool

func (*QueryDiskInfoRequest) IsSetNode1 

func (p *QueryDiskInfoRequest) IsSetNode1() bool

func (*QueryDiskInfoRequest) Read 

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

func (*QueryDiskInfoRequest) ReadField1 

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

func (*QueryDiskInfoRequest) ReadField2 

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

func (*QueryDiskInfoRequest) ReadField3 

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

func (*QueryDiskInfoRequest) String 

func (p *QueryDiskInfoRequest) String() string

func (*QueryDiskInfoRequest) Write 

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

type QueryDiskInfoResponse 

type QueryDiskInfoResponse struct {
	Err              *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	TotalCapacityMb  int64           `thrift:"total_capacity_mb,2" db:"total_capacity_mb" json:"total_capacity_mb"`
	TotalAvailableMb int64           `thrift:"total_available_mb,3" db:"total_available_mb" json:"total_available_mb"`
	DiskInfos        []*DiskInfo     `thrift:"disk_infos,4" db:"disk_infos" json:"disk_infos"`
}

Attributes:

  • Err
  • TotalCapacityMb
  • TotalAvailableMb
  • DiskInfos
var ReplicaClientQueryDiskInfoResult_Success_DEFAULT *QueryDiskInfoResponse

func NewQueryDiskInfoResponse 

func NewQueryDiskInfoResponse() *QueryDiskInfoResponse

func (*QueryDiskInfoResponse) GetDiskInfos 

func (p *QueryDiskInfoResponse) GetDiskInfos() []*DiskInfo

func (*QueryDiskInfoResponse) GetErr 

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

func (*QueryDiskInfoResponse) GetTotalAvailableMb 

func (p *QueryDiskInfoResponse) GetTotalAvailableMb() int64

func (*QueryDiskInfoResponse) GetTotalCapacityMb 

func (p *QueryDiskInfoResponse) GetTotalCapacityMb() int64

func (*QueryDiskInfoResponse) IsSetErr 

func (p *QueryDiskInfoResponse) IsSetErr() bool

func (*QueryDiskInfoResponse) Read 

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

func (*QueryDiskInfoResponse) ReadField1 

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

func (*QueryDiskInfoResponse) ReadField2 

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

func (*QueryDiskInfoResponse) ReadField3 

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

func (*QueryDiskInfoResponse) ReadField4 

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

func (*QueryDiskInfoResponse) String 

func (p *QueryDiskInfoResponse) String() string

func (*QueryDiskInfoResponse) Write 

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

type QueryReplicaDecreeRequest 

type QueryReplicaDecreeRequest struct {
	Pid     *base.Gpid       `thrift:"pid,1" db:"pid" json:"pid"`
	Node1   *base.RPCAddress `thrift:"node1,2" db:"node1" json:"node1"`
	HpNode1 *base.HostPort   `thrift:"hp_node1,3" db:"hp_node1" json:"hp_node1,omitempty"`
}

Attributes:

  • Pid
  • Node1
  • HpNode1

func NewQueryReplicaDecreeRequest 

func NewQueryReplicaDecreeRequest() *QueryReplicaDecreeRequest

func (*QueryReplicaDecreeRequest) GetHpNode1 

func (p *QueryReplicaDecreeRequest) GetHpNode1() *base.HostPort

func (*QueryReplicaDecreeRequest) GetNode1 

func (p *QueryReplicaDecreeRequest) GetNode1() *base.RPCAddress

func (*QueryReplicaDecreeRequest) GetPid 

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

func (*QueryReplicaDecreeRequest) IsSetHpNode1 

func (p *QueryReplicaDecreeRequest) IsSetHpNode1() bool

func (*QueryReplicaDecreeRequest) IsSetNode1 

func (p *QueryReplicaDecreeRequest) IsSetNode1() bool

func (*QueryReplicaDecreeRequest) IsSetPid 

func (p *QueryReplicaDecreeRequest) IsSetPid() bool

func (*QueryReplicaDecreeRequest) Read 

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

func (*QueryReplicaDecreeRequest) ReadField1 

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

func (*QueryReplicaDecreeRequest) ReadField2 

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

func (*QueryReplicaDecreeRequest) ReadField3 

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

func (*QueryReplicaDecreeRequest) String 

func (p *QueryReplicaDecreeRequest) String() string

func (*QueryReplicaDecreeRequest) Write 

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

type QueryReplicaDecreeResponse 

type QueryReplicaDecreeResponse struct {
	Err        *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	LastDecree int64           `thrift:"last_decree,2" db:"last_decree" json:"last_decree"`
}

Attributes:

  • Err
  • LastDecree

func NewQueryReplicaDecreeResponse 

func NewQueryReplicaDecreeResponse() *QueryReplicaDecreeResponse

func (*QueryReplicaDecreeResponse) GetErr 

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

func (*QueryReplicaDecreeResponse) GetLastDecree 

func (p *QueryReplicaDecreeResponse) GetLastDecree() int64

func (*QueryReplicaDecreeResponse) IsSetErr 

func (p *QueryReplicaDecreeResponse) IsSetErr() bool

func (*QueryReplicaDecreeResponse) Read 

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

func (*QueryReplicaDecreeResponse) ReadField1 

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

func (*QueryReplicaDecreeResponse) ReadField2 

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

func (*QueryReplicaDecreeResponse) String 

func (p *QueryReplicaDecreeResponse) String() string

func (*QueryReplicaDecreeResponse) Write 

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

type QueryReplicaInfoRequest 

type QueryReplicaInfoRequest struct {
	Node1   *base.RPCAddress `thrift:"node1,1" db:"node1" json:"node1"`
	HpNode1 *base.HostPort   `thrift:"hp_node1,2" db:"hp_node1" json:"hp_node1,omitempty"`
}

Attributes:

  • Node1
  • HpNode1

func NewQueryReplicaInfoRequest 

func NewQueryReplicaInfoRequest() *QueryReplicaInfoRequest

func (*QueryReplicaInfoRequest) GetHpNode1 

func (p *QueryReplicaInfoRequest) GetHpNode1() *base.HostPort

func (*QueryReplicaInfoRequest) GetNode1 

func (p *QueryReplicaInfoRequest) GetNode1() *base.RPCAddress

func (*QueryReplicaInfoRequest) IsSetHpNode1 

func (p *QueryReplicaInfoRequest) IsSetHpNode1() bool

func (*QueryReplicaInfoRequest) IsSetNode1 

func (p *QueryReplicaInfoRequest) IsSetNode1() bool

func (*QueryReplicaInfoRequest) Read 

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

func (*QueryReplicaInfoRequest) ReadField1 

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

func (*QueryReplicaInfoRequest) ReadField2 

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

func (*QueryReplicaInfoRequest) String 

func (p *QueryReplicaInfoRequest) String() string

func (*QueryReplicaInfoRequest) Write 

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

type QueryReplicaInfoResponse 

type QueryReplicaInfoResponse struct {
	Err      *base.ErrorCode      `thrift:"err,1" db:"err" json:"err"`
	Replicas []*admin.ReplicaInfo `thrift:"replicas,2" db:"replicas" json:"replicas"`
}

Attributes:

  • Err
  • Replicas

func NewQueryReplicaInfoResponse 

func NewQueryReplicaInfoResponse() *QueryReplicaInfoResponse

func (*QueryReplicaInfoResponse) GetErr 

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

func (*QueryReplicaInfoResponse) GetReplicas 

func (p *QueryReplicaInfoResponse) GetReplicas() []*admin.ReplicaInfo

func (*QueryReplicaInfoResponse) IsSetErr 

func (p *QueryReplicaInfoResponse) IsSetErr() bool

func (*QueryReplicaInfoResponse) Read 

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

func (*QueryReplicaInfoResponse) ReadField1 

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

func (*QueryReplicaInfoResponse) ReadField2 

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

func (*QueryReplicaInfoResponse) String 

func (p *QueryReplicaInfoResponse) String() string

func (*QueryReplicaInfoResponse) Write 

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

type ReplicaClient 

type ReplicaClient interface {
	// Parameters:
	//  - Req
	QueryDiskInfo(ctx context.Context, req *QueryDiskInfoRequest) (r *QueryDiskInfoResponse, err error)
	// Parameters:
	//  - Req
	DiskMigrate(ctx context.Context, req *ReplicaDiskMigrateRequest) (r *ReplicaDiskMigrateResponse, err error)
	// Parameters:
	//  - Req
	AddDisk(ctx context.Context, req *AddNewDiskRequest) (r *AddNewDiskResponse, err error)
}

type ReplicaClientAddDiskArgs 

type ReplicaClientAddDiskArgs struct {
	Req *AddNewDiskRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewReplicaClientAddDiskArgs 

func NewReplicaClientAddDiskArgs() *ReplicaClientAddDiskArgs

func (*ReplicaClientAddDiskArgs) GetReq 

func (p *ReplicaClientAddDiskArgs) GetReq() *AddNewDiskRequest

func (*ReplicaClientAddDiskArgs) IsSetReq 

func (p *ReplicaClientAddDiskArgs) IsSetReq() bool

func (*ReplicaClientAddDiskArgs) Read 

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

func (*ReplicaClientAddDiskArgs) ReadField1 

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

func (*ReplicaClientAddDiskArgs) String 

func (p *ReplicaClientAddDiskArgs) String() string

func (*ReplicaClientAddDiskArgs) Write 

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

type ReplicaClientAddDiskResult 

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

Attributes:

  • Success

func NewReplicaClientAddDiskResult 

func NewReplicaClientAddDiskResult() *ReplicaClientAddDiskResult

func (*ReplicaClientAddDiskResult) GetSuccess 

func (p *ReplicaClientAddDiskResult) GetSuccess() *AddNewDiskResponse

func (*ReplicaClientAddDiskResult) IsSetSuccess 

func (p *ReplicaClientAddDiskResult) IsSetSuccess() bool

func (*ReplicaClientAddDiskResult) Read 

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

func (*ReplicaClientAddDiskResult) ReadField0 

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

func (*ReplicaClientAddDiskResult) String 

func (p *ReplicaClientAddDiskResult) String() string

func (*ReplicaClientAddDiskResult) Write 

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

type ReplicaClientClient 

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

func NewReplicaClientClient 

func NewReplicaClientClient(c thrift.TClient) *ReplicaClientClient

func NewReplicaClientClientFactory 

func NewReplicaClientClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ReplicaClientClient

func NewReplicaClientClientProtocol 

func NewReplicaClientClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ReplicaClientClient

func (*ReplicaClientClient) AddDisk 

func (p *ReplicaClientClient) AddDisk(ctx context.Context, req *AddNewDiskRequest) (r *AddNewDiskResponse, err error)

Parameters:

  • Req

func (*ReplicaClientClient) Client_ 

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

func (*ReplicaClientClient) DiskMigrate 

func (p *ReplicaClientClient) DiskMigrate(ctx context.Context, req *ReplicaDiskMigrateRequest) (r *ReplicaDiskMigrateResponse, err error)

Parameters:

  • Req

func (*ReplicaClientClient) QueryDiskInfo 

func (p *ReplicaClientClient) QueryDiskInfo(ctx context.Context, req *QueryDiskInfoRequest) (r *QueryDiskInfoResponse, err error)

Parameters:

  • Req

type ReplicaClientDiskMigrateArgs 

type ReplicaClientDiskMigrateArgs struct {
	Req *ReplicaDiskMigrateRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewReplicaClientDiskMigrateArgs 

func NewReplicaClientDiskMigrateArgs() *ReplicaClientDiskMigrateArgs

func (*ReplicaClientDiskMigrateArgs) GetReq 

func (p *ReplicaClientDiskMigrateArgs) GetReq() *ReplicaDiskMigrateRequest

func (*ReplicaClientDiskMigrateArgs) IsSetReq 

func (p *ReplicaClientDiskMigrateArgs) IsSetReq() bool

func (*ReplicaClientDiskMigrateArgs) Read 

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

func (*ReplicaClientDiskMigrateArgs) ReadField1 

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

func (*ReplicaClientDiskMigrateArgs) String 

func (p *ReplicaClientDiskMigrateArgs) String() string

func (*ReplicaClientDiskMigrateArgs) Write 

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

type ReplicaClientDiskMigrateResult 

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

Attributes:

  • Success

func NewReplicaClientDiskMigrateResult 

func NewReplicaClientDiskMigrateResult() *ReplicaClientDiskMigrateResult

func (*ReplicaClientDiskMigrateResult) GetSuccess 

func (p *ReplicaClientDiskMigrateResult) GetSuccess() *ReplicaDiskMigrateResponse

func (*ReplicaClientDiskMigrateResult) IsSetSuccess 

func (p *ReplicaClientDiskMigrateResult) IsSetSuccess() bool

func (*ReplicaClientDiskMigrateResult) Read 

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

func (*ReplicaClientDiskMigrateResult) ReadField0 

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

func (*ReplicaClientDiskMigrateResult) String 

func (p *ReplicaClientDiskMigrateResult) String() string

func (*ReplicaClientDiskMigrateResult) Write 

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

type ReplicaClientProcessor 

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

func NewReplicaClientProcessor 

func NewReplicaClientProcessor(handler ReplicaClient) *ReplicaClientProcessor

func (*ReplicaClientProcessor) AddToProcessorMap 

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

func (*ReplicaClientProcessor) GetProcessorFunction 

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

func (*ReplicaClientProcessor) Process 

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

func (*ReplicaClientProcessor) ProcessorMap 

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

type ReplicaClientQueryDiskInfoArgs 

type ReplicaClientQueryDiskInfoArgs struct {
	Req *QueryDiskInfoRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewReplicaClientQueryDiskInfoArgs 

func NewReplicaClientQueryDiskInfoArgs() *ReplicaClientQueryDiskInfoArgs

func (*ReplicaClientQueryDiskInfoArgs) GetReq 

func (p *ReplicaClientQueryDiskInfoArgs) GetReq() *QueryDiskInfoRequest

func (*ReplicaClientQueryDiskInfoArgs) IsSetReq 

func (p *ReplicaClientQueryDiskInfoArgs) IsSetReq() bool

func (*ReplicaClientQueryDiskInfoArgs) Read 

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

func (*ReplicaClientQueryDiskInfoArgs) ReadField1 

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

func (*ReplicaClientQueryDiskInfoArgs) String 

func (p *ReplicaClientQueryDiskInfoArgs) String() string

func (*ReplicaClientQueryDiskInfoArgs) Write 

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

type ReplicaClientQueryDiskInfoResult 

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

Attributes:

  • Success

func NewReplicaClientQueryDiskInfoResult 

func NewReplicaClientQueryDiskInfoResult() *ReplicaClientQueryDiskInfoResult

func (*ReplicaClientQueryDiskInfoResult) GetSuccess 

func (p *ReplicaClientQueryDiskInfoResult) GetSuccess() *QueryDiskInfoResponse

func (*ReplicaClientQueryDiskInfoResult) IsSetSuccess 

func (p *ReplicaClientQueryDiskInfoResult) IsSetSuccess() bool

func (*ReplicaClientQueryDiskInfoResult) Read 

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

func (*ReplicaClientQueryDiskInfoResult) ReadField0 

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

func (*ReplicaClientQueryDiskInfoResult) String 

func (p *ReplicaClientQueryDiskInfoResult) String() string

func (*ReplicaClientQueryDiskInfoResult) Write 

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

type ReplicaDiskMigrateRequest 

type ReplicaDiskMigrateRequest struct {
	Pid        *base.Gpid `thrift:"pid,1" db:"pid" json:"pid"`
	OriginDisk string     `thrift:"origin_disk,2" db:"origin_disk" json:"origin_disk"`
	TargetDisk string     `thrift:"target_disk,3" db:"target_disk" json:"target_disk"`
}

Attributes:

  • Pid
  • OriginDisk
  • TargetDisk
var ReplicaClientDiskMigrateArgs_Req_DEFAULT *ReplicaDiskMigrateRequest

func NewReplicaDiskMigrateRequest 

func NewReplicaDiskMigrateRequest() *ReplicaDiskMigrateRequest

func (*ReplicaDiskMigrateRequest) GetOriginDisk 

func (p *ReplicaDiskMigrateRequest) GetOriginDisk() string

func (*ReplicaDiskMigrateRequest) GetPid 

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

func (*ReplicaDiskMigrateRequest) GetTargetDisk 

func (p *ReplicaDiskMigrateRequest) GetTargetDisk() string

func (*ReplicaDiskMigrateRequest) IsSetPid 

func (p *ReplicaDiskMigrateRequest) IsSetPid() bool

func (*ReplicaDiskMigrateRequest) Read 

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

func (*ReplicaDiskMigrateRequest) ReadField1 

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

func (*ReplicaDiskMigrateRequest) ReadField2 

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

func (*ReplicaDiskMigrateRequest) ReadField3 

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

func (*ReplicaDiskMigrateRequest) String 

func (p *ReplicaDiskMigrateRequest) String() string

func (*ReplicaDiskMigrateRequest) Write 

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

type ReplicaDiskMigrateResponse 

type ReplicaDiskMigrateResponse struct {
	Err  *base.ErrorCode `thrift:"err,1" db:"err" json:"err"`
	Hint *string         `thrift:"hint,2" db:"hint" json:"hint,omitempty"`
}

Attributes:

  • Err
  • Hint
var ReplicaClientDiskMigrateResult_Success_DEFAULT *ReplicaDiskMigrateResponse

func NewReplicaDiskMigrateResponse 

func NewReplicaDiskMigrateResponse() *ReplicaDiskMigrateResponse

func (*ReplicaDiskMigrateResponse) GetErr 

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

func (*ReplicaDiskMigrateResponse) GetHint 

func (p *ReplicaDiskMigrateResponse) GetHint() string

func (*ReplicaDiskMigrateResponse) IsSetErr 

func (p *ReplicaDiskMigrateResponse) IsSetErr() bool

func (*ReplicaDiskMigrateResponse) IsSetHint 

func (p *ReplicaDiskMigrateResponse) IsSetHint() bool

func (*ReplicaDiskMigrateResponse) Read 

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

func (*ReplicaDiskMigrateResponse) ReadField1 

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

func (*ReplicaDiskMigrateResponse) ReadField2 

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

func (*ReplicaDiskMigrateResponse) String 

func (p *ReplicaDiskMigrateResponse) String() string

func (*ReplicaDiskMigrateResponse) Write 

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