Documentation
¶
Index ¶
- Variables
- type Audit
- type Checksum
- type Decode
- type Derive
- type DownloadDRPC
- type DownloadPieceStore
- type Downloader
- type Exist
- type List
- type NoHash
- type NodeSpeed
- type Nodes
- type Piece
- type PieceFinder
- type Unalias
- type UploadDrpc
- func (u *UploadDrpc) ConnectAndUpload(ctx context.Context, orderLimitCreator *util.KeySigner) (size int, id storj.PieceID, err error)
- func (u *UploadDrpc) Run() error
- func (d *UploadDrpc) Upload(ctx context.Context, client pb.DRPCReplaySafePiecestoreClient, ...) (uploaded int, id storj.PieceID, err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var PieceCmd = &cobra.Command{
Use: "piece",
}
Functions ¶
This section is empty.
Types ¶
type Audit ¶
type Derive ¶
type DownloadDRPC ¶
type DownloadDRPC struct {
util.Loop
util.DialerHelper
NodeURL storj.NodeURL `arg:"" name:"nodeurl"`
Piece storj.PieceID `arg:"" help:"Piece hash to download"`
Size int64 `arg:"" help:"size of bytes to download"`
Keys string `help:"location of the identity files to sign orders"`
Save bool `help:"safe piece to a file"`
}
func (*DownloadDRPC) ConnectAndDownload ¶
func (*DownloadDRPC) Run ¶
func (d *DownloadDRPC) Run() error
type DownloadPieceStore ¶
type DownloadPieceStore struct {
util.Loop
util.DialerHelper
NodeURL storj.NodeURL `arg:"" name:"nodeurl"`
Piece string `arg:"" help:"Piece hash to download"`
Size int64 `arg:"" help:"size of bytes to download"`
Keys string `help:"location of the identity files to sign orders"`
}
func (*DownloadPieceStore) Run ¶
func (d *DownloadPieceStore) Run() error
type Downloader ¶
type Downloader struct {
OrderLimitCreator util.OrderLimitCreator
// contains filtered or unexported fields
}
func NewDownloader ¶
func NewDownloader(ctx context.Context, storagenodeURL string, dh *util.DialerHelper) (d Downloader, err error)
type Exist ¶
type List ¶
type List struct {
util.DialerHelper
Path string `arg:"" help:"key url (sj://bucket/.../key)"`
}
type NodeSpeed ¶
type NodeSpeed struct {
util.DialerHelper
Keys string `help:"location of the identity files to sign orders"`
Path string `arg:"" help:"key url (sj://bucket/encryptedpath)"`
}
type Nodes ¶
type Nodes struct {
util.DialerHelper
Path string `arg:"" help:"key url (sj://bucket/encryptedpath)"`
DesiredNodes int
}
func (*Nodes) OnEachNode ¶
type Piece ¶
type Piece struct {
UploadDrpc UploadDrpc `cmd:"" help:"Upload piece to the Storagenode"`
DownloadDrpc DownloadDRPC `cmd:"" help:"Download piece from the Storagenode"`
List List `cmd:"" help:"Print out pieces for one particular object"`
Nodes Nodes `cmd:"" help:"Print out piece locations with pieceID and node ID"`
NodeSpeed NodeSpeed `cmd:"" help:"Download one piece from all the nodes"`
Decode Decode `cmd:"" help:"Decode piece alias (from the condensed format, stored in db)"`
DownloadPs DownloadPieceStore `cmd:"" help:"Download piece from the Storagenode using piece store"`
Unalias Unalias `cmd:"" help:"Decode node aliases"`
Exist Exist `cmd:"" help:"check if piece id is on SN"`
Audit Audit `cmd:"" help:"audit pieces on node"`
Derive Derive `cmd:"" help:"derive piece id"`
Checksum Checksum `cmd:"" help:"download piece and checks if stored checksum is fine"`
}
type PieceFinder ¶
type PieceFinder struct {
Downloader
}
func NewPieceFinder ¶
func NewPieceFinder(ctx context.Context, storagenodeID string, dh *util.DialerHelper) (PieceFinder, error)
type UploadDrpc ¶
type UploadDrpc struct {
util.Loop
util.DialerHelper
NoSync bool `help:"Disable file sync on upload"`
Hash pb.PieceHashAlgorithm `default:"0" help:"Piece hash algorithm to use"`
NodeURL storj.NodeURL `arg:"" name:"nodeurl"`
File string `arg:"" help:"file to upload as a piece"`
Keys string `help:"location of the identity files to sign orders"`
}
func (*UploadDrpc) ConnectAndUpload ¶
func (*UploadDrpc) Run ¶
func (u *UploadDrpc) Run() error
Click to show internal directories.
Click to hide internal directories.