coordinator

May 6, 2026

Changes in this version

type Coordinator

+ func (c *Coordinator) RunReconciler(ctx context.Context)

Apr 25, 2026

Changes in this version

type Coordinator

+ func (c *Coordinator) RunningStreams() []domain.StreamCode

Apr 24, 2026

Changes in this version

type Coordinator

+ func (c *Coordinator) ABRCopyRuntimeStatus(code domain.StreamCode) (manager.RuntimeStatus, bool)

+ func (c *Coordinator) ABRMixerRuntimeStatus(code domain.StreamCode) (manager.RuntimeStatus, bool)

Apr 24, 2026

Changes in this version

type Coordinator

+ func (c *Coordinator) SetUpstreamLookupForTesting(fn func(domain.StreamCode) (*domain.Stream, bool))

Apr 22, 2026

Changes in this version

+ func BootstrapPersistedStreams(ctx context.Context, log *slog.Logger, repo store.StreamRepository, ...)

+ type Coordinator struct

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

+ func (c *Coordinator) IsRunning(streamID domain.StreamCode) bool

+ func (c *Coordinator) Start(ctx context.Context, stream *domain.Stream) error

+ func (c *Coordinator) Stop(ctx context.Context, streamID domain.StreamCode)

+ func (c *Coordinator) StreamStatus(code domain.StreamCode) domain.StreamStatus

+ func (c *Coordinator) Update(ctx context.Context, old, new *domain.Stream) error

+ type ProfileChange struct

+ Index int

+ New *domain.VideoProfile

+ Old *domain.VideoProfile

+ type ProfilesDiff struct

+ Added []ProfileChange

+ Removed []ProfileChange

+ Updated []ProfileChange

+ func (d *ProfilesDiff) HasAddedOrRemoved() bool

+ func (d *ProfilesDiff) HasProfileChanges() bool

+ type StreamDiff struct

+ AddedInputs []domain.Input

+ DVRChanged bool

+ InputsChanged bool

+ NowDisabled bool

+ ProfilesDiff *ProfilesDiff

+ ProtocolsChanged bool

+ PushChanged bool

+ RemovedInputs []domain.Input

+ TranscoderChanged bool

+ TranscoderTopologyChanged bool

+ UpdatedInputs []domain.Input

+ func ComputeDiff(old, new *domain.Stream) StreamDiff