Documentation
¶
Overview ¶
Package coordinator wires buffer, stream manager, transcoder, and publisher for a single stream lifecycle. Used by the HTTP API and server bootstrap.
Index ¶
- func BootstrapPersistedStreams(ctx context.Context, log *slog.Logger, repo store.StreamRepository, ...)
- type Coordinator
- 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
- type ProfilesDiff
- type StreamDiff
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BootstrapPersistedStreams ¶
func BootstrapPersistedStreams(ctx context.Context, log *slog.Logger, repo store.StreamRepository, coord *Coordinator)
BootstrapPersistedStreams starts the pipeline for every non-disabled stream that has at least one input configured. Stream status is never persisted, so all eligible streams are started fresh on every boot regardless of their last known runtime state.
Types ¶
type Coordinator ¶
type Coordinator struct {
// contains filtered or unexported fields
}
Coordinator starts and stops the full per-stream pipeline.
func New ¶
func New(i do.Injector) (*Coordinator, error)
New registers a Coordinator with the DI injector.
func (*Coordinator) IsRunning ¶
func (c *Coordinator) IsRunning(streamID domain.StreamCode) bool
IsRunning reports whether the stream pipeline is active in memory.
func (*Coordinator) Start ¶
Start creates the buffer, registers the stream with the manager (ingest + failover), starts publisher outputs, and optionally a transcoder worker.
func (*Coordinator) Stop ¶
func (c *Coordinator) Stop(ctx context.Context, streamID domain.StreamCode)
Stop tears down publisher, transcoder, manager (ingest), and the buffer. ctx is used for the DVR stop and the EventStreamStopped publish; cleanup of in-memory state always proceeds even if ctx is cancelled.
func (*Coordinator) StreamStatus ¶
func (c *Coordinator) StreamStatus(code domain.StreamCode) domain.StreamStatus
StreamStatus returns the runtime status of a stream pipeline. It is derived purely from in-memory state — never read from the store.
- StatusStopped — pipeline is not registered (never started, or was stopped)
- StatusActive — pipeline is running and at least one input is live
- StatusDegraded — pipeline is running but all inputs are currently exhausted
type ProfileChange ¶
type ProfileChange struct {
Index int
Old *domain.VideoProfile // nil when added
New *domain.VideoProfile // nil when removed
}
ProfileChange describes one profile that was added, removed, or updated.
type ProfilesDiff ¶
type ProfilesDiff struct {
Added []ProfileChange
Removed []ProfileChange
Updated []ProfileChange
}
ProfilesDiff holds per-profile changes when the transcoder topology stays the same.
func (*ProfilesDiff) HasAddedOrRemoved ¶
func (d *ProfilesDiff) HasAddedOrRemoved() bool
HasAddedOrRemoved reports whether the profile count changed (master playlist rebuild needed).
func (*ProfilesDiff) HasProfileChanges ¶
func (d *ProfilesDiff) HasProfileChanges() bool
HasProfileChanges reports whether there are any per-profile changes.
type StreamDiff ¶
type StreamDiff struct {
// Inputs
InputsChanged bool
AddedInputs []domain.Input // priority exists in new but not old
RemovedInputs []domain.Input // priority exists in old but not new
UpdatedInputs []domain.Input // same priority, different config (carries NEW input)
// Transcoder
TranscoderChanged bool // any transcoder config change
TranscoderTopologyChanged bool // nil↔non-nil, mode change, video.copy change → buffer layout changes
ProfilesDiff *ProfilesDiff // per-profile granular diff; nil when topology changed
// Publisher
ProtocolsChanged bool
PushChanged bool
// DVR
DVRChanged bool
// Lifecycle
NowDisabled bool // was enabled → now disabled
}
StreamDiff describes what changed between two versions of a stream configuration. Only non-metadata fields are compared (name, description, tags, timestamps are ignored).
func ComputeDiff ¶
func ComputeDiff(old, new *domain.Stream) StreamDiff
ComputeDiff compares two stream configurations and returns a diff.
Source Files