spectator-go

Feb 16, 2024

Changes in this version

type Registry

+ func (r *Registry) Count() int

Nov 13, 2023

Changes in this version

type HttpClient

+ Client *http.Client

type HttpClientOption

+ func WithCompressThreshold(threshold int) HttpClientOption

Aug 12, 2021

Changes in this version

+ type HttpClientOption func(client *http.Client)

type HttpResponse

+ Body []byte

+ Status int

Mar 3, 2021

Changes in this version

type Config

+ PublishWorkers int64

+ type HttpResponse struct

Jan 28, 2020

Changes in this version

type Id

+ func (id *Id) MapKey() string

Dec 20, 2019

Changes in this version

+ func CollectMemStats(registry *Registry)

+ func CollectRuntimeMetrics(registry *Registry)

+ func CollectSysStats(registry *Registry)

+ type Clock interface

+ Nanos func() int64

+ Now func() time.Time

+ type Config struct

+ BatchSize int

+ CommonTags map[string]string

+ Frequency time.Duration

+ IpcTimerRecord func(registry *Registry, id *Id, duration time.Duration)

+ IsEnabled func() bool

+ Log Logger

+ Timeout time.Duration

+ Uri string

+ type Counter struct

+ func NewCounter(id *Id) *Counter

+ func (c *Counter) Add(delta int64)

+ func (c *Counter) AddFloat(delta float64)

+ func (c *Counter) Count() float64

+ func (c *Counter) Increment()

+ func (c *Counter) Measure() []Measurement

+ func (c *Counter) MeterId() *Id

+ type DefaultLogger struct

+ func (l *DefaultLogger) Debugf(format string, v ...interface{})

+ func (l *DefaultLogger) Errorf(format string, v ...interface{})

+ func (l *DefaultLogger) Infof(format string, v ...interface{})

+ type DistributionSummary struct

+ func NewDistributionSummary(id *Id) *DistributionSummary

+ func (d *DistributionSummary) Count() int64

+ func (d *DistributionSummary) Measure() []Measurement

+ func (d *DistributionSummary) MeterId() *Id

+ func (d *DistributionSummary) Record(amount int64)

+ func (d *DistributionSummary) TotalAmount() int64

+ type Gauge struct

+ func NewGauge(id *Id) *Gauge

+ func (g *Gauge) Get() float64

+ func (g *Gauge) Measure() []Measurement

+ func (g *Gauge) MeterId() *Id

+ func (g *Gauge) Set(value float64)

+ type HttpClient struct

+ func NewHttpClient(registry *Registry, timeout time.Duration) *HttpClient

+ func (h *HttpClient) PostJson(uri string, jsonBytes []byte) (statusCode int, err error)

+ type Id struct

+ func NewId(name string, tags map[string]string) *Id

+ func (id *Id) Name() string

+ func (id *Id) String() string

+ func (id *Id) Tags() map[string]string

+ func (id *Id) WithDefaultStat(stat string) *Id

+ func (id *Id) WithStat(stat string) *Id

+ func (id *Id) WithTag(key string, value string) *Id

+ func (id *Id) WithTags(tags map[string]string) *Id

+ type LogEntry struct

+ func NewLogEntry(registry *Registry, method string, url string) *LogEntry

+ func (entry *LogEntry) Log()

+ func (entry *LogEntry) SetAttempt(attemptNumber int, final bool)

+ func (entry *LogEntry) SetError(err string)

+ func (entry *LogEntry) SetStatusCode(code int)

+ func (entry *LogEntry) SetSuccess()

+ type Logger interface

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

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

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

+ type ManualClock struct

+ func (c *ManualClock) Nanos() int64

+ func (c *ManualClock) Now() time.Time

+ func (c *ManualClock) SetFromDuration(duration time.Duration)

+ func (c *ManualClock) SetNanos(nanos int64)

+ type Measurement struct

+ func NewMeasurement(id *Id, Value float64) Measurement

+ func (m Measurement) Id() *Id

+ func (m Measurement) String() string

+ func (m Measurement) Value() float64

+ type Meter interface

+ Measure func() []Measurement

+ MeterId func() *Id

+ type MeterFactoryFun func() Meter

+ type MonotonicCounter struct

+ func NewMonotonicCounter(registry *Registry, name string, tags map[string]string) *MonotonicCounter

+ func NewMonotonicCounterWithId(registry *Registry, id *Id) *MonotonicCounter

+ func (c *MonotonicCounter) Count() int64

+ func (c *MonotonicCounter) Set(amount int64)

+ type Registry struct

+ func NewRegistry(config *Config) *Registry

+ func NewRegistryConfiguredBy(filePath string) (*Registry, error)

+ func NewRegistryWithClock(config *Config, clock Clock) *Registry

+ func (r *Registry) Clock() Clock

+ func (r *Registry) Counter(name string, tags map[string]string) *Counter

+ func (r *Registry) CounterWithId(id *Id) *Counter

+ func (r *Registry) DistributionSummary(name string, tags map[string]string) *DistributionSummary

+ func (r *Registry) DistributionSummaryWithId(id *Id) *DistributionSummary

+ func (r *Registry) Gauge(name string, tags map[string]string) *Gauge

+ func (r *Registry) GaugeWithId(id *Id) *Gauge

+ func (r *Registry) GetLogger() Logger

+ func (r *Registry) Measurements() []Measurement

+ func (r *Registry) Meters() []Meter

+ func (r *Registry) NewId(name string, tags map[string]string) *Id

+ func (r *Registry) NewMeter(id *Id, meterFactory MeterFactoryFun) Meter

+ func (r *Registry) SetLogger(logger Logger)

+ func (r *Registry) Start() error

+ func (r *Registry) Stop()

+ func (r *Registry) Timer(name string, tags map[string]string) *Timer

+ func (r *Registry) TimerWithId(id *Id) *Timer

+ type SystemClock struct

+ func (c *SystemClock) Nanos() int64

+ func (c *SystemClock) Now() time.Time

+ type Timer struct

+ func NewTimer(id *Id) *Timer

+ func (t *Timer) Count() int64

+ func (t *Timer) Measure() []Measurement

+ func (t *Timer) MeterId() *Id

+ func (t *Timer) Record(amount time.Duration)

+ func (t *Timer) TotalTime() time.Duration