mediaserver

package module

Go to main page

Versions in this module

v0

v0.2.1

May 8, 2020

v0.2.0

May 5, 2020

Changes in this version

+ type MediaFrameSession struct

+ func NewMediaFrameSession(media *sdp.MediaInfo) *MediaFrameSession

+ func (s *MediaFrameSession) GetIncomingStreamTrack() *IncomingStreamTrack

+ func (s *MediaFrameSession) Push(rtp []byte)

+ func (s *MediaFrameSession) Stop()

v0.1.18

Jan 12, 2020

v0.1.17

Jan 9, 2020

v0.1.16

Jan 8, 2020

v0.1.15

Jan 1, 2020

Changes in this version

type IncomingStream

+ func (i *IncomingStream) RemoveTrack(track *IncomingStreamTrack) error

type OutgoingStream

+ func (o *OutgoingStream) RemoveTrack(track *OutgoingStreamTrack)

v0.1.14

Jun 30, 2019

v0.1.13

Jun 30, 2019

Changes in this version

type StreamerSession

+ func NewStreamerSessionWithLocalPort(port int, media *sdp.MediaInfo) *StreamerSession

+ func (s *StreamerSession) GetLocalPort() int

v0.1.12

Jun 30, 2019

Changes in this version

type StreamerSession

+ func (s *StreamerSession) SetLocalPort(port int)

+ func (s *StreamerSession) SetRemotePort(ip string, port int)

v0.1.11

Jun 25, 2019

v0.1.10

Jun 24, 2019

v0.1.9

Jun 24, 2019

Changes in this version

type ActiveSpeakerDetector

+ func (a *ActiveSpeakerDetector) SetMaxAccumulatedScore(maxAcummulatedScore uint64)

+ func (a *ActiveSpeakerDetector) SetMinActivationScore(minActivationScore uint)

+ func (a *ActiveSpeakerDetector) SetNoiseGatingThreshold(noiseGatingThreshold byte)

+ type DTLSStateListener func(state string)

type Endpoint

+ func (e *Endpoint) SetAffinity(cpu int)

+ type ICEStats struct

+ RequestsReceived int64

+ RequestsSent int64

+ ResponsesReceived int64

+ ResponsesSent int64

+ type IncomingStreamTrackMirrored struct

+ func NewMirrorIncomingTrack(track *IncomingStreamTrack, timeService native.TimeService) *IncomingStreamTrackMirrored

+ func (t *IncomingStreamTrackMirrored) Attached() bool

+ func (t *IncomingStreamTrackMirrored) Detached() bool

+ func (t *IncomingStreamTrackMirrored) GetActiveLayers() *ActiveLayersInfo

+ func (t *IncomingStreamTrackMirrored) GetID() string

+ func (t *IncomingStreamTrackMirrored) GetMedia() string

+ func (t *IncomingStreamTrackMirrored) GetSSRCs()

+ func (t *IncomingStreamTrackMirrored) GetStats() map[string]*IncomingAllStats

+ func (t *IncomingStreamTrackMirrored) GetTrackInfo() *sdp.TrackInfo

+ func (t *IncomingStreamTrackMirrored) Refresh()

+ func (t *IncomingStreamTrackMirrored) Stop()

+ type MediaFrameMultiplexer struct

+ func NewMediaFrameMultiplexer(track *IncomingStreamTrack) *MediaFrameMultiplexer

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

+ func (d *MediaFrameMultiplexer) Stop()

type Transport

+ func (t *Transport) GetDTLSState() string

+ func (t *Transport) GetICEStats() *ICEStats

+ func (t *Transport) OnDTLSICEState(listener DTLSStateListener)

+ func (t *Transport) RemoveIncomingStream(incomingStream *IncomingStream)

v0.1.8

Apr 22, 2019

v0.1.7

Apr 18, 2019

v0.1.6

Mar 22, 2019

v0.1.5

Feb 26, 2019

Changes in this version

type IncomingStreamTrack

+ func NewIncomingStreamTrack(media string, id string, receiver native.RTPReceiverFacade, ...) *IncomingStreamTrack

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

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

type MediaStreamDuplicater

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

+ type RawStreamer struct

+ func NewRawStreamer() *RawStreamer

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

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

+ func (s *RawStreamer) Stop()

+ type RawStreamerSession struct

+ func NewRawStreamerSession(media *sdp.MediaInfo) *RawStreamerSession

+ func (s *RawStreamerSession) GetID() string

+ func (s *RawStreamerSession) GetIncomingStreamTrack() *IncomingStreamTrack

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

+ func (s *RawStreamerSession) Stop()

type Streamer

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

v0.1.4

Jan 15, 2019

Changes in this version

+ type ActiveDetectorListener func(*IncomingStreamTrack)

type ActiveSpeakerDetector

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

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

type EmulatedTransport

+ func (e *EmulatedTransport) OnIncomingTrack(listener IncomingTrackListener)

type IncomingStream

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

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

type IncomingStreamTrack

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

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

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

+ type IncomingTrackListener func(*IncomingStreamTrack, *IncomingStream)

+ type IncomingTrackStopListener func()

type OutgoingStream

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

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

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

type OutgoingStreamTrack

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

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

+ type OutgoingTrackListener func(*OutgoingStreamTrack, *OutgoingStream)

+ type PlayerEndListener func()

type RecorderTrack

+ func (r *RecorderTrack) OnStop(stop RecorderTrackStopListener)

+ type RecorderTrackStopListener func()

type StreamerSession

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

type Transponder

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

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

type Transport

+ func (t *Transport) OnIncomingTrack(listener IncomingTrackListener)

+ func (t *Transport) OnOutgoingTrack(listener OutgoingTrackListener)

+ func (t *Transport) OnStop(stop TransportStopListener)

+ type TransportStopListener func()

v0.1.3

Jan 3, 2019

Changes in this version

type BitrateTraversal

+ const TraversalTemporalSpatial

+ type EmulatedTransport struct

+ func NewEmulatedTransport(pcap string) *EmulatedTransport

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

+ func (e *EmulatedTransport) Pause() bool

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

+ func (e *EmulatedTransport) Resume() bool

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

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

+ func (e *EmulatedTransport) Stop()

type IncomingStream

+ func NewIncomingStreamWithEmulatedTransport(transport native.PCAPTransportEmulator, receiver native.RTPReceiverFacade, ...) *IncomingStream

type Transport

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

v0.1.2

Dec 28, 2018

Changes in this version

+ const MaxLayerId

+ func EnableDebug(flag bool)

+ func EnableLog(flag bool)

+ func EnableUltraDebug(flag bool)

+ func Max(x, y int) int

+ func Min(x, y int) int

+ func NextSSRC() uint

+ func SetPortRange(minPort, maxPort int) bool

+ type ActiveEncoding struct

+ Bitrate uint

+ EncodingId string

+ Layers []*Layer

+ SimulcastIdx int

+ type ActiveLayersInfo struct

+ Active []*ActiveEncoding

+ Inactive []*ActiveEncoding

+ Layers []*Layer

+ type ActiveSpeakerDetector struct

+ func NewActiveSpeakerDetector() *ActiveSpeakerDetector

+ func (a *ActiveSpeakerDetector) AddSpeaker(track *IncomingStreamTrack)

+ func (a *ActiveSpeakerDetector) RemoveSpeaker(track *IncomingStreamTrack)

+ func (a *ActiveSpeakerDetector) SetMinChangePeriod(minChangePeriod uint)

+ func (a *ActiveSpeakerDetector) Stop()

+ type BitrateTraversal string

+ const TraversalDefault

+ const TraversalSpatialTemporal

+ const TraversalZigZagSpatialTemporal

+ const TraversalZigZagTemporalSpatial

+ type Encoding struct

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

+ func (e *Encoding) GetID() string

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

+ type Endpoint struct

+ func NewEndpoint(ip string) *Endpoint

+ func NewEndpointWithPort(ip string, port int) *Endpoint

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

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

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

+ func (e *Endpoint) CreateTransportWithRemote(sdpInfo *sdp.SDPInfo, disableSTUNKeepAlive bool) *Transport

+ func (e *Endpoint) GetDTLSFingerprint() string

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

+ func (e *Endpoint) Stop()

+ type IncomingAllStats struct

+ AvgWaitTime float64

+ Bitrate uint

+ Fec *IncomingStats

+ MaxWaitTime uint

+ Media *IncomingStats

+ MinWaitTime uint

+ Remb uint

+ Rtt uint

+ Rtx *IncomingStats

+ SimulcastIdx int

+ Total uint

+ type IncomingStats struct

+ Bitrate uint

+ DropPackets uint

+ Layers []*Layer

+ LostPackets uint

+ NumPackets uint

+ NumRTCPPackets uint

+ TotalBytes uint

+ TotalNACKs uint

+ TotalPLIs uint

+ TotalRTCPBytes uint

+ type IncomingStream struct

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

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

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

+ func (i *IncomingStream) GetID() string

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

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

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

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

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

+ func (i *IncomingStream) Stop()

+ type IncomingStreamTrack struct

+ func (i *IncomingStreamTrack) Attached()

+ func (i *IncomingStreamTrack) Detached()

+ func (i *IncomingStreamTrack) GetActiveLayers() *ActiveLayersInfo

+ func (i *IncomingStreamTrack) GetEncodings() map[string]*Encoding

+ func (i *IncomingStreamTrack) GetFirstEncoding() *Encoding

+ func (i *IncomingStreamTrack) GetID() string

+ func (i *IncomingStreamTrack) GetMedia() string

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

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

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

+ func (i *IncomingStreamTrack) Refresh()

+ func (i *IncomingStreamTrack) Stop()

+ type Layer struct

+ Bitrate uint

+ EncodingId string

+ NumPackets uint

+ SimulcastIdx int

+ SpatialLayerId int

+ TemporalLayerId int

+ TotalBytes uint

+ type MediaFrameCallback func(frame []byte, duration uint, timestamp uint)

+ type MediaStreamDuplicater struct

+ func NewMediaStreamDuplicater(track *IncomingStreamTrack, callback MediaFrameCallback) *MediaStreamDuplicater

+ func (d *MediaStreamDuplicater) Stop()

+ type OutgoingStats struct

+ Bitrate uint

+ NumPackets uint

+ NumRTCPPackets uint

+ TotalBytes uint

+ TotalRTCPBytes uint

+ type OutgoingStatss struct

+ Fec *OutgoingStats

+ Media *OutgoingStats

+ Rtx *OutgoingStats

+ type OutgoingStream struct

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

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

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

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

+ func (o *OutgoingStream) Detach()

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

+ func (o *OutgoingStream) GetID() string

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

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

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

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

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

+ func (o *OutgoingStream) IsMuted() bool

+ func (o *OutgoingStream) Mute(muting bool)

+ func (o *OutgoingStream) Stop()

+ type OutgoingStreamTrack struct

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

+ func (o *OutgoingStreamTrack) Detach()

+ func (o *OutgoingStreamTrack) GetID() string

+ func (o *OutgoingStreamTrack) GetMedia() string

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

+ func (o *OutgoingStreamTrack) GetStats() *OutgoingStatss

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

+ func (o *OutgoingStreamTrack) GetTransponder() *Transponder

+ func (o *OutgoingStreamTrack) IsMuted() bool

+ func (o *OutgoingStreamTrack) Mute(muting bool)

+ func (o *OutgoingStreamTrack) Stop()

+ type Player struct

+ func NewPlayer(filename string) (*Player, error)

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

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

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

+ func (p *Player) Pause()

+ func (p *Player) Play()

+ func (p *Player) Resume()

+ func (p *Player) Seek(time uint64)

+ func (p *Player) Stop()

+ type RawRTPStreamer struct

+ func NewRawRTPStreamer() *RawRTPStreamer

+ func (s *RawRTPStreamer) CreateSession(media *sdp.MediaInfo) *RawRTPStreamerSession

+ func (s *RawRTPStreamer) Stop()

+ type RawRTPStreamerSession struct

+ func NewRawRTPStreamerSession(media *sdp.MediaInfo) *RawRTPStreamerSession

+ func (s *RawRTPStreamerSession) GetID() string

+ func (s *RawRTPStreamerSession) GetIncomingStreamTrack() *IncomingStreamTrack

+ func (s *RawRTPStreamerSession) Push(rtp []byte)

+ func (s *RawRTPStreamerSession) Stop()

+ type Recorder struct

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

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

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

+ func (r *Recorder) Stop()

+ type RecorderTrack struct

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

+ func (r *RecorderTrack) GetEncoding() *Encoding

+ func (r *RecorderTrack) GetID() string

+ func (r *RecorderTrack) GetTrack() *IncomingStreamTrack

+ func (r *RecorderTrack) Stop()

+ type Refresher struct

+ func NewRefresher(period int) *Refresher

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

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

+ func (r *Refresher) Stop()

+ type RenegotiationCallback func(transport *Transport)

+ type SDPManager interface

+ CreateLocalDescription func() (*sdp.SDPInfo, error)

+ GetState func() string

+ GetTransport func() *Transport

+ ProcessRemoteDescription func(sdp string) (*sdp.SDPInfo, error)

+ type SDPManagerPlanb struct

+ OnRenegotiation RenegotiationCallback

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

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

+ func (s *SDPManagerPlanb) GetState() string

+ func (s *SDPManagerPlanb) GetTransport() *Transport

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

+ type SDPManagerUnified struct

+ OnRenegotiation RenegotiationCallback

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

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

+ func (s *SDPManagerUnified) GetState() string

+ func (s *SDPManagerUnified) GetTransport() *Transport

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

+ type Streamer struct

+ func NewStreamer() *Streamer

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

+ func (s *Streamer) Stop()

+ type StreamerSession struct

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

+ func (s *StreamerSession) GetID() string

+ func (s *StreamerSession) GetIncomingStreamTrack() *IncomingStreamTrack

+ func (s *StreamerSession) GetOutgoingStreamTrack() *OutgoingStreamTrack

+ func (s *StreamerSession) Stop()

+ type Transponder struct

+ func NewTransponder(transponderFacade native.RTPStreamTransponderFacade) *Transponder

+ func (t *Transponder) GetAvailableLayers()

+ func (t *Transponder) GetIncomingTrack() *IncomingStreamTrack

+ func (t *Transponder) GetSelectedEncoding() string

+ func (t *Transponder) GetSelectedSpatialLayerId() int

+ func (t *Transponder) GetSelectedTemporalLayerId() int

+ func (t *Transponder) IsMuted() bool

+ func (t *Transponder) Mute(muting bool)

+ func (t *Transponder) SelectEncoding()

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

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

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

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

+ func (t *Transponder) Stop()

+ type Transport struct

+ func NewTransport(bundle native.RTPBundleTransport, remoteIce *sdp.ICEInfo, ...) *Transport

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

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

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

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

+ func (t *Transport) CreateOutgoingStream2(streamInfo *sdp.StreamInfo) *OutgoingStream

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

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

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

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

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

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

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

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

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

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

+ func (t *Transport) SetBandwidthProbing(probe bool)

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

+ func (t *Transport) SetMaxProbingBitrate(bitrate uint)

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

+ func (t *Transport) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL