metrics

Documentation

Index

• Constants
• Variables
• func RegisterTowerMetrics()
• func RegisterWorkerMetrics()

Constants

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

	LabelWorkerName = "worker_name"
	LabelStage      = "stage"
)

const (
	WorkerStatusAvailable = "available"
	WorkerStatusCapacity  = "capacity"
)

Variables

var (
	WorkersHeartbeats = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "workers_heartbeats",
	}, []string{LabelWorkerName})

	WorkersSpentSeconds = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "workers_spent_seconds",
	}, []string{LabelWorkerName, LabelStage})

	TranscodingRequestsPublished = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "transcoding_requests_published",
	})
	TranscodingRequestsRunning = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "transcoding_requests_running",
	}, []string{LabelWorkerName})
	TranscodingRequestsDone = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "transcoding_requests_done",
	}, []string{LabelWorkerName})

	TranscodingRequestsRetries = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "transcoding_requests_retries",
	}, []string{LabelWorkerName})
	TranscodingRequestsErrors = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "transcoding_requests_errors",
	}, []string{LabelWorkerName})
)

var (
	WorkerCapability = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "worker_capability",
	}, []string{"status"})

	TranscodedSeconds = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "transcoded_seconds",
	})

	PipelineSpentSeconds = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "pipeline_spent_seconds",
	}, []string{LabelStage})
	PipelineStagesRunning = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "pipeline_stages_running",
	}, []string{LabelStage})

	InputBytes = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "input_bytes",
	})
	OutputBytes = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "output_bytes",
	})

	TranscodedStreamsCount = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "done_streams_count",
	})
	TranscodingErrorsCount = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "errors_count",
	}, []string{LabelStage})
)

Functions

func RegisterTowerMetrics

func RegisterTowerMetrics()

func RegisterWorkerMetrics

func RegisterWorkerMetrics()