prometheus

type Gatherer ¶

type Gatherer interface {
	Gather() error
}

Gatherer is a reflection of an object in the processor (e.g. trigger, runtime, worker) that holds prometheus metrics. when Gather() is called, the resource is queried for its primitive statistics. this way we decouple prometheus metrics from the fast path

type TriggerGatherer ¶

type TriggerGatherer struct {
	// contains filtered or unexported fields
}

func NewTriggerGatherer(instanceName string,
	trigger trigger.Trigger,
	logger logger.Logger,
	metricRegistry *prometheus.Registry) (*TriggerGatherer, error)

func (tg *TriggerGatherer) Gather() error

type WorkerGatherer ¶

type WorkerGatherer struct {
	// contains filtered or unexported fields
}

func NewWorkerGatherer(instanceName string,
	trigger trigger.Trigger,
	logger logger.Logger,
	worker *worker.Worker,
	metricRegistry *prometheus.Registry) (*WorkerGatherer, error)

func (wg *WorkerGatherer) Gather() error