shell

Documentation

Index

• Variables
• func ListCollectionNames(commandEnv *CommandEnv, includeNormalVolumes, includeEcVolumes bool) (collections []string, err error)
• func LiveMoveVolume(grpcDialOption grpc.DialOption, writer io.Writer, volumeId needle.VolumeId, ...) (err error)
• func RunShell(options ShellOptions)
• type CandidateEcNode
• type CapacityFunc
• type CollectionInfo
• type CommandEnv
  • func NewCommandEnv(options *ShellOptions) *CommandEnv
  • func (ce *CommandEnv) AdjustedUrl(location *filer_pb.Location) string
  • func (ce *CommandEnv) GetDataCenter() string
  • func (ce *CommandEnv) WithFilerClient(streamingMode bool, fn func(filer_pb.SeaweedFilerClient) error) error
• type EcNode
• type EcNodeId
• type EcRack
• type EcShardLocations
• type EcShardMap
• type FileFilter
• type Item
• type ItemEntry
• type Node
• type Prefix
• type RackId
• type SelectOneVolumeFunc
• type ShellOptions
• type VInfo
• type VolumeReplica

Variables

var (
	Commands = []command{}
)

var LoadConfig = loadConfig

Functions

func ListCollectionNames

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

func LiveMoveVolume

func LiveMoveVolume(grpcDialOption grpc.DialOption, writer io.Writer, volumeId needle.VolumeId, sourceVolumeServer, targetVolumeServer pb.ServerAddress, idleTimeout time.Duration, diskType string, ioBytePerSecond int64, skipTailError bool) (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 CapacityFunc

type CapacityFunc func(*master_pb.DataNodeInfo) float64

type CollectionInfo

type CollectionInfo struct {
	FileCount        float64
	DeleteCount      float64
	DeletedByteCount float64
	Size             float64
	VolumeCount      int
}

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) GetDataCenter

func (ce *CommandEnv) GetDataCenter() string

func (*CommandEnv) WithFilerClient

func (ce *CommandEnv) WithFilerClient(streamingMode bool, 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 FileFilter

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

type Item

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

type ItemEntry

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

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 SelectOneVolumeFunc

type SelectOneVolumeFunc func(replicas []*VolumeReplica, replicaPlacement *super_block.ReplicaPlacement) *VolumeReplica

type ShellOptions

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

type VInfo

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

type VolumeReplica

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