shell

package
v0.0.0-...-935c85c Latest Latest
Warning

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

Go to latest
Published: Oct 17, 2020 License: Apache-2.0 Imports: 40 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(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

func (*CommandEnv) AdjustedUrl

func (ce *CommandEnv) AdjustedUrl(location *filer_pb.Location) string

func (*CommandEnv) WithFilerClient

func (ce *CommandEnv) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) error) error

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
}

type VInfo

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

type VolumeReplica

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

Jump to

Keyboard shortcuts

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