3pp-mirror/neko
1
0
Fork 0
mirror of https://github.com/m1k1o/neko.git synced 2025-08-01 16:00:51 +02:00
Code Issues Projects Releases Packages Wiki Activity

WIP: legacy config integration.

Browse source
This commit is contained in:
Miroslav Šedivý 2024-07-18 18:58:40 +02:00
parent 0ee11b661a
commit b5c3f8d4a6
3 changed files with 10 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
server/internal/capture/broadcast.go
View file

@ -28,7 +28,7 @@ type BroacastManagerCtx struct {
pipelinesActive prometheus.Gauge
}
func broadcastNew(pipelineFn func(url string) (string, error), defaultUrl string) *BroacastManagerCtx {
func broadcastNew(pipelineFn func(url string) (string, error), defaultUrl string, autostart bool) *BroacastManagerCtx {
logger := log.With().
Str("module", "capture").
Str("submodule", "broadcast").
@ -38,7 +38,7 @@ func broadcastNew(pipelineFn func(url string) (string, error), defaultUrl string
logger: logger,
pipelineFn: pipelineFn,
url: defaultUrl,
started: defaultUrl != "",
started: defaultUrl != "" && autostart,
// metrics
pipelinesCounter: promauto.NewCounter(prometheus.CounterOpts{