rtc

Documentation

Index

• Constants
• func Decode(in string, obj interface{})
• type BitrateChangeOffer
• type MessageType
• type OutputMessage
• type WebRTCStreamer
  • func NewWebRTCStreamer() *WebRTCStreamer
  • func (r *WebRTCStreamer) Recv() chan []byte
  • func (r *WebRTCStreamer) Send() chan OutputMessage
  • func (r *WebRTCStreamer) Start()
• type WebRTCViewer
  • func NewWebRTCViewer() *WebRTCViewer
  • func (r *WebRTCViewer) LateStart(videoStream *webrtc.TrackLocalStaticRTP, ...)
  • func (r *WebRTCViewer) Recv() chan []byte
  • func (r *WebRTCViewer) Send() chan OutputMessage
  • func (r *WebRTCViewer) Start()
• type WebRtcClient
• type WebRtcInfo

Constants

const (
	WebRTCOffer       MessageType = "webRtcOffer"
	IceCandidate                  = "iceCandidate"
	BitrateChangeType             = "bitrateChange"
)

Functions

func Decode

func Decode(in string, obj interface{})

Types

type BitrateChangeOffer

type BitrateChangeOffer struct {
	Bitrate uint64 `json:"bitrate"`
}

type MessageType

type MessageType string

type OutputMessage

type OutputMessage struct {
	Data []byte
	Type messages.MessageType
}

type WebRTCStreamer

type WebRTCStreamer struct {
	WebRtcVideoStream chan *webrtc.TrackLocalStaticRTP
	WebRtcAudioStream chan *webrtc.TrackLocalStaticRTP
	// contains filtered or unexported fields
}

func NewWebRTCStreamer

func NewWebRTCStreamer() *WebRTCStreamer

func (*WebRTCStreamer) Recv

func (r *WebRTCStreamer) Recv() chan []byte

func (*WebRTCStreamer) Send

func (r *WebRTCStreamer) Send() chan OutputMessage

func (*WebRTCStreamer) Start

func (r *WebRTCStreamer) Start()

type WebRTCViewer

type WebRTCViewer struct {
	WebRtcVideoStream chan *webrtc.TrackLocalStaticRTP
	WebRtcAudioStream chan *webrtc.TrackLocalStaticRTP
	// contains filtered or unexported fields
}

func NewWebRTCViewer

func NewWebRTCViewer() *WebRTCViewer

func (*WebRTCViewer) LateStart

func (r *WebRTCViewer) LateStart(videoStream *webrtc.TrackLocalStaticRTP, audioStream *webrtc.TrackLocalStaticRTP)

func (*WebRTCViewer) Recv

func (r *WebRTCViewer) Recv() chan []byte

func (*WebRTCViewer) Send

func (r *WebRTCViewer) Send() chan OutputMessage

func (*WebRTCViewer) Start

func (r *WebRTCViewer) Start()

type WebRtcClient

type WebRtcClient interface {
	Send() chan OutputMessage
	Recv() chan []byte
}

type WebRtcInfo

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