copyset

Documentation

Index

• func NewCopysetCommand() *cobra.Command
• func QueryCopysetInfo(caller *cobra.Command) (map[uint64]*cobrautil.CopysetInfoStatus, *cmderror.CmdError)
• func QueryCopysetInfoStatus(caller *cobra.Command) (map[uint64]*cobrautil.CopysetInfoStatus, *cmderror.CmdError)
• type CopysetCommand
  • func NewQueryCopysetCommand() *CopysetCommand
  • func (cCmd *CopysetCommand) AddFlags()
  • func (cCmd *CopysetCommand) Init(cmd *cobra.Command, args []string) error
  • func (cCmd *CopysetCommand) Print(cmd *cobra.Command, args []string) error
  • func (cCmd *CopysetCommand) ResultPlainOutput() error
  • func (cCmd *CopysetCommand) RunCommand(cmd *cobra.Command, args []string) error
  • func (cCmd *CopysetCommand) UpdateCopysetsStatus(values []*topology.CopysetValue) []*cmderror.CmdError
• type QueryCopysetRpc
  • func (qcRpc *QueryCopysetRpc) NewRpcClient(cc grpc.ClientConnInterface)
  • func (qcRpc *QueryCopysetRpc) Stub_Func(ctx context.Context) (interface{}, error)
• type StatusCopysetRpc
  • func (scRpc *StatusCopysetRpc) NewRpcClient(cc grpc.ClientConnInterface)
  • func (scRpc *StatusCopysetRpc) Stub_Func(ctx context.Context) (interface{}, error)
• type StatusResult
  • func GetCopysetsStatus(addr2Request map[string]*copyset.CopysetsStatusRequest, timeout time.Duration, ...) []*StatusResult

Functions

func NewCopysetCommand

func NewCopysetCommand() *cobra.Command

func QueryCopysetInfo

func QueryCopysetInfo(caller *cobra.Command) (map[uint64]*cobrautil.CopysetInfoStatus, *cmderror.CmdError)

func QueryCopysetInfoStatus

func QueryCopysetInfoStatus(caller *cobra.Command) (map[uint64]*cobrautil.CopysetInfoStatus, *cmderror.CmdError)

copsetIds,poolId just like: 1,2,3

Types

type CopysetCommand

type CopysetCommand struct {
	basecmd.FinalCurveCmd
	Rpc  *QueryCopysetRpc
	Rows []map[string]string
	// contains filtered or unexported fields
}

func NewQueryCopysetCommand

func NewQueryCopysetCommand() *CopysetCommand

func (*CopysetCommand) AddFlags

func (cCmd *CopysetCommand) AddFlags()

func (*CopysetCommand) Init

func (cCmd *CopysetCommand) Init(cmd *cobra.Command, args []string) error

func (*CopysetCommand) Print

func (cCmd *CopysetCommand) Print(cmd *cobra.Command, args []string) error

func (*CopysetCommand) ResultPlainOutput

func (cCmd *CopysetCommand) ResultPlainOutput() error

func (*CopysetCommand) RunCommand

func (cCmd *CopysetCommand) RunCommand(cmd *cobra.Command, args []string) error

func (*CopysetCommand) UpdateCopysetsStatus

func (cCmd *CopysetCommand) UpdateCopysetsStatus(values []*topology.CopysetValue) []*cmderror.CmdError

type QueryCopysetRpc

type QueryCopysetRpc struct {
	Info    *basecmd.Rpc
	Request *topology.GetCopysetsInfoRequest
	// contains filtered or unexported fields
}

func (*QueryCopysetRpc) NewRpcClient

func (qcRpc *QueryCopysetRpc) NewRpcClient(cc grpc.ClientConnInterface)

func (*QueryCopysetRpc) Stub_Func

func (qcRpc *QueryCopysetRpc) Stub_Func(ctx context.Context) (interface{}, error)

type StatusCopysetRpc

type StatusCopysetRpc struct {
	Info    *basecmd.Rpc
	Request *copyset.CopysetsStatusRequest
	// contains filtered or unexported fields
}

func (*StatusCopysetRpc) NewRpcClient

func (scRpc *StatusCopysetRpc) NewRpcClient(cc grpc.ClientConnInterface)

func (*StatusCopysetRpc) Stub_Func

func (scRpc *StatusCopysetRpc) Stub_Func(ctx context.Context) (interface{}, error)

type StatusResult

type StatusResult struct {
	Request *copyset.CopysetsStatusRequest
	Status  *copyset.CopysetsStatusResponse
	Error   *cmderror.CmdError
	Addr    string
}

func GetCopysetsStatus

func GetCopysetsStatus(addr2Request map[string]*copyset.CopysetsStatusRequest, timeout time.Duration, retrytimes int32) []*StatusResult