Documentation
¶
Index ¶
- Constants
- func GetBaseTags() map[string]string
- func SetGauge(scope tally.Scope, name string, tags map[string]string, value interface{})
- func SetMultipleGauges(scope tally.Scope, metrics map[string]interface{}, tags map[string]string)
- func StandardizeTags(tags map[string]string, stdKeys []string) map[string]string
- type BackupMetricGroup
- type Collectable
- type CoordinatorMetricGroup
- type DataMetricGroup
- type DbStatusMetricGroup
- type LatencyProbeMetricGroup
- type MetricReporter
- func (s *MetricReporter) AddScope(parentScope tally.Scope, key string, name string)
- func (m *MetricReporter) Close()
- func (m *MetricReporter) Collect()
- func (s *MetricReporter) CreateScope(key string, name string, parentScope tally.Scope) error
- func (s *MetricReporter) GetScope(key string) (tally.Scope, error)
- func (s *MetricReporter) GetScopeOrExit(key string) tally.Scope
- func (m *MetricReporter) ServeHttp()
- type ProcessesMetricGroup
- type WorkloadBytesMetricGroup
- type WorkloadKeysMetricGroup
- type WorkloadOperationsMetricGroup
- type WorkloadTransactionsMetricGroup
Constants ¶
View Source
const ( RelativeJsonFileLocation = "test/data" DefaultListenAddress = ":8080" )
View Source
const UnknownValue = "unknown"
Variables ¶
This section is empty.
Functions ¶
func GetBaseTags ¶
func SetMultipleGauges ¶
Types ¶
type BackupMetricGroup ¶
type BackupMetricGroup struct {
// contains filtered or unexported fields
}
func NewBackupMetricGroup ¶
func NewBackupMetricGroup(reporter *MetricReporter) *BackupMetricGroup
func (*BackupMetricGroup) GetMetrics ¶
func (b *BackupMetricGroup) GetMetrics(status *models.FullStatus)
type Collectable ¶
type Collectable interface {
GetMetrics(status *models.FullStatus)
}
Each group that collects metrics needs to implement the Collectable interface
type CoordinatorMetricGroup ¶
type CoordinatorMetricGroup struct {
// contains filtered or unexported fields
}
func NewCoordinatorMetricGroup ¶
func NewCoordinatorMetricGroup(info *MetricReporter) *CoordinatorMetricGroup
func (*CoordinatorMetricGroup) GetMetrics ¶
func (c *CoordinatorMetricGroup) GetMetrics(status *models.FullStatus)
type DataMetricGroup ¶
type DataMetricGroup struct {
// contains filtered or unexported fields
}
func NewDataMetricGroup ¶
func NewDataMetricGroup(info *MetricReporter) *DataMetricGroup
func (*DataMetricGroup) GetMetrics ¶
func (d *DataMetricGroup) GetMetrics(status *models.FullStatus)
type DbStatusMetricGroup ¶
type DbStatusMetricGroup struct {
// contains filtered or unexported fields
}
func NewDbStatusMetricGroup ¶
func NewDbStatusMetricGroup(info *MetricReporter) *DbStatusMetricGroup
func (*DbStatusMetricGroup) GetMetrics ¶
func (d *DbStatusMetricGroup) GetMetrics(status *models.FullStatus)
type LatencyProbeMetricGroup ¶
type LatencyProbeMetricGroup struct {
// contains filtered or unexported fields
}
func NewLatencyProbeMetricGroup ¶
func NewLatencyProbeMetricGroup(info *MetricReporter) *LatencyProbeMetricGroup
func (*LatencyProbeMetricGroup) GetMetrics ¶
func (d *LatencyProbeMetricGroup) GetMetrics(status *models.FullStatus)
type MetricReporter ¶
type MetricReporter struct {
// contains filtered or unexported fields
}
High level type that can report all the metrics. Reponsible for: * getting the status json output periodically * call the GetMetrics() method of each group, which will set up the metrics in tally
func NewMetricReporter ¶
func NewMetricReporter() *MetricReporter
func (*MetricReporter) Close ¶
func (m *MetricReporter) Close()
func (*MetricReporter) Collect ¶
func (m *MetricReporter) Collect()
Periodic data collection, called from main in a goroutine
func (*MetricReporter) CreateScope ¶
func (*MetricReporter) GetScopeOrExit ¶
func (*MetricReporter) ServeHttp ¶
func (m *MetricReporter) ServeHttp()
type ProcessesMetricGroup ¶
type ProcessesMetricGroup struct {
// contains filtered or unexported fields
}
func NewProcessesMetricGroup ¶
func NewProcessesMetricGroup(reporter *MetricReporter) *ProcessesMetricGroup
func (*ProcessesMetricGroup) GetMetrics ¶
func (p *ProcessesMetricGroup) GetMetrics(status *models.FullStatus)
type WorkloadBytesMetricGroup ¶
type WorkloadBytesMetricGroup struct {
// contains filtered or unexported fields
}
func NewWorkloadBytesMetricGroup ¶
func NewWorkloadBytesMetricGroup(info *MetricReporter) *WorkloadBytesMetricGroup
func (*WorkloadBytesMetricGroup) GetMetrics ¶
func (w *WorkloadBytesMetricGroup) GetMetrics(status *models.FullStatus)
type WorkloadKeysMetricGroup ¶
type WorkloadKeysMetricGroup struct {
// contains filtered or unexported fields
}
func NewWorkloadKeysMetricGroup ¶
func NewWorkloadKeysMetricGroup(info *MetricReporter) *WorkloadKeysMetricGroup
func (*WorkloadKeysMetricGroup) GetMetrics ¶
func (w *WorkloadKeysMetricGroup) GetMetrics(status *models.FullStatus)
type WorkloadOperationsMetricGroup ¶
type WorkloadOperationsMetricGroup struct {
// contains filtered or unexported fields
}
func NewWorkloadOperationsMetricGroup ¶
func NewWorkloadOperationsMetricGroup(info *MetricReporter) *WorkloadOperationsMetricGroup
func (*WorkloadOperationsMetricGroup) GetMetrics ¶
func (w *WorkloadOperationsMetricGroup) GetMetrics(status *models.FullStatus)
type WorkloadTransactionsMetricGroup ¶
type WorkloadTransactionsMetricGroup struct {
// contains filtered or unexported fields
}
func NewWorkloadTransactionsMetricGroup ¶
func NewWorkloadTransactionsMetricGroup(info *MetricReporter) *WorkloadTransactionsMetricGroup
func (*WorkloadTransactionsMetricGroup) GetMetrics ¶
func (w *WorkloadTransactionsMetricGroup) GetMetrics(status *models.FullStatus)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.