prometheus

Documentation

Index

• type Metrics
  • func NewMetrics(prefix string, ignoreUsers []string) *Metrics
  • func Start(ctx context.Context, config util.Config) (metrics *Metrics, err error)
  • func (this *Metrics) HandleResponseTrace(trace []messages.Trace)
  • func (this *Metrics) LogCamundaCompleteTask()
  • func (this *Metrics) LogCamundaCompleteTaskError()
  • func (this *Metrics) LogCamundaGetShardsError()
  • func (this *Metrics) LogCamundaGetTasksError()
  • func (this *Metrics) LogCamundaLoadedTasks(count int)
  • func (this *Metrics) LogIncident()
  • func (this *Metrics) LogTaskCommandResponseReceived(task messages.TaskInfo)
  • func (this *Metrics) LogTaskCommandSend(task messages.GroupTaskMetadataElement)
  • func (this *Metrics) LogTaskCompleted(task messages.TaskInfo)
  • func (this *Metrics) LogTaskLastEventValueRequest(task messages.GroupTaskMetadataElement)
  • func (this *Metrics) LogTaskMarshallingLatency(endpoint string, userId string, serviceId string, functionId string, ...)
  • func (this *Metrics) LogTaskReceived(task messages.CamundaExternalTask)
  • func (this *Metrics) ServeHTTP(writer http.ResponseWriter, request *http.Request)

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

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

func (*Metrics) LogTaskCommandSend

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

func (*Metrics) LogTaskCompleted

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

func (*Metrics) LogTaskLastEventValueRequest

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

func (*Metrics) LogTaskMarshallingLatency

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

func (*Metrics) LogTaskReceived

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

func (*Metrics) ServeHTTP

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