Documentation
¶
Index ¶
- func PrintBusFactor(nodes []*nodeselection.SelectedNode, selector nodeselection.NodeAttribute, ...)
- func ReadSegmentFile(path string) (metabase.Segment, error)
- type AliasPiece
- type Availability
- type Checksum
- type Classify
- type Decrypt
- type Download
- type ECDecode
- type ECRepair
- type Histogram
- type Nodes
- type Piece
- type PieceList
- type Redundancy
- type Report
- type Segment
- type SegmentFile
- type Show
- type Smoketest
- type WithStreamIDs
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PrintBusFactor ¶
func PrintBusFactor(nodes []*nodeselection.SelectedNode, selector nodeselection.NodeAttribute, threshold int)
Types ¶
type AliasPiece ¶ added in v1.19.0
type Availability ¶
type Availability struct {
StreamID string `arg:""`
util.DialerHelper
Keys string `required:""`
}
Availability reports the status / availability of one single segment.
func (*Availability) Run ¶
func (s *Availability) Run() error
type Checksum ¶ added in v1.10.0
type Checksum struct {
db.WithDatabase
StreamID string `arg:""`
PieceInfo bool `help:"Print additional information (with using db / segment list) "`
}
type Classify ¶
type Classify struct {
db.WithDatabase
placement.WithPlacement
StreamID string `arg:""`
PlacementCheck bool `help:"Check placement rules" default:"true"`
}
type Decrypt ¶ added in v1.10.0
type Download ¶
type Download struct {
util.DialerHelper
db.WithDatabase
StreamID string `arg:""`
Keys string `required:""`
NodeInfo bool
SegmentMetafil string `help:"Path to segment metafile to read segment info from instead of metabase"`
}
type ECDecode ¶
type ECRepair ¶ added in v1.19.0
type Nodes ¶
type Nodes struct {
db.WithDatabase
NodeIDs string `arg:""`
Verbose bool `default:"true"`
}
type PieceList ¶
type PieceList struct {
StreamID string `arg:""`
util.DialerHelper
Keys string
}
PieceList reports the status / availability of one single segment.
type Redundancy ¶ added in v1.19.0
type Redundancy struct {
Algorithm int `yaml:"algorithm"`
}
type Report ¶ added in v1.2.0
type Segment ¶
type Segment struct {
Histogram Histogram `cmd:"" help:"diversity histogram of a segment"`
List PieceList `cmd:"" help:"list piece locations in a csv for one single segment"`
Availability Availability `cmd:"" help:"test availability of the segment with calling exists endpoints"`
Classify Classify `cmd:"" help:"execute piece classification on segment"`
Download Download `cmd:"" help:"download all the available pieces ASAP"`
Ecdecode ECDecode `cmd:"" help:"decode original segment from downloaded pieces"`
Ecrepair ECRepair `cmd:"" help:"try to localize EC problems with ignoring different pieces"`
Show Show `cmd:"" help:"show information about the segment"`
Report Report `cmd:"" help:"show segments based on segment id list"`
Nodes Nodes `cmd:"" help:"print details of nodes"`
Checksum Checksum `cmd:"" help:"Check checksum of the downloaded segment"`
Decrypt Decrypt `cmd:"" help:"Decrypt segment with the provided keys"`
Smoketest Smoketest `cmd:"" help:"Download Hash of the pieces and check if they are zero"`
}
Segment contains command which uses direct database connection.
type SegmentFile ¶ added in v1.19.0
type SegmentFile struct {
StreamID uuid.UUID `yaml:"streamid"`
Position struct {
Part int `yaml:"part"`
Index int `yaml:"index"`
} `yaml:"position"`
CreatedAt time.Time `yaml:"createdat"`
ExpiresAt *time.Time `yaml:"expiresat"`
RepairedAt *time.Time `yaml:"repairedat"`
RootPieceID storj.PieceID `yaml:"rootpieceid"`
EncryptedSize int64 `yaml:"encryptedsize"`
PlainOffset int64 `yaml:"plainoffset"`
PlainSize int64 `yaml:"plainsize"`
AliasPieces []AliasPiece `yaml:"aliaspieces"`
Redundancy Redundancy `yaml:"redundancy"`
Pieces []Piece `yaml:"pieces"`
Placement int `yaml:"placement"`
Source string `yaml:"source"`
}
func (*SegmentFile) ToMetabaseSegment ¶ added in v1.19.0
func (sf *SegmentFile) ToMetabaseSegment() metabase.Segment
ToMetabaseSegment converts a *SegmentFile to a metabase.Segment.
type Show ¶
type Show struct {
StreamID string `arg:""`
db.WithDatabase
}
type Smoketest ¶ added in v1.12.0
type Smoketest struct {
db.WithDatabase
util.DialerHelper
WithStreamIDs
Offset int
Keys string `required:"" help:"the satellite identity directory"`
}
type WithStreamIDs ¶ added in v1.12.0
type WithStreamIDs struct {
StreamID string `arg:""`
}
Click to show internal directories.
Click to hide internal directories.