shell

package
v0.0.0-...-f1e43fe Latest Latest
Warning

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

Go to latest
Published: Jul 24, 2019 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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
}

Jump to

Keyboard shortcuts

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