trapmetrics

Mar 28, 2023

Changes in this version

type Result

+ BytesSentGzip int

Aug 22, 2022

Changes in this version

type Config

+ TrapID string

type Trap

+ UpdateCheckTags func(ctx context.Context, tags []string) (*apiclient.CheckBundle, error)

type TrapMetrics

+ func (tm *TrapMetrics) QueueCheckTag(key, val string)

+ func (tm *TrapMetrics) TrapID() string

+ func (tm *TrapMetrics) UpdateCheckTags(ctx context.Context) (*apiclient.CheckBundle, error)

May 23, 2022

Changes in this version

type Config

+ NonPrintCharReplace string

Sep 8, 2021

Changes in this version

type TrapMetrics

+ func (tm *TrapMetrics) FlushRawJSON(ctx context.Context, data []byte) (*Result, error)

+ func (tm *TrapMetrics) FlushWithBuffer(ctx context.Context, buf bytes.Buffer) (*Result, error)

+ func (tm *TrapMetrics) WriteJSONMetrics(w io.Writer) error

Jun 7, 2021

Changes in this version

+ type Config struct

+ BufferSize uint

+ GlobalTags Tags

+ Logger Logger

+ Trap Trap

+ type LogWrapper struct

+ Debug bool

+ Log *log.Logger

+ func (lw *LogWrapper) Debugf(fmt string, v ...interface{})

+ func (lw *LogWrapper) Errorf(fmt string, v ...interface{})

+ func (lw *LogWrapper) Infof(fmt string, v ...interface{})

+ func (lw *LogWrapper) Printf(fmt string, v ...interface{})

+ func (lw *LogWrapper) Warnf(fmt string, v ...interface{})

+ type Logger interface

+ Debugf func(fmt string, v ...interface{})

+ Errorf func(fmt string, v ...interface{})

+ Infof func(fmt string, v ...interface{})

+ Printf func(fmt string, v ...interface{})

+ Warnf func(fmt string, v ...interface{})

+ type Metric struct

+ ID uint64

+ Mtype string

+ Name string

+ Rtype string

+ Samples Samples

+ Tags Tags

+ func (m *Metric) String() string

+ type Metrics map[uint64]*Metric

+ type Result struct

+ BytesSent int

+ CheckUUID string

+ EncodeDuration time.Duration

+ Error string

+ Filtered uint64

+ FlushDuration time.Duration

+ LastReqDuration time.Duration

+ Stats uint64

+ SubmitDuration time.Duration

+ SubmitUUID string

+ type Samples map[uint64]interface

+ type Tag struct

+ Category string

+ Value string

+ func (t *Tag) Encode() string

+ func (t *Tag) String() string

+ type Tags []Tag

+ func (tt *Tags) Encode() string

+ func (tt *Tags) Stream() string

+ func (tt *Tags) String() string

+ type Trap interface

+ SendMetrics func(ctx context.Context, metrics *strings.Builder) (*trapcheck.TrapResult, error)

+ type TrapMetrics struct

+ Log Logger

+ func New(cfg *Config) (*TrapMetrics, error)

+ func (tm *TrapMetrics) CounterAdjustByValue(name string, tags Tags, val int64) error

+ func (tm *TrapMetrics) CounterFetch(name string, tags Tags) (*Metric, error)

+ func (tm *TrapMetrics) CounterIncrement(name string, tags Tags) error

+ func (tm *TrapMetrics) CounterIncrementByValue(name string, tags Tags, val uint64) error

+ func (tm *TrapMetrics) CumulativeHistogramFetch(name string, tags Tags) (*Metric, error)

+ func (tm *TrapMetrics) CumulativeHistogramRecordCountForValue(name string, tags Tags, count int64, val float64) error

+ func (tm *TrapMetrics) Flush(ctx context.Context) (*Result, error)

+ func (tm *TrapMetrics) GaugeAdd(name string, tags Tags, val interface{}, ts *time.Time) error

+ func (tm *TrapMetrics) GaugeFetch(name string, tags Tags) (*Metric, error)

+ func (tm *TrapMetrics) GaugeSet(name string, tags Tags, val interface{}, ts *time.Time) error

+ func (tm *TrapMetrics) HistogramFetch(name string, tags Tags) (*Metric, error)

+ func (tm *TrapMetrics) HistogramRecordCountForValue(name string, tags Tags, count int64, val float64) error

+ func (tm *TrapMetrics) HistogramRecordDuration(name string, tags Tags, val time.Duration) error

+ func (tm *TrapMetrics) HistogramRecordTiming(name string, tags Tags, val float64) error

+ func (tm *TrapMetrics) HistogramRecordValue(name string, tags Tags, val float64) error

+ func (tm *TrapMetrics) JSONMetrics() ([]byte, error)

+ func (tm *TrapMetrics) TextFetch(name string, tags Tags) (*Metric, error)

+ func (tm *TrapMetrics) TextSet(name string, tags Tags, val string, ts *time.Time) error