httpnet

Jul 31, 2025

Changes in this version

type Network

+ func (ht *Network) IsConnectedToPeer(ctx context.Context, p peer.ID) bool

type Option

+ func WithConnectEventManager(evm *network.ConnectEventManager) Option

Jul 8, 2025

Changes in this version

type Option

+ func WithMetricsLabelsForEndpoints(hosts []string) Option

Jun 17, 2025

Changes in this version

type Network

+ func (ht *Network) Host() host.Host

May 28, 2025

Changes in this version

+ const DefaultMaxDontHaveErrors

type Option

+ func WithMaxDontHaveErrors(threshold int) Option

Apr 30, 2025

Changes in this version

+ var ErrNotConnected = errors.New("no HTTP connection has been setup to this peer")

type Option

+ func WithDenylist(hosts []string) Option

Mar 5, 2025

Changes in this version

+ const DefaultDialTimeout

+ const DefaultHTTPWorkers

+ const DefaultIdleConnTimeout

+ const DefaultInsecureSkipVerify

+ const DefaultMaxBackoff

+ const DefaultMaxBlockSize

+ const DefaultMaxHTTPAddressesPerPeer

+ const DefaultMaxIdleConns

+ const DefaultMaxRetries

+ const DefaultResponseHeaderTimeout

+ const DefaultSendErrorBackoff

+ const DefaultSendTimeout

+ var DefaultUserAgent = defaultUserAgent()

+ var ErrNoHTTPAddresses = errors.New("AddrInfo does not contain any valid HTTP addresses")

+ var ErrNoSuccess = errors.New("none of the peer HTTP endpoints responded successfully to request")

+ func New(host host.Host, opts ...Option) network.BitSwapNetwork

+ type Network struct

+ func (ht *Network) Connect(ctx context.Context, p peer.AddrInfo) error

+ func (ht *Network) DisconnectFrom(ctx context.Context, p peer.ID) error

+ func (ht *Network) Latency(p peer.ID) time.Duration

+ func (ht *Network) NewMessageSender(ctx context.Context, p peer.ID, opts *network.MessageSenderOpts) (network.MessageSender, error)

+ func (ht *Network) Ping(ctx context.Context, p peer.ID) ping.Result

+ func (ht *Network) Protect(p peer.ID, tag string)

+ func (ht *Network) Self() peer.ID

+ func (ht *Network) SendMessage(ctx context.Context, p peer.ID, msg bsmsg.BitSwapMessage) error

+ func (ht *Network) Start(receivers ...network.Receiver)

+ func (ht *Network) Stats() network.Stats

+ func (ht *Network) Stop()

+ func (ht *Network) TagPeer(p peer.ID, tag string, w int)

+ func (ht *Network) Unprotect(p peer.ID, tag string) bool

+ func (ht *Network) UntagPeer(p peer.ID, tag string)

+ type Option func(net *Network)

+ func WithAllowlist(hosts []string) Option

+ func WithDialTimeout(t time.Duration) Option

+ func WithHTTPWorkers(n int) Option

+ func WithIdleConnTimeout(t time.Duration) Option

+ func WithInsecureSkipVerify(b bool) Option

+ func WithMaxBlockSize(size int64) Option

+ func WithMaxHTTPAddressesPerPeer(max int) Option

+ func WithMaxIdleConns(n int) Option

+ func WithResponseHeaderTimeout(t time.Duration) Option

+ func WithUserAgent(agent string) Option