metrics

package
v0.0.0-...-e939e73 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 4, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MetricsCollector 

type MetricsCollector struct {
	// contains filtered or unexported fields
}

MetricsCollector centralizes all metrics recording with proper labeling

func NewMetricsCollector 

func NewMetricsCollector(namespace string, logger *zap.Logger) *MetricsCollector

NewMetricsCollector creates a new MetricsCollector instance

func (*MetricsCollector) AddCacheSize 

func (mc *MetricsCollector) AddCacheSize(sizeBytes int64)

AddCacheSize increments the cache size gauge by the given number of bytes

func (*MetricsCollector) DecActiveRequests 

func (mc *MetricsCollector) DecActiveRequests()

DecActiveRequests decrements active request counter

func (*MetricsCollector) IncActiveRequests 

func (mc *MetricsCollector) IncActiveRequests()

IncActiveRequests increments active request counter

func (*MetricsCollector) RecordBypass 

func (mc *MetricsCollector) RecordBypass(host, reason string)

RecordBypass records when bypass mode is used

func (*MetricsCollector) RecordCacheHit 

func (mc *MetricsCollector) RecordCacheHit(host, dimension string)

RecordCacheHit records a successful cache hit

func (*MetricsCollector) RecordCacheMiss 

func (mc *MetricsCollector) RecordCacheMiss(host, dimension string)

RecordCacheMiss records a cache miss

func (*MetricsCollector) RecordCompression 

func (mc *MetricsCollector) RecordCompression(algorithm string, originalSize, compressedSize int)

RecordCompression records compression metrics (ratio and bytes saved)

func (*MetricsCollector) RecordDecompressionError 

func (mc *MetricsCollector) RecordDecompressionError(algorithm string)

RecordDecompressionError records a decompression failure

func (*MetricsCollector) RecordError 

func (mc *MetricsCollector) RecordError(errorType, host string)

RecordError records an error by type

func (*MetricsCollector) RecordRenderDuration 

func (mc *MetricsCollector) RecordRenderDuration(host, dimension, serviceID string, duration time.Duration)

RecordRenderDuration records how long a render service call took

func (*MetricsCollector) RecordRequest 

func (mc *MetricsCollector) RecordRequest(host, dimension, status string, duration time.Duration)

RecordRequest records a request with timing

func (*MetricsCollector) RecordStaleServed 

func (mc *MetricsCollector) RecordStaleServed(host, dimension, source string)

RecordStaleServed records that a stale cache was served

func (*MetricsCollector) RecordStatusCodeResponse 

func (mc *MetricsCollector) RecordStatusCodeResponse(host, dimension string, statusCode int)

RecordStatusCodeResponse records a response by status code

func (*MetricsCollector) RecordWaitSuccess 

func (mc *MetricsCollector) RecordWaitSuccess(host, dimension string, duration time.Duration)

RecordWaitSuccess records a successful wait for concurrent render

func (*MetricsCollector) RecordWaitTimeout 

func (mc *MetricsCollector) RecordWaitTimeout(host, dimension string, duration time.Duration)

RecordWaitTimeout records a timeout while waiting for concurrent render

func (*MetricsCollector) ServeHTTP 

func (mc *MetricsCollector) ServeHTTP(ctx *fasthttp.RequestCtx)

ServeHTTP serves Prometheus metrics via HTTP

type PrometheusMetrics 

type PrometheusMetrics struct {
	// contains filtered or unexported fields
}

PrometheusMetrics provides high-performance metrics collection using Prometheus

func NewPrometheusMetrics 

func NewPrometheusMetrics(namespace string, logger *zap.Logger) *PrometheusMetrics

NewPrometheusMetrics creates a new Prometheus-based metrics collector

func NewPrometheusMetricsWithRegistry 

func NewPrometheusMetricsWithRegistry(namespace string, registerer prometheus.Registerer, logger *zap.Logger) *PrometheusMetrics

NewPrometheusMetricsWithRegistry creates a new Prometheus-based metrics collector with custom registry

func (*PrometheusMetrics) AddCacheSize 

func (pm *PrometheusMetrics) AddCacheSize(sizeBytes float64)

AddCacheSize increments the cache size gauge by the given number of bytes

func (*PrometheusMetrics) DecActiveRequests 

func (pm *PrometheusMetrics) DecActiveRequests()

DecActiveRequests decrements active request counter

func (*PrometheusMetrics) IncActiveRequests 

func (pm *PrometheusMetrics) IncActiveRequests()

IncActiveRequests increments active request counter

func (*PrometheusMetrics) RecordBypass 

func (pm *PrometheusMetrics) RecordBypass(host, reason string)

RecordBypass records when bypass mode is used

func (*PrometheusMetrics) RecordBytesSaved 

func (pm *PrometheusMetrics) RecordBytesSaved(algorithm string, bytesSaved int64)

RecordBytesSaved records bytes saved by compression

func (*PrometheusMetrics) RecordCacheHit 

func (pm *PrometheusMetrics) RecordCacheHit(host, dimension string)

RecordCacheHit records a cache hit and updates hit ratio

func (*PrometheusMetrics) RecordCacheMiss 

func (pm *PrometheusMetrics) RecordCacheMiss(host, dimension string)

RecordCacheMiss records a cache miss and updates hit ratio

func (*PrometheusMetrics) RecordCompressionRatio 

func (pm *PrometheusMetrics) RecordCompressionRatio(algorithm string, ratio float64)

RecordCompressionRatio records the compression ratio for a cached file

func (*PrometheusMetrics) RecordDecompressionError 

func (pm *PrometheusMetrics) RecordDecompressionError(algorithm string)

RecordDecompressionError records a decompression failure

func (*PrometheusMetrics) RecordError 

func (pm *PrometheusMetrics) RecordError(errorType, host string)

RecordError records an error by type

func (*PrometheusMetrics) RecordRenderDuration 

func (pm *PrometheusMetrics) RecordRenderDuration(host, dimension, serviceID string, duration time.Duration)

RecordRenderDuration records time taken by render service

func (*PrometheusMetrics) RecordRequest 

func (pm *PrometheusMetrics) RecordRequest(host, dimension, status string, duration time.Duration)

RecordRequest records a request with timing

func (*PrometheusMetrics) RecordStaleServed 

func (pm *PrometheusMetrics) RecordStaleServed(host, dimension, source string)

RecordStaleServed records that a stale cache entry was served

func (*PrometheusMetrics) RecordStatusCodeResponse 

func (pm *PrometheusMetrics) RecordStatusCodeResponse(host, dimension string, statusCode int)

RecordStatusCodeResponse records a response by status code range

func (*PrometheusMetrics) RecordWaitSuccess 

func (pm *PrometheusMetrics) RecordWaitSuccess(host, dimension string, duration time.Duration)

RecordWaitSuccess records a successful wait for concurrent render

func (*PrometheusMetrics) RecordWaitTimeout 

func (pm *PrometheusMetrics) RecordWaitTimeout(host, dimension string, duration time.Duration)

RecordWaitTimeout records a timeout while waiting for concurrent render

func (*PrometheusMetrics) ServeHTTP 

func (pm *PrometheusMetrics) ServeHTTP(ctx *fasthttp.RequestCtx)

ServeHTTP serves Prometheus metrics via HTTP

func (*PrometheusMetrics) UpdateCacheSize 

func (pm *PrometheusMetrics) UpdateCacheSize(sizeBytes float64)

UpdateCacheSize updates the total cache size metric

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.