prometheus

package

v0.0.3 Latest Latest Go to latest Published: Jan 5, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation ¶

Index ¶

type Metrics
- func NewMetrics(prefix string) *Metrics
- func Start(ctx context.Context, config util.Config) (metrics *Metrics, err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Metrics ¶

type Metrics struct {
	IncidentsCount              prometheus.Counter
	TasksReceivedCount          prometheus.Counter
	TasksCompletedCount         prometheus.Counter
	TaskCompleteLatencyMs       prometheus.Gauge
	TasksCompleteErrors         prometheus.Counter
	GetTasksErrors              prometheus.Counter
	GetShardsError              prometheus.Counter
	CommandRoundtripMs          prometheus.Gauge
	CommandRoundtripMsHistogram prometheus.Histogram
	CommandResponsesReceived    prometheus.Counter
	// contains filtered or unexported fields
}

func NewMetrics ¶

func NewMetrics(prefix string) *Metrics

func Start ¶

func Start(ctx context.Context, config util.Config) (metrics *Metrics, err error)

func (*Metrics) HandleResponseTrace ¶

func (this *Metrics) HandleResponseTrace(trace []messages.Trace)

func (*Metrics) LogCamundaCompleteTask ¶

func (this *Metrics) LogCamundaCompleteTask(latency time.Duration)

func (*Metrics) LogCamundaCompleteTaskError ¶

func (this *Metrics) LogCamundaCompleteTaskError()

func (*Metrics) LogCamundaGetShardsError ¶

func (this *Metrics) LogCamundaGetShardsError()

func (*Metrics) LogCamundaGetTasksError ¶

func (this *Metrics) LogCamundaGetTasksError()

func (*Metrics) LogCamundaLoadedTasks ¶

func (this *Metrics) LogCamundaLoadedTasks(count int)

func (*Metrics) LogIncident ¶

func (this *Metrics) LogIncident()

func (*Metrics) ServeHTTP ¶

func (this *Metrics) ServeHTTP(writer http.ResponseWriter, request *http.Request)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL