fetcher

Documentation

Index

• type Fetcher
  • func New(maxConcurrentConnections int, allowInsecureTavern bool) *Fetcher
  • func (fetcher *Fetcher) Fetch(path string, tracker *trackerv1.Tracker) error
  • func (fetcher *Fetcher) ListPeers(hash []byte, addr string) ([]Peer, error)
  • func (fetcher *Fetcher) Resolve(tracker *trackerv1.Tracker) ([]Peer, error)
• type Peer
  • func (peer *Peer) HasChunks(hash []byte) (*bitset.BitSet, error)
  • func (peer *Peer) Refresh()
• type Task
  • func (task Task) Fetch() (int64, error)

Types

type Fetcher

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

func New

func New(maxConcurrentConnections int, allowInsecureTavern bool) *Fetcher

func (*Fetcher) Fetch

func (fetcher *Fetcher) Fetch(path string, tracker *trackerv1.Tracker) error

Fetch downloads a file to the given destination.

func (*Fetcher) ListPeers

func (fetcher *Fetcher) ListPeers(hash []byte, addr string) ([]Peer, error)

ListPeers contacts a tracker looking for a given hash.

func (*Fetcher) Resolve

func (fetcher *Fetcher) Resolve(tracker *trackerv1.Tracker) ([]Peer, error)

Resolve fetches a list of serving peer from the tracker.

type Peer

type Peer struct {
	Address  string
	Hash     []byte
	Chunkset *bitset.BitSet
	Client   seederv1connect.SeederServiceClient
}

func (*Peer) HasChunks

func (peer *Peer) HasChunks(hash []byte) (*bitset.BitSet, error)

HasChunks fetches the set of chunks served by the peer.

func (*Peer) Refresh

func (peer *Peer) Refresh()

type Task

type Task struct {
	Fetched     chan int64
	Tracker     *trackerv1.Tracker
	Peers       []Peer
	Peer        int
	Hash        []byte
	ChunkHash   []byte
	Chunk       int64
	Destination string
}

func (Task) Fetch

func (task Task) Fetch() (int64, error)