overlay

Documentation

Index

• Variables
• func NewOverlayListener(ol *OverlayPeer) net.Listener
• type OverlayClient
  • func NewOverlayClient(p *gossip.GossipPeer, remotePeer mesh.PeerName, remotePeerHost string, ...) (*OverlayClient, error)
  • func (oc *OverlayClient) Destroy() error
  • func (oc *OverlayClient) NotifyOpenChReqToServer(streamId uint16) error
  • func (oc *OverlayClient) OpenChannel(streamId uint16) (*OverlayStream, uint16, error)
• type OverlayListener
  • func (ol *OverlayListener) Accept() (net.Conn, error)
  • func (ol *OverlayListener) Addr() net.Addr
  • func (ol *OverlayListener) Close() error
• type OverlayPeer
  • func NewOverlayPeer(selfPeerId uint64, gossipListenHost *string, gossipListenPort int, ...) (*OverlayPeer, error)
  • func (olPeer *OverlayPeer) Accept() (stream *OverlayStream, remotePeerId mesh.PeerName, remotePeerHost *string, ...)
  • func (olPeer *OverlayPeer) GetOverlayListener() net.Listener
  • func (olPeer *OverlayPeer) OpenStreamToTargetPeer(peerId mesh.PeerName, remotePeerHost string) net.Conn
• type OverlayServer
  • func NewOverlayServer(p *gossip.GossipPeer, gossipMM *gossip.GossipMessageManager) (*OverlayServer, error)
  • func (ols *OverlayServer) Accept() (*OverlayStream, mesh.PeerName, *string, uint16, error)
  • func (ols *OverlayServer) ClientInfoNotifyPktRootHandlerTh()
  • func (ols *OverlayServer) Close() error
  • func (ols *OverlayServer) InitClientInfoNotifyPktRootHandlerTh() error
• type OverlayStream
  • func NewOverlayStream(channel *datachannel.DataChannel, oc *OverlayClient, assoc *sctp.Association, ...) *OverlayStream
  • func (os *OverlayStream) Close() error
  • func (os *OverlayStream) LocalAddr() net.Addr
  • func (os *OverlayStream) Read(p []byte) (n int, err error)
  • func (os *OverlayStream) RemoteAddr() net.Addr
  • func (os *OverlayStream) SetDeadline(t time.Time) error
  • func (os *OverlayStream) SetReadDeadline(t time.Time) error
  • func (os *OverlayStream) SetWriteDeadline(t time.Time) error
  • func (os *OverlayStream) Write(p []byte) (n int, err error)

Variables

var LoggerObj *log.Logger

Functions

func NewOverlayListener

func NewOverlayListener(ol *OverlayPeer) net.Listener

Types

type OverlayClient

type OverlayClient struct {
	HertbeatThFinCh *chan bool
	// contains filtered or unexported fields
}

wrapper of sctp.Client

func NewOverlayClient

func NewOverlayClient(p *gossip.GossipPeer, remotePeer mesh.PeerName, remotePeerHost string, gossipMM *gossip.GossipMessageManager) (*OverlayClient, error)

func (*OverlayClient) Destroy

func (oc *OverlayClient) Destroy() error

func (*OverlayClient) NotifyOpenChReqToServer

func (oc *OverlayClient) NotifyOpenChReqToServer(streamId uint16) error

func (*OverlayClient) OpenChannel

func (oc *OverlayClient) OpenChannel(streamId uint16) (*OverlayStream, uint16, error)

type OverlayListener

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

func (*OverlayListener) Accept

func (ol *OverlayListener) Accept() (net.Conn, error)

Accept waits for and returns the next connection to the listener. func (ol *OverlayListener) Accept() (net.Conn, error) {

func (*OverlayListener) Addr

func (ol *OverlayListener) Addr() net.Addr

Addr returns the listener's network address.

func (*OverlayListener) Close

func (ol *OverlayListener) Close() error

Close closes the listener. Any blocked Accept operations will be unblocked and return errors.

type OverlayPeer

type OverlayPeer struct {
	Peer *gossip.GossipPeer
	// contains filtered or unexported fields
}

func NewOverlayPeer

func NewOverlayPeer(selfPeerId uint64, gossipListenHost *string, gossipListenPort int, peers *util.Stringset, isUseOnProxy bool) (*OverlayPeer, error)

func (*OverlayPeer) Accept

func (olPeer *OverlayPeer) Accept() (stream *OverlayStream, remotePeerId mesh.PeerName, remotePeerHost *string, streamId uint16, err error)

func (*OverlayPeer) GetOverlayListener

func (olPeer *OverlayPeer) GetOverlayListener() net.Listener

func (*OverlayPeer) OpenStreamToTargetPeer

func (olPeer *OverlayPeer) OpenStreamToTargetPeer(peerId mesh.PeerName, remotePeerHost string) net.Conn

type OverlayServer

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

wrapper of sctp.Server

func NewOverlayServer

func NewOverlayServer(p *gossip.GossipPeer, gossipMM *gossip.GossipMessageManager) (*OverlayServer, error)

func (*OverlayServer) Accept

func (ols *OverlayServer) Accept() (*OverlayStream, mesh.PeerName, *string, uint16, error)

func (*OverlayServer) ClientInfoNotifyPktRootHandlerTh

func (ols *OverlayServer) ClientInfoNotifyPktRootHandlerTh()

func (*OverlayServer) Close

func (ols *OverlayServer) Close() error

func (*OverlayServer) InitClientInfoNotifyPktRootHandlerTh

func (ols *OverlayServer) InitClientInfoNotifyPktRootHandlerTh() error

type OverlayStream

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

func NewOverlayStream

func NewOverlayStream(channel *datachannel.DataChannel, oc *OverlayClient, assoc *sctp.Association, gsess *gossip.GossipSession) *OverlayStream

func (*OverlayStream) Close

func (os *OverlayStream) Close() error

func (*OverlayStream) LocalAddr

func (os *OverlayStream) LocalAddr() net.Addr

func (*OverlayStream) Read

func (os *OverlayStream) Read(p []byte) (n int, err error)

func (*OverlayStream) RemoteAddr

func (os *OverlayStream) RemoteAddr() net.Addr

func (*OverlayStream) SetDeadline

func (os *OverlayStream) SetDeadline(t time.Time) error

func (*OverlayStream) SetReadDeadline

func (os *OverlayStream) SetReadDeadline(t time.Time) error

func (*OverlayStream) SetWriteDeadline

func (os *OverlayStream) SetWriteDeadline(t time.Time) error

func (*OverlayStream) Write

func (os *OverlayStream) Write(p []byte) (n int, err error)