metrics

package

Go to main page

Versions in this module

v0

v0.50.0

Mar 25, 2024

v0.49.0

Jan 29, 2024

v0.48.0

Dec 6, 2023

v0.47.0

Oct 10, 2023

v0.46.0

Aug 14, 2023

Changes in this version

type TrendSink

+ func NewTrendSink() *TrendSink

+ func (t *TrendSink) Total() float64

v0.45.1

Aug 4, 2023

v0.45.0

Jun 19, 2023

Changes in this version

type Registry

+ func (r *Registry) All() []*Metric

type Sink

+ func NewSink(mt MetricType) Sink

v0.44.1

May 8, 2023

v0.44.0

Apr 24, 2023

v0.43.1

Feb 27, 2023

v0.43.0

Feb 20, 2023

v0.42.0

Dec 20, 2022

v0.41.0

Nov 2, 2022

Changes in this version

+ var NonIndexableSystemTags = SystemTagSet(TagIter | TagVU)

type Registry

+ func (r *Registry) RootTagSet() *TagSet

type Sample

+ Metadata map[string]string

+ type SystemTag uint32

+ func SystemTagString(s string) (SystemTag, error)

+ func SystemTagValues() []SystemTag

+ func (i SystemTag) IsASystemTag() bool

+ func (i SystemTag) String() string

type TagSet

+ func (ts *TagSet) Contains(other *TagSet) bool

+ func (ts *TagSet) Get(name string) (string, bool)

+ func (ts *TagSet) IsEmpty() bool

+ func (ts *TagSet) Map() map[string]string

+ func (ts *TagSet) MarshalEasyJSON(w *jwriter.Writer)

+ func (ts *TagSet) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (ts *TagSet) With(name, value string) *TagSet

+ func (ts *TagSet) WithTagsFromMap(m map[string]string) *TagSet

+ func (ts *TagSet) Without(name string) *TagSet

+ type TagsAndMeta struct

+ Metadata map[string]string

+ Tags *TagSet

+ func (tm *TagsAndMeta) DeleteMetadata(key string)

+ func (tm *TagsAndMeta) DeleteTag(key string)

+ func (tm *TagsAndMeta) SetMetadata(key, value string)

+ func (tm *TagsAndMeta) SetSystemTagOrMeta(tag SystemTag, value string)

+ func (tm *TagsAndMeta) SetSystemTagOrMetaIfEnabled(enabledSystemTags *SystemTagSet, tag SystemTag, value string)

+ func (tm *TagsAndMeta) SetTag(key, value string)

+ func (tm TagsAndMeta) Clone() TagsAndMeta

+ type TimeSeries struct

+ Metric *Metric

+ Tags *TagSet

v0.40.0

Sep 8, 2022

Changes in this version

+ type EnabledTags map[string]bool

+ func (i *EnabledTags) MarshalJSON() ([]byte, error)

+ func (i *EnabledTags) UnmarshalJSON(data []byte) error

+ func (i *EnabledTags) UnmarshalText(data []byte) error

v0.39.0

Jul 5, 2022

v0.38.3

May 17, 2022

v0.38.2

May 11, 2022

Changes in this version

type CounterSink

+ func (c *CounterSink) IsEmpty() bool

type DummySink

+ func (d DummySink) IsEmpty() bool

type GaugeSink

+ func (g *GaugeSink) IsEmpty() bool

type RateSink

+ func (r *RateSink) IsEmpty() bool

type Sink

+ IsEmpty func() bool

type TrendSink

+ func (t *TrendSink) IsEmpty() bool

v0.38.1

May 5, 2022

v0.38.0

May 4, 2022

Changes in this version

+ const ChecksName

+ const Counter

+ const Data

+ const DataReceivedName

+ const DataSentName

+ const Default

+ const DroppedIterationsName

+ const GRPCReqDurationName

+ const Gauge

+ const GroupDurationName

+ const HTTPReqBlockedName

+ const HTTPReqConnectingName

+ const HTTPReqDurationName

+ const HTTPReqFailedName

+ const HTTPReqReceivingName

+ const HTTPReqSendingName

+ const HTTPReqTLSHandshakingName

+ const HTTPReqWaitingName

+ const HTTPReqsName

+ const IterationDurationName

+ const IterationsName

+ const Rate

+ const Time

+ const Trend

+ const VUsMaxName

+ const VUsName

+ const WSConnectingName

+ const WSMessagesReceivedName

+ const WSMessagesSentName

+ const WSPingName

+ const WSSessionDurationName

+ const WSSessionsName

+ var DefaultSystemTagSet = ...

+ var ErrInvalidMetricType = errors.New("invalid metric type")

+ var ErrInvalidThreshold = errors.New("invalid threshold")

+ var ErrInvalidValueType = errors.New("invalid value type")

+ var ErrMetricNameParsing = errors.New("parsing metric name failed")

+ func B(b bool) float64

+ func D(d time.Duration) float64

+ func GetResolversForTrendColumns(trendColumns []string) (map[string]func(s *TrendSink) float64, error)

+ func MarshalJSONWithoutHTMLEscape(t interface{}) ([]byte, error)

+ func ParseMetricName(name string) (string, []string, error)

+ func PushIfNotDone(ctx context.Context, output chan<- SampleContainer, sample SampleContainer) bool

+ func ToD(d float64) time.Duration

+ type BuiltinMetrics struct

+ Checks *Metric

+ DataReceived *Metric

+ DataSent *Metric

+ DroppedIterations *Metric

+ GRPCReqDuration *Metric

+ GroupDuration *Metric

+ HTTPReqBlocked *Metric

+ HTTPReqConnecting *Metric

+ HTTPReqDuration *Metric

+ HTTPReqFailed *Metric

+ HTTPReqReceiving *Metric

+ HTTPReqSending *Metric

+ HTTPReqTLSHandshaking *Metric

+ HTTPReqWaiting *Metric

+ HTTPReqs *Metric

+ IterationDuration *Metric

+ Iterations *Metric

+ VUs *Metric

+ VUsMax *Metric

+ WSConnecting *Metric

+ WSMessagesReceived *Metric

+ WSMessagesSent *Metric

+ WSPing *Metric

+ WSSessionDuration *Metric

+ WSSessions *Metric

+ func RegisterBuiltinMetrics(registry *Registry) *BuiltinMetrics

+ type ConnectedSampleContainer interface

+ GetTags func() *SampleTags

+ GetTime func() time.Time

+ type ConnectedSamples struct

+ Samples []Sample

+ Tags *SampleTags

+ Time time.Time

+ func (cs ConnectedSamples) GetSamples() []Sample

+ func (cs ConnectedSamples) GetTags() *SampleTags

+ func (cs ConnectedSamples) GetTime() time.Time

+ type CounterSink struct

+ First time.Time

+ Value float64

+ func (c *CounterSink) Add(s Sample)

+ func (c *CounterSink) Calc()

+ func (c *CounterSink) Format(t time.Duration) map[string]float64

+ type DummySink map[string]float64

+ func (d DummySink) Add(s Sample)

+ func (d DummySink) Calc()

+ func (d DummySink) Format(t time.Duration) map[string]float64

+ type GaugeSink struct

+ Max float64

+ Min float64

+ Value float64

+ func (g *GaugeSink) Add(s Sample)

+ func (g *GaugeSink) Calc()

+ func (g *GaugeSink) Format(t time.Duration) map[string]float64

+ type Metric struct

+ Contains ValueType

+ Name string

+ Observed bool

+ Sink Sink

+ Sub *Submetric

+ Submetrics []*Submetric

+ Tainted null.Bool

+ Thresholds Thresholds

+ Type MetricType

+ func (m *Metric) AddSubmetric(keyValues string) (*Submetric, error)

+ func (m *Metric) Sample(t time.Time, tags *SampleTags, value float64) Sample

+ type MetricType int

+ func (t *MetricType) UnmarshalText(data []byte) error

+ func (t MetricType) MarshalJSON() ([]byte, error)

+ func (t MetricType) MarshalText() ([]byte, error)

+ func (t MetricType) String() string

+ type RateSink struct

+ Total int64

+ Trues int64

+ func (r *RateSink) Add(s Sample)

+ func (r RateSink) Calc()

+ func (r RateSink) Format(t time.Duration) map[string]float64

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Get(name string) *Metric

+ func (r *Registry) MustNewMetric(name string, typ MetricType, t ...ValueType) *Metric

+ func (r *Registry) NewMetric(name string, typ MetricType, t ...ValueType) (*Metric, error)

+ type Sample struct

+ Metric *Metric

+ Tags *SampleTags

+ Time time.Time

+ Value float64

+ func (s Sample) GetSamples() []Sample

+ func (s Sample) GetTags() *SampleTags

+ func (s Sample) GetTime() time.Time

+ type SampleContainer interface

+ GetSamples func() []Sample

+ func GetBufferedSamples(input <-chan SampleContainer) (result []SampleContainer)

+ type SampleTags struct

+ func IntoSampleTags(data *map[string]string) *SampleTags

+ func NewSampleTags(data map[string]string) *SampleTags

+ func (st *SampleTags) CloneTags() map[string]string

+ func (st *SampleTags) Contains(other *SampleTags) bool

+ func (st *SampleTags) Get(key string) (string, bool)

+ func (st *SampleTags) IsEmpty() bool

+ func (st *SampleTags) IsEqual(other *SampleTags) bool

+ func (st *SampleTags) MarshalEasyJSON(w *jwriter.Writer)

+ func (st *SampleTags) MarshalJSON() ([]byte, error)

+ func (st *SampleTags) UnmarshalJSON(data []byte) error

+ type Samples []Sample

+ func (s Samples) GetSamples() []Sample

+ type Sink interface

+ Add func(s Sample)

+ Calc func()

+ Format func(t time.Duration) map[string]float64

+ type Submetric struct

+ Metric *Metric

+ Name string

+ Parent *Metric

+ Suffix string

+ Tags *SampleTags

+ type SystemTagSet uint32

+ const TagCheck

+ const TagError

+ const TagErrorCode

+ const TagExpectedResponse

+ const TagGroup

+ const TagIP

+ const TagIter

+ const TagMethod

+ const TagName

+ const TagOCSPStatus

+ const TagProto

+ const TagScenario

+ const TagService

+ const TagStatus

+ const TagSubproto

+ const TagTLSVersion

+ const TagURL

+ const TagVU

+ func NewSystemTagSet(tags ...SystemTagSet) *SystemTagSet

+ func SystemTagSetString(s string) (SystemTagSet, error)

+ func SystemTagSetValues() []SystemTagSet

+ func ToSystemTagSet(tags []string) *SystemTagSet

+ func (i *SystemTagSet) Add(tag SystemTagSet)

+ func (i *SystemTagSet) Has(tag SystemTagSet) bool

+ func (i *SystemTagSet) MarshalJSON() ([]byte, error)

+ func (i *SystemTagSet) UnmarshalJSON(data []byte) error

+ func (i *SystemTagSet) UnmarshalText(data []byte) error

+ func (i SystemTagSet) IsASystemTagSet() bool

+ func (i SystemTagSet) Map() TagSet

+ func (i SystemTagSet) SetString() string

+ func (i SystemTagSet) String() string

+ type TagSet map[string]bool

+ func (i *TagSet) MarshalJSON() ([]byte, error)

+ func (i *TagSet) UnmarshalJSON(data []byte) error

+ func (i *TagSet) UnmarshalText(data []byte) error

+ type Threshold struct

+ AbortGracePeriod types.NullDuration

+ AbortOnFail bool

+ LastFailed bool

+ Source string

+ type Thresholds struct

+ Abort bool

+ Thresholds []*Threshold

+ func NewThresholds(sources []string) Thresholds

+ func (ts *Thresholds) Parse() error

+ func (ts *Thresholds) Run(sink Sink, duration time.Duration) (bool, error)

+ func (ts *Thresholds) UnmarshalJSON(data []byte) error

+ func (ts *Thresholds) Validate(metricName string, r *Registry) error

+ func (ts Thresholds) MarshalJSON() ([]byte, error)

+ type TrendSink struct

+ Avg float64

+ Count uint64

+ Max float64

+ Med float64

+ Min float64

+ Sum float64

+ Values []float64

+ func (t *TrendSink) Add(s Sample)

+ func (t *TrendSink) Calc()

+ func (t *TrendSink) Format(tt time.Duration) map[string]float64

+ func (t *TrendSink) P(pct float64) float64

+ type ValueType int

+ func (t *ValueType) UnmarshalText(data []byte) error

+ func (t ValueType) MarshalJSON() ([]byte, error)

+ func (t ValueType) MarshalText() ([]byte, error)

+ func (t ValueType) String() string

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