chunkserver

package
v0.0.0-...-46d4b59 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

* Copyright (c) 2023 NetEase Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Project: CurveCli * Created Date: 2023-05-11 * Author: chengyi01

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetChunkServerInCluster 

func GetChunkServerInCluster(caller *cobra.Command) ([]*topology.ChunkServerInfo, *cmderror.CmdError)

func GetCopySetsInChunkServer 

func GetCopySetsInChunkServer(caller *cobra.Command) ([]*common.CopysetInfo, *cmderror.CmdError)

func ListChunkServerInfos 

func ListChunkServerInfos(caller *cobra.Command) ([]*topology.ChunkServerInfo, *cmderror.CmdError)

func ListOfflineChunkServer 

func ListOfflineChunkServer(caller *cobra.Command) ([]*topology.ChunkServerInfo, *cmderror.CmdError)

func NewChunkServerCommand 

func NewChunkServerCommand() *cobra.Command

func NewChunkServerInClusterCommand 

func NewChunkServerInClusterCommand() *cobra.Command

func NewCopySetsInChunkServerCommand 

func NewCopySetsInChunkServerCommand() *cobra.Command

func NewOfflineChunkServerCommand 

func NewOfflineChunkServerCommand() *cobra.Command

Types

type ChunkServerCommand 

type ChunkServerCommand struct {
	basecmd.FinalCurveCmd
	Rpc              []*ListChunkServerRpc
	Response         []*topology.ListChunkServerResponse
	ChunkServerInfos []*topology.ChunkServerInfo
}

func NewListChunkServerCommand 

func NewListChunkServerCommand() *ChunkServerCommand

func (*ChunkServerCommand) AddFlags 

func (pCmd *ChunkServerCommand) AddFlags()

AddFlags implements basecmd.FinalCurveCmdFunc

func (*ChunkServerCommand) Init 

func (pCmd *ChunkServerCommand) Init(cmd *cobra.Command, args []string) error

Init implements basecmd.FinalCurveCmdFunc

func (*ChunkServerCommand) Print 

func (pCmd *ChunkServerCommand) Print(cmd *cobra.Command, args []string) error

Print implements basecmd.FinalCurveCmdFunc

func (*ChunkServerCommand) ResultPlainOutput 

func (pCmd *ChunkServerCommand) ResultPlainOutput() error

ResultPlainOutput implements basecmd.FinalCurveCmdFunc

func (*ChunkServerCommand) RunCommand 

func (pCmd *ChunkServerCommand) RunCommand(cmd *cobra.Command, args []string) error

RunCommand implements basecmd.FinalCurveCmdFunc

type ChunkServerInClusterCommand 

type ChunkServerInClusterCommand struct {
	basecmd.FinalCurveCmd
	Rpc              *GetChunkServerInClusterRpc
	ChunkServerInfos []*topology.ChunkServerInfo
}

func NewListChunkServerInClusterCommand 

func NewListChunkServerInClusterCommand() *ChunkServerInClusterCommand

func (*ChunkServerInClusterCommand) AddFlags 

func (csicCmd *ChunkServerInClusterCommand) AddFlags()

func (*ChunkServerInClusterCommand) Init 

func (csicCmd *ChunkServerInClusterCommand) Init(cmd *cobra.Command, args []string) error

func (*ChunkServerInClusterCommand) Print 

func (csicCmd *ChunkServerInClusterCommand) Print(cmd *cobra.Command, args []string) error

func (*ChunkServerInClusterCommand) ResultPlainOutput 

func (csicCmd *ChunkServerInClusterCommand) ResultPlainOutput() error

func (*ChunkServerInClusterCommand) RunCommand 

func (csicCmd *ChunkServerInClusterCommand) RunCommand(cmd *cobra.Command, args []string) error

type CopySetCommand 

type CopySetCommand struct {
	basecmd.FinalCurveCmd
	Rpc      *GetCopySetsInChunkServerRpc
	Response *topology.GetCopySetsInChunkServerResponse
	CopySets []*common.CopysetInfo
}

func NewGetCopySetsInCopySetCommand 

func NewGetCopySetsInCopySetCommand() *CopySetCommand

func (*CopySetCommand) AddFlags 

func (pCmd *CopySetCommand) AddFlags()

AddFlags implements basecmd.FinalCurveCmdFunc

func (*CopySetCommand) Init 

func (pCmd *CopySetCommand) Init(cmd *cobra.Command, args []string) error

Init implements basecmd.FinalCurveCmdFunc

func (*CopySetCommand) Print 

func (pCmd *CopySetCommand) Print(cmd *cobra.Command, args []string) error

Print implements basecmd.FinalCurveCmdFunc

func (*CopySetCommand) ResultPlainOutput 

func (pCmd *CopySetCommand) ResultPlainOutput() error

ResultPlainOutput implements basecmd.FinalCurveCmdFunc

func (*CopySetCommand) RunCommand 

func (pCmd *CopySetCommand) RunCommand(cmd *cobra.Command, args []string) error

RunCommand implements basecmd.FinalCurveCmdFunc

type GetChunkServerInClusterRpc 

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

func (*GetChunkServerInClusterRpc) NewRpcClient 

func (gRpc *GetChunkServerInClusterRpc) NewRpcClient(cc grpc.ClientConnInterface)

func (*GetChunkServerInClusterRpc) Stub_Func 

func (gRpc *GetChunkServerInClusterRpc) Stub_Func(ctx context.Context) (interface{}, error)

type GetCopySetsInChunkServerRpc 

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

func (*GetCopySetsInChunkServerRpc) NewRpcClient 

func (lRpc *GetCopySetsInChunkServerRpc) NewRpcClient(cc grpc.ClientConnInterface)

func (*GetCopySetsInChunkServerRpc) Stub_Func 

func (lRpc *GetCopySetsInChunkServerRpc) Stub_Func(ctx context.Context) (interface{}, error)

type ListChunkServerRpc 

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

func (*ListChunkServerRpc) NewRpcClient 

func (lRpc *ListChunkServerRpc) NewRpcClient(cc grpc.ClientConnInterface)

func (*ListChunkServerRpc) Stub_Func 

func (lRpc *ListChunkServerRpc) Stub_Func(ctx context.Context) (interface{}, error)

type OfflineChunkServerCommand 

type OfflineChunkServerCommand struct {
	basecmd.FinalCurveCmd
	// contains filtered or unexported fields
}

func NewListOfflineChunkServerCommand 

func NewListOfflineChunkServerCommand() *OfflineChunkServerCommand

func (*OfflineChunkServerCommand) AddFlags 

func (oCmd *OfflineChunkServerCommand) AddFlags()

func (*OfflineChunkServerCommand) Init 

func (oCmd *OfflineChunkServerCommand) Init(cmd *cobra.Command, args []string) error

func (*OfflineChunkServerCommand) Print 

func (oCmd *OfflineChunkServerCommand) Print(cmd *cobra.Command, args []string) error

func (*OfflineChunkServerCommand) ResultPlainOutput 

func (oCmd *OfflineChunkServerCommand) ResultPlainOutput() error

func (*OfflineChunkServerCommand) RunCommand 

func (oCmd *OfflineChunkServerCommand) RunCommand(cmd *cobra.Command, args []string) 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.