Documentation
¶
Index ¶
- func NewManager(ctx context.Context, config types.ConfigManager, logger types.Logger, ...) (types.MetricsManager, error)
- func NewMemoryMetrics(ctx context.Context, logger types.Logger, config *types.MetricsConfig, ...) (types.MetricsManager, error)
- func NewPrometheusMetrics(ctx context.Context, logger types.Logger, config *types.MetricsConfig, ...) (types.MetricsManager, error)
- func RegisterMetricsManager(metricsManagerName string, creator types.MetricsManagerCreator)
- type DashboardData
- type Manager
- func (w *Manager) Close() error
- func (w *Manager) Counter(name string, labels map[string]string) types.Counter
- func (w *Manager) Gauge(name string, labels map[string]string) types.Gauge
- func (w *Manager) GetMetrics() ([]byte, error)
- func (w *Manager) GetStats() ([]byte, error)
- func (w *Manager) Histogram(name string, buckets []float64, labels map[string]string) types.Histogram
- func (w *Manager) IsRunning() bool
- func (w *Manager) RegisterSystemMetrics() error
- func (w *Manager) Start() error
- func (w *Manager) StartSystemCollection() error
- func (w *Manager) Stop() error
- func (w *Manager) StopSystemCollection() error
- func (w *Manager) Summary(name string, objectives map[float64]float64, labels map[string]string) types.Summary
- type ManagerState
- type MemoryConfig
- type MemoryCounter
- type MemoryGauge
- type MemoryHistogram
- type MemoryMetrics
- func (m *MemoryMetrics) Close() error
- func (m *MemoryMetrics) Counter(name string, labels map[string]string) types.Counter
- func (m *MemoryMetrics) Gauge(name string, labels map[string]string) types.Gauge
- func (m *MemoryMetrics) GetMetrics() ([]byte, error)
- func (m *MemoryMetrics) GetStats() ([]byte, error)
- func (m *MemoryMetrics) Histogram(name string, buckets []float64, labels map[string]string) types.Histogram
- func (m *MemoryMetrics) IsRunning() bool
- func (m *MemoryMetrics) RegisterSystemMetrics() error
- func (m *MemoryMetrics) Start() error
- func (m *MemoryMetrics) StartSystemCollection() error
- func (m *MemoryMetrics) Stop() error
- func (m *MemoryMetrics) StopSystemCollection() error
- func (m *MemoryMetrics) Summary(name string, objectives map[float64]float64, labels map[string]string) types.Summary
- type MemoryState
- type MemorySummary
- type MetricStats
- type MetricValue
- type PrometheusConfig
- type PrometheusCounter
- type PrometheusGauge
- type PrometheusHistogram
- type PrometheusMetrics
- func (p *PrometheusMetrics) Close() error
- func (p *PrometheusMetrics) Counter(name string, labels map[string]string) types.Counter
- func (p *PrometheusMetrics) Gauge(name string, labels map[string]string) types.Gauge
- func (p *PrometheusMetrics) GetMetrics() ([]byte, error)
- func (p *PrometheusMetrics) GetStats() ([]byte, error)
- func (p *PrometheusMetrics) Histogram(name string, buckets []float64, labels map[string]string) types.Histogram
- func (p *PrometheusMetrics) IsRunning() bool
- func (p *PrometheusMetrics) RegisterSystemMetrics() error
- func (p *PrometheusMetrics) Start() error
- func (p *PrometheusMetrics) StartSystemCollection() error
- func (p *PrometheusMetrics) Stop() error
- func (p *PrometheusMetrics) StopSystemCollection() error
- func (p *PrometheusMetrics) Summary(name string, objectives map[float64]float64, labels map[string]string) types.Summary
- type PrometheusState
- type PrometheusSummary
- type SystemMetricsCollector
- type SystemState
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) GetMetrics ¶
func (*Manager) RegisterSystemMetrics ¶
func (*Manager) StartSystemCollection ¶
func (*Manager) StopSystemCollection ¶
type ManagerState ¶
type ManagerState int32
const ( ManagerStateStopped ManagerState = iota ManagerStateStarting ManagerStateRunning ManagerStateStopping )
type MemoryConfig ¶
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) GetMetrics ¶
func (m *MemoryMetrics) GetMetrics() ([]byte, error)
func (*MemoryMetrics) GetStats ¶
func (m *MemoryMetrics) GetStats() ([]byte, error)
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
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 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) GetMetrics ¶
func (p *PrometheusMetrics) GetMetrics() ([]byte, error)
func (*PrometheusMetrics) GetStats ¶
func (p *PrometheusMetrics) GetStats() ([]byte, error)
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
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 )
Click to show internal directories.
Click to hide internal directories.