metrics

func (*Metrics) AddAggregatorGasCostPaidTotal ¶ added in v0.13.0

func (m *Metrics) AddAggregatorGasCostPaidTotal(value float64)

func (*Metrics) AddAggregatorGasPaidForBatcher ¶ added in v0.11.0

func (m *Metrics) AddAggregatorGasPaidForBatcher(value float64)

func (*Metrics) IncAggregatedResponses ¶

func (m *Metrics) IncAggregatedResponses()

func (*Metrics) IncAggregatorPaidForBatcher ¶ added in v0.11.0

func (m *Metrics) IncAggregatorPaidForBatcher()

func (*Metrics) IncAggregatorReceivedTasks ¶ added in v0.9.0

func (m *Metrics) IncAggregatorReceivedTasks()

func (*Metrics) IncBumpedGasPriceForAggregatedResponse ¶ added in v0.11.0

func (m *Metrics) IncBumpedGasPriceForAggregatedResponse()

func (*Metrics) IncOperatorTaskResponses ¶

func (m *Metrics) IncOperatorTaskResponses()

func (*Metrics) ObserveLatencyForRespondToTask ¶ added in v0.13.0

func (m *Metrics) ObserveLatencyForRespondToTask(elapsed time.Duration)

func (*Metrics) ObserveTaskQuorumReached ¶ added in v0.13.0

func (m *Metrics) ObserveTaskQuorumReached(elapsed time.Duration)

func (*Metrics) Start ¶

func (m *Metrics) Start(ctx context.Context, reg prometheus.Gatherer) <-chan error

Start creates a http handler for reg and starts the prometheus server in a goroutine, listening at m.ipPortAddress. reg needs to be the prometheus registry that was passed in the NewMetrics constructor