meter

Oct 22, 2018

Changes in this version

type Snapshot

+ func (s Snapshot) FilterZero() Snapshot

Oct 18, 2018

Changes in this version

+ const DefaultSeparator

+ type Client struct

+ URL string

+ func (c *Client) Batch(logger *log.Logger, events ...*Event)

+ func (c *Client) Run(ctx context.Context, interval time.Duration, logger *log.Logger, ...)

+ func (c *Client) Sync(e *Event) error

type Controller

+ FlushInterval time.Duration

+ Logger Logger

+ func (c *Controller) Close()

+ func (c *Controller) Flush(t time.Time)

type Counter

+ func (c *Counter) Match(values []string) bool

type DB

+ KeySeparator byte

+ func (db *DB) Batch(tm time.Time, events ...*Event) (err []error)

type Event

+ func (e *Event) Add(n int64, values ...string) int64

+ func (e *Event) AddVolatile(n int64, values ...string) int64

+ func (e *Event) Describe() *Desc

+ func (e *Event) Flush(s Snapshot) Snapshot

+ func (e *Event) Len() (n int)

+ func (e *Event) Merge(s Snapshot)

+ func (e *Event) Pack()

type Logger

+ Printf func(format string, args ...interface{})

type MetricType

+ func (t MetricType) RedisCmd() string

type Result

+ func (r *Result) Match(values map[string]string) bool

+ type Snapshot []Counter

Nov 16, 2017

Changes in this version

type Registry

+ func NewRegistryEvents(events ...Event) *Registry

Nov 10, 2017

Changes in this version

+ const DefaultScanSize

type DB

+ ScanSize int64

Oct 31, 2017

Changes in this version

type Controller

+ Events Resolver

type QueryBuilder

+ func (q QueryBuilder) Scan() QueryBuilder

+ func (q QueryBuilder) Values() QueryBuilder

+ type Resolver interface

+ Get func(eventName string) Event

+ type ResolverFunc func(eventName string) Event

+ func (rf ResolverFunc) Get(eventName string) Event

Oct 24, 2017

Changes in this version

+ func Field(labels, values []string) (f string)

Oct 24, 2017

Changes in this version

type Collector

+ Len func() int

Oct 24, 2017

Changes in this version

+ func MatchField(labels []string, group []string, q map[string]string) (f string)

type Controller

+ Q Queryer

type QueryMode

+ const ModeExact

+ const ModeScan

+ const ModeValues

+ type Queryer interface

+ Query func(m QueryMode, queries ...Query) (Results, error)

type Results

+ func (s Results) FrequencyMap() FrequencyMap

+ type ScanQuery struct

+ End time.Time

+ Event *Desc

+ Group []string

+ Mode QueryMode

+ Resolution Resolution

+ Start time.Time

+ Values []LabelValues

+ func (q ScanQuery) Error() error

type ScanResult

+ Event string

+ func (r ScanResult) AppendTo(results Results) Results

Oct 18, 2017

Changes in this version

+ func CollectResults(scan <-chan ScanResult) <-chan Results

type LabelValues

+ func FieldLabels(field []string) LabelValues

Oct 17, 2017

Changes in this version

+ const DefaultKeyPrefix

+ const FieldTerminator

+ const NilByte

+ const QueryParamEnd

+ const QueryParamEvent

+ const QueryParamGroup

+ const QueryParamMode

+ const QueryParamResolution

+ const QueryParamStart

+ var ErrDuplicateEvent = errors.New("Duplicate event registration.")

+ var ErrInvalidEventLabel = errors.New("Invalid event label")

+ var ErrInvalidGroupLabel = errors.New("Invalid group label")

+ var ErrInvalidResolution = errors.New("Invalid event resolution")

+ var ErrNilDesc = errors.New("Desc is nil")

+ var ErrNilEvent = errors.New("Event is nil")

+ var ErrNilRegistry = errors.New("Registry is nil")

+ var ErrUnregisteredEvent = errors.New("Unregistered event")

+ func AppendField(data []byte, labels, values []string) []byte

+ func AppendMatch(data []byte, s string) []byte

+ func AppendMatchField(data []byte, labels []string, group []string, q map[string]string) []byte

+ func QueryPermutations(input url.Values) []map[string]string

+ type Collector interface

+ Collect func(chan<- Metric)

type Controller

+ Registry *Registry

+ TimeDecoder tcodec.TimeDecoder

type Counter

+ Add func(n int64) int64

+ Count func() int64

+ Values func() []string

type Counters

+ func (cc *Counters) MergeInto(e Event)

+ func (cc *Counters) Reset()

+ func (cs *Counters) WithLabelValues(values ...string) (c Counter)

type DB

+ KeyPrefix string

+ func (db *DB) ExactQuery(results chan<- ScanResult, q Query) error

+ func (db *DB) Gather(col Collector, tm time.Time) (pipelineSize int64, err error)

+ func (db *DB) Query(queries ...Query) (Results, error)

+ func (db *DB) Scan(key, match string, group []string, r ScanResult, results chan<- ScanResult) (err error)

+ func (db *DB) ScanQuery(results chan<- ScanResult, q Query) (err error)

+ func (db *DB) ValueScan(event Descriptor, res Resolution, start, end time.Time) FrequencyMap

+ func (db DB) AppendKey(data []byte, r Resolution, event string, t time.Time) []byte

+ func (db DB) Key(r Resolution, event string, t time.Time) (k string)

type DataPoint

+ func (p *DataPoint) UnmarshalJSON(data []byte) (err error)

+ type DataPoints []DataPoint

+ func (data DataPoints) Find(tm time.Time) (int64, bool)

+ func (data DataPoints) IndexOf(tm time.Time) int

+ func (s DataPoints) Len() int

+ func (s DataPoints) Less(i, j int) bool

+ func (s DataPoints) MarshalJSON() (data []byte, err error)

+ func (s DataPoints) Sort()

+ func (s DataPoints) Swap(i, j int)

+ type Desc struct

+ func NewCounterDesc(name string, labels []string, res ...Resolution) *Desc

+ func NewDesc(t MetricType, name string, labels []string, res ...Resolution) *Desc

+ func NewValueDesc(name string, labels []string, res ...Resolution) *Desc

+ func (d *Desc) Describe() *Desc

+ func (d *Desc) Error() error

+ func (d *Desc) HasLabel(label string) bool

+ func (d *Desc) LabelIndex(label string) int

+ func (d *Desc) LabelValues(values []string) LabelValues

+ func (d *Desc) Labels() []string

+ func (d *Desc) Name() string

+ func (d *Desc) Resolution(name string) (r Resolution, ok bool)

+ func (d *Desc) Resolutions() []Resolution

+ func (d *Desc) Type() MetricType

+ func (e *Desc) MatchingQueries(q url.Values) url.Values

+ type Descriptor interface

+ Describe func() *Desc

type Event

+ WithLabelValues func(values ...string) Counter

+ WithLabels func(labels LabelValues) Counter

+ type EventSampler struct

+ func (s *EventSampler) Describe() *Desc

+ func (s *EventSampler) LabelValues() (lvs LabelValues)

+ func (s *EventSampler) Values() []string

+ func (s EventSampler) Cap() int

+ func (s EventSampler) ObserveAt(ts int64, v float64)

+ type FrequencyMap map[string]map[string]int64

+ type Gatherer interface

+ Gather func(col Collector, tm time.Time) error

+ type LabelValues map[string]string

+ func (values LabelValues) Equal(other LabelValues) bool

+ func (values LabelValues) Values(labels []string) []string

+ type Metric interface

+ func NewMetric(n int64, values []string, desc *Desc) Metric

+ type MetricType uint8

+ const MetricTypeIncrement

+ const MetricTypeUpdate

+ const MetricTypeUpdateOnce

type Query

+ Event Descriptor

+ Group []string

+ Mode QueryMode

+ Values url.Values

+ func (q *Query) Error() error

+ type QueryBuilder struct

+ End time.Time

+ Events []string

+ Group []string

+ Mode QueryMode

+ Query url.Values

+ Resolution string

+ Start time.Time

+ func NewQueryBuilder() QueryBuilder

+ func ParseQuery(q url.Values, tdec tcodec.TimeDecoder) (s QueryBuilder, err error)

+ func (q QueryBuilder) At(res Resolution) QueryBuilder

+ func (q QueryBuilder) Between(start, end time.Time) QueryBuilder

+ func (q QueryBuilder) Exact() QueryBuilder

+ func (q QueryBuilder) From(event ...string) QueryBuilder

+ func (q QueryBuilder) GroupBy(label ...string) QueryBuilder

+ func (q QueryBuilder) QueryValues(d *Desc) []map[string]string

+ func (q QueryBuilder) Where(label string, value ...string) QueryBuilder

+ func (qb QueryBuilder) Queries(r ...*Registry) (queries []Query)

+ type QueryMode uint8

+ const QueryModeExact

+ const QueryModeScan

+ func (m QueryMode) String() string

+ type Registries []*Registry

+ func (r Registries) Get(name string) Event

type Registry

+ func (c *Registry) Events() []Event

+ type Resetable interface

+ Reset func()

type Resolution

+ func (r Resolution) AddSteps(t time.Time, n int) time.Time

+ func (r Resolution) IsZero() bool

+ func (r Resolution) WithCodec(codec tcodec.TimeCodec) Resolution

+ func (r Resolution) WithLayout(layout string) Resolution

+ func (r Resolution) WithName(name string) Resolution

+ func (r Resolution) WithStep(step time.Duration) Resolution

+ type Results []Result

+ func (results Results) Append(r ScanResult) Results

+ func (s Results) Find(event string, values LabelValues) *Result

+ func (s Results) IndexOf(event string, values LabelValues) int

+ type SafeSampler struct

+ func NewSafeSampler(size int) *SafeSampler

+ func (s *SafeSampler) Avg(since time.Time, q int) (avg float64)

+ func (s *SafeSampler) Diff(since time.Time, q int) (v float64)

+ func (s *SafeSampler) Len() (n int)

+ func (s *SafeSampler) Observe(v float64)

+ func (s SafeSampler) Cap() int

+ func (s SafeSampler) ObserveAt(ts int64, v float64)

+ type Sample struct

+ Timestamp int64

+ Value float64

+ type Sampler interface

+ Avg func(since time.Time, q int) float64

+ Cap func() int

+ Diff func(since time.Time, q int) float64

+ Len func() int

+ Observe func(v float64)

+ func NewSampler(size int) Sampler

+ type Samplers struct

+ func NewSamplers(size int, desc *Desc) *Samplers

+ func (s *Samplers) WithLabelValues(values ...string) (ss *SafeSampler)

+ func (s *Samplers) WithLabels(lvs LabelValues) *SafeSampler

+ type ScanResult struct

+ Group []string

+ Name string

+ Time time.Time

+ Values LabelValues

Jul 31, 2017

Changes in this version

type Event

+ func (e *Event) MatchField(group string, input ...string) string

type Labels

+ func ParseField(field string) Labels

Jul 31, 2017

Changes in this version

+ var InvalidEventLabelError = errors.New("Invalid event label.")

+ var NilResolutionError = errors.New("Resolution is nil.")

type DB

+ func (db *DB) SummaryScan(q SummaryQuery) (sum Summary, err error)

type Event

+ func (e *Event) ValueIndex(label string) int

type Labels

+ func (labels Labels) Get(label string) (string, bool)

+ type Summary map[string]int64

+ func (s Summary) Add(other Summary)

+ type SummaryController struct

+ DB *DB

+ MaxRecords int

+ Resolution *Resolution

+ func (c *SummaryController) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type SummaryQuery struct

+ Event string

+ Group string

+ Labels []string

+ Resolution *Resolution

+ Time time.Time

Jul 30, 2017

Changes in this version

+ const LabelSeparator

Jun 21, 2017

Changes in this version

+ const Daily

+ const DailyDateFormat

+ const DefaultMaxResults

+ const Hourly

+ const HourlyDateFormat

+ const Minly

+ const MinlyDateFormat

+ const Monthly

+ const Weekly

+ const Yearly

+ var DuplicateTypeError = errors.New("Duplicate type registration.")

+ var MaxRecordsError = errors.New("Max records reached")

+ var NilEventError = errors.New("Event is nil.")

+ var NoResolution = &Resolution

+ var NoResolutionCodec = tc.NewTimeCodec(func(t time.Time) string { ... }, ...)

+ var ResolutionDaily = &Resolution

+ var ResolutionHourly = &Resolution

+ var ResolutionMinly = &Resolution

+ var ResolutionWeekly = &Resolution

+ var UnregisteredEventError = errors.New("Unregistered event type")

+ func Alias(s string) string

+ func IsTemplateName(name string) bool

+ func Join(sep string, parts ...string) string

+ func Label(s string) string

+ func Log(name string, n int64, labels ...string) error

+ func LogEvent(e *Event, n int64, labels ...string)

+ func MustLog(name string, n int64, labels ...string)

+ func MustPersist(tm time.Time, r *redis.Client)

+ func MustRegister(name string, t *Event)

+ func NormalizeLabels(labels ...string) (out []string)

+ func PermutationPairs(input url.Values) [][]string

+ func Persist(tm time.Time, r *redis.Client) error

+ func ReadRecords(r redis.UniversalClient, records []*Record) error

+ func Register(name string, t *Event) error

+ func Replacer(labels ...string) *strings.Replacer

+ func SetAlias(label string, aliases ...string)

+ func SubQuery(q url.Values, prefix string) url.Values

+ func TimeSequence(start time.Time, end time.Time, unit time.Duration) []time.Time

+ type Aliases map[string]string

+ func AliasesFromValues(input url.Values) Aliases

+ func NewAliases() Aliases

+ func (a Aliases) Alias(s string) string

+ func (a Aliases) Set(label string, aliases ...string)

+ type Batch map[string]int64

+ type Controller struct

+ DB *DB

+ MaxRecords int

+ Resolution *Resolution

+ func (c Controller) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Counter struct

+ func (v *Counter) Get() int64

+ func (v *Counter) Inc(d int64) int64

+ func (v *Counter) Set(n int64) int64

+ type Counters struct

+ func NewCounters() *Counters

+ func (c *Counters) BatchIncrement(b Batch)

+ func (c *Counters) Flush() Batch

+ func (c *Counters) Increment(key string, n int64) int64

+ func (c *Counters) Snapshot() Batch

+ type DB struct

+ Aliases Aliases

+ Redis redis.UniversalClient

+ Registry *Registry

+ func NewDB(r redis.UniversalClient) *DB

+ func (db *DB) Mux(maxrecords int, resolutions ...*Resolution) *http.ServeMux

+ func (db *DB) Records(q Query) (rs RecordSequence, err error)

+ func (db *DB) Results(q Query) (results []*Result, err error)

+ type DataPoint struct

+ Timestamp int64

+ Value int64

+ func (d *DataPoint) MarshalJSON() ([]byte, error)

+ type DateRangeParserFunc func(string, string, time.Duration) (time.Time, time.Time, error)

+ func DateRangeParser(dec tc.TimeDecoder) DateRangeParserFunc

+ type Dimension []string

+ func Dim(labels ...string) Dimension

+ func LabelDimensions(labels ...string) []Dimension

+ type Event struct

+ func GetEvent(name string) *Event

+ func NewEvent(name string, labels []string, res ...*Resolution) *Event

+ func (e *Event) AliasedLabels(input []string, aliases Aliases) (labels Labels)

+ func (e *Event) AllField() string

+ func (e *Event) DimField(dim Dimension, q map[string]string) (field string, ok bool)

+ func (e *Event) EventName(labels Labels) string

+ func (e *Event) Field(input ...string) string

+ func (e *Event) HasLabel(a string) bool

+ func (e *Event) Key(res *Resolution, tm time.Time, labels Labels) string

+ func (e *Event) Labels(input ...string) (labels []string)

+ func (e *Event) Log(n int64, labels ...string)

+ func (e *Event) MustPersist(tm time.Time, r *redis.Client)

+ func (e *Event) Persist(tm time.Time, r *redis.Client) error

+ func (e *Event) Record(r *Resolution, t time.Time, labels []string) *Record

+ func (e *Event) Records(res *Resolution, start, end time.Time, queries ...[]string) []*Record

+ func (e *Event) Snapshot() map[string]int64

+ type FlushError map[string]error

+ func (e FlushError) Error() string

+ type Labels []string

+ func (labels Labels) Map() map[string]string

+ func (labels Labels) Set(pairs ...string) Labels

+ type Logger struct

+ Aliases Aliases

+ Resolutions []*Resolution

+ func NewLogger(resolutions ...*Resolution) *Logger

+ func (lo *Logger) Close()

+ func (lo *Logger) FlushErrors() int64

+ func (lo *Logger) Log(name string, n int64, labels ...string) error

+ func (lo *Logger) MustLog(name string, n int64, labels ...string)

+ func (lo *Logger) MustPersist(tm time.Time, r *redis.Client)

+ func (lo *Logger) Persist(tm time.Time, r *redis.Client) error

+ type Query struct

+ End time.Time

+ Events []string

+ Grouped bool

+ Labels map[string][]string

+ MaxRecords int

+ Resolution *Resolution

+ Start time.Time

+ func (q *Query) Records(r *Registry) (rs RecordSequence, err error)

+ type Record struct

+ Field string

+ Key string

+ Labels []string

+ Name string

+ Result *redis.StringCmd

+ Time time.Time

+ func (r *Record) MarshalJSON() ([]byte, error)

+ func (r *Record) Value() int64

+ type RecordSequence []*Record

+ func (s RecordSequence) Group() []*Result

+ func (s RecordSequence) Results() []*Result

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Each(fn func(name string, t *Event))

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

+ func (r *Registry) Logger(res ...*Resolution) *Logger

+ func (r *Registry) MustRegister(name string, t *Event)

+ func (r *Registry) Register(name string, t *Event) error

+ type Resolution struct

+ Name string

+ func NewResolution(name string, step, ttl time.Duration) *Resolution

+ func (r *Resolution) Key(event string, t time.Time) string

+ func (r *Resolution) MarshalTime(t time.Time) string

+ func (r *Resolution) ParseDateRange(s, e string) (start, end time.Time, err error)

+ func (r *Resolution) Round(t time.Time) time.Time

+ func (r *Resolution) Step() time.Duration

+ func (r *Resolution) TTL() time.Duration

+ func (r *Resolution) TimeSequence(s, e time.Time) []time.Time

+ func (r *Resolution) UnmarshalTime(s string) (t time.Time, err error)

+ func (r *Resolution) WithTTL(ttl time.Duration) *Resolution

+ type Result struct

+ Data []DataPoint

+ Event string

+ Labels map[string]string