net

Documentation

Index

• type NetAPI
  • func (a *NetAPI) ID(context.Context) (peer.ID, error)
  • func (a *NetAPI) NetAddrsListen(context.Context) (peer.AddrInfo, error)
  • func (a *NetAPI) NetAgentVersion(ctx context.Context, p peer.ID) (string, error)
  • func (a *NetAPI) NetAutoNatStatus(context.Context) (i api.NatInfo, err error)
  • func (a *NetAPI) NetBandwidthStats(ctx context.Context) (metrics.Stats, error)
  • func (a *NetAPI) NetBandwidthStatsByPeer(ctx context.Context) (map[string]metrics.Stats, error)
  • func (a *NetAPI) NetBandwidthStatsByProtocol(ctx context.Context) (map[protocol.ID]metrics.Stats, error)
  • func (a *NetAPI) NetBlockAdd(ctx context.Context, acl api.NetBlockList) error
  • func (a *NetAPI) NetBlockList(ctx context.Context) (result api.NetBlockList, err error)
  • func (a *NetAPI) NetBlockRemove(ctx context.Context, acl api.NetBlockList) error
  • func (a *NetAPI) NetConnect(ctx context.Context, p peer.AddrInfo) error
  • func (a *NetAPI) NetConnectedness(ctx context.Context, pid peer.ID) (network.Connectedness, error)
  • func (a *NetAPI) NetDisconnect(ctx context.Context, p peer.ID) error
  • func (a *NetAPI) NetFindPeer(ctx context.Context, p peer.ID) (peer.AddrInfo, error)
  • func (a *NetAPI) NetLimit(ctx context.Context, scope string) (result api.NetLimit, err error)
  • func (a *NetAPI) NetPeerInfo(_ context.Context, p peer.ID) (*api.ExtendedPeerInfo, error)
  • func (a *NetAPI) NetPeers(context.Context) ([]peer.AddrInfo, error)
  • func (a *NetAPI) NetPing(ctx context.Context, p peer.ID) (time.Duration, error)
  • func (a *NetAPI) NetProtectAdd(ctx context.Context, peers []peer.ID) error
  • func (a *NetAPI) NetProtectList(ctx context.Context) (result []peer.ID, err error)
  • func (a *NetAPI) NetProtectRemove(ctx context.Context, peers []peer.ID) error
  • func (a *NetAPI) NetPubsubScores(context.Context) ([]api.PubsubScore, error)
  • func (a *NetAPI) NetSetLimit(ctx context.Context, scope string, limit api.NetLimit) error
  • func (a *NetAPI) NetStat(ctx context.Context, scope string) (result api.NetStat, err error)

Types

type NetAPI

type NetAPI struct {
	fx.In

	RawHost         lp2p.RawHost
	Host            host.Host
	Router          lp2p.BaseIpfsRouting
	ConnGater       *conngater.BasicConnectionGater
	ResourceManager network.ResourceManager
	Reporter        metrics.Reporter
	Sk              *dtypes.ScoreKeeper
}

func (*NetAPI) ID

func (a *NetAPI) ID(context.Context) (peer.ID, error)

func (*NetAPI) NetAddrsListen

func (a *NetAPI) NetAddrsListen(context.Context) (peer.AddrInfo, error)

func (*NetAPI) NetAgentVersion

func (a *NetAPI) NetAgentVersion(ctx context.Context, p peer.ID) (string, error)

func (*NetAPI) NetAutoNatStatus

func (a *NetAPI) NetAutoNatStatus(context.Context) (i api.NatInfo, err error)

func (*NetAPI) NetBandwidthStats

func (a *NetAPI) NetBandwidthStats(ctx context.Context) (metrics.Stats, error)

func (*NetAPI) NetBandwidthStatsByPeer

func (a *NetAPI) NetBandwidthStatsByPeer(ctx context.Context) (map[string]metrics.Stats, error)

func (*NetAPI) NetBandwidthStatsByProtocol

func (a *NetAPI) NetBandwidthStatsByProtocol(ctx context.Context) (map[protocol.ID]metrics.Stats, error)

func (*NetAPI) NetBlockAdd

func (a *NetAPI) NetBlockAdd(ctx context.Context, acl api.NetBlockList) error

func (*NetAPI) NetBlockList

func (a *NetAPI) NetBlockList(ctx context.Context) (result api.NetBlockList, err error)

func (*NetAPI) NetBlockRemove

func (a *NetAPI) NetBlockRemove(ctx context.Context, acl api.NetBlockList) error

func (*NetAPI) NetConnect

func (a *NetAPI) NetConnect(ctx context.Context, p peer.AddrInfo) error

func (*NetAPI) NetConnectedness

func (a *NetAPI) NetConnectedness(ctx context.Context, pid peer.ID) (network.Connectedness, error)

func (*NetAPI) NetDisconnect

func (a *NetAPI) NetDisconnect(ctx context.Context, p peer.ID) error

func (*NetAPI) NetFindPeer

func (a *NetAPI) NetFindPeer(ctx context.Context, p peer.ID) (peer.AddrInfo, error)

func (*NetAPI) NetLimit

func (a *NetAPI) NetLimit(ctx context.Context, scope string) (result api.NetLimit, err error)

func (*NetAPI) NetPeerInfo

func (a *NetAPI) NetPeerInfo(_ context.Context, p peer.ID) (*api.ExtendedPeerInfo, error)

func (*NetAPI) NetPeers

func (a *NetAPI) NetPeers(context.Context) ([]peer.AddrInfo, error)

func (*NetAPI) NetPing

func (a *NetAPI) NetPing(ctx context.Context, p peer.ID) (time.Duration, error)

func (*NetAPI) NetProtectAdd

func (a *NetAPI) NetProtectAdd(ctx context.Context, peers []peer.ID) error

func (*NetAPI) NetProtectList

func (a *NetAPI) NetProtectList(ctx context.Context) (result []peer.ID, err error)

func (*NetAPI) NetProtectRemove

func (a *NetAPI) NetProtectRemove(ctx context.Context, peers []peer.ID) error

func (*NetAPI) NetPubsubScores

func (a *NetAPI) NetPubsubScores(context.Context) ([]api.PubsubScore, error)

func (*NetAPI) NetSetLimit

func (a *NetAPI) NetSetLimit(ctx context.Context, scope string, limit api.NetLimit) error

func (*NetAPI) NetStat

func (a *NetAPI) NetStat(ctx context.Context, scope string) (result api.NetStat, err error)