radmin

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

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

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

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 GoUnusedProtection__ int
View Source
var QueryDiskInfoRequest_Node_DEFAULT *base.RPCAddress
View Source
var QueryDiskInfoResponse_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 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 QueryDiskInfoRequest

type QueryDiskInfoRequest struct {
	Node    *base.RPCAddress `thrift:"node,1" db:"node" json:"node"`
	AppName string           `thrift:"app_name,2" db:"app_name" json:"app_name"`
}

Attributes:

  • Node
  • AppName
var ReplicaClientQueryDiskInfoArgs_Req_DEFAULT *QueryDiskInfoRequest

func NewQueryDiskInfoRequest

func NewQueryDiskInfoRequest() *QueryDiskInfoRequest

func (*QueryDiskInfoRequest) GetAppName

func (p *QueryDiskInfoRequest) GetAppName() string

func (*QueryDiskInfoRequest) GetNode

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

func (*QueryDiskInfoRequest) IsSetNode

func (p *QueryDiskInfoRequest) IsSetNode() 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) 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 (*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 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 (*ReplicaClientAddDiskArgs) IsSetReq

func (p *ReplicaClientAddDiskArgs) IsSetReq() bool

func (*ReplicaClientAddDiskArgs) Read

func (*ReplicaClientAddDiskArgs) ReadField1

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

func (*ReplicaClientAddDiskArgs) String

func (p *ReplicaClientAddDiskArgs) String() string

func (*ReplicaClientAddDiskArgs) Write

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 (*ReplicaClientAddDiskResult) IsSetSuccess

func (p *ReplicaClientAddDiskResult) IsSetSuccess() bool

func (*ReplicaClientAddDiskResult) Read

func (*ReplicaClientAddDiskResult) ReadField0

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

func (*ReplicaClientAddDiskResult) String

func (p *ReplicaClientAddDiskResult) String() string

func (*ReplicaClientAddDiskResult) Write

type ReplicaClientClient

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

func NewReplicaClientClient

func NewReplicaClientClient(c thrift.TClient) *ReplicaClientClient

func NewReplicaClientClientProtocol

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

func (*ReplicaClientClient) AddDisk

Parameters:

  • Req

func (*ReplicaClientClient) Client_

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

func (*ReplicaClientClient) DiskMigrate

Parameters:

  • Req

func (*ReplicaClientClient) QueryDiskInfo

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 (*ReplicaClientDiskMigrateArgs) IsSetReq

func (p *ReplicaClientDiskMigrateArgs) IsSetReq() bool

func (*ReplicaClientDiskMigrateArgs) Read

func (*ReplicaClientDiskMigrateArgs) ReadField1

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

func (*ReplicaClientDiskMigrateArgs) String

func (*ReplicaClientDiskMigrateArgs) Write

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 (*ReplicaClientDiskMigrateResult) IsSetSuccess

func (p *ReplicaClientDiskMigrateResult) IsSetSuccess() bool

func (*ReplicaClientDiskMigrateResult) Read

func (*ReplicaClientDiskMigrateResult) ReadField0

func (*ReplicaClientDiskMigrateResult) String

func (*ReplicaClientDiskMigrateResult) Write

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

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 (*ReplicaClientQueryDiskInfoArgs) IsSetReq

func (p *ReplicaClientQueryDiskInfoArgs) IsSetReq() bool

func (*ReplicaClientQueryDiskInfoArgs) Read

func (*ReplicaClientQueryDiskInfoArgs) ReadField1

func (*ReplicaClientQueryDiskInfoArgs) String

func (*ReplicaClientQueryDiskInfoArgs) Write

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 (*ReplicaClientQueryDiskInfoResult) IsSetSuccess

func (p *ReplicaClientQueryDiskInfoResult) IsSetSuccess() bool

func (*ReplicaClientQueryDiskInfoResult) Read

func (*ReplicaClientQueryDiskInfoResult) ReadField0

func (*ReplicaClientQueryDiskInfoResult) String

func (*ReplicaClientQueryDiskInfoResult) Write

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 (*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

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 (*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 (*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

Jump to

Keyboard shortcuts

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