stream

package

Go to main page

Versions in this module

v1

v1.1.0

Mar 5, 2026

Changes in this version

type ClientStreamStatus

+ PlaylistSourceID int64

+ PlaylistSourceName string

+ VirtualTunerSlot int

type Lease

+ PlaylistSourceID int64

+ PlaylistSourceName string

+ VirtualTunerSlot int

type Pool

+ func (p *Pool) AcquireClientForSource(ctx context.Context, _ int64, guideNumber, clientAddr string) (*Lease, error)

+ func (p *Pool) AcquireProbeForSource(ctx context.Context, _ int64, label string, cancel context.CancelCauseFunc) (*Lease, error)

+ func (p *Pool) CapacityForSource(_ int64) int

+ func (p *Pool) InUseCountForSource(_ int64) int

+ func (p *Pool) VirtualTunerSnapshot() []VirtualTunerPoolSnapshot

type ProbeTunerUsage

+ AcquireProbeForSource func(ctx context.Context, sourceID int64, label string, ...) (*Lease, error)

type Session

+ PlaylistSourceID int64

+ PlaylistSourceName string

+ VirtualTunerSlot int

type SharedSessionHistory

+ SubscriberWriteDeadlineUnsupportedTotal uint64

type SharedSessionStats

+ PlaylistSourceID int64

+ PlaylistSourceName string

+ SubscriberWriteDeadlineUnsupportedTotal uint64

+ VirtualTunerSlot int

type TunerStatus

+ PlaylistSourceID int64

+ PlaylistSourceName string

+ SubscriberWriteDeadlineUnsupportedTotal uint64

+ VirtualTunerSlot int

type TunerStatusSnapshot

+ VirtualTuners []VirtualTunerStatus

+ type VirtualTunerManager struct

+ func NewVirtualTunerManager(sources []VirtualTunerSource) *VirtualTunerManager

+ func (m *VirtualTunerManager) Acquire(ctx context.Context, guideNumber, clientAddr string) (*Lease, error)

+ func (m *VirtualTunerManager) AcquireClient(ctx context.Context, guideNumber, clientAddr string) (*Lease, error)

+ func (m *VirtualTunerManager) AcquireClientForSource(ctx context.Context, sourceID int64, guideNumber, clientAddr string) (*Lease, error)

+ func (m *VirtualTunerManager) AcquireProbe(ctx context.Context, label string, cancel context.CancelCauseFunc) (*Lease, error)

+ func (m *VirtualTunerManager) AcquireProbeForSource(ctx context.Context, sourceID int64, label string, ...) (*Lease, error)

+ func (m *VirtualTunerManager) Capacity() int

+ func (m *VirtualTunerManager) CapacityForSource(sourceID int64) int

+ func (m *VirtualTunerManager) Close()

+ func (m *VirtualTunerManager) InUseCount() int

+ func (m *VirtualTunerManager) InUseCountForSource(sourceID int64) int

+ func (m *VirtualTunerManager) Reconfigure(sources []VirtualTunerSource)

+ func (m *VirtualTunerManager) SetPreemptSettleDelay(delay time.Duration)

+ func (m *VirtualTunerManager) Snapshot() []Session

+ func (m *VirtualTunerManager) VirtualTunerSnapshot() []VirtualTunerPoolSnapshot

+ type VirtualTunerPoolSnapshot struct

+ IdleCount int

+ InUseCount int

+ PlaylistSourceID int64

+ PlaylistSourceName string

+ PlaylistSourceOrder int

+ TunerCount int

+ type VirtualTunerSource struct

+ Enabled bool

+ Name string

+ OrderIndex int

+ SourceID int64

+ TunerCount int

+ type VirtualTunerStatus struct

+ ActiveSessionCount int

+ IdleCount int

+ InUseCount int

+ PlaylistSourceID int64

+ PlaylistSourceName string

+ PlaylistSourceOrder int

+ TunerCount int

v1.0.6

Mar 2, 2026

Changes in this version

type Config

+ FFmpegRWTimeout time.Duration

+ FFmpegSourceLogLevel string

+ FFmpegSourceStderrLogLevel string

+ FFmpegSourceStderrMaxLineBytes int

+ FFmpegSourceStderrPassthroughEnabled *bool

type ProberConfig

+ FFmpegRWTimeout time.Duration

type SessionManagerConfig

+ FFmpegRWTimeout time.Duration

+ FFmpegSourceLogLevel string

+ FFmpegSourceStderrLogLevel string

+ FFmpegSourceStderrMaxLineBytes int

+ FFmpegSourceStderrPassthroughEnabled *bool

v1.0.5

Feb 25, 2026

Changes in this version

type Config

+ FFprobePath string

type SessionManagerConfig

+ FFprobePath string

v1.0.4

Feb 24, 2026

Changes in this version

type ClientStreamStatus

+ ClientHost string

type Config

+ FFmpegDiscardCorrupt bool

+ FFmpegInputBufferSize int

type ProberConfig

+ FFmpegDiscardCorrupt bool

+ FFmpegInputBufferSize int

type SessionManagerConfig

+ FFmpegDiscardCorrupt bool

+ FFmpegInputBufferSize int

type SharedSessionSubscriberHistory

+ ClientHost string

v1.0.3

Feb 23, 2026

Changes in this version

type Config

+ ProducerReadRateCatchup float64

type ProberConfig

+ ProducerReadRateCatchup float64

type SessionManagerConfig

+ ProducerReadRateCatchup float64

v1.0.2

Feb 22, 2026

v1.0.1

Feb 22, 2026

v1.0.0

Feb 22, 2026

Changes in this version

+ var ErrNoTunersAvailable = errors.New("no tuners available")

+ var ErrProbePreempted = errors.New("probe preempted by client stream")

+ var ErrRingClosed = errors.New("chunk ring is closed")

+ var ErrSessionMaxSubscribers = errors.New("shared session max subscribers reached")

+ var ErrSessionNoSources = errors.New("channel has no enabled sources")

+ var ErrSessionNotFound = errors.New("shared session not found")

+ var ErrSessionRecoveryAlreadyPending = errors.New("shared session manual recovery is already pending")

+ var ErrSlowClientLagged = errors.New("subscriber fell behind stream tail")

+ func SanitizeURLForLog(raw string) string

+ type BackgroundProber struct

+ func NewBackgroundProber(cfg ProberConfig, provider ProbeChannelsProvider) *BackgroundProber

+ func (p *BackgroundProber) Close()

+ func (p *BackgroundProber) Enabled() bool

+ func (p *BackgroundProber) ProbeOnce(ctx context.Context) error

+ func (p *BackgroundProber) Run(ctx context.Context)

+ type ChannelsProvider interface

+ GetByGuideNumber func(ctx context.Context, guideNumber string) (channels.Channel, error)

+ ListSources func(ctx context.Context, channelID int64, enabledOnly bool) ([]channels.Source, error)

+ MarkSourceFailure func(ctx context.Context, sourceID int64, reason string, failedAt time.Time) error

+ MarkSourceSuccess func(ctx context.Context, sourceID int64, succeededAt time.Time) error

+ UpdateSourceProfile func(ctx context.Context, sourceID int64, profile channels.SourceProfileUpdate) error

+ type ChunkPublisher interface

+ PublishChunk func(data []byte, publishedAt time.Time) error

+ type ChunkPublisherCopyAware interface

+ CopiesPublishedChunkData func() bool

+ type ChunkRing struct

+ func NewChunkRing(maxChunks int) *ChunkRing

+ func NewChunkRingWithLimits(maxChunks, maxBytes int) *ChunkRing

+ func NewChunkRingWithLimitsAndStartupHint(maxChunks, maxBytes, startupChunkHint int) *ChunkRing

+ func (r *ChunkRing) Close(err error)

+ func (r *ChunkRing) CopiesPublishedChunkData() bool

+ func (r *ChunkRing) PublishChunk(data []byte, publishedAt time.Time) error

+ func (r *ChunkRing) ReadFrom(seq uint64) ReadResult

+ func (r *ChunkRing) Snapshot() []RingChunk

+ func (r *ChunkRing) StartSeqByLagBytes(lagBytes int) uint64

+ func (r *ChunkRing) WaitForChange(ctx context.Context, waitSeq uint64) error

+ type ChurnSummary struct

+ MaxReselectChannelID int64

+ MaxReselectGuideNumber string

+ MaxSameSourceReselectCount int64

+ RecoveringSessionCount int

+ ReselectAlertThreshold int64

+ SessionCount int

+ SessionsOverReselectThreshold int

+ SessionsWithReselectCount int

+ TotalRecoveryCycles int64

+ TotalSameSourceReselectCount int64

+ TotalSourceSelectCount int64

+ type ClientStreamStatus struct

+ AudioCodec string

+ ChannelID int64

+ ClientAddr string

+ ConnectedAt time.Time

+ CurrentBitrateBPS int64

+ FrameRate float64

+ GuideName string

+ GuideNumber string

+ Kind string

+ Producer string

+ ProfileBitrateBPS int64

+ Resolution string

+ SourceID int64

+ SourceItemKey string

+ SourceStreamURL string

+ SubscriberID uint64

+ TunerID int

+ VideoCodec string

+ type Config struct

+ BufferChunkBytes int

+ BufferPublishFlushInterval time.Duration

+ BufferTSAlign188 bool

+ CycleFailureMinHealth time.Duration

+ FFmpegCopyRegenerateTimestamps *bool

+ FFmpegPath string

+ FFmpegReconnectDelayMax time.Duration

+ FFmpegReconnectEnabled bool

+ FFmpegReconnectHTTPErrors string

+ FFmpegReconnectMaxRetries int

+ FFmpegStartupAnalyzeDelay time.Duration

+ FFmpegStartupProbeSize int

+ FailoverTotalTimeout time.Duration

+ HTTPClient *http.Client

+ Logger *slog.Logger

+ MaxFailovers int

+ MinProbeBytes int

+ Mode string

+ ProducerInitialBurst int

+ ProducerReadRate float64

+ RecoveryFillerEnableAudio bool

+ RecoveryFillerEnabled bool

+ RecoveryFillerInterval time.Duration

+ RecoveryFillerMode string

+ RecoveryFillerText string

+ SessionDrainTimeout time.Duration

+ SessionHistoryLimit int

+ SessionIdleTimeout time.Duration

+ SessionMaxSubscribers int

+ SessionSourceHistoryLimit int

+ SessionSubscriberHistoryLimit int

+ SourceHealthDrainTimeout time.Duration

+ StallDetect time.Duration

+ StallHardDeadline time.Duration

+ StallMaxFailoversPerStall int

+ StallPolicy string

+ StartupRandomAccessRecoveryOnly bool

+ StartupTimeout time.Duration

+ SubscriberJoinLagBytes int

+ SubscriberMaxBlockedWrite time.Duration

+ SubscriberSlowClientPolicy string

+ TuneBackoffCooldown time.Duration

+ TuneBackoffInterval time.Duration

+ TuneBackoffMaxTunes int

+ UpstreamOverlimitCooldown time.Duration

+ type DrainWaitTelemetry struct

+ Error uint64

+ OK uint64

+ WaitDurationMS uint64

+ WaitDurationUS uint64

+ type FFmpegProducer struct

+ func NewFFmpegProducer(cfg FFmpegProducerConfig) (*FFmpegProducer, error)

+ func (p *FFmpegProducer) Describe() string

+ func (p *FFmpegProducer) Start(ctx context.Context) (io.ReadCloser, error)

+ type FFmpegProducerConfig struct

+ FFmpegPath string

+ InitialBurstSeconds int

+ LogLevel string

+ Mode string

+ ReadRate float64

+ StreamURL string

+ type Handler struct

+ func NewHandler(cfg Config, tuners *Pool, channelsProvider ChannelsProvider) *Handler

+ func (h *Handler) ClearAllSourceHealth() error

+ func (h *Handler) ClearSourceHealth(channelID int64) error

+ func (h *Handler) Close()

+ func (h *Handler) CloseWithContext(ctx context.Context) error

+ func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (h *Handler) TriggerSessionRecovery(channelID int64, reason string) error

+ func (h *Handler) TunerStatusSnapshot() TunerStatusSnapshot

+ type Lease struct

+ ID int

+ func (l *Lease) Release()

+ type Pool struct

+ func NewPool(count int) *Pool

+ func (p *Pool) Acquire(ctx context.Context, guideNumber, clientAddr string) (*Lease, error)

+ func (p *Pool) AcquireClient(ctx context.Context, guideNumber, clientAddr string) (*Lease, error)

+ func (p *Pool) AcquireProbe(ctx context.Context, label string, cancel context.CancelCauseFunc) (*Lease, error)

+ func (p *Pool) Capacity() int

+ func (p *Pool) InUseCount() int

+ func (p *Pool) SetPreemptSettleDelay(delay time.Duration)

+ func (p *Pool) Snapshot() []Session

+ type ProbeChannelsProvider interface

+ ListEnabled func(ctx context.Context) ([]channels.Channel, error)

+ ListSources func(ctx context.Context, channelID int64, enabledOnly bool) ([]channels.Source, error)

+ MarkSourceFailure func(ctx context.Context, sourceID int64, reason string, failedAt time.Time) error

+ MarkSourceSuccess func(ctx context.Context, sourceID int64, succeededAt time.Time) error

+ type ProbeCloseTelemetry struct

+ InlineCount uint64

+ QueueFullCount uint64

+ type ProbeTunerUsage interface

+ AcquireProbe func(ctx context.Context, label string, cancel context.CancelCauseFunc) (*Lease, error)

+ type ProberConfig struct

+ FFmpegCopyRegenerateTimestamps *bool

+ FFmpegPath string

+ FFmpegReconnectDelayMax time.Duration

+ FFmpegReconnectEnabled bool

+ FFmpegReconnectHTTPErrors string

+ FFmpegReconnectMaxRetries int

+ FFmpegStartupAnalyzeDelay time.Duration

+ FFmpegStartupProbeSize int

+ HTTPClient *http.Client

+ Logger *slog.Logger

+ MinProbeBytes int

+ Mode string

+ ProbeCloseQueueDepth int

+ ProbeInterval time.Duration

+ ProbeTimeout time.Duration

+ ProbeTuneDelay time.Duration

+ ProducerInitialBurst int

+ ProducerReadRate float64

+ TunerUsage ProbeTunerUsage

+ type Producer interface

+ Describe func() string

+ Start func(ctx context.Context) (io.ReadCloser, error)

+ type Pump struct

+ func NewPump(cfg PumpConfig, publisher ChunkPublisher) *Pump

+ func (p *Pump) Run(ctx context.Context, src io.ReadCloser) error

+ func (p *Pump) Stats() PumpStats

+ type PumpConfig struct

+ ChunkBytes int

+ PublishFlushInterval time.Duration

+ ReadBufferBytes int

+ TSAlign188 bool

+ type PumpStats struct

+ BytesPublished int64

+ BytesRead int64

+ ChunksPublished int64

+ LastByteReadAt time.Time

+ LastPublishAt time.Time

+ type ReadResult struct

+ Behind bool

+ BufferedBytes int

+ BufferedChunks int

+ Chunks []RingChunk

+ Closed bool

+ Err error

+ NextSeq uint64

+ OldestSeq uint64

+ RequestedSeq uint64

+ RingNextSeq uint64

+ WaitSeq uint64

+ func (r *ReadResult) Release()

+ type RingChunk struct

+ Data []byte

+ PublishedAt time.Time

+ Seq uint64

+ type Session struct

+ ClientAddr string

+ GuideNumber string

+ ID int

+ Kind string

+ StartedAt time.Time

+ type SessionManager struct

+ func NewSessionManager(cfg SessionManagerConfig, tuners *Pool, channelsProvider ChannelsProvider) *SessionManager

+ func (m *SessionManager) ClearAllSourceHealth() error

+ func (m *SessionManager) ClearSourceHealth(channelID int64) error

+ func (m *SessionManager) Close()

+ func (m *SessionManager) CloseWithContext(ctx context.Context) error

+ func (m *SessionManager) HasActiveOrPendingSession(channelID int64) bool

+ func (m *SessionManager) HistorySnapshot() ([]SharedSessionHistory, int, int64)

+ func (m *SessionManager) Snapshot() []SharedSessionStats

+ func (m *SessionManager) Subscribe(ctx context.Context, channel channels.Channel) (*SessionSubscription, error)

+ func (m *SessionManager) SubscribeImmediate(ctx context.Context, channel channels.Channel) (*SessionSubscription, error)

+ func (m *SessionManager) TriggerRecovery(channelID int64, reason string) error

+ func (m *SessionManager) WaitForDrain(ctx context.Context) error

+ type SessionManagerConfig struct

+ BufferChunkBytes int

+ BufferPublishFlushInterval time.Duration

+ BufferTSAlign188 bool

+ CycleFailureMinHealth time.Duration

+ FFmpegCopyRegenerateTimestamps *bool

+ FFmpegPath string

+ FFmpegReconnectDelayMax time.Duration

+ FFmpegReconnectEnabled bool

+ FFmpegReconnectHTTPErrors string

+ FFmpegReconnectMaxRetries int

+ FFmpegStartupAnalyzeDelay time.Duration

+ FFmpegStartupProbeSize int

+ FailoverTotalTimeout time.Duration

+ HTTPClient *http.Client

+ Logger *slog.Logger

+ MaxFailovers int

+ MinProbeBytes int

+ Mode string

+ ProducerInitialBurst int

+ ProducerReadRate float64

+ RecoveryFillerEnableAudio bool

+ RecoveryFillerEnabled bool

+ RecoveryFillerInterval time.Duration

+ RecoveryFillerMode string

+ RecoveryFillerText string

+ SessionDrainTimeout time.Duration

+ SessionHistoryLimit int

+ SessionIdleTimeout time.Duration

+ SessionMaxSubscribers int

+ SessionSourceHistoryLimit int

+ SessionSubscriberHistoryLimit int

+ SourceHealthDrainTimeout time.Duration

+ StallDetect time.Duration

+ StallHardDeadline time.Duration

+ StallMaxFailoversPerStall int

+ StallPolicy string

+ StartupRandomAccessRecoveryOnly bool

+ StartupTimeout time.Duration

+ SubscriberJoinLagBytes int

+ SubscriberMaxBlockedWrite time.Duration

+ SubscriberSlowClientPolicy string

+ UpstreamOverlimitCooldown time.Duration

+ type SessionSubscription struct

+ func (s *SessionSubscription) Close()

+ func (s *SessionSubscription) Stats() SharedSessionStats

+ func (s *SessionSubscription) Stream(ctx context.Context, w http.ResponseWriter) error

+ type SharedSessionHistory struct

+ Active bool

+ ChannelID int64

+ ClosedAt time.Time

+ CompletedSubscribers int64

+ GuideName string

+ GuideNumber string

+ LastError string

+ LastRecoveryReason string

+ LastSourceSelectReason string

+ LastSourceSelectedAt time.Time

+ OpenedAt time.Time

+ PeakSubscribers int

+ RecoveryCycleCount int64

+ SameSourceReselectCount int64

+ SessionID uint64

+ SlowSkipEventsTotal uint64

+ SlowSkipLagBytesTotal uint64

+ SlowSkipLagChunksTotal uint64

+ SlowSkipMaxLagChunks uint64

+ SourceHistoryLimit int

+ SourceHistoryTruncated int64

+ SourceSelectCount int64

+ Sources []SharedSessionSourceHistory

+ SubscriberHistoryLimit int

+ SubscriberHistoryTruncated int64

+ SubscriberWriteBlockedDurationMS uint64

+ SubscriberWriteBlockedDurationUS uint64

+ SubscriberWriteDeadlineTimeoutsTotal uint64

+ SubscriberWriteShortWritesTotal uint64

+ Subscribers []SharedSessionSubscriberHistory

+ TerminalError string

+ TerminalStatus string

+ TotalSubscribers int64

+ TunerID int

+ type SharedSessionSourceHistory struct

+ AudioCodec string

+ DeselectedAt time.Time

+ FrameRate float64

+ ItemKey string

+ Producer string

+ ProfileBitrateBPS int64

+ Resolution string

+ SelectedAt time.Time

+ SelectionReason string

+ SourceID int64

+ StartupAudioCodecs string

+ StartupAudioStreams int

+ StartupComponentState string

+ StartupInventoryMethod string

+ StartupProbeCutoverOffset int

+ StartupProbeDroppedBytes int

+ StartupProbeRawBytes int

+ StartupProbeTrimmedBytes int

+ StartupRandomAccessCodec string

+ StartupRandomAccessReady bool

+ StartupRetryRelaxedProbe bool

+ StartupRetryRelaxedProbeReason string

+ StartupVideoCodecs string

+ StartupVideoStreams int

+ StreamURL string

+ VideoCodec string

+ type SharedSessionStats struct

+ AudioCodec string

+ BytesPushed int64

+ BytesRead int64

+ ChannelID int64

+ ChunksPushed int64

+ CurrentBitrateBPS int64

+ FrameRate float64

+ GuideName string

+ GuideNumber string

+ LastByteAt time.Time

+ LastError string

+ LastPushAt time.Time

+ LastSourceSelectReason string

+ LastSourceSelectedAt time.Time

+ Producer string

+ ProfileBitrateBPS int64

+ RecoveryCycle int64

+ RecoveryKeepaliveBytes int64

+ RecoveryKeepaliveChunks int64

+ RecoveryKeepaliveDuration string

+ RecoveryKeepaliveExpectedRate float64

+ RecoveryKeepaliveFallbackCount int64

+ RecoveryKeepaliveFallbackReason string

+ RecoveryKeepaliveGuardrailCount int64

+ RecoveryKeepaliveGuardrailReason string

+ RecoveryKeepaliveMode string

+ RecoveryKeepaliveRateBytesPerSecond float64

+ RecoveryKeepaliveRealtimeMultiplier float64

+ RecoveryKeepaliveStartedAt time.Time

+ RecoveryKeepaliveStoppedAt time.Time

+ RecoveryReason string

+ RecoveryTransitionEffectiveMode string

+ RecoveryTransitionFallbackCount int64

+ RecoveryTransitionFallbackReason string

+ RecoveryTransitionMode string

+ RecoveryTransitionSignalSkips string

+ RecoveryTransitionSignalsApplied string

+ RecoveryTransitionStitchApplied bool

+ Resolution string

+ SameSourceReselectCount int64

+ SinceLastSourceSelect string

+ SlowSkipEventsTotal uint64

+ SlowSkipLagBytesTotal uint64

+ SlowSkipLagChunksTotal uint64

+ SlowSkipMaxLagChunks uint64

+ SourceHealthPersistCoalescedBySource map[int64]int64

+ SourceHealthPersistCoalescedTotal int64

+ SourceHealthPersistDroppedBySource map[int64]int64

+ SourceHealthPersistDroppedTotal int64

+ SourceID int64

+ SourceItemKey string

+ SourceSelectCount int64

+ SourceStartupAudioCodecs string

+ SourceStartupAudioStreams int

+ SourceStartupComponentState string

+ SourceStartupInventoryMethod string

+ SourceStartupProbeBytes int

+ SourceStartupProbeCutoverOffset int

+ SourceStartupProbeDroppedBytes int

+ SourceStartupProbeRawBytes int

+ SourceStartupProbeTrimmedBytes int

+ SourceStartupRandomAccessCodec string

+ SourceStartupRandomAccessReady bool

+ SourceStartupRetryRelaxedProbe bool

+ SourceStartupRetryRelaxedProbeReason string

+ SourceStartupVideoCodecs string

+ SourceStartupVideoStreams int

+ SourceStreamURL string

+ StallCount int64

+ StartedAt time.Time

+ SubscriberInfo []SubscriberStats

+ SubscriberWriteBlockedDurationMS uint64

+ SubscriberWriteBlockedDurationUS uint64

+ SubscriberWriteDeadlineTimeoutsTotal uint64

+ SubscriberWriteShortWritesTotal uint64

+ Subscribers int

+ TunerID int

+ VideoCodec string

+ type SharedSessionSubscriberHistory struct

+ ClientAddr string

+ CloseReason string

+ ClosedAt time.Time

+ ConnectedAt time.Time

+ SubscriberID uint64

+ type SubscriberStats struct

+ ClientAddr string

+ StartedAt time.Time

+ SubscriberID uint64

+ type TunerStatus struct

+ AudioCodec string

+ BytesPushed int64

+ BytesRead int64

+ ChannelID int64

+ ChunksPushed int64

+ CurrentBitrateBPS int64

+ FrameRate float64

+ GuideName string

+ GuideNumber string

+ Kind string

+ LastByteAt time.Time

+ LastError string

+ LastPushAt time.Time

+ LastSourceSelectReason string

+ LastSourceSelectedAt time.Time

+ LeaseClientAddr string

+ LeaseStartedAt time.Time

+ Producer string

+ ProfileBitrateBPS int64

+ RecoveryCycle int64

+ RecoveryKeepaliveBytes int64

+ RecoveryKeepaliveChunks int64

+ RecoveryKeepaliveDuration string

+ RecoveryKeepaliveExpectedRate float64

+ RecoveryKeepaliveFallbackCount int64

+ RecoveryKeepaliveFallbackReason string

+ RecoveryKeepaliveGuardrailCount int64

+ RecoveryKeepaliveGuardrailReason string

+ RecoveryKeepaliveMode string

+ RecoveryKeepaliveRateBytesPerSecond float64

+ RecoveryKeepaliveRealtimeMultiplier float64

+ RecoveryKeepaliveStartedAt time.Time

+ RecoveryKeepaliveStoppedAt time.Time

+ RecoveryReason string

+ RecoveryTransitionEffectiveMode string

+ RecoveryTransitionFallbackCount int64

+ RecoveryTransitionFallbackReason string

+ RecoveryTransitionMode string

+ RecoveryTransitionSignalSkips string

+ RecoveryTransitionSignalsApplied string

+ RecoveryTransitionStitchApplied bool

+ Resolution string

+ SameSourceReselectCount int64

+ SessionStartedAt time.Time

+ SinceLastSourceSelect string

+ SlowSkipEventsTotal uint64

+ SlowSkipLagBytesTotal uint64

+ SlowSkipLagChunksTotal uint64

+ SlowSkipMaxLagChunks uint64

+ SourceHealthPersistCoalescedBySource map[int64]int64

+ SourceHealthPersistCoalescedTotal int64

+ SourceHealthPersistDroppedBySource map[int64]int64

+ SourceHealthPersistDroppedTotal int64

+ SourceID int64

+ SourceItemKey string

+ SourceSelectCount int64

+ SourceStartupAudioCodecs string

+ SourceStartupAudioStreams int

+ SourceStartupComponentState string

+ SourceStartupInventoryMethod string

+ SourceStartupProbeBytes int

+ SourceStartupProbeCutoverOffset int

+ SourceStartupProbeDroppedBytes int

+ SourceStartupProbeRawBytes int

+ SourceStartupProbeTrimmedBytes int

+ SourceStartupRandomAccessCodec string

+ SourceStartupRandomAccessReady bool

+ SourceStartupRetryRelaxedProbe bool

+ SourceStartupRetryRelaxedProbeReason string

+ SourceStartupVideoCodecs string

+ SourceStartupVideoStreams int

+ SourceStreamURL string

+ StallCount int64

+ State string

+ SubscriberWriteBlockedDurationMS uint64

+ SubscriberWriteBlockedDurationUS uint64

+ SubscriberWriteDeadlineTimeoutsTotal uint64

+ SubscriberWriteShortWritesTotal uint64

+ Subscribers []SubscriberStats

+ TunerID int

+ VideoCodec string

+ type TunerStatusSnapshot struct

+ Churn ChurnSummary

+ ClientStreams []ClientStreamStatus

+ DrainWait DrainWaitTelemetry

+ GeneratedAt time.Time

+ IdleCount int

+ InUseCount int

+ ProbeClose ProbeCloseTelemetry

+ SessionHistory []SharedSessionHistory

+ SessionHistoryLimit int

+ SessionHistoryTruncatedCount int64

+ TunerCount int

+ Tuners []TunerStatus

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