peer

Documentation

Index

• Variables
• type Peer
  • func NewTunnel(parentCtx context.Context, id string, stunServers []string, ...) *Peer
  • func (p *Peer) AddICECandidate(candidateStr string) error
  • func (p *Peer) Close() error
  • func (p *Peer) RecvMessage(msg webrtc.DataChannelMessage)
  • func (p *Peer) SendMessage(msg proxymsg.ProxyMessage) error
  • func (p *Peer) SetRemoteDescription(descrStr string) error
  • func (p *Peer) SetStateListener(listener StateListener)
  • func (p *Peer) Start(descrStr string) (err error)
• type PeersContainer
  • func NewAllowedPeers() *PeersContainer
  • func (a *PeersContainer) Add(id string, peer *Peer)
  • func (a *PeersContainer) Get(id string) *Peer
  • func (a *PeersContainer) Remove(id string)
• type ProxyMessageReceiver
• type StateListener
• type WebRTCListener

Variables

var AlreadyStartedError = errors.New("tunnel already started")

Types

type Peer

type Peer struct {
	Id                string
	AllowedLocalPorts []int
	AllowedAll        bool
	// contains filtered or unexported fields
}

func NewTunnel

func NewTunnel(parentCtx context.Context, id string, stunServers []string, listener WebRTCListener) *Peer

func (*Peer) AddICECandidate

func (p *Peer) AddICECandidate(candidateStr string) error

func (*Peer) Close

func (p *Peer) Close() error

func (*Peer) RecvMessage

func (p *Peer) RecvMessage(msg webrtc.DataChannelMessage)

func (*Peer) SendMessage

func (p *Peer) SendMessage(msg proxymsg.ProxyMessage) error

func (*Peer) SetRemoteDescription

func (p *Peer) SetRemoteDescription(descrStr string) error

func (*Peer) SetStateListener

func (p *Peer) SetStateListener(listener StateListener)

func (*Peer) Start

func (p *Peer) Start(descrStr string) (err error)

type PeersContainer

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

func NewAllowedPeers

func NewAllowedPeers() *PeersContainer

func (*PeersContainer) Add

func (a *PeersContainer) Add(id string, peer *Peer)

func (*PeersContainer) Get

func (a *PeersContainer) Get(id string) *Peer

func (*PeersContainer) Remove

func (a *PeersContainer) Remove(id string)

type ProxyMessageReceiver

type ProxyMessageReceiver interface {
	RecvMessage(msg proxymsg.ProxyMessage) error
}

type StateListener

type StateListener interface {
	OnICEConnectionStateChange(p *Peer, state webrtc.ICEConnectionState)
	OnDataChannel(p *Peer, channel *webrtc.DataChannel)
}

type WebRTCListener

type WebRTCListener interface {
	OnICECandidate(p *Peer, candidate *webrtc.ICECandidate)
	OnLocalDescription(p *Peer, sdp webrtc.SessionDescription)
	OnConnected(p *Peer)
}