node

Mar 23, 2021

Changes in this version

type TransferHandler

+ Done func()

+ HandleFile func(*tar.Header, io.Reader)

Feb 25, 2021

Changes in this version

+ const Advertising

+ const Connected

+ const Discovering

+ const Idle

type Node

+ func (n *Node) GetState() State

+ func (n *Node) SetState(s State) State

+ type State uint8

Feb 19, 2021

Changes in this version

type Node

+ ChanID int

+ Words []string

type PakeProtocol

+ func NewPakeProtocol(node *Node, words []string) (*PakeProtocol, error)

+ func (p *PakeProtocol) AddAuthenticatedPeer(peerID peer.ID, key []byte)

+ func (p *PakeProtocol) GetSessionKey(peerID peer.ID) ([]byte, bool)

+ func (p *PakeProtocol) IsAuthenticated(peerID peer.ID) bool

+ func (p *PakeProtocol) RegisterKeyExchangeHandler(keh KeyExchangeHandler)

+ func (p *PakeProtocol) StartKeyExchange(ctx context.Context, peerID peer.ID) ([]byte, error)

+ func (p *PakeProtocol) UnregisterKeyExchangeHandler()

Feb 13, 2021

Changes in this version

+ const ProtocolPake

+ const ProtocolPushRequest

+ const ProtocolTransfer

+ type KeyExchangeHandler interface

+ HandleSuccessfulKeyExchange func(peerID peer.ID)

+ type Node struct

+ DHT *kaddht.IpfsDHT

+ func New(ctx context.Context, opts ...libp2p.Option) (*Node, error)

+ func (n *Node) AddAuthenticatedPeer(peerID peer.ID)

+ func (n *Node) AdvertiseIdentifier(t time.Time, chanID int16) string

+ func (n *Node) HasPublicAddr() bool

+ func (n *Node) IsAuthenticated(peerID peer.ID) bool

+ func (n *Node) Read(s network.Stream, data p2p.HeaderMessage) error

+ func (n *Node) ReadBytes(r io.Reader) ([]byte, error)

+ func (n *Node) ResetOnShutdown(s network.Stream) context.CancelFunc

+ func (n *Node) Send(s network.Stream, msg p2p.HeaderMessage) error

+ func (n *Node) Shutdown()

+ func (n *Node) WaitForEOF(s network.Stream) error

+ func (n *Node) WriteBytes(w io.Writer, data []byte) (int, error)

+ type PakeClientProtocol struct

+ func NewPakeClientProtocol(node *Node, pw []byte) *PakeClientProtocol

+ func (p *PakeClientProtocol) StartKeyExchange(ctx context.Context, peerID peer.ID) ([]byte, error)

+ type PakeProtocol struct

+ func (p *PakeProtocol) ReceiveVerifyProof(s network.Stream, key []byte) error

+ func (p *PakeProtocol) SendProof(s network.Stream, key []byte) error

+ type PakeServerProtocol struct

+ func NewPakeServerProtocol(node *Node, pw []byte) *PakeServerProtocol

+ func (p *PakeServerProtocol) RegisterKeyExchangeHandler(keh KeyExchangeHandler)

+ func (p *PakeServerProtocol) UnregisterKeyExchangeHandler()

+ type PeerHandler interface

+ HandlePeer func(info peer.AddrInfo)

+ type PushProtocol struct

+ func NewPushProtocol(node *Node) *PushProtocol

+ func (p *PushProtocol) RegisterPushRequestHandler(prh PushRequestHandler)

+ func (p *PushProtocol) SendPushRequest(ctx context.Context, peerID peer.ID, filename string, size int64, c cid.Cid) (bool, error)

+ func (p *PushProtocol) UnregisterPushRequestHandler()

+ type PushRequestHandler interface

+ HandlePushRequest func(*p2p.PushRequest) (bool, error)

+ type TransferHandler interface

+ GetLimit func() int64

+ HandleTransfer func(r io.Reader)

+ type TransferProtocol struct

+ func NewTransferProtocol(node *Node) *TransferProtocol

+ func (t *TransferProtocol) RegisterTransferHandler(th TransferHandler)

+ func (t *TransferProtocol) Transfer(ctx context.Context, peerID peer.ID, bar io.Writer, payload io.Reader) (int64, error)

+ func (t *TransferProtocol) UnregisterTransferHandler()