manager

Apr 29, 2026

Changes in this version

type Service

+ func (s *Service) SetConfig(cfg config.ManagerConfig)

Apr 29, 2026

Changes in this version

type InputHealthSnapshot

+ Tracks []domain.MediaTrackInfo

+ type MediaSummary struct

+ InputBitrateKbps int

+ Inputs []domain.MediaTrackInfo

+ OutputBitrateKbps int

+ Outputs []domain.MediaTrackInfo

type RuntimeStatus

+ Media *MediaSummary

type Service

+ func (s *Service) RecordMediaPacket(streamID domain.StreamCode, inputPriority int, p *domain.AVPacket)

Apr 25, 2026

Changes in this version

type SwitchReason

+ const SwitchReasonInitial

Apr 25, 2026

Changes in this version

type RuntimeStatus

+ Switches []SwitchEvent

type Service

+ func (s *Service) RegisteredStreams() []domain.StreamCode

+ type SwitchEvent struct

+ At time.Time

+ Detail string

+ From int

+ Reason SwitchReason

+ To int

+ type SwitchReason string

+ const SwitchReasonError

+ const SwitchReasonFailback

+ const SwitchReasonInputAdded

+ const SwitchReasonInputRemoved

+ const SwitchReasonManual

+ const SwitchReasonRecovery

+ const SwitchReasonTimeout

Apr 24, 2026

Changes in this version

type Service

+ func NewForTesting(bus events.Bus, ing ingestorDep, m *metrics.Metrics, packetTimeoutSec int) *Service

Apr 23, 2026

Changes in this version

type RuntimeStatus

+ Publisher *publisher.RuntimeStatus

Apr 23, 2026

Changes in this version

type InputHealth

+ Errors []domain.ErrorEntry

type InputHealthSnapshot

+ Errors []domain.ErrorEntry

type RuntimeStatus

+ PipelineActive bool

+ Status domain.StreamStatus

+ Transcoder *transcoder.RuntimeStatus

Apr 22, 2026

Changes in this version

+ type InputHealth struct

+ Bitrate float64

+ Input domain.Input

+ LastError string

+ LastErrorAt time.Time

+ LastPacketAt time.Time

+ PacketLoss float64

+ Status domain.StreamStatus

+ type InputHealthSnapshot struct

+ BitrateKbps float64

+ InputPriority int

+ LastError string

+ LastErrorAt *time.Time

+ LastPacketAt time.Time

+ PacketLoss float64

+ Status domain.StreamStatus

+ type RuntimeStatus struct

+ ActiveInputPriority int

+ Exhausted bool

+ Inputs []InputHealthSnapshot

+ OverrideInputPriority *int

+ type Service struct

+ func New(i do.Injector) (*Service, error)

+ func (s *Service) IsRegistered(streamID domain.StreamCode) bool

+ func (s *Service) RecordPacket(streamID domain.StreamCode, inputPriority int)

+ func (s *Service) Register(ctx context.Context, stream *domain.Stream, bufferWriteID domain.StreamCode) error

+ func (s *Service) ReportInputError(streamID domain.StreamCode, inputPriority int, err error)

+ func (s *Service) RuntimeStatus(streamID domain.StreamCode) (RuntimeStatus, bool)

+ func (s *Service) SetExhaustedCallback(fn func(domain.StreamCode))

+ func (s *Service) SetRestoredCallback(fn func(domain.StreamCode))

+ func (s *Service) SwitchInput(streamID domain.StreamCode, priority int) error

+ func (s *Service) Unregister(streamID domain.StreamCode)

+ func (s *Service) UpdateBufferWriteID(streamID domain.StreamCode, newBufID domain.StreamCode)

+ func (s *Service) UpdateInputs(streamID domain.StreamCode, added, removed, updated []domain.Input)