metric

Documentation

Index

• Variables
• func HandledIncomingRequest(ctx context.Context, component, method, statusCode string, took time.Duration)

Variables

var (

	// server metrics
	ServerRequestReceived = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "requests_received_total",
		Help:      "",
	}, []string{componentLabel, methodLabel})
	ServerRequestHandled = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "requests_handled_total",
		Help:      "",
	}, []string{componentLabel, methodLabel, statusCodeLabel})
	ServerRequestDuration = promauto.NewHistogramVec(prometheus.HistogramOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "requests_duration_seconds",
		Help:      "",
		Buckets:   defaultBuckets,
	}, []string{componentLabel, methodLabel, statusCodeLabel})
	ServerRequestPanics = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "requests_panics_total",
		Help:      "",
	})
	ServerRateLimits = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "requests_rate_limits_total",
		Help:      "",
	})
	ServerExportRequestLimits = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "export_requests_limits_total",
		Help:      "",
	})
	ServerCacheInmemoryHits = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "cache_inmemory_hits_total",
		Help:      "",
	})
	ServerCacheInmemoryMisses = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "cache_inmemory_misses_total",
		Help:      "",
	})
	ServerCacheRedisHits = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "cache_redis_hits_total",
		Help:      "",
	})
	ServerCacheRedisMisses = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "cache_redis_misses_total",
		Help:      "",
	})
	// client metrics
	SeqDBClientRequestSent = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: seqDBClientSubsys,
		Name:      "requests_sent_total",
		Help:      "",
	}, []string{methodLabel})
	SeqDBClientResponseReceived = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: seqDBClientSubsys,
		Name:      "responses_received_total",
		Help:      "",
	}, []string{methodLabel, statusCodeLabel})
	SeqDBClientRequestDuration = promauto.NewHistogramVec(prometheus.HistogramOpts{
		Namespace: seqUINS,
		Subsystem: seqDBClientSubsys,
		Name:      "requests_sent_duration_seconds",
		Help:      "",
		Buckets:   defaultBuckets,
	}, []string{methodLabel, statusCodeLabel})
	SeqDBClientRequestError = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: seqDBClientSubsys,
		Name:      "requests_errors_total",
		Help:      "",
	}, []string{methodLabel, errorTypeLabel})
	SeqDBClientPartialResponse = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: seqDBClientSubsys,
		Name:      "partial_responses_total",
		Help:      "",
	}, []string{methodLabel, errorTypeLabel})
	SeqDBClientStreamError = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: seqDBClientSubsys,
		Name:      "stream_errors_total",
		Help:      "",
	}, []string{methodLabel, opLabel})
	SeqDBClientEmptyDataResponse = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: seqDBClientSubsys,
		Name:      "empty_data_responses_total",
		Help:      "",
	})
	// auth metrics
	AuthVerifyDuration = promauto.NewHistogram(prometheus.HistogramOpts{
		Namespace: seqUINS,
		Subsystem: authSubsys,
		Name:      "verify_duration_seconds",
		Help:      "",
		Buckets:   defaultBuckets,
	})
	// repository metrics
	RepositoryRequestSent = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: repoSubsys,
		Name:      "requests_sent_total",
		Help:      "",
	}, []string{tableLabel, queryLabel})
	RepositoryRequestDuration = promauto.NewHistogramVec(prometheus.HistogramOpts{
		Namespace: seqUINS,
		Subsystem: repoSubsys,
		Name:      "requests_sent_duration_seconds",
		Help:      "",
		Buckets:   defaultBuckets,
	}, []string{tableLabel, queryLabel})
	RepositoryRequestError = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: repoSubsys,
		Name:      "requests_errors_total",
		Help:      "",
	}, []string{tableLabel, queryLabel, errorTypeLabel})
	UnauthorizedClientsRequests = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: serverSubsys,
		Name:      "unauthorized_clients_requests_count",
		Help:      "",
	}, []string{"client"})

	// clickhouse repository metrics
	ClickHouseRequestSent = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: clickHouseSubsys,
		Name:      "requests_sent_total",
		Help:      "",
	}, []string{tableLabel, queryLabel})
	ClickHouseRequestDuration = promauto.NewHistogramVec(prometheus.HistogramOpts{
		Namespace: seqUINS,
		Subsystem: clickHouseSubsys,
		Name:      "requests_sent_duration_seconds",
		Help:      "",
		Buckets:   defaultBuckets,
	}, []string{tableLabel, queryLabel})
	ClickHouseRequestError = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: seqUINS,
		Subsystem: clickHouseSubsys,
		Name:      "requests_errors_total",
		Help:      "",
	}, []string{tableLabel, queryLabel, errorTypeLabel})

	// mass export metrics
	MassExportSeqDBSearchDuration = promauto.NewHistogramVec(prometheus.HistogramOpts{
		Namespace: seqUINS,
		Subsystem: massExportSubsys,
		Name:      "seq_db_search_duration",
		Help:      "",
		Buckets:   defaultBuckets,
	}, []string{sessionIDLabel})

	MassExportOnePartExportDuration = promauto.NewHistogramVec(prometheus.HistogramOpts{
		Namespace: seqUINS,
		Subsystem: massExportSubsys,
		Name:      "one_part_export_duration",
		Help:      "",
		Buckets:   defaultBuckets,
	}, []string{sessionIDLabel})
)

Functions

func HandledIncomingRequest

func HandledIncomingRequest(ctx context.Context, component, method, statusCode string, took time.Duration)

HandledIncomingRequest handles metrics for processed incoming request.