quichub

Documentation

Index

• func Dial(privateKey inet256.PrivateKey, id inet256.ID, addr string) (p2p.SecureAskSwarm[inet256.Addr], error)
• func Listen(privateKey inet256.PrivateKey, addr string) (p2p.SecureAskSwarm[inet256.Addr], error)
• type Addr
  • func ParseAddr(x string) (*Addr, error)
  • func (a *Addr) String() string
• type QUICHub
  • func (qh *QUICHub) Ask(ctx context.Context, resp []byte, dst inet256.Addr, req p2p.IOVec) (int, error)
  • func (qh *QUICHub) Close() error
  • func (qh *QUICHub) LocalAddrs() []inet256.Addr
  • func (qh *QUICHub) LookupPublicKey(ctx context.Context, target inet256.Addr) (p2p.PublicKey, error)
  • func (qh *QUICHub) MTU(ctx context.Context, target inet256.Addr) int
  • func (qh *QUICHub) MaxIncomingSize() int
  • func (qh *QUICHub) ParseAddr(x []byte) (inet256.Addr, error)
  • func (qh *QUICHub) PublicKey() p2p.PublicKey
  • func (qh *QUICHub) Receive(ctx context.Context, fn func(p2p.Message[inet256.Addr])) error
  • func (qh *QUICHub) ServeAsk(ctx context.Context, ...) error
  • func (qh *QUICHub) Tell(ctx context.Context, dst inet256.Addr, data p2p.IOVec) error

Functions

func Dial

func Dial(privateKey inet256.PrivateKey, id inet256.ID, addr string) (p2p.SecureAskSwarm[inet256.Addr], error)

func Listen

func Listen(privateKey inet256.PrivateKey, addr string) (p2p.SecureAskSwarm[inet256.Addr], error)

Types

type Addr

type Addr struct {
	ID   inet256.ID
	Addr string
}

func ParseAddr

func ParseAddr(x string) (*Addr, error)

ParseAddr parses an address of the form <id>@<host>:<port>

func (*Addr) String

func (a *Addr) String() string

type QUICHub

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

QUICHub provides a p2p.SecureAskSwarm[inet256.Addr] using QUIC.

func (*QUICHub) Ask

func (qh *QUICHub) Ask(ctx context.Context, resp []byte, dst inet256.Addr, req p2p.IOVec) (int, error)

func (*QUICHub) Close

func (qh *QUICHub) Close() error

func (*QUICHub) LocalAddrs

func (qh *QUICHub) LocalAddrs() []inet256.Addr

func (*QUICHub) LookupPublicKey

func (qh *QUICHub) LookupPublicKey(ctx context.Context, target inet256.Addr) (p2p.PublicKey, error)

func (*QUICHub) MTU

func (qh *QUICHub) MTU(ctx context.Context, target inet256.Addr) int

func (*QUICHub) MaxIncomingSize

func (qh *QUICHub) MaxIncomingSize() int

func (*QUICHub) ParseAddr

func (qh *QUICHub) ParseAddr(x []byte) (inet256.Addr, error)

func (*QUICHub) PublicKey

func (qh *QUICHub) PublicKey() p2p.PublicKey

func (*QUICHub) Receive

func (qh *QUICHub) Receive(ctx context.Context, fn func(p2p.Message[inet256.Addr])) error

func (*QUICHub) ServeAsk

func (qh *QUICHub) ServeAsk(ctx context.Context, fn func(context.Context, []byte, p2p.Message[inet256.Addr]) int) error

func (*QUICHub) Tell

func (qh *QUICHub) Tell(ctx context.Context, dst inet256.Addr, data p2p.IOVec) error