distribution

package

Go to main page

Versions in this module

v0

v0.1.5

Mar 12, 2026

v0.1.4

Mar 12, 2026

v0.1.3

Mar 10, 2026

Changes in this version

type Relay

+ func (r *Relay) BroadcastVideoNoCache(frame *media.VideoFrame)

v0.1.2

Mar 10, 2026

Changes in this version

type MoQSessionConfig

+ OnDatagram func(streamKey string, data []byte)

type ServerConfig

+ OnDatagram func(streamKey string, data []byte)

v0.1.1

Mar 4, 2026

Changes in this version

+ type ControlBroadcaster struct

+ func NewControlBroadcaster() *ControlBroadcaster

+ func (b *ControlBroadcaster) Run(ctx context.Context, source <-chan []byte)

+ func (b *ControlBroadcaster) Subscribe(id string) <-chan []byte

+ func (b *ControlBroadcaster) Unsubscribe(id string)

type MoQSessionConfig

+ ControlBroadcaster *ControlBroadcaster

type ServerConfig

+ ControlCh <-chan []byte

+ OnStreamRegistered func(key string, relay *Relay)

+ OnStreamUnregistered func(key string)

type StreamFrameWriter

+ WriteDataObject func(w io.Writer, data []byte, timestampMS uint32) (int64, error)

v0.1.0

Mar 4, 2026

Changes in this version

+ const TrackIDAudioBase

+ const TrackIDCaptions

+ const TrackIDVideo

+ func AudioTrackID(trackIndex int) byte

+ type AudioInfo struct

+ Channels int

+ Codec string

+ SampleRate int

+ type AudioTrackStats struct

+ BitrateKbps float64

+ Channels int

+ Codec string

+ Frames int64

+ PTSErrors int64

+ SampleRate int

+ TotalBytes int64

+ TrackIndex int

+ type CaptionStats struct

+ ActiveChannels []int

+ TotalFrames int64

+ type DebugProvider interface

+ DemuxStats func() *DemuxStats

+ PipelineDebug func() PipelineDebugStats

+ type DemuxStats struct

+ func NewDemuxStats() *DemuxStats

+ func (ds *DemuxStats) PTSDebug() PTSDebugStats

+ func (ds *DemuxStats) RecordAudioFrame(trackIdx int, bytes int64, pts int64, sampleRate, channels int)

+ func (ds *DemuxStats) RecordCaption(channel int)

+ func (ds *DemuxStats) RecordResolution(width, height int)

+ func (ds *DemuxStats) RecordSCTE35(event demux.SCTE35Event)

+ func (ds *DemuxStats) RecordTimecode(tc string)

+ func (ds *DemuxStats) RecordVideoCodec(codec string)

+ func (ds *DemuxStats) RecordVideoFrame(bytes int64, isKeyframe bool, pts int64)

+ func (ds *DemuxStats) Snapshot() (VideoStats, []AudioTrackStats, CaptionStats, SCTE35Stats)

+ func (ds *DemuxStats) VideoBitrateKbps() float64

+ func (ds *DemuxStats) VideoFPS() float64

+ type IngestDebugStats struct

+ BytesReceived int64

+ ConnectedAt int64

+ ReadCount int64

+ RemoteAddr string

+ UptimeMs int64

+ type IngestLookup func(key string) *IngestDebugStats

+ type MoQSession struct

+ func NewMoQSession(cfg MoQSessionConfig) *MoQSession

+ func (m *MoQSession) ID() string

+ func (m *MoQSession) Run(ctx context.Context) error

+ func (m *MoQSession) SendAudio(frame *media.AudioFrame)

+ func (m *MoQSession) SendCaptions(frame *ccx.CaptionFrame)

+ func (m *MoQSession) SendVideo(frame *media.VideoFrame)

+ func (m *MoQSession) Stats() ViewerStats

+ type MoQSessionConfig struct

+ Control webtransport.Stream

+ ID string

+ Relay *Relay

+ Session *webtransport.Session

+ StatsProvider StatsProviderFunc

+ StreamKey string

+ type PTSDebugStats struct

+ AudioPTSWraps int64

+ FirstAudioPTS int64

+ FirstVideoPTS int64

+ LastAudioPTS int64

+ LastVideoPTS int64

+ RecentWraps []PTSWrapEvent

+ VideoPTSWraps int64

+ type PTSWrapEvent struct

+ DeltaMs int64

+ NewPTS int64

+ OldPTS int64

+ Timestamp int64

+ Track string

+ type PipelineDebugSnapshot struct

+ Demuxer PTSDebugStats

+ Ingest *IngestDebugStats

+ Pipeline PipelineDebugStats

+ Viewers []ViewerStats

+ type PipelineDebugStats struct

+ AudioChanDepth int

+ AudioForwarded int64

+ CaptionFwd int64

+ LastAudioFwdPTS int64

+ LastVideoFwdPTS int64

+ VideoChanDepth int

+ VideoForwarded int64

+ type Relay struct

+ func NewRelay() *Relay

+ func (r *Relay) AddViewer(session Viewer)

+ func (r *Relay) AudioInfo() AudioInfo

+ func (r *Relay) AudioTrackCount() int

+ func (r *Relay) BroadcastAudio(frame *media.AudioFrame)

+ func (r *Relay) BroadcastCaptions(frame *ccx.CaptionFrame)

+ func (r *Relay) BroadcastVideo(frame *media.VideoFrame)

+ func (r *Relay) RemoveViewer(id string)

+ func (r *Relay) ReplayAudioToChannel(trackIndex int, ch chan<- *media.AudioFrame) int

+ func (r *Relay) ReplayFullGOPToChannel(ch chan<- *media.VideoFrame) int

+ func (r *Relay) SetAudioInfo(info AudioInfo)

+ func (r *Relay) SetAudioTrackCount(count int)

+ func (r *Relay) SetVideoInfo(info VideoInfo)

+ func (r *Relay) VideoInfo() VideoInfo

+ func (r *Relay) ViewerCount() int

+ func (r *Relay) ViewerStatsAll() []ViewerStats

+ func (r *Relay) WaitVideoInfo(ctx context.Context) bool

+ type SCTE35Stats struct

+ Recent []demux.SCTE35Event

+ TotalEvents int64

+ type SRTListFunc func() []SRTPullInfo

+ type SRTPullFunc func(address, streamKey, streamID string) error

+ type SRTPullInfo struct

+ Address string

+ StreamID string

+ StreamKey string

+ type SRTStopFunc func(streamKey string) error

+ type Server struct

+ func NewServer(config ServerConfig) (*Server, error)

+ func (s *Server) APIHandler() http.Handler

+ func (s *Server) GetPipeline(streamKey string) StatsProvider

+ func (s *Server) GetRelay(streamKey string) *Relay

+ func (s *Server) RegisterStream(streamKey string) *Relay

+ func (s *Server) SetPipeline(streamKey string, p StatsProvider)

+ func (s *Server) Start(ctx context.Context) error

+ func (s *Server) UnregisterStream(streamKey string)

+ type ServerConfig struct

+ Addr string

+ Cert *certs.CertInfo

+ ExtraRoutes func(mux *http.ServeMux)

+ IngestLookup IngestLookup

+ SRTList SRTListFunc

+ SRTPull SRTPullFunc

+ SRTStop SRTStopFunc

+ StreamLister StreamLister

+ WebDir string

+ type StatsProvider interface

+ StreamSnapshot func() StreamSnapshot

+ type StatsProviderFunc func(streamKey string) StatsProvider

+ type StreamFrameWriter interface

+ StreamHeaderSize func() int64

+ WriteAudioFrame func(w io.Writer, data []byte, timestampMS uint32) (int64, error)

+ WriteCaptionFrame func(w io.Writer, data []byte, timestampMS uint32) (int64, error)

+ WriteStreamHeader func(w io.Writer, trackID byte, groupID uint32, timestampMS uint32) error

+ WriteVideoFrame func(w io.Writer, frame *media.VideoFrame) (int64, error)

+ func NewMoQWriter(trackAlias uint64, publisherPriority byte) StreamFrameWriter

+ type StreamInfo struct

+ AudioChannels int

+ AudioTracks int

+ CaptionChannels []int

+ Description string

+ HasCaptions bool

+ HasSCTE35 bool

+ Height int

+ Key string

+ Protocol string

+ UptimeMs int64

+ VideoCodec string

+ Viewers int

+ Width int

+ type StreamLister func() []StreamInfo

+ type StreamSnapshot struct

+ Audio []AudioTrackStats

+ Captions CaptionStats

+ IngestBytes int64

+ IngestKbps float64

+ Protocol string

+ SCTE35 SCTE35Stats

+ Timestamp int64

+ UptimeMs int64

+ Video VideoStats

+ ViewerCount int

+ Viewers []ViewerStats

+ type VideoInfo struct

+ Codec string

+ DecoderConfig []byte

+ Height int

+ Width int

+ type VideoStats struct

+ BitrateKbps float64

+ Codec string

+ CurrentGOPLen int

+ DeltaFrames int64

+ FrameRate float64

+ Height int

+ KeyFrames int64

+ PTSErrors int64

+ Timecode string

+ TotalBytes int64

+ TotalFrames int64

+ Width int

+ type Viewer interface

+ ID func() string

+ SendAudio func(frame *media.AudioFrame)

+ SendCaptions func(frame *ccx.CaptionFrame)

+ SendVideo func(frame *media.VideoFrame)

+ Stats func() ViewerStats

+ type ViewerStats struct

+ AudioDropped int64

+ AudioSent int64

+ BytesSent int64

+ CaptionDropped int64

+ CaptionSent int64

+ ID string

+ LastAudioTsMS int64

+ LastVideoTsMS int64

+ VideoDropped int64

+ VideoSent int64

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