Documentation
¶
Overview ¶
Package metrics exports the host's media worker queue health. It is kept separate from workqueue so a host can enqueue without linking Prometheus.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Collector ¶
type Collector struct {
// contains filtered or unexported fields
}
Collector serves the latest queue snapshot read by an always-on host's River leader. A one-shot media worker can scale to zero and cannot expose backlog.
func NewCollector ¶
NewCollector returns queue metrics for one worker schema.
func (*Collector) Collect ¶
func (c *Collector) Collect(ch chan<- prometheus.Metric)
func (*Collector) Describe ¶
func (*Collector) Describe(ch chan<- *prometheus.Desc)
func (*Collector) LeaderHook ¶
LeaderHook starts queue polling only while this River client holds leadership.
Source Files
Click to show internal directories.
Click to hide internal directories.