downloadng

package
v0.0.0-...-e477e18 Latest Latest
Warning

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

Go to latest
Published: May 3, 2024 License: AGPL-3.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DecodeShares

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

type DecodedShare

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

type Decrypt

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

func NewDecrypt

func NewDecrypt(inbox chan any, store *encryption.Store) (*Decrypt, error)

func (*Decrypt) Run

func (d *Decrypt) Run(ctx context.Context) error

type DecryptBuffer

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

type Done

type Done struct {
}

type DownloadCmd

type DownloadCmd struct {
	Path string `arg:""`
}

func (DownloadCmd) Run

func (d DownloadCmd) Run() error

type DownloadObject

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

type DownloadPiece

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

type DownloadRouter

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

func (*DownloadRouter) Run

func (d *DownloadRouter) Run(ctx context.Context) (err error)

type DownloadSegment

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

type ECDecoder

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

func NewECDecoder

func NewECDecoder(inbox chan any) (*ECDecoder, error)

func (*ECDecoder) Run

func (e *ECDecoder) Run(ctx context.Context) error

type FatalFailure

type FatalFailure struct {
	Error error
}

type InitDecryption

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

type ObjectDownloader

type ObjectDownloader struct {
	APIKey *macaroon.APIKey
	// contains filtered or unexported fields
}

func (*ObjectDownloader) Download

func (s *ObjectDownloader) Download(ctx context.Context, metainfoClient *metaclient.Client, req *DownloadObject) error

func (*ObjectDownloader) Run

func (s *ObjectDownloader) Run(ctx context.Context) error

type Parallel

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

func (*Parallel) Add

func (p *Parallel) Add(req *DownloadSegment) *segmentBuffer

func (*Parallel) Run

func (p *Parallel) Run(ctx context.Context) error

type PieceStoreClient

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

func NewPieceStoreClient

func NewPieceStoreClient(node storj.NodeURL, outbox chan any) (*PieceStoreClient, error)

func (*PieceStoreClient) Download

func (d *PieceStoreClient) Download(ctx context.Context, client pb.DRPCPiecestoreClient, req *DownloadPiece) (downloaded int64, err error)

func (*PieceStoreClient) Run

func (d *PieceStoreClient) Run(ctx context.Context)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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