p2p

package

v0.4.18 Latest Latest Go to latest Published: Nov 2, 2018 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gochain-io/go-ipfs

Links

Open Source Insights

Documentation ¶

Index ¶

type Listener
type Listeners
- func (r *Listeners) Close(matchFunc func(listener Listener) bool) int
- func (r *Listeners) Register(l Listener) error
type P2P
- func NewP2P(identity peer.ID, peerHost p2phost.Host, peerstore pstore.Peerstore) *P2P
type Stream
type StreamRegistry

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Listener ¶

type Listener interface {
	Protocol() protocol.ID
	ListenAddress() ma.Multiaddr
	TargetAddress() ma.Multiaddr
	// contains filtered or unexported methods
}

Listener listens for connections and proxies them to a target

type Listeners ¶ added in v0.4.18

type Listeners struct {
	sync.RWMutex

	Listeners map[string]Listener
}

Listeners manages a group of Listener implementations, checking for conflicts and optionally dispatching connections

func (*Listeners) Close ¶ added in v0.4.18

func (r *Listeners) Close(matchFunc func(listener Listener) bool) int

func (*Listeners) Register ¶ added in v0.4.18

func (r *Listeners) Register(l Listener) error

Register registers listenerInfo into this registry and starts it

type P2P ¶

type P2P struct {
	ListenersLocal *Listeners
	ListenersP2P   *Listeners
	Streams        *StreamRegistry
	// contains filtered or unexported fields
}

P2P structure holds information on currently running streams/Listeners

func NewP2P ¶

func NewP2P(identity peer.ID, peerHost p2phost.Host, peerstore pstore.Peerstore) *P2P

NewP2P creates new P2P struct

func (*P2P) CheckProtoExists ¶

func (p2p *P2P) CheckProtoExists(proto string) bool

CheckProtoExists checks whether a proto handler is registered to mux handler

func (*P2P) ForwardLocal ¶ added in v0.4.18

func (p2p *P2P) ForwardLocal(ctx context.Context, peer peer.ID, proto protocol.ID, bindAddr ma.Multiaddr) (Listener, error)

ForwardLocal creates new P2P stream to a remote listener

func (*P2P) ForwardRemote ¶ added in v0.4.18

func (p2p *P2P) ForwardRemote(ctx context.Context, proto protocol.ID, addr ma.Multiaddr) (Listener, error)

ForwardRemote creates new p2p listener

type Stream ¶ added in v0.4.18

type Stream struct {
	Protocol protocol.ID

	OriginAddr ma.Multiaddr
	TargetAddr ma.Multiaddr

	Local  manet.Conn
	Remote net.Stream

	Registry *StreamRegistry
	// contains filtered or unexported fields
}

Stream holds information on active incoming and outgoing p2p streams.

type StreamRegistry ¶

type StreamRegistry struct {
	sync.Mutex

	Streams map[uint64]*Stream

	ifconnmgr.ConnManager
	// contains filtered or unexported fields
}

StreamRegistry is a collection of active incoming and outgoing proto app streams.

func (*StreamRegistry) Close ¶ added in v0.4.18

func (r *StreamRegistry) Close(s *Stream) error

Close stream endpoints and deregister it

func (*StreamRegistry) Deregister ¶

func (r *StreamRegistry) Deregister(streamID uint64)

Deregister deregisters stream from the registry

func (*StreamRegistry) Register ¶

func (r *StreamRegistry) Register(streamInfo *Stream)

Register registers a stream to the registry

func (*StreamRegistry) Reset ¶ added in v0.4.18

func (r *StreamRegistry) Reset(s *Stream) error

Reset closes stream endpoints and deregisters it

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL