mediaserver

package module
v0.1.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 22, 2019 License: GPL-2.0 Imports: 13 Imported by: 24

README

media-server-go

Build Status

WebRTC media server for go

Functionality

We intend to implement support the following features:

How to use

Read the Tutorial

Yon can see the demos from here Demos

Install

You should install libtool and autoconf automake before you build

ubuntu

apt install autoconf
apt install libtool
apt install automake

macOS

brew install libtool
brew install autoconf
brew install automake

Your compiler should support c++17, for linux, you should update your gcc/g++ to 7.0+

sudo add-apt-repository -y ppa:ubuntu-toolchain-r/test
sudo apt-get update -qq
sudo apt-get install g++-7
sudo update-alternatives --install /usr/bin/g++ g++ /usr/bin/g++-7 90

Build the native c/c++ code, it will install openssl libsrtp mp4v2 libmediaserver into /usr/local

git clone --recurse-submodules https://github.com/notedit/media-server-go-native.git  

cd media-server-go-native

make

Install mediaserver go lib

go get github.com/notedit/media-server-go

Thanks

Documentation

Index

Constants

View Source 
const MaxLayerId = 0xFF

Variables

This section is empty.

Functions

func EnableDebug 

func EnableDebug(flag bool)

func EnableLog 

func EnableLog(flag bool)

func EnableUltraDebug 

func EnableUltraDebug(flag bool)

func Max 

func Max(x, y int) int

func Min 

func Min(x, y int) int

func NextSSRC 

func NextSSRC() uint

func SetPortRange 

func SetPortRange(minPort, maxPort int) bool

Types

type ActiveDetectorListener added in v0.1.4 

type ActiveDetectorListener func(*IncomingStreamTrack)

ActiveDetectorListener listener

type ActiveEncoding 

type ActiveEncoding struct {
	EncodingId   string
	SimulcastIdx int
	Bitrate      uint
	Layers       []*Layer
}

ActiveEncoding info

type ActiveLayersInfo 

type ActiveLayersInfo struct {
	Active   []*ActiveEncoding
	Inactive []*ActiveEncoding
	Layers   []*Layer
}

ActiveLayersInfo info

type ActiveSpeakerDetector 

type ActiveSpeakerDetector struct {
	sync.Mutex
	// contains filtered or unexported fields
}

ActiveSpeakerDetector detector the spkeaking track

func NewActiveSpeakerDetector 

func NewActiveSpeakerDetector(listener ActiveDetectorListener) *ActiveSpeakerDetector

NewActiveSpeakerDetector create new active speaker detector

func (*ActiveSpeakerDetector) AddTrack added in v0.1.4 

func (a *ActiveSpeakerDetector) AddTrack(track *IncomingStreamTrack)

AddTrack add incoming track into detector

func (*ActiveSpeakerDetector) RemoveTrack added in v0.1.4 

func (a *ActiveSpeakerDetector) RemoveTrack(track *IncomingStreamTrack)

RemoveTrack remove incoming track from detector

func (*ActiveSpeakerDetector) SetMinChangePeriod 

func (a *ActiveSpeakerDetector) SetMinChangePeriod(minChangePeriod uint)

SetMinChangePeriod set min period change callback in ms

func (*ActiveSpeakerDetector) Stop 

func (a *ActiveSpeakerDetector) Stop()

Stop stop the detector

type BitrateTraversal 

type BitrateTraversal string
const (
	TraversalDefault               BitrateTraversal = "default"
	TraversalSpatialTemporal       BitrateTraversal = "spatial-temporal"
	TraversalTemporalSpatial       BitrateTraversal = "temporal-spatial"
	TraversalZigZagSpatialTemporal BitrateTraversal = "zig-zag-spatial-temporal"
	TraversalZigZagTemporalSpatial BitrateTraversal = "zig-zag-temporal-spatial"
)

type EmulatedTransport added in v0.1.3 

type EmulatedTransport struct {
	sync.Mutex
	// contains filtered or unexported fields
}

EmulatedTransport pcap file as a transport

func NewEmulatedTransport added in v0.1.3 

func NewEmulatedTransport(pcap string) *EmulatedTransport

NewEmulatedTransport create a transport by pcap file

func (*EmulatedTransport) CreateIncomingStream added in v0.1.3 

func (e *EmulatedTransport) CreateIncomingStream(streamInfo *sdp.StreamInfo) *IncomingStream

CreateIncomingStream create incoming stream base on streaminfo

func (*EmulatedTransport) OnIncomingTrack added in v0.1.4 

func (e *EmulatedTransport) OnIncomingTrack(listener IncomingTrackListener)

OnIncomingTrack register incoming track

func (*EmulatedTransport) Pause added in v0.1.3 

func (e *EmulatedTransport) Pause() bool

Pause pause

func (*EmulatedTransport) Play added in v0.1.3 

func (e *EmulatedTransport) Play(time uint64) bool

Play play at start time

func (*EmulatedTransport) Resume added in v0.1.3 

func (e *EmulatedTransport) Resume() bool

Resume resume to play

func (*EmulatedTransport) Seek added in v0.1.3 

func (e *EmulatedTransport) Seek(time uint64) bool

Seek to some time

func (*EmulatedTransport) SetRemoteProperties added in v0.1.3 

func (e *EmulatedTransport) SetRemoteProperties(audio *sdp.MediaInfo, video *sdp.MediaInfo)

func (*EmulatedTransport) Stop added in v0.1.3 

func (e *EmulatedTransport) Stop()

Stop stop this transport

type Encoding 

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

Encoding info

func (*Encoding) GetDepacketizer 

func (e *Encoding) GetDepacketizer() native.StreamTrackDepacketizer

GetDepacketizer get native StreamTrackDepacketizer

func (*Encoding) GetID 

func (e *Encoding) GetID() string

GetID encoding id

func (*Encoding) GetSource 

func (e *Encoding) GetSource() native.RTPIncomingSourceGroup

GetSource get native RTPIncomingSourceGroup

type Endpoint 

type Endpoint struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Endpoint is an endpoint represent an UDP server socket. The endpoint will process STUN requests in order to be able to associate the remote ip:port with the registered transport and forward any further data comming from that transport. Being a server it is ICE-lite.

func NewEndpoint 

func NewEndpoint(ip string) *Endpoint

NewEndpoint create a new endpoint with given ip

func NewEndpointWithPort 

func NewEndpointWithPort(ip string, port int) *Endpoint

NewEndpointWithPort create a new endpint with given ip and port

func (*Endpoint) CreateOffer 

func (e *Endpoint) CreateOffer(video *sdp.Capability, audio *sdp.Capability) *sdp.SDPInfo

CreateOffer create offer based on audio and video capability It generates a random ICE username and password and gets endpoint fingerprint

func (*Endpoint) CreateSDPManager 

func (e *Endpoint) CreateSDPManager(sdpSemantics string, capabilities map[string]*sdp.Capability) SDPManager

CreateSDPManager Create new SDP manager, this object will manage the SDP O/A for you and produce a suitable trasnport.

func (*Endpoint) CreateTransport 

func (e *Endpoint) CreateTransport(remoteSdp *sdp.SDPInfo, localSdp *sdp.SDPInfo, options ...bool) *Transport

CreateTransport create a new transport object and register it with the remote ICE username and password disableSTUNKeepAlive - Disable ICE/STUN keep alives, required for server to server transports, set this to false if you do not how to use it

func (*Endpoint) GetDTLSFingerprint 

func (e *Endpoint) GetDTLSFingerprint() string

GetDTLSFingerprint Get local DTLS fingerprint for this endpoint. It will be shared by all the transport associated to this endpoint

func (*Endpoint) GetLocalCandidates 

func (e *Endpoint) GetLocalCandidates() []*sdp.CandidateInfo

GetLocalCandidates Get local ICE candidates for this endpoint. It will be shared by all the transport associated to this endpoint.

func (*Endpoint) Stop 

func (e *Endpoint) Stop()

Stop stop the endpoint UDP server and terminate any associated transport

type IncomingAllStats 

type IncomingAllStats struct {
	Rtt          uint
	MinWaitTime  uint
	MaxWaitTime  uint
	AvgWaitTime  float64
	Media        *IncomingStats
	Rtx          *IncomingStats
	Fec          *IncomingStats
	Bitrate      uint
	Total        uint
	Remb         uint
	SimulcastIdx int
	// contains filtered or unexported fields
}

IncomingAllStats info

type IncomingStats 

type IncomingStats struct {
	LostPackets    uint
	DropPackets    uint
	NumPackets     uint
	NumRTCPPackets uint
	TotalBytes     uint
	TotalRTCPBytes uint
	TotalPLIs      uint
	TotalNACKs     uint
	Bitrate        uint
	Layers         []*Layer
}

IncomingStats info

type IncomingStream 

type IncomingStream struct {
	sync.Mutex
	// contains filtered or unexported fields
}

IncomingStream The incoming streams represent the recived media stream from a remote peer.

func NewIncomingStreamWithEmulatedTransport added in v0.1.3 

func NewIncomingStreamWithEmulatedTransport(transport native.PCAPTransportEmulator, receiver native.RTPReceiverFacade, info *sdp.StreamInfo) *IncomingStream

NewIncomingStreamWithEmulatedTransport Create new incoming stream through PCAPTransportEmulator

func (*IncomingStream) AddTrack 

func (i *IncomingStream) AddTrack(track *IncomingStreamTrack) error

AddTrack Adds an incoming stream track created using the Transpocnder.CreateIncomingStreamTrack to this stream

func (*IncomingStream) CreateTrack 

func (i *IncomingStream) CreateTrack(track *sdp.TrackInfo) *IncomingStreamTrack

CreateTrack Create new track from a TrackInfo object and add it to this stream

func (*IncomingStream) GetAudioTracks 

func (i *IncomingStream) GetAudioTracks() []*IncomingStreamTrack

GetAudioTracks get all audio tracks

func (*IncomingStream) GetID 

func (i *IncomingStream) GetID() string

GetID get id

func (*IncomingStream) GetStats 

func (i *IncomingStream) GetStats() map[string]map[string]*IncomingAllStats

GetStats Get statistics for all tracks in the stream

func (*IncomingStream) GetStreamInfo 

func (i *IncomingStream) GetStreamInfo() *sdp.StreamInfo

GetStreamInfo get stream info

func (*IncomingStream) GetTrack 

func (i *IncomingStream) GetTrack(trackID string) *IncomingStreamTrack

GetTrack Get track by id

func (*IncomingStream) GetTracks 

func (i *IncomingStream) GetTracks() []*IncomingStreamTrack

GetTracks Get all tracks in this stream

func (*IncomingStream) GetVideoTracks 

func (i *IncomingStream) GetVideoTracks() []*IncomingStreamTrack

GetVideoTracks get all video tracks

func (*IncomingStream) OnStop added in v0.1.4 

func (i *IncomingStream) OnStop(stop func())

OnStop register stop listener

func (*IncomingStream) OnTrack added in v0.1.4 

func (i *IncomingStream) OnTrack(ontrack func(*IncomingStreamTrack))

OnTrack register addtrack listener

func (*IncomingStream) Stop 

func (i *IncomingStream) Stop()

Stop Removes the media strem from the transport and also detaches from any attached incoming stream

type IncomingStreamTrack 

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

IncomingStreamTrack Audio or Video track of a remote media stream

func NewIncomingStreamTrack added in v0.1.5 

func NewIncomingStreamTrack(media string, id string, receiver native.RTPReceiverFacade, sources map[string]native.RTPIncomingSourceGroup) *IncomingStreamTrack

NewIncomingStreamTrack Create incoming audio/video track

func (*IncomingStreamTrack) Attached 

func (i *IncomingStreamTrack) Attached()

Attached Signal that this track has been attached.

func (*IncomingStreamTrack) Detached 

func (i *IncomingStreamTrack) Detached()

Detached Signal that this track has been detached.

func (*IncomingStreamTrack) GetActiveLayers 

func (i *IncomingStreamTrack) GetActiveLayers() *ActiveLayersInfo

GetActiveLayers Get active encodings and layers ordered by bitrate

func (*IncomingStreamTrack) GetEncoding added in v0.1.5 

func (i *IncomingStreamTrack) GetEncoding(encodingID string) *Encoding

GetEncoding get Encoding by id

func (*IncomingStreamTrack) GetEncodings 

func (i *IncomingStreamTrack) GetEncodings() []*Encoding

GetEncodings get all encodings

func (*IncomingStreamTrack) GetFirstEncoding 

func (i *IncomingStreamTrack) GetFirstEncoding() *Encoding

GetFirstEncoding get the first Encoding

func (*IncomingStreamTrack) GetID 

func (i *IncomingStreamTrack) GetID() string

GetID get track id

func (*IncomingStreamTrack) GetMedia 

func (i *IncomingStreamTrack) GetMedia() string

GetMedia get track media type "video" or "audio"

func (*IncomingStreamTrack) GetSSRCs 

func (i *IncomingStreamTrack) GetSSRCs() []map[string]native.RTPIncomingSource

GetSSRCs get all RTPIncomingSource include "media" "rtx" "fec"

func (*IncomingStreamTrack) GetStats 

func (i *IncomingStreamTrack) GetStats() map[string]*IncomingAllStats

GetStats Get stats for all encodings

func (*IncomingStreamTrack) GetTrackInfo 

func (i *IncomingStreamTrack) GetTrackInfo() *sdp.TrackInfo

GetTrackInfo get track info

func (*IncomingStreamTrack) OnAttach added in v0.1.4 

func (i *IncomingStreamTrack) OnAttach(attach func())

OnAttach

func (*IncomingStreamTrack) OnDetach added in v0.1.4 

func (i *IncomingStreamTrack) OnDetach(detach func())

OnDetach

func (*IncomingStreamTrack) OnMediaFrame added in v0.1.5 

func (i *IncomingStreamTrack) OnMediaFrame(listener func([]byte, uint))

func (*IncomingStreamTrack) OnStop added in v0.1.4 

func (i *IncomingStreamTrack) OnStop(stop func())

OnStop register stop callback

func (*IncomingStreamTrack) Refresh 

func (i *IncomingStreamTrack) Refresh()

Refresh Request an intra refres

func (*IncomingStreamTrack) Stop 

func (i *IncomingStreamTrack) Stop()

Stop Removes the track from the incoming stream and also detaches any attached outgoing track or recorder

type IncomingTrackListener added in v0.1.4 

type IncomingTrackListener func(*IncomingStreamTrack, *IncomingStream)

IncomingTrackListener new track listener

type IncomingTrackStopListener added in v0.1.4 

type IncomingTrackStopListener func()

IncomingTrackStopListener stop listener

type Layer 

type Layer struct {
	// EncodingId str
	EncodingId string
	// SpatialLayerId int
	SpatialLayerId int
	// TemporalLayerId  int
	TemporalLayerId int
	// SimulcastIdx int
	SimulcastIdx int
	// TotalBytes uint
	TotalBytes uint
	// NumPackets uint
	NumPackets uint
	// Bitrate  uint
	Bitrate uint
}

Layer info

type MediaStreamDuplicater 

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

MediaStreamDuplicater we can make a copy of the incoming stream and callback the mediaframe data

func NewMediaStreamDuplicater 

func NewMediaStreamDuplicater(track *IncomingStreamTrack) *MediaStreamDuplicater

NewMediaStreamDuplicater duplicate this IncomingStreamTrack and callback the mediaframe

func (*MediaStreamDuplicater) SetMediaFrameListener added in v0.1.5 

func (d *MediaStreamDuplicater) SetMediaFrameListener(listener func([]byte, uint))

SetMediaFrameListener set outside mediaframe listener

func (*MediaStreamDuplicater) Stop 

func (d *MediaStreamDuplicater) Stop()

Stop stop this

type OutgoingStats 

type OutgoingStats struct {
	NumPackets     uint
	NumRTCPPackets uint
	TotalBytes     uint
	TotalRTCPBytes uint
	Bitrate        uint
}

OutgoingStats stats info

type OutgoingStatss 

type OutgoingStatss struct {
	Media *OutgoingStats
	Rtx   *OutgoingStats
	Fec   *OutgoingStats
	// contains filtered or unexported fields
}

OutgoingStatss stats info

type OutgoingStream 

type OutgoingStream struct {
	sync.Mutex
	// contains filtered or unexported fields
}

OutgoingStream represent the media stream sent to a remote peer

func NewOutgoingStream 

func NewOutgoingStream(transport native.DTLSICETransport, info *sdp.StreamInfo) *OutgoingStream

NewOutgoingStream create outgoing stream

func (*OutgoingStream) AddTrack 

func (o *OutgoingStream) AddTrack(track *OutgoingStreamTrack)

AddTrack add one outgoing track

func (*OutgoingStream) AttachTo 

func (o *OutgoingStream) AttachTo(incomingStream *IncomingStream) []*Transponder

AttachTo Listen media from the incoming stream and send it to the remote peer of the associated transport

func (*OutgoingStream) CreateTrack 

func (o *OutgoingStream) CreateTrack(track *sdp.TrackInfo) *OutgoingStreamTrack

CreateTrack Create new track from a TrackInfo object and add it to this stream

func (*OutgoingStream) Detach 

func (o *OutgoingStream) Detach()

Detach Stop listening for media

func (*OutgoingStream) GetAudioTracks 

func (o *OutgoingStream) GetAudioTracks() []*OutgoingStreamTrack

GetAudioTracks Get an array of the media stream audio tracks

func (*OutgoingStream) GetID 

func (o *OutgoingStream) GetID() string

GetID get id

func (*OutgoingStream) GetStats 

func (o *OutgoingStream) GetStats() map[string]*OutgoingStatss

GetStats Get statistics for all tracks in the stream

func (*OutgoingStream) GetStreamInfo 

func (o *OutgoingStream) GetStreamInfo() *sdp.StreamInfo

GetStreamInfo get the stream info

func (*OutgoingStream) GetTrack 

func (o *OutgoingStream) GetTrack(trackID string) *OutgoingStreamTrack

GetTrack get one track

func (*OutgoingStream) GetTracks 

func (o *OutgoingStream) GetTracks() []*OutgoingStreamTrack

GetTracks get all the tracks

func (*OutgoingStream) GetVideoTracks 

func (o *OutgoingStream) GetVideoTracks() []*OutgoingStreamTrack

GetVideoTracks Get an array of the media stream video tracks

func (*OutgoingStream) IsMuted 

func (o *OutgoingStream) IsMuted() bool

IsMuted Check if the stream is muted or not

func (*OutgoingStream) Mute 

func (o *OutgoingStream) Mute(muting bool)

Mute Mute/Unmute this stream and all the tracks in it

func (*OutgoingStream) OnMute added in v0.1.4 

func (o *OutgoingStream) OnMute(listener func(bool))

OnMute register onmute listener

func (*OutgoingStream) OnStop added in v0.1.4 

func (o *OutgoingStream) OnStop(listener func())

OnStop register onstop listener

func (*OutgoingStream) OnTrack added in v0.1.4 

func (o *OutgoingStream) OnTrack(listener func(*OutgoingStreamTrack))

OnTrack new outgoing track listener

func (*OutgoingStream) Stop 

func (o *OutgoingStream) Stop()

Stop stop the remote stream

type OutgoingStreamTrack 

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

OutgoingStreamTrack Audio or Video track of a media stream sent to a remote peer

func (*OutgoingStreamTrack) AttachTo 

func (o *OutgoingStreamTrack) AttachTo(incomingTrack *IncomingStreamTrack) *Transponder

AttachTo Listen media from the incoming stream track and send it to the remote peer of the associated transport

func (*OutgoingStreamTrack) Detach 

func (o *OutgoingStreamTrack) Detach()

Detach Stop forwarding any previous attached track

func (*OutgoingStreamTrack) GetID 

func (o *OutgoingStreamTrack) GetID() string

GetID get track id

func (*OutgoingStreamTrack) GetMedia 

func (o *OutgoingStreamTrack) GetMedia() string

GetMedia get media type

func (*OutgoingStreamTrack) GetSSRCs 

func (o *OutgoingStreamTrack) GetSSRCs() map[string]native.RTPOutgoingSource

GetSSRCs get ssrcs map

func (*OutgoingStreamTrack) GetStats 

func (o *OutgoingStreamTrack) GetStats() *OutgoingStatss

GetStats get stats info

func (*OutgoingStreamTrack) GetTrackInfo 

func (o *OutgoingStreamTrack) GetTrackInfo() *sdp.TrackInfo

GetTrackInfo get track info

func (*OutgoingStreamTrack) GetTransponder 

func (o *OutgoingStreamTrack) GetTransponder() *Transponder

GetTransponder Get attached transpoder for this track

func (*OutgoingStreamTrack) IsMuted 

func (o *OutgoingStreamTrack) IsMuted() bool

IsMuted Check if the track is muted or not

func (*OutgoingStreamTrack) Mute 

func (o *OutgoingStreamTrack) Mute(muting bool)

Mute Mute/Unmute the track

func (*OutgoingStreamTrack) OnMute added in v0.1.4 

func (o *OutgoingStreamTrack) OnMute(mute func(bool))

func (*OutgoingStreamTrack) OnStop added in v0.1.4 

func (o *OutgoingStreamTrack) OnStop(stop func())

OnStop

func (*OutgoingStreamTrack) Stop 

func (o *OutgoingStreamTrack) Stop()

Stop Removes the track from the outgoing stream and also detaches from any attached incoming track

type OutgoingTrackListener added in v0.1.4 

type OutgoingTrackListener func(*OutgoingStreamTrack, *OutgoingStream)

OutgoingTrackListener new track listener

type Player 

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

Player can player the file as webrtc source

func NewPlayer 

func NewPlayer(filename string, listener PlayerEndListener) (*Player, error)

NewPlayer create new file player

func (*Player) GetAudioTracks 

func (p *Player) GetAudioTracks() []*IncomingStreamTrack

GetAudioTracks audio tracks this file contains

func (*Player) GetTracks 

func (p *Player) GetTracks() []*IncomingStreamTrack

GetTracks tracks this file contains

func (*Player) GetVideoTracks 

func (p *Player) GetVideoTracks() []*IncomingStreamTrack

GetVideoTracks video tracks this file contains

func (*Player) Pause 

func (p *Player) Pause()

Pause play

func (*Player) Play 

func (p *Player) Play()

Play start

func (*Player) Resume 

func (p *Player) Resume()

Resume play

func (*Player) Seek 

func (p *Player) Seek(time uint64)

Seek seek to

func (*Player) Stop 

func (p *Player) Stop()

Stop stop play

type PlayerEndListener added in v0.1.4 

type PlayerEndListener func()

PlayerEndListener end listener

type RawStreamer added in v0.1.5 

type RawStreamer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

RawStreamer streamer that can send raw rtp data

func NewRawStreamer added in v0.1.5 

func NewRawStreamer() *RawStreamer

NewRawStreamer create new raw rtp streamer

func (*RawStreamer) CreateSession added in v0.1.5 

func (s *RawStreamer) CreateSession(media *sdp.MediaInfo) *RawStreamerSession

CreateSession create a audio/media session

func (*RawStreamer) RemoveSession added in v0.1.5 

func (s *RawStreamer) RemoveSession(session *RawStreamerSession)

RemoveSession remove a session

func (*RawStreamer) Stop added in v0.1.5 

func (s *RawStreamer) Stop()

Stop stop this streamer

type RawStreamerSession added in v0.1.5 

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

func NewRawStreamerSession added in v0.1.5 

func NewRawStreamerSession(media *sdp.MediaInfo) *RawStreamerSession

func (*RawStreamerSession) GetID added in v0.1.5 

func (s *RawStreamerSession) GetID() string

func (*RawStreamerSession) GetIncomingStreamTrack added in v0.1.5 

func (s *RawStreamerSession) GetIncomingStreamTrack() *IncomingStreamTrack

func (*RawStreamerSession) Push added in v0.1.5 

func (s *RawStreamerSession) Push(rtp []byte)

func (*RawStreamerSession) Stop added in v0.1.5 

func (s *RawStreamerSession) Stop()

type Recorder 

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

Recorder represent a file recorder

func NewRecorder 

func NewRecorder(filename string, waitForIntra bool, refresh int) *Recorder

func (*Recorder) Record 

func (r *Recorder) Record(incoming *IncomingStreamTrack)

func (*Recorder) RecordStream 

func (r *Recorder) RecordStream(incoming *IncomingStream)

func (*Recorder) Stop 

func (r *Recorder) Stop()

type RecorderTrack 

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

RecorderTrack a track to record

func NewRecorderTrack 

func NewRecorderTrack(id string, track *IncomingStreamTrack, encoding *Encoding) *RecorderTrack

NewRecorderTrack create a new recorder track

func (*RecorderTrack) GetEncoding 

func (r *RecorderTrack) GetEncoding() *Encoding

GetEncoding get encoding info

func (*RecorderTrack) GetID 

func (r *RecorderTrack) GetID() string

GetID get recorder track id

func (*RecorderTrack) GetTrack 

func (r *RecorderTrack) GetTrack() *IncomingStreamTrack

GetTrack get internal IncomingStreamTrack

func (*RecorderTrack) OnStop added in v0.1.4 

func (r *RecorderTrack) OnStop(stop RecorderTrackStopListener)

OnStop register a stop listener

func (*RecorderTrack) Stop 

func (r *RecorderTrack) Stop()

Stop stop the recorder track

type RecorderTrackStopListener added in v0.1.4 

type RecorderTrackStopListener func()

type Refresher 

type Refresher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewRefresher 

func NewRefresher(period int) *Refresher

func (*Refresher) Add 

func (r *Refresher) Add(incom *IncomingStreamTrack)

func (*Refresher) AddStream 

func (r *Refresher) AddStream(incoming *IncomingStream)

func (*Refresher) Stop 

func (r *Refresher) Stop()

type RenegotiationCallback 

type RenegotiationCallback func(transport *Transport)

type SDPManager 

type SDPManager interface {
	GetState() string
	GetTransport() *Transport
	CreateLocalDescription() (*sdp.SDPInfo, error)
	ProcessRemoteDescription(sdp string) (*sdp.SDPInfo, error)
}

SDPManager interface

type SDPManagerPlanb 

type SDPManagerPlanb struct {
	OnRenegotiation RenegotiationCallback
	// contains filtered or unexported fields
}

SDPManagerPlanb planb manager

func NewSDPManagerPlanb 

func NewSDPManagerPlanb(endpoint *Endpoint, capabilities map[string]*sdp.Capability) *SDPManagerPlanb

func (*SDPManagerPlanb) CreateLocalDescription 

func (s *SDPManagerPlanb) CreateLocalDescription() (*sdp.SDPInfo, error)

func (*SDPManagerPlanb) GetState 

func (s *SDPManagerPlanb) GetState() string

func (*SDPManagerPlanb) GetTransport 

func (s *SDPManagerPlanb) GetTransport() *Transport

func (*SDPManagerPlanb) ProcessRemoteDescription 

func (s *SDPManagerPlanb) ProcessRemoteDescription(sdpStr string) (*sdp.SDPInfo, error)

type SDPManagerUnified 

type SDPManagerUnified struct {
	OnRenegotiation RenegotiationCallback
	// contains filtered or unexported fields
}

SDPManagerUnified unified plan manager

func NewSDPManagerUnified 

func NewSDPManagerUnified(endpoint *Endpoint, capabilities map[string]*sdp.Capability) *SDPManagerUnified

NewSDPManagerUnified create SDPUnified manager

func (*SDPManagerUnified) CreateLocalDescription 

func (s *SDPManagerUnified) CreateLocalDescription() (*sdp.SDPInfo, error)

func (*SDPManagerUnified) GetState 

func (s *SDPManagerUnified) GetState() string

func (*SDPManagerUnified) GetTransport 

func (s *SDPManagerUnified) GetTransport() *Transport

func (*SDPManagerUnified) ProcessRemoteDescription 

func (s *SDPManagerUnified) ProcessRemoteDescription(sdpStr string) (*sdp.SDPInfo, error)

type Streamer 

type Streamer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Streamer

func NewStreamer 

func NewStreamer() *Streamer

NewStreamer create a streamer

func (*Streamer) CreateSession 

func (s *Streamer) CreateSession(local bool, ip string, port int, media *sdp.MediaInfo) *StreamerSession

CreateSession

func (*Streamer) RemoveSession added in v0.1.5 

func (s *Streamer) RemoveSession(session *StreamerSession)

RemoveSession remove a session

func (*Streamer) Stop 

func (s *Streamer) Stop()

Stop stop all sessions

type StreamerSession 

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

StreamerSession represent a rtp session

func NewStreamerSession 

func NewStreamerSession(local bool, ip string, port int, media *sdp.MediaInfo) *StreamerSession

NewStreamerSession new StreamerSession

func (*StreamerSession) GetID 

func (s *StreamerSession) GetID() string

GetID get id

func (*StreamerSession) GetIncomingStreamTrack 

func (s *StreamerSession) GetIncomingStreamTrack() *IncomingStreamTrack

GetIncomingStreamTrack get asso incoming track,

func (*StreamerSession) GetOutgoingStreamTrack 

func (s *StreamerSession) GetOutgoingStreamTrack() *OutgoingStreamTrack

GetOutgoingStreamTrack get asso outgoing track,

func (*StreamerSession) OnStop added in v0.1.4 

func (s *StreamerSession) OnStop(stop func())

OnStop register stop listener

func (*StreamerSession) Stop 

func (s *StreamerSession) Stop()

Stop it

type Transponder 

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

Transponder

func NewTransponder 

func NewTransponder(transponderFacade native.RTPStreamTransponderFacade) *Transponder

func (*Transponder) GetAvailableLayers 

func (t *Transponder) GetAvailableLayers() *ActiveLayersInfo

GetAvailableLayers Get available encodings and layers

func (*Transponder) GetIncomingTrack 

func (t *Transponder) GetIncomingTrack() *IncomingStreamTrack

func (*Transponder) GetSelectedEncoding 

func (t *Transponder) GetSelectedEncoding() string

GetSelectedEncoding get selected encoding id

func (*Transponder) GetSelectedSpatialLayerId 

func (t *Transponder) GetSelectedSpatialLayerId() int

GetSelectedSpatialLayerId return int

func (*Transponder) GetSelectedTemporalLayerId 

func (t *Transponder) GetSelectedTemporalLayerId() int

GetSelectedTemporalLayerId return int

func (*Transponder) IsMuted 

func (t *Transponder) IsMuted() bool

func (*Transponder) Mute 

func (t *Transponder) Mute(muting bool)

func (*Transponder) OnMute added in v0.1.4 

func (t *Transponder) OnMute(listener func(bool))

OnMute register mute listener

func (*Transponder) OnStop added in v0.1.4 

func (t *Transponder) OnStop(stop func())

OnStop register stop listener

func (*Transponder) SelectEncoding 

func (t *Transponder) SelectEncoding(encodingId string)

SelectEncoding by id

func (*Transponder) SelectLayer 

func (t *Transponder) SelectLayer(spatialLayerId, temporalLayerId int)

SelectLayer Select SVC temporatl and spatial layers. Only available for VP9 media.

func (*Transponder) SetIncomingTrack 

func (t *Transponder) SetIncomingTrack(incomingTrack *IncomingStreamTrack) error

func (*Transponder) SetMaximumLayers 

func (t *Transponder) SetMaximumLayers(maxSpatialLayerId, maxTemporalLayerId int)

func (*Transponder) SetTargetBitrate 

func (t *Transponder) SetTargetBitrate(bitrate uint, traversal BitrateTraversal, strict bool) uint

func (*Transponder) Stop 

func (t *Transponder) Stop()

Stop stop this transponder

type Transport 

type Transport struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Transport represent a connection between a local ICE candidate and a remote set of ICE candidates over a single DTLS session

func NewTransport 

func NewTransport(bundle native.RTPBundleTransport, remoteIce *sdp.ICEInfo, remoteDtls *sdp.DTLSInfo, remoteCandidates []*sdp.CandidateInfo,
	localIce *sdp.ICEInfo, localDtls *sdp.DTLSInfo, localCandidates []*sdp.CandidateInfo, disableSTUNKeepAlive bool) *Transport

NewTransport create a new transport

func (*Transport) AddRemoteCandidate 

func (t *Transport) AddRemoteCandidate(candidate *sdp.CandidateInfo)

AddRemoteCandidate register a remote candidate info. Only needed for ice-lite to ice-lite endpoints

func (*Transport) CreateIncomingStream 

func (t *Transport) CreateIncomingStream(streamInfo *sdp.StreamInfo) *IncomingStream

CreateIncomingStream Create an incoming stream object from the media stream info objet

func (*Transport) CreateIncomingStreamTrack 

func (t *Transport) CreateIncomingStreamTrack(media string, trackId string, ssrcs map[string]uint) *IncomingStreamTrack

CreateIncomingStreamTrack Create new incoming stream in this transport. TODO: Simulcast is still not supported You can use IncomingStream's CreateTrack

func (*Transport) CreateOutgoingStream 

func (t *Transport) CreateOutgoingStream(streamInfo *sdp.StreamInfo) *OutgoingStream

CreateOutgoingStream Create new outgoing stream in this transport using StreamInfo

func (*Transport) CreateOutgoingStreamTrack 

func (t *Transport) CreateOutgoingStreamTrack(media string, trackId string, ssrcs map[string]uint) *OutgoingStreamTrack

CreateOutgoingStreamTrack Create new outgoing track in this transport

func (*Transport) CreateOutgoingStreamWithID 

func (t *Transport) CreateOutgoingStreamWithID(streamID string, audio bool, video bool) *OutgoingStream

CreateOutgoingStreamWithID alias CreateOutgoingStream

func (*Transport) Dump added in v0.1.3 

func (t *Transport) Dump(filename string, incoming bool, outgoing bool, rtcp bool) bool

Dump dump incoming and outgoint rtp and rtcp packets into a pcap file

func (*Transport) GetIncomingStream 

func (t *Transport) GetIncomingStream(streamId string) *IncomingStream

GetIncomingStream get one incoming stream

func (*Transport) GetIncomingStreams 

func (t *Transport) GetIncomingStreams() []*IncomingStream

GetIncomingStreams get all incoming streams

func (*Transport) GetLocalCandidates 

func (t *Transport) GetLocalCandidates() []*sdp.CandidateInfo

GetLocalCandidates Get local ICE candidates for this transport

func (*Transport) GetLocalDTLSInfo 

func (t *Transport) GetLocalDTLSInfo() *sdp.DTLSInfo

GetLocalDTLSInfo Get transport local DTLS info

func (*Transport) GetLocalICEInfo 

func (t *Transport) GetLocalICEInfo() *sdp.ICEInfo

GetLocalICEInfo Get transport local ICE info

func (*Transport) GetOutgoingStream 

func (t *Transport) GetOutgoingStream(streamId string) *OutgoingStream

GetOutgoingStream get one outgoing stream

func (*Transport) GetOutgoingStreams 

func (t *Transport) GetOutgoingStreams() []*OutgoingStream

GetOutgoingStreams get all outgoing streams

func (*Transport) GetRemoteCandidates 

func (t *Transport) GetRemoteCandidates() []*sdp.CandidateInfo

GetRemoteCandidates Get remote ICE candidates for this transport

func (*Transport) OnIncomingTrack added in v0.1.4 

func (t *Transport) OnIncomingTrack(listener IncomingTrackListener)

OnIncomingTrack register incoming track

func (*Transport) OnOutgoingTrack added in v0.1.4 

func (t *Transport) OnOutgoingTrack(listener OutgoingTrackListener)

OnOutgoingTrack register outgoing track

func (*Transport) OnStop added in v0.1.4 

func (t *Transport) OnStop(stop TransportStopListener)

OnStop register a stop listener

func (*Transport) SetBandwidthProbing 

func (t *Transport) SetBandwidthProbing(probe bool)

SetBandwidthProbing Enable/Disable bitrate probing This will send padding only RTX packets to allow bandwidth estimation algortithm to probe bitrate beyonf current sent values. The ammoung of probing bitrate would be limited by the sender bitrate estimation and the limit set on the setMaxProbing Bitrate.

func (*Transport) SetLocalProperties 

func (t *Transport) SetLocalProperties(audio *sdp.MediaInfo, video *sdp.MediaInfo)

SetLocalProperties Set local RTP properties

func (*Transport) SetMaxProbingBitrate 

func (t *Transport) SetMaxProbingBitrate(bitrate uint)

SetMaxProbingBitrate Set the maximum bitrate to be used if probing is enabled.

func (*Transport) SetRemoteProperties 

func (t *Transport) SetRemoteProperties(audio *sdp.MediaInfo, video *sdp.MediaInfo)

SetRemoteProperties Set remote RTP properties

func (*Transport) Stop 

func (t *Transport) Stop()

Stop stop this transport

type TransportStopListener added in v0.1.4 

type TransportStopListener func()

TransportStopListener listener

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.