prometheus

package

v0.0.17 Latest Latest Go to latest Published: Mar 14, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/SENERGY-Platform/external-task-worker

Links

Open Source Insights

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