webrtc

Documentation

Index

• Variables
• func InitializeWebRTCConnection(configuration *models.Configuration, communication *models.Communication, ...)
• func NewAudioTrack(streams []packets.Stream) *pionWebRTC.TrackLocalStaticSample
• func NewVideoTrack(streams []packets.Stream) *pionWebRTC.TrackLocalStaticSample
• func RegisterCandidates(key string, candidate models.ReceiveHDCandidatesPayload)
• func WriteToTrack(livestreamCursor *packets.QueueCursor, configuration *models.Configuration, ...)
• type WebRTC
  • func CreateWebRTC(name string, stunServers []string, turnServers []string, ...) *WebRTC
  • func (w WebRTC) CreateOffer(sd []byte) pionWebRTC.SessionDescription
  • func (w WebRTC) DecodeSessionDescription(data string) ([]byte, error)

Variables

var (
	CandidatesMutex sync.Mutex
	CandidateArrays map[string](chan string)
)

Functions

func InitializeWebRTCConnection

func InitializeWebRTCConnection(configuration *models.Configuration, communication *models.Communication, mqttClient mqtt.Client, videoTrack *pionWebRTC.TrackLocalStaticSample, audioTrack *pionWebRTC.TrackLocalStaticSample, handshake models.RequestHDStreamPayload)

func NewAudioTrack

func NewAudioTrack(streams []packets.Stream) *pionWebRTC.TrackLocalStaticSample

func NewVideoTrack

func NewVideoTrack(streams []packets.Stream) *pionWebRTC.TrackLocalStaticSample

func RegisterCandidates

func RegisterCandidates(key string, candidate models.ReceiveHDCandidatesPayload)

func WriteToTrack

func WriteToTrack(livestreamCursor *packets.QueueCursor, configuration *models.Configuration, communication *models.Communication, mqttClient mqtt.Client, videoTrack *pionWebRTC.TrackLocalStaticSample, audioTrack *pionWebRTC.TrackLocalStaticSample, rtspClient capture.RTSPClient)

Types

type WebRTC

type WebRTC struct {
	Name                  string
	StunServers           []string
	TurnServers           []string
	TurnServersUsername   string
	TurnServersCredential string
	Timer                 *time.Timer
	PacketsCount          chan int
}

func CreateWebRTC

func CreateWebRTC(name string, stunServers []string, turnServers []string, turnServersUsername string, turnServersCredential string) *WebRTC

func (WebRTC) CreateOffer

func (w WebRTC) CreateOffer(sd []byte) pionWebRTC.SessionDescription

func (WebRTC) DecodeSessionDescription

func (w WebRTC) DecodeSessionDescription(data string) ([]byte, error)