service

Documentation

Index

• Constants
• type Peer
  • func NewPeer(stream proto.TunnelService_ConnectServer, logger *logrus.Logger, ...) (*Peer, error)
  • func (peer *Peer) Close()
  • func (peer *Peer) Handle() error
• type Peers
  • func NewPeers() *Peers
  • func (p *Peers) Add(peer *Peer)
  • func (p *Peers) Close() error
  • func (p *Peers) Remove(peer *Peer)
• type TunnelService
  • func NewTunnel(logger *logrus.Logger, conf *config.ConfMap) *TunnelService
  • func (t *TunnelService) Close() error
  • func (t *TunnelService) Connect(stream proto.TunnelService_ConnectServer) error
  • func (t *TunnelService) IsAvailableFromThisSource(stream proto.TunnelService_ConnectServer, peerConf *config.PeerConfMap) error

Constants

const MaxSegmentSize = (1 << 16) - 1 // largest possible TCP datagram

Types

type Peer

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

func NewPeer

func NewPeer(stream proto.TunnelService_ConnectServer, logger *logrus.Logger, peerConf *config.PeerConfMap) (*Peer, error)

func (*Peer) Close

func (peer *Peer) Close()

func (*Peer) Handle

func (peer *Peer) Handle() error

type Peers

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

func NewPeers

func NewPeers() *Peers

func (*Peers) Add

func (p *Peers) Add(peer *Peer)

func (*Peers) Close

func (p *Peers) Close() error

func (*Peers) Remove

func (p *Peers) Remove(peer *Peer)

type TunnelService

type TunnelService struct {
	proto.UnimplementedTunnelServiceServer
	// contains filtered or unexported fields
}

func NewTunnel

func NewTunnel(logger *logrus.Logger, conf *config.ConfMap) *TunnelService

func (*TunnelService) Close

func (t *TunnelService) Close() error

func (*TunnelService) Connect

func (t *TunnelService) Connect(stream proto.TunnelService_ConnectServer) error

func (*TunnelService) IsAvailableFromThisSource

func (t *TunnelService) IsAvailableFromThisSource(stream proto.TunnelService_ConnectServer, peerConf *config.PeerConfMap) error