rtc

Documentation

Index

• Variables
• func RoomConnection(c *websocket.Conn, p *Peers)
• func StreamConn(c *websocket.Conn, p *Peers)
• type PeerConnectionState
  • func NewPeerConnectionState() *PeerConnectionState
• type Peers
  • func (p *Peers) AddTrack(t *webrtc.TrackRemote) *webrtc.TrackLocalStaticRTP
  • func (p *Peers) DispatchKeyFrame()
  • func (p *Peers) RemoveTrack(t *webrtc.TrackLocalStaticRTP)
  • func (p *Peers) SignalPeerConnections()
• type Room
• type ThreadSafeWriter
  • func (t *ThreadSafeWriter) WriteJSON(v interface{}) error

Variables

var (
	RoomsLock sync.RWMutex
	Rooms     map[string]*Room
	Streams   map[string]*Room
)

Functions

func RoomConnection

func RoomConnection(c *websocket.Conn, p *Peers)

func StreamConn

func StreamConn(c *websocket.Conn, p *Peers)

Types

type PeerConnectionState

type PeerConnectionState struct {
	PeerConnection *webrtc.PeerConnection
	Websocket      *ThreadSafeWriter
}

func NewPeerConnectionState

func NewPeerConnectionState() *PeerConnectionState

type Peers

type Peers struct {
	ListLock    sync.RWMutex
	Connections []PeerConnectionState
	TrackLocals map[string]*webrtc.TrackLocalStaticRTP
}

func (*Peers) AddTrack

func (p *Peers) AddTrack(t *webrtc.TrackRemote) *webrtc.TrackLocalStaticRTP

func (*Peers) DispatchKeyFrame

func (p *Peers) DispatchKeyFrame()

func (*Peers) RemoveTrack

func (p *Peers) RemoveTrack(t *webrtc.TrackLocalStaticRTP)

func (*Peers) SignalPeerConnections

func (p *Peers) SignalPeerConnections()

type Room

type Room struct {
	Peers *Peers
	Hub   *chat.Hub
}

type ThreadSafeWriter

type ThreadSafeWriter struct {
	Conn  *websocket.Conn
	Mutex sync.Mutex
}

func (*ThreadSafeWriter) WriteJSON

func (t *ThreadSafeWriter) WriteJSON(v interface{}) error