opp2p_client

Documentation

Index

• type InstrumentedOpP2PClient
  • func New(ctx context.Context, config *config.Config, network string, nodeName string, ...) (*InstrumentedOpP2PClient, error)
  • func (i *InstrumentedOpP2PClient) ConnectPeer(ctx context.Context, addr string) error
  • func (i *InstrumentedOpP2PClient) DisconnectPeer(ctx context.Context, p peer.ID) error
  • func (i *InstrumentedOpP2PClient) PeerStats(ctx context.Context) (*opp2p.PeerStats, error)
  • func (i *InstrumentedOpP2PClient) Peers(ctx context.Context, connected bool) (*opp2p.PeerDump, error)
  • func (i *InstrumentedOpP2PClient) ProtectPeer(ctx context.Context, p peer.ID) error
  • func (i *InstrumentedOpP2PClient) Self(ctx context.Context) (*opp2p.PeerInfo, error)
  • func (i *InstrumentedOpP2PClient) UnblockPeer(ctx context.Context, p peer.ID) error
  • func (i *InstrumentedOpP2PClient) UnprotectPeer(ctx context.Context, p peer.ID) error

Types

type InstrumentedOpP2PClient

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

func New

func New(ctx context.Context, config *config.Config, network string, nodeName string, rpcUrl string) (*InstrumentedOpP2PClient, error)

func (*InstrumentedOpP2PClient) ConnectPeer

func (i *InstrumentedOpP2PClient) ConnectPeer(ctx context.Context, addr string) error

func (*InstrumentedOpP2PClient) DisconnectPeer

func (i *InstrumentedOpP2PClient) DisconnectPeer(ctx context.Context, p peer.ID) error

func (*InstrumentedOpP2PClient) PeerStats

func (i *InstrumentedOpP2PClient) PeerStats(ctx context.Context) (*opp2p.PeerStats, error)

func (*InstrumentedOpP2PClient) Peers

func (i *InstrumentedOpP2PClient) Peers(ctx context.Context, connected bool) (*opp2p.PeerDump, error)

func (*InstrumentedOpP2PClient) ProtectPeer

func (i *InstrumentedOpP2PClient) ProtectPeer(ctx context.Context, p peer.ID) error

func (*InstrumentedOpP2PClient) Self

func (i *InstrumentedOpP2PClient) Self(ctx context.Context) (*opp2p.PeerInfo, error)

func (*InstrumentedOpP2PClient) UnblockPeer

func (i *InstrumentedOpP2PClient) UnblockPeer(ctx context.Context, p peer.ID) error

func (*InstrumentedOpP2PClient) UnprotectPeer

func (i *InstrumentedOpP2PClient) UnprotectPeer(ctx context.Context, p peer.ID) error