prometheus

package

v0.0.41 Latest Latest Go to latest Published: Dec 18, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation ¶

Index ¶

type Metrics
- func NewMetrics(prefix string, ignoreUsers []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
	TasksCompleteErrors         prometheus.Counter
	GetTasksErrors              prometheus.Counter
	GetShardsError              prometheus.Counter
	CommandRoundtripMsHistogram prometheus.Histogram
	CommandResponsesReceived    prometheus.Counter

	TaskMarshallingLatencySummary        prometheus.Summary
	TaskCommandRoundtripLatencyMsSummary prometheus.Summary

	TaskMarshallingLatency              *prometheus.HistogramVec
	TaskLastEventValueRequestCountVec   *prometheus.CounterVec
	TaskCommandSendCountVec             *prometheus.CounterVec
	TaskReceivedCountVec                *prometheus.CounterVec
	TaskCommandResponseReceivedCountVec *prometheus.CounterVec
	TaskCompletedCountVec               *prometheus.CounterVec
	// contains filtered or unexported fields
}

func NewMetrics ¶

func NewMetrics(prefix string, ignoreUsers []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()

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) LogTaskCommandResponseReceived ¶ added in v0.0.5

func (this *Metrics) LogTaskCommandResponseReceived(task messages.TaskInfo)

func (*Metrics) LogTaskCommandSend ¶ added in v0.0.5

func (this *Metrics) LogTaskCommandSend(task messages.GroupTaskMetadataElement)

func (*Metrics) LogTaskCompleted ¶ added in v0.0.5

func (this *Metrics) LogTaskCompleted(task messages.TaskInfo)

func (*Metrics) LogTaskLastEventValueRequest ¶ added in v0.0.5

func (this *Metrics) LogTaskLastEventValueRequest(task messages.GroupTaskMetadataElement)

func (*Metrics) LogTaskMarshallingLatency ¶ added in v0.0.5

func (this *Metrics) LogTaskMarshallingLatency(endpoint string, userId string, serviceId string, functionId string, latency time.Duration)

func (*Metrics) LogTaskReceived ¶ added in v0.0.5

func (this *Metrics) LogTaskReceived(task messages.CamundaExternalTask)

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