Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

statprocessors

package

Go to main page

Versions in this module

v1

v1.21.1

Jan 15, 2025

v1.21.0

Dec 17, 2024

Changes in this version

+ var NamespaceLatencyBenchmarks = make(map[string]map[string]string)

+ var ServiceLatencyBenchmarks = make(map[string]string)

v1.20.0

Sep 24, 2024

v1.19.0

Aug 21, 2024

v1.18.0

Jun 19, 2024

v1.17.0

Apr 10, 2024

v1.16.1

Mar 5, 2024

v1.16.0

Feb 26, 2024

Changes in this version

+ const INFOKEY_SERVICE_CLEAR_STD

+ const INFOKEY_SERVICE_TLS_STD

+ const KEY_NS_INDEX_PRESSURE

+ const KEY_NS_METADATA

+ const KEY_NS_NAMESPACE

+ const KEY_SERVICE_CONFIG

+ const KEY_SERVICE_STATISTICS

+ const KEY_SETS

+ const KEY_XDR_CONFIG

+ const KEY_XDR_METADATA

+ const KEY_XDR_STAT

+ const TYPE_FLASH

+ var Build string

+ var ClusterName string

+ var GlobbingPattern = regexp.MustCompile(`\[|\]|\*|\?|\{|\}|\\|!`)

+ var Infokey_Build = "build"

+ var Infokey_ClusterName = "cluster-name"

+ var Infokey_Service = INFOKEY_SERVICE_CLEAR_STD

+ var LatencyBenchmarks = make(map[string]string)

+ var PREFIX_AEROSPIKE = "aerospike_"

+ var Service string

+ func BuildVersionGreaterThanOrEqual(rawMetrics map[string]string, ref string) (bool, error)

+ func GetMetricType(pContext commons.ContextType, pRawMetricName string) commons.MetricType

+ type AerospikeStat struct

+ Context commons.ContextType

+ IsAllowed bool

+ IsConfig bool

+ LabelValues []string

+ Labels []string

+ MType commons.MetricType

+ Name string

+ Value float64

+ func NewAerospikeStat(pContext commons.ContextType, pStatName string, allowed bool) AerospikeStat

+ func Refresh() ([]AerospikeStat, error)

+ func RefreshSystemInfo() ([]AerospikeStat, error)

+ func (as *AerospikeStat) QualifyMetricContext() string

+ type LatencyInfoParser struct

+ func NewInfoParser(s string) *LatencyInfoParser

+ func (ip *LatencyInfoParser) Expect(s string) error

+ func (ip *LatencyInfoParser) PeekAndExpect(s string) error

+ func (ip *LatencyInfoParser) ReadUntil(delim byte) (string, error)

+ type LatencyStatsMap map[string]interface

+ func (s LatencyStatsMap) Get(name string, aliases ...string) interface{}

+ func (s LatencyStatsMap) TryFloat(name string, defValue float64, aliases ...string) float64

+ func (s LatencyStatsMap) TryString(name string, defValue string, aliases ...string) string

+ type LatencyStatsProcessor struct

+ func (lw *LatencyStatsProcessor) PassOneKeys() []string

+ func (lw *LatencyStatsProcessor) PassTwoKeys(rawMetrics map[string]string) (latencyCommands []string)

+ func (lw *LatencyStatsProcessor) Refresh(infoKeys []string, rawMetrics map[string]string) ([]AerospikeStat, error)

+ type NamespaceStatsProcessor struct

+ func (nw *NamespaceStatsProcessor) PassOneKeys() []string

+ func (nw *NamespaceStatsProcessor) PassTwoKeys(rawMetrics map[string]string) []string

+ func (nw *NamespaceStatsProcessor) Refresh(infoKeys []string, rawMetrics map[string]string) ([]AerospikeStat, error)

+ type NodeStatsProcessor struct

+ func (sw *NodeStatsProcessor) PassOneKeys() []string

+ func (sw *NodeStatsProcessor) PassTwoKeys(rawMetrics map[string]string) []string

+ func (sw *NodeStatsProcessor) Refresh(infoKeys []string, rawMetrics map[string]string) ([]AerospikeStat, error)

+ type SetsStatsProcessor struct

+ func (sw *SetsStatsProcessor) PassOneKeys() []string

+ func (sw *SetsStatsProcessor) PassTwoKeys(rawMetrics map[string]string) []string

+ func (sw *SetsStatsProcessor) Refresh(infoKeys []string, rawMetrics map[string]string) ([]AerospikeStat, error)

+ type SindexStatsProcessor struct

+ func (siw *SindexStatsProcessor) PassOneKeys() []string

+ func (siw *SindexStatsProcessor) PassTwoKeys(rawMetrics map[string]string) (sindexCommands []string)

+ func (siw *SindexStatsProcessor) Refresh(infoKeys []string, rawMetrics map[string]string) ([]AerospikeStat, error)

+ type StatProcessor interface

+ PassOneKeys func() []string

+ PassTwoKeys func(rawMetrics map[string]string) []string

+ Refresh func(infoKeys []string, rawMetrics map[string]string) ([]AerospikeStat, error)

+ func GetStatsProcessors() []StatProcessor

+ type UserStatsProcessor struct

+ func (uw *UserStatsProcessor) PassOneKeys() []string

+ func (uw *UserStatsProcessor) PassTwoKeys(rawMetrics map[string]string) []string

+ func (uw *UserStatsProcessor) Refresh(infoKeys []string, rawMetrics map[string]string) ([]AerospikeStat, error)

+ type XdrStatsProcessor struct

+ func (xw *XdrStatsProcessor) PassOneKeys() []string

+ func (xw *XdrStatsProcessor) PassTwoKeys(rawMetrics map[string]string) []string

+ func (xw *XdrStatsProcessor) Refresh(infoKeys []string, rawMetrics map[string]string) ([]AerospikeStat, error)