shell

Documentation

Index

• Variables
• func ListCollectionNames(commandEnv *CommandEnv, includeNormalVolumes, includeEcVolumes bool) (collections []string, err error)
• func LiveMoveVolume(ctx context.Context, grpcDialOption grpc.DialOption, volumeId needle.VolumeId, ...) (err error)
• func RunShell(options ShellOptions)
• type CandidateEcNode
• type CommandEnv
  • func NewCommandEnv(options ShellOptions) *CommandEnv
• type EcNode
• type EcNodeId
• type EcRack
• type EcShardLocations
• type EcShardMap
• type Node
• type Prefix
• type RackId
• type ShellOptions

Variables

var (
	Commands = []command{}
)

Functions

func ListCollectionNames

func ListCollectionNames(commandEnv *CommandEnv, includeNormalVolumes, includeEcVolumes bool) (collections []string, err error)

func LiveMoveVolume

func LiveMoveVolume(ctx context.Context, grpcDialOption grpc.DialOption, volumeId needle.VolumeId, sourceVolumeServer, targetVolumeServer string, idleTimeout time.Duration) (err error)

LiveMoveVolume moves one volume from one source volume server to one target volume server, with idleTimeout to drain the incoming requests.

func RunShell

func RunShell(options ShellOptions)

Types

type CandidateEcNode

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

type CommandEnv

type CommandEnv struct {
	MasterClient *wdclient.MasterClient
	// contains filtered or unexported fields
}

func NewCommandEnv

func NewCommandEnv(options ShellOptions) *CommandEnv

type EcNode

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

type EcNodeId

type EcNodeId string

type EcRack

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

type EcShardLocations

type EcShardLocations [][]*EcNode

type EcShardMap

type EcShardMap map[needle.VolumeId]EcShardLocations

type Node

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

type Prefix

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

type RackId

type RackId string

type ShellOptions

type ShellOptions struct {
	Masters        *string
	GrpcDialOption grpc.DialOption
	// shell transient context
	FilerHost string
	FilerPort int64
	Directory string
}