monkit

Jul 19, 2022

Changes in this version

type Span

+ func (s *Span) ParentId() (int64, bool)

Jun 29, 2021

Changes in this version

+ type CallbackTransformer interface

+ Transform func(func(SeriesKey, string, float64)) func(SeriesKey, string, float64)

+ type CallbackTransformerFunc func(func(SeriesKey, string, float64)) func(SeriesKey, string, float64)

+ func (f CallbackTransformerFunc) Transform(cb func(SeriesKey, string, float64)) func(SeriesKey, string, float64)

+ type DeltaTransformer struct

+ func NewDeltaTransformer() *DeltaTransformer

+ func (dt *DeltaTransformer) Transform(cb func(SeriesKey, string, float64)) func(SeriesKey, string, float64)

type Registry

+ func (r *Registry) WithTransformers(t ...CallbackTransformer) *Registry

type StatSource

+ func TransformStatSource(s StatSource, transformers ...CallbackTransformer) StatSource

Apr 15, 2021

Changes in this version

type SeriesKey

+ func (s SeriesKey) WithTags(tags ...SeriesTag) SeriesKey

type TagSet

+ func (t *TagSet) SetTags(tags ...SeriesTag) *TagSet

Oct 27, 2020

Changes in this version

+ type DurationVal struct

+ func NewDurationVal(key SeriesKey) (v *DurationVal)

+ func (v *DurationVal) Observe(val time.Duration)

+ func (v *DurationVal) Quantile(quantile float64) (rv time.Duration)

+ func (v *DurationVal) Stats(cb func(key SeriesKey, field string, val float64))

type Func

+ func (f *Func) RestartTrace(ctx *context.Context, args ...interface{}) func(*error)

type Scope

+ func (s *Scope) DurationVal(name string) *DurationVal

type Trace

+ func (t *Trace) GetAll() (val map[interface{}]interface{})

Apr 27, 2020

Changes in this version

+ type SeriesTag struct

+ Key string

+ Val string

+ func NewSeriesTag(key, val string) SeriesTag

Feb 26, 2020

Changes in this version

type Trace

+ func (t *Trace) Spans() int64

Feb 24, 2020

Changes in this version

+ func ResetContextSpan(ctx context.Context) context.Context

Dec 12, 2019

Changes in this version

+ const ReservoirSize

+ var Default = NewRegistry()

+ var ObservedQuantiles = []float64

+ var Window int64 = 1024

+ func AddErrorNameHandler(f func(error) (string, bool))

+ func Collect(mon StatSource) map[string]float64

+ func Funcs(cb func(f *Func))

+ func NewId() int64

+ func RootSpans(cb func(s *Span))

+ func Scopes(cb func(s *Scope))

+ func Stats(cb func(key SeriesKey, field string, val float64))

+ type Annotation struct

+ Name string

+ Value string

+ type BoolVal struct

+ func NewBoolVal(key SeriesKey) *BoolVal

+ func (v *BoolVal) Observe(val bool)

+ func (v *BoolVal) Stats(cb func(key SeriesKey, field string, val float64))

+ type Counter struct

+ func NewCounter(key SeriesKey) *Counter

+ func (c *Counter) Current() (cur int64)

+ func (c *Counter) Dec(delta int64) (current int64)

+ func (c *Counter) High() (h int64)

+ func (c *Counter) Inc(delta int64) (current int64)

+ func (c *Counter) Low() (l int64)

+ func (c *Counter) Reset() (val, low, high int64)

+ func (c *Counter) Set(val int64) (former int64)

+ func (c *Counter) Stats(cb func(key SeriesKey, field string, val float64))

+ type DiffMeter struct

+ func NewDiffMeter(key SeriesKey, meter1, meter2 *Meter) *DiffMeter

+ func (m *DiffMeter) Stats(cb func(key SeriesKey, field string, val float64))

+ type DurationDist struct

+ Count int64

+ High time.Duration

+ Low time.Duration

+ Recent time.Duration

+ Sum time.Duration

+ func NewDurationDist(key SeriesKey) (d *DurationDist)

+ func (d *DurationDist) Copy() *DurationDist

+ func (d *DurationDist) FullAverage() time.Duration

+ func (d *DurationDist) Insert(val time.Duration)

+ func (d *DurationDist) Query(quantile float64) time.Duration

+ func (d *DurationDist) ReservoirAverage() time.Duration

+ func (d *DurationDist) Reset()

+ func (d *DurationDist) Stats(cb func(key SeriesKey, field string, val float64))

+ type FloatDist struct

+ Count int64

+ High float64

+ Low float64

+ Recent float64

+ Sum float64

+ func NewFloatDist(key SeriesKey) (d *FloatDist)

+ func (d *FloatDist) Copy() *FloatDist

+ func (d *FloatDist) FullAverage() float64

+ func (d *FloatDist) Insert(val float64)

+ func (d *FloatDist) Query(quantile float64) float64

+ func (d *FloatDist) ReservoirAverage() float64

+ func (d *FloatDist) Reset()

+ func (d *FloatDist) Stats(cb func(key SeriesKey, field string, val float64))

+ type FloatVal struct

+ func NewFloatVal(key SeriesKey) (v *FloatVal)

+ func (v *FloatVal) Observe(val float64)

+ func (v *FloatVal) Quantile(quantile float64) (rv float64)

+ func (v *FloatVal) Stats(cb func(key SeriesKey, field string, val float64))

+ type Func struct

+ func (f *Func) FullName() string

+ func (f *Func) Id() int64

+ func (f *Func) Parents(cb func(f *Func))

+ func (f *Func) RemoteTrace(ctx *context.Context, spanId int64, trace *Trace, args ...interface{}) func(*error)

+ func (f *Func) ResetTrace(ctx *context.Context, args ...interface{}) func(*error)

+ func (f *Func) Scope() *Scope

+ func (f *Func) ShortName() string

+ func (f *Func) Task(ctx *context.Context, args ...interface{}) func(*error)

+ type FuncStats struct

+ func NewFuncStats(key SeriesKey) (f *FuncStats)

+ func (f *FuncStats) Current() int64

+ func (f *FuncStats) Errors() (rv map[string]int64)

+ func (f *FuncStats) FailureTimes() *DurationDist

+ func (f *FuncStats) Highwater() int64

+ func (f *FuncStats) Observe() func(errptr *error)

+ func (f *FuncStats) Panics() (rv int64)

+ func (f *FuncStats) Reset()

+ func (f *FuncStats) Stats(cb func(key SeriesKey, field string, val float64))

+ func (f *FuncStats) Success() (rv int64)

+ func (f *FuncStats) SuccessTimes() *DurationDist

+ type IntDist struct

+ Count int64

+ High int64

+ Low int64

+ Recent int64

+ Sum int64

+ func NewIntDist(key SeriesKey) (d *IntDist)

+ func (d *IntDist) Copy() *IntDist

+ func (d *IntDist) FullAverage() int64

+ func (d *IntDist) Insert(val int64)

+ func (d *IntDist) Query(quantile float64) int64

+ func (d *IntDist) ReservoirAverage() int64

+ func (d *IntDist) Reset()

+ func (d *IntDist) Stats(cb func(key SeriesKey, field string, val float64))

+ type IntVal struct

+ func NewIntVal(key SeriesKey) (v *IntVal)

+ func (v *IntVal) Observe(val int64)

+ func (v *IntVal) Quantile(quantile float64) (rv int64)

+ func (v *IntVal) Stats(cb func(key SeriesKey, field string, val float64))

+ type Meter struct

+ func NewMeter(key SeriesKey) *Meter

+ func (e *Meter) Mark(amount int)

+ func (e *Meter) Mark64(amount int64)

+ func (e *Meter) Rate() float64

+ func (e *Meter) Reset(new_total int64)

+ func (e *Meter) SetTotal(total int64)

+ func (e *Meter) Stats(cb func(key SeriesKey, field string, val float64))

+ func (e *Meter) Total() float64

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) AllSpans(cb func(s *Span))

+ func (r *Registry) Funcs(cb func(f *Func))

+ func (r *Registry) ObserveTraces(cb func(*Trace)) (cancel func())

+ func (r *Registry) Package() *Scope

+ func (r *Registry) RootSpans(cb func(s *Span))

+ func (r *Registry) ScopeNamed(name string) *Scope

+ func (r *Registry) Scopes(cb func(s *Scope))

+ func (r *Registry) Stats(cb func(key SeriesKey, field string, val float64))

+ type RunningTimer struct

+ func (r *RunningTimer) Elapsed() time.Duration

+ func (r *RunningTimer) Stop() time.Duration

+ type Scope struct

+ func Package() *Scope

+ func ScopeNamed(name string) *Scope

+ func (s *Scope) BoolVal(name string) *BoolVal

+ func (s *Scope) BoolValf(template string, args ...interface{}) *BoolVal

+ func (s *Scope) Chain(source StatSource)

+ func (s *Scope) Counter(name string) *Counter

+ func (s *Scope) DiffMeter(name string, m1, m2 *Meter)

+ func (s *Scope) Event(name string)

+ func (s *Scope) FloatVal(name string) *FloatVal

+ func (s *Scope) FloatValf(template string, args ...interface{}) *FloatVal

+ func (s *Scope) Func() *Func

+ func (s *Scope) FuncNamed(name string) *Func

+ func (s *Scope) Funcs(cb func(f *Func))

+ func (s *Scope) Gauge(name string, cb func() float64)

+ func (s *Scope) IntVal(name string) *IntVal

+ func (s *Scope) IntValf(template string, args ...interface{}) *IntVal

+ func (s *Scope) Meter(name string) *Meter

+ func (s *Scope) Name() string

+ func (s *Scope) Stats(cb func(key SeriesKey, field string, val float64))

+ func (s *Scope) StructVal(name string) *StructVal

+ func (s *Scope) Task() Task

+ func (s *Scope) TaskNamed(name string) Task

+ func (s *Scope) Timer(name string) *Timer

+ type SeriesKey struct

+ Measurement string

+ Tags *TagSet

+ func NewSeriesKey(measurement string) SeriesKey

+ func (s SeriesKey) String() string

+ func (s SeriesKey) WithField(field string) string

+ func (s SeriesKey) WithTag(key, value string) SeriesKey

+ type Span struct

+ func SpanFromCtx(ctx context.Context) *Span

+ func (s *Span) Annotate(name, val string)

+ func (s *Span) Annotations() []Annotation

+ func (s *Span) Args() (rv []string)

+ func (s *Span) Children(cb func(s *Span))

+ func (s *Span) Duration() time.Duration

+ func (s *Span) Func() *Func

+ func (s *Span) Id() int64

+ func (s *Span) Orphaned() (rv bool)

+ func (s *Span) Parent() *Span

+ func (s *Span) Start() time.Time

+ func (s *Span) String() string

+ func (s *Span) Trace() *Trace

+ func (s *Span) Value(key interface{}) interface{}

+ type SpanCtxObserver interface

+ Finish func(ctx context.Context, s *Span, err error, panicked bool, finish time.Time)

+ Start func(ctx context.Context, s *Span) context.Context

+ type SpanObserver interface

+ Finish func(s *Span, err error, panicked bool, finish time.Time)

+ Start func(s *Span)

+ type StatSource interface

+ Stats func(cb func(key SeriesKey, field string, val float64))

+ func StatSourceFromStruct(key SeriesKey, structData interface{}) StatSource

+ type StatSourceFunc func(cb func(key SeriesKey, field string, val float64))

+ func (f StatSourceFunc) Stats(cb func(key SeriesKey, field string, val float64))

+ type StructVal struct

+ func NewStructVal(key SeriesKey) *StructVal

+ func (v *StructVal) Observe(val interface{})

+ func (v *StructVal) Stats(cb func(key SeriesKey, field string, val float64))

+ type TagSet struct

+ func (t *TagSet) All() map[string]string

+ func (t *TagSet) Get(key string) string

+ func (t *TagSet) Len() int

+ func (t *TagSet) Set(key, value string) *TagSet

+ func (t *TagSet) SetAll(kvs map[string]string) *TagSet

+ func (t *TagSet) String() string

+ type Task func(ctx *context.Context, args ...interface{}) func(*error)

+ func (f Task) Func() (out *Func)

+ type Timer struct

+ func NewTimer(key SeriesKey) *Timer

+ func (t *Timer) Start() *RunningTimer

+ func (t *Timer) Stats(cb func(key SeriesKey, field string, val float64))

+ func (t *Timer) Values() *DurationDist

+ type Trace struct

+ func NewTrace(id int64) *Trace

+ func (t *Trace) Get(key interface{}) (val interface{})

+ func (t *Trace) Id() int64

+ func (t *Trace) ObserveSpans(observer SpanObserver) (cancel func())

+ func (t *Trace) ObserveSpansCtx(observer SpanCtxObserver) (cancel func())

+ func (t *Trace) Set(key, val interface{})