Documentation
¶
Index ¶
- func CalculateQueryRuntime(prev, curr map[string]CachedPGStatStatement) float64
- func TryUint64ToInt64(value uint64) (int64, error)
- func ValidateStruct(s interface{}) error
- type CachedPGStatStatement
- type FlatValue
- type FormattedMetrics
- type FormattedSystemInfo
- type LeveledLogrus
- type MetricData
- type MetricType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CalculateQueryRuntime ¶
func CalculateQueryRuntime(prev, curr map[string]CachedPGStatStatement) float64
CalculateQueryRuntime calculates the runtime of a query based on two consecutive snapshots of the pg_stat_statements table and returns the runtime in milliseconds.
func TryUint64ToInt64 ¶ added in v0.3.0
func ValidateStruct ¶
func ValidateStruct(s interface{}) error
ValidateStruct validates a struct using the validator package It returns a single error with all validation errors combined Used to validate configs when we start the agent
Types ¶
type CachedPGStatStatement ¶
type CachedPGStatStatement struct {
QueryID string `json:"query_id"`
Calls int `json:"calls"`
TotalExecTime float64 `json:"total_exec_time"`
}
func CalculateQueryRuntimeDelta ¶ added in v0.2.0
func CalculateQueryRuntimeDelta(prev, curr map[string]CachedPGStatStatement) ([]CachedPGStatStatement, int)
CalculateQueryRuntimeDelta calculates the delta between two consecutive snapshots of the pg_stat_statements and returns: [{ query_id: "query_id", calls: 10, total_exec_time: 1000 }, ...] The diff will be limited to only 100 different queries changed by default. Also, it will return the total number of diffs found to give us an idea if a lot of information is not captured The cap will be based upon their average execution time (descending)
type FlatValue ¶
type FlatValue struct {
Key string `json:"key"`
Value interface{} `json:"value"`
Type MetricType `json:"type"`
}
FlatValue is a struct that represents a flat metric value.
type FormattedMetrics ¶
type FormattedMetrics struct {
Metrics map[string]MetricData `json:"metrics"`
Timestamp string `json:"timestamp"`
}
FormattedMetrics matches the expected payload of DBtune backend
func FormatMetrics ¶
func FormatMetrics(metrics []FlatValue) FormattedMetrics
TODO: write util tests for this FormatMetrics converts the MetricsState object into a FormattedMetrics object to be used as a metrics payload
type FormattedSystemInfo ¶
type FormattedSystemInfo struct {
SystemInfo map[string]MetricData `json:"system_info"`
Timestamp string `json:"timestamp"`
}
func FormatSystemInfo ¶
func FormatSystemInfo(metrics []FlatValue) FormattedSystemInfo
type LeveledLogrus ¶
LeveledLogrus is a wrapper around logrus that provides leveled logging This is needed to be compatible with retryablehttp: https://github.com/hashicorp/go-retryablehttp/pull/101#issuecomment-735206810
func (*LeveledLogrus) Debug ¶
func (l *LeveledLogrus) Debug(msg string, keysAndValues ...interface{})
func (*LeveledLogrus) Error ¶
func (l *LeveledLogrus) Error(msg string, keysAndValues ...interface{})
func (*LeveledLogrus) Info ¶
func (l *LeveledLogrus) Info(msg string, keysAndValues ...interface{})
func (*LeveledLogrus) Warn ¶
func (l *LeveledLogrus) Warn(msg string, keysAndValues ...interface{})
type MetricData ¶
type MetricData struct {
Type string `json:"type"`
Value interface{} `json:"value"`
}
type MetricType ¶
type MetricType string
const ( Int MetricType = "int" Float MetricType = "float" String MetricType = "string" Bytes MetricType = "bytes" Boolean MetricType = "boolean" Time MetricType = "time" Percentage MetricType = "percentage" PgssDelta MetricType = "pgss_delta" )
Source Files