Versions in this module Expand all Collapse all v0 v0.1.10 Dec 16, 2019 Changes in this version + type Engine struct + func NewEngine(ctx context.Context, bs bstore.Blockstore, peerTagger PeerTagger, ...) *Engine + func (e *Engine) AddBlocks(ctx context.Context, ks []cid.Cid) + func (e *Engine) LedgerForPeer(p peer.ID) *Receipt + func (e *Engine) MessageReceived(ctx context.Context, p peer.ID, m bsmsg.BitSwapMessage) + func (e *Engine) MessageSent(p peer.ID, m bsmsg.BitSwapMessage) + func (e *Engine) Outbox() <-chan (<-chan *Envelope) + func (e *Engine) PeerConnected(p peer.ID) + func (e *Engine) PeerDisconnected(p peer.ID) + func (e *Engine) Peers() []peer.ID + func (e *Engine) SendTicketAcks(target peer.ID, ticketAcks []tickets.TicketAck) + func (e *Engine) SendTickets(target peer.ID, tickets []tickets.Ticket) + func (e *Engine) StartWorkers(ctx context.Context, px process.Process) + func (e *Engine) TicketAckOutbox() chan *Envelope + func (e *Engine) TicketOutbox() chan *Envelope + func (e *Engine) WantlistForPeer(p peer.ID) (out []wl.Entry) + type Envelope struct + Message bsmsg.BitSwapMessage + Peer peer.ID + Sent func() + type PeerTagger interface + TagPeer func(peer.ID, string, int) + UntagPeer func(p peer.ID, tag string) + type Receipt struct + Exchanged uint64 + Peer string + Recv uint64 + Sent uint64 + Value float64 v0.1.10-1 Dec 16, 2019
Go to main page