retrieval

Documentation

Index

• Variables
• type ChunkDelivery
• type Peer
  • func NewPeer(peer *network.BzzPeer) *Peer
• type Retrieval
  • func New(kad *network.Kademlia, ns *storage.NetStore) *Retrieval
  • func (r *Retrieval) APIs() []rpc.API
  • func (r *Retrieval) Protocols() []p2p.Protocol
  • func (r *Retrieval) RequestFromPeers(ctx context.Context, req *storage.Request, localID enode.ID) (*enode.ID, error)
  • func (r *Retrieval) Run(p *p2p.Peer, rw p2p.MsgReadWriter) error
  • func (r *Retrieval) Start(server *p2p.Server) error
  • func (r *Retrieval) Stop() error
• type RetrieveRequest

Variables

var (
	ErrNoPeerFound = errors.New("no peer found")
)

Types

type ChunkDelivery

type ChunkDelivery struct {
	Addr  storage.Address
	SData []byte // the stored chunk Data (incl size)
}

ChunkDelivery is the protocol msg for delivering a solicited chunk to a peer

type Peer

type Peer struct {
	*network.BzzPeer
	// contains filtered or unexported fields
}

Peer wraps BzzPeer with a contextual logger for this peer

func NewPeer

func NewPeer(peer *network.BzzPeer) *Peer

NewPeer is the constructor for Peer

type Retrieval

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

Retrieval holds state and handles protocol messages for the `bzz-retrieve` protocol

func New

func New(kad *network.Kademlia, ns *storage.NetStore) *Retrieval

NewRetrieval returns a new instance of the retrieval protocol handler

func (*Retrieval) APIs

func (r *Retrieval) APIs() []rpc.API

func (*Retrieval) Protocols

func (r *Retrieval) Protocols() []p2p.Protocol

func (*Retrieval) RequestFromPeers

func (r *Retrieval) RequestFromPeers(ctx context.Context, req *storage.Request, localID enode.ID) (*enode.ID, error)

RequestFromPeers sends a chunk retrieve request to the next found peer

func (*Retrieval) Run

func (r *Retrieval) Run(p *p2p.Peer, rw p2p.MsgReadWriter) error

Run protocol function

func (*Retrieval) Start

func (r *Retrieval) Start(server *p2p.Server) error

func (*Retrieval) Stop

func (r *Retrieval) Stop() error

type RetrieveRequest

type RetrieveRequest struct {
	Addr storage.Address
}

RetrieveRequestMsg is the protocol msg for chunk retrieve requests