metrics

package
v1.1.4 Latest Latest
Warning

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

Go to latest
Published: Dec 1, 2025 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewManager

func NewManager(ctx context.Context, config types.ConfigManager, logger types.Logger, router types.HTTPRouter, health types.HealthManager) (types.MetricsManager, error)

func NewMemoryMetrics

func NewMemoryMetrics(ctx context.Context, logger types.Logger, config *types.MetricsConfig, router types.HTTPRouter, health types.HealthManager) (types.MetricsManager, error)

func NewPrometheusMetrics

func NewPrometheusMetrics(ctx context.Context, logger types.Logger, config *types.MetricsConfig, router types.HTTPRouter, health types.HealthManager) (types.MetricsManager, error)

func RegisterMetricsManager

func RegisterMetricsManager(metricsManagerName string, creator types.MetricsManagerCreator)

Types

type DashboardData

type DashboardData struct {
	Stats  *MetricStats
	Groups map[string][]MetricValue
	Error  string
}

type Manager

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

func (*Manager) Close

func (w *Manager) Close() error

func (*Manager) Counter

func (w *Manager) Counter(name string, labels map[string]string) types.Counter

func (*Manager) Gauge

func (w *Manager) Gauge(name string, labels map[string]string) types.Gauge

func (*Manager) GetMetrics

func (w *Manager) GetMetrics() ([]byte, error)

func (*Manager) GetStats

func (w *Manager) GetStats() ([]byte, error)

func (*Manager) Histogram

func (w *Manager) Histogram(name string, buckets []float64, labels map[string]string) types.Histogram

func (*Manager) IsRunning

func (w *Manager) IsRunning() bool

func (*Manager) RegisterSystemMetrics

func (w *Manager) RegisterSystemMetrics() error

func (*Manager) Start

func (w *Manager) Start() error

func (*Manager) StartSystemCollection

func (w *Manager) StartSystemCollection() error

func (*Manager) Stop

func (w *Manager) Stop() error

func (*Manager) StopSystemCollection

func (w *Manager) StopSystemCollection() error

func (*Manager) Summary

func (w *Manager) Summary(name string, objectives map[float64]float64, labels map[string]string) types.Summary

type ManagerState

type ManagerState int32
const (
	ManagerStateStopped ManagerState = iota
	ManagerStateStarting
	ManagerStateRunning
	ManagerStateStopping
)

type MemoryConfig

type MemoryConfig struct {
	RetentionPeriod time.Duration `yaml:"retention_period" json:"retention_period"`
	MaxMetrics      int           `yaml:"max_metrics" json:"max_metrics"`
	CleanupInterval time.Duration `yaml:"cleanup_interval" json:"cleanup_interval"`
}

type MemoryCounter

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

func (*MemoryCounter) Add

func (c *MemoryCounter) Add(value float64)

func (*MemoryCounter) Get

func (c *MemoryCounter) Get() float64

func (*MemoryCounter) Inc

func (c *MemoryCounter) Inc()

type MemoryGauge

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

func (*MemoryGauge) Add

func (g *MemoryGauge) Add(value float64)

func (*MemoryGauge) Dec

func (g *MemoryGauge) Dec()

func (*MemoryGauge) Get

func (g *MemoryGauge) Get() float64

func (*MemoryGauge) Inc

func (g *MemoryGauge) Inc()

func (*MemoryGauge) Set

func (g *MemoryGauge) Set(value float64)

func (*MemoryGauge) Sub

func (g *MemoryGauge) Sub(value float64)

type MemoryHistogram

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

func (*MemoryHistogram) GetCount

func (h *MemoryHistogram) GetCount() uint64

func (*MemoryHistogram) GetSum

func (h *MemoryHistogram) GetSum() float64

func (*MemoryHistogram) Observe

func (h *MemoryHistogram) Observe(value float64)

func (*MemoryHistogram) ObserveDuration

func (h *MemoryHistogram) ObserveDuration(start time.Time)

type MemoryMetrics

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

func (*MemoryMetrics) Close

func (m *MemoryMetrics) Close() error

func (*MemoryMetrics) Counter

func (m *MemoryMetrics) Counter(name string, labels map[string]string) types.Counter

func (*MemoryMetrics) Gauge

func (m *MemoryMetrics) Gauge(name string, labels map[string]string) types.Gauge

func (*MemoryMetrics) GetMetrics

func (m *MemoryMetrics) GetMetrics() ([]byte, error)

func (*MemoryMetrics) GetStats

func (m *MemoryMetrics) GetStats() ([]byte, error)

func (*MemoryMetrics) Histogram

func (m *MemoryMetrics) Histogram(name string, buckets []float64, labels map[string]string) types.Histogram

func (*MemoryMetrics) IsRunning

func (m *MemoryMetrics) IsRunning() bool

func (*MemoryMetrics) RegisterSystemMetrics

func (m *MemoryMetrics) RegisterSystemMetrics() error

func (*MemoryMetrics) Start

func (m *MemoryMetrics) Start() error

func (*MemoryMetrics) StartSystemCollection

func (m *MemoryMetrics) StartSystemCollection() error

func (*MemoryMetrics) Stop

func (m *MemoryMetrics) Stop() error

func (*MemoryMetrics) StopSystemCollection

func (m *MemoryMetrics) StopSystemCollection() error

func (*MemoryMetrics) Summary

func (m *MemoryMetrics) Summary(name string, objectives map[float64]float64, labels map[string]string) types.Summary

type MemoryState

type MemoryState int32
const (
	MemoryStateStopped MemoryState = iota
	MemoryStateStarting
	MemoryStateRunning
	MemoryStateStopping
)

type MemorySummary

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

func (*MemorySummary) GetCount

func (s *MemorySummary) GetCount() uint64

func (*MemorySummary) GetSum

func (s *MemorySummary) GetSum() float64

func (*MemorySummary) Observe

func (s *MemorySummary) Observe(value float64)

func (*MemorySummary) ObserveDuration

func (s *MemorySummary) ObserveDuration(start time.Time)

type MetricStats

type MetricStats struct {
	TotalMetrics     int       `json:"total_metrics"`
	CounterMetrics   int       `json:"counter_metrics"`
	GaugeMetrics     int       `json:"gauge_metrics"`
	HistogramMetrics int       `json:"histogram_metrics"`
	SummaryMetrics   int       `json:"summary_metrics"`
	LastUpdate       time.Time `json:"last_update"`
	MemoryUsage      int64     `json:"memory_usage"`
	Collections      uint64    `json:"collections"`
	Errors           uint64    `json:"errors"`
}

type MetricValue

type MetricValue struct {
	Name      string            `json:"name"`
	Type      string            `json:"type"`
	Value     float64           `json:"value"`
	Labels    map[string]string `json:"labels"`
	Timestamp time.Time         `json:"timestamp"`
	Help      string            `json:"help"`
}

type PrometheusConfig

type PrometheusConfig struct {
	Path            string            `yaml:"path" json:"path"`
	Registry        string            `yaml:"registry" json:"registry"`
	Namespace       string            `yaml:"namespace" json:"namespace"`
	Subsystem       string            `yaml:"subsystem" json:"subsystem"`
	Labels          map[string]string `yaml:"labels" json:"labels"`
	Gatherer        string            `yaml:"gatherer" json:"gatherer"`
	EnableGoMetrics bool              `yaml:"enable_go_metrics" json:"enable_go_metrics"`
}

type PrometheusCounter

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

func (*PrometheusCounter) Add

func (c *PrometheusCounter) Add(value float64)

func (*PrometheusCounter) Get

func (c *PrometheusCounter) Get() float64

func (*PrometheusCounter) Inc

func (c *PrometheusCounter) Inc()

type PrometheusGauge

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

func (*PrometheusGauge) Add

func (g *PrometheusGauge) Add(value float64)

func (*PrometheusGauge) Dec

func (g *PrometheusGauge) Dec()

func (*PrometheusGauge) Get

func (g *PrometheusGauge) Get() float64

func (*PrometheusGauge) Inc

func (g *PrometheusGauge) Inc()

func (*PrometheusGauge) Set

func (g *PrometheusGauge) Set(value float64)

func (*PrometheusGauge) Sub

func (g *PrometheusGauge) Sub(value float64)

type PrometheusHistogram

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

func (*PrometheusHistogram) GetBuckets

func (h *PrometheusHistogram) GetBuckets() map[float64]uint64

func (*PrometheusHistogram) GetCount

func (h *PrometheusHistogram) GetCount() uint64

func (*PrometheusHistogram) GetSum

func (h *PrometheusHistogram) GetSum() float64

func (*PrometheusHistogram) Observe

func (h *PrometheusHistogram) Observe(value float64)

func (*PrometheusHistogram) ObserveDuration

func (h *PrometheusHistogram) ObserveDuration(start time.Time)

type PrometheusMetrics

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

func (*PrometheusMetrics) Close

func (p *PrometheusMetrics) Close() error

func (*PrometheusMetrics) Counter

func (p *PrometheusMetrics) Counter(name string, labels map[string]string) types.Counter

func (*PrometheusMetrics) Gauge

func (p *PrometheusMetrics) Gauge(name string, labels map[string]string) types.Gauge

func (*PrometheusMetrics) GetMetrics

func (p *PrometheusMetrics) GetMetrics() ([]byte, error)

func (*PrometheusMetrics) GetStats

func (p *PrometheusMetrics) GetStats() ([]byte, error)

func (*PrometheusMetrics) Histogram

func (p *PrometheusMetrics) Histogram(name string, buckets []float64, labels map[string]string) types.Histogram

func (*PrometheusMetrics) IsRunning

func (p *PrometheusMetrics) IsRunning() bool

func (*PrometheusMetrics) RegisterSystemMetrics

func (p *PrometheusMetrics) RegisterSystemMetrics() error

func (*PrometheusMetrics) Start

func (p *PrometheusMetrics) Start() error

func (*PrometheusMetrics) StartSystemCollection

func (p *PrometheusMetrics) StartSystemCollection() error

func (*PrometheusMetrics) Stop

func (p *PrometheusMetrics) Stop() error

func (*PrometheusMetrics) StopSystemCollection

func (p *PrometheusMetrics) StopSystemCollection() error

func (*PrometheusMetrics) Summary

func (p *PrometheusMetrics) Summary(name string, objectives map[float64]float64, labels map[string]string) types.Summary

type PrometheusState

type PrometheusState int32
const (
	PrometheusStateStopped PrometheusState = iota
	PrometheusStateStarting
	PrometheusStateRunning
	PrometheusStateStopping
)

type PrometheusSummary

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

func (*PrometheusSummary) GetCount

func (s *PrometheusSummary) GetCount() uint64

func (*PrometheusSummary) GetQuantiles

func (s *PrometheusSummary) GetQuantiles() map[float64]float64

func (*PrometheusSummary) GetSum

func (s *PrometheusSummary) GetSum() float64

func (*PrometheusSummary) Observe

func (s *PrometheusSummary) Observe(value float64)

func (*PrometheusSummary) ObserveDuration

func (s *PrometheusSummary) ObserveDuration(start time.Time)

type SystemMetricsCollector

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

func NewSystemMetricsCollector

func NewSystemMetricsCollector(ctx context.Context, logger types.Logger, metricsManager types.MetricsManager) *SystemMetricsCollector

func (*SystemMetricsCollector) IsRunning

func (smc *SystemMetricsCollector) IsRunning() bool

func (*SystemMetricsCollector) Start

func (smc *SystemMetricsCollector) Start() error

func (*SystemMetricsCollector) Stop

func (smc *SystemMetricsCollector) Stop() error

type SystemState

type SystemState int32
const (
	SystemStateStopped SystemState = iota
	SystemStateStarting
	SystemStateRunning
	SystemStateStopping
)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL