proximitytransport

Nov 13, 2020

Changes in this version

type NoopNativeDriver

+ func NewNoopNativeDriver(protocolCode int, protocolName, defaultAddr string) *NoopNativeDriver

+ func (d *NoopNativeDriver) SetDefaultAddr(protocolAddr string)

+ func (d *NoopNativeDriver) SetProtocolCode(protocolCode int)

+ func (d *NoopNativeDriver) SetProtocolName(protocolName string)

Oct 26, 2020

Changes in this version

+ var TransportMap sync.Map

+ func NewTransport(ctx context.Context, l *zap.Logger, driver NativeDriver) func(h host.Host, u *tptu.Upgrader) (*ProximityTransport, error)

+ type Addr struct

+ Address string

+ func (b *Addr) Network() string

+ func (b *Addr) String() string

+ type Conn struct

+ func (c *Conn) Close() error

+ func (c *Conn) LocalAddr() net.Addr

+ func (c *Conn) LocalMultiaddr() ma.Multiaddr

+ func (c *Conn) Read(payload []byte) (n int, err error)

+ func (c *Conn) RemoteAddr() net.Addr

+ func (c *Conn) RemoteMultiaddr() ma.Multiaddr

+ func (c *Conn) SetDeadline(t time.Time) error

+ func (c *Conn) SetReadDeadline(t time.Time) error

+ func (c *Conn) SetWriteDeadline(t time.Time) error

+ func (c *Conn) Write(payload []byte) (n int, err error)

+ type Listener struct

+ func (l *Listener) Accept() (tpt.CapableConn, error)

+ func (l *Listener) Addr() net.Addr

+ func (l *Listener) Close() error

+ func (l *Listener) Multiaddr() ma.Multiaddr

+ type NativeDriver interface

+ CloseConnWithPeer func(remotePID string)

+ DefaultAddr func() string

+ DialPeer func(remotePID string) bool

+ ProtocolCode func() int

+ ProtocolName func() string

+ SendToPeer func(remotePID string, payload []byte) bool

+ Start func(localPID string)

+ Stop func()

+ type NoopNativeDriver struct

+ func (d *NoopNativeDriver) CloseConnWithPeer(_ string)

+ func (d *NoopNativeDriver) DefaultAddr() string

+ func (d *NoopNativeDriver) DialPeer(_ string) bool

+ func (d *NoopNativeDriver) ProtocolCode() int

+ func (d *NoopNativeDriver) ProtocolName() string

+ func (d *NoopNativeDriver) SendToPeer(_ string, _ []byte) bool

+ func (d *NoopNativeDriver) Start(_ string)

+ func (d *NoopNativeDriver) Stop()

+ type ProximityTransport struct

+ func (t *ProximityTransport) CanDial(remoteMa ma.Multiaddr) bool

+ func (t *ProximityTransport) Dial(ctx context.Context, remoteMa ma.Multiaddr, remotePID peer.ID) (tpt.CapableConn, error)

+ func (t *ProximityTransport) HandleFoundPeer(sRemotePID string) bool

+ func (t *ProximityTransport) HandleLostPeer(sRemotePID string)

+ func (t *ProximityTransport) Listen(localMa ma.Multiaddr) (tpt.Listener, error)

+ func (t *ProximityTransport) Protocols() []int

+ func (t *ProximityTransport) Proxy() bool

+ func (t *ProximityTransport) ReceiveFromPeer(remotePID string, payload []byte)

+ func (t *ProximityTransport) String() string