p2p

Documentation

Index

• Constants
• Variables
• func RunDaemon() (*core.IpfsNode, func(), error)
• type P2pService
  • func NewP2pService(node *core.IpfsNode) *P2pService
  • func (s *P2pService) CheckPort(target ma.Multiaddr) error
  • func (s *P2pService) CloseListen(ctx context.Context, protoOpt string, listenOpt string, targetOpt string) error
  • func (s *P2pService) CreateForward(ctx context.Context, protoOpt string, listenOpt string, targetOpt string) error
  • func (s *P2pService) Ping(ctx context.Context, peerId string) bool

Constants

const P2PProtoPrefix = "/x/"

const SwarmKey = "/key/swarm/psk/1.0.0/\n/base16/\n2108249f85354ed11ecf999a4500e9b616f71516b6c222ce630d14e434ef5562"

Variables

var ProviderSet = wire.NewSet(RunDaemon)

Functions

func RunDaemon

func RunDaemon() (*core.IpfsNode, func(), error)

Types

type P2pService

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

func NewP2pService

func NewP2pService(node *core.IpfsNode) *P2pService

func (*P2pService) CheckPort

func (s *P2pService) CheckPort(target ma.Multiaddr) error

checkPort checks whether target multiaddr contains tcp or udp protocol and whether the port is equal to 0

func (*P2pService) CloseListen

func (s *P2pService) CloseListen(ctx context.Context, protoOpt string, listenOpt string, targetOpt string) error

func (*P2pService) CreateForward

func (s *P2pService) CreateForward(ctx context.Context, protoOpt string, listenOpt string, targetOpt string) error

func (*P2pService) Ping

func (s *P2pService) Ping(ctx context.Context, peerId string) bool