peer

Documentation

Index

• type ClientPeer
  • func NewClientPeer(tunnelNum int, endpoint string, cipher tunnel.Cipher) ClientPeer
  • func (cp *ClientPeer) Dial(address string) connection.Connection
• type Peer
  • func (p *Peer) Stop()
• type PeerGroup
  • func NewPeerGroup(cipher tunnel.Cipher) PeerGroup
  • func (pg *PeerGroup) AddTunnel(tunnel *tunnel_pool.Tunnel) error
  • func (pg *PeerGroup) AddTunnelFromConn(conn net.Conn) error
  • func (pg *PeerGroup) RemovePeer(peerID uint32)
• type ServerPeer
  • func NewServerPeerWithID(peerID uint32, peerContext context.Context, removePeerFunc context.CancelFunc) ServerPeer

Types

type ClientPeer

type ClientPeer struct {
	Peer
}

func NewClientPeer

func NewClientPeer(tunnelNum int, endpoint string, cipher tunnel.Cipher) ClientPeer

func (*ClientPeer) Dial

func (cp *ClientPeer) Dial(address string) connection.Connection

type Peer

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

func (*Peer) Stop

func (p *Peer) Stop()

type PeerGroup

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

func NewPeerGroup

func NewPeerGroup(cipher tunnel.Cipher) PeerGroup

func (*PeerGroup) AddTunnel

func (pg *PeerGroup) AddTunnel(tunnel *tunnel_pool.Tunnel) error

Add a tunnel to it's peer; will create peer if not exists

func (*PeerGroup) AddTunnelFromConn

func (pg *PeerGroup) AddTunnelFromConn(conn net.Conn) error

Like AddTunnel, add a raw connection

func (*PeerGroup) RemovePeer

func (pg *PeerGroup) RemovePeer(peerID uint32)

type ServerPeer

type ServerPeer struct {
	Peer
}

func NewServerPeerWithID

func NewServerPeerWithID(peerID uint32, peerContext context.Context, removePeerFunc context.CancelFunc) ServerPeer