workers

Documentation

Index

• Constants
• Variables
• func RegisterMetrics()
• func SetLogger(l *zap.SugaredLogger)
• func SpawnEncoderWorkers(wnum int, mgr *manager.VideoManager) chan<- interface{}

Constants

const (
	StorageLocal  = "local"
	StorageRemote = "remote"
)

Variables

var (
	TranscodingRunning = prometheus.NewGauge(prometheus.GaugeOpts{
		Name: "transcoding_running",
	})
	TranscodingDownloading = prometheus.NewGauge(prometheus.GaugeOpts{
		Name: "transcoding_downloading",
	})

	TranscodingSpentSeconds = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "transcoded_spent_seconds",
	})
	TranscodedSizeMB = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "transcoded_size_mb",
	})
	TranscodedCount = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "transcoded_count",
	})

	TranscodingErrors = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "transcoding_error_count",
	}, []string{"stage"})
)

Functions

func RegisterMetrics

func RegisterMetrics()

func SetLogger

func SetLogger(l *zap.SugaredLogger)

func SpawnEncoderWorkers

func SpawnEncoderWorkers(wnum int, mgr *manager.VideoManager) chan<- interface{}