requestParser

Apr 11, 2022

Changes in this version

+ type RecordConfig struct

Oct 19, 2020

Changes in this version

+ const EventCounter

+ type EventTypeMetrics struct

+ EventTypeIndex int

+ Regex *regexp.Regexp

type Measures

+ EventsCount metrics.Counter

Feb 19, 2020

Changes in this version

+ type TimeTracker interface

+ TrackTime func(time.Duration)

+ type WrpWithTime struct

+ Beginning time.Time

+ Message wrp.Message

Jul 11, 2019

Changes in this version

+ const DroppedEventsCounter

+ const ParsingQueueDepth

+ func Metrics() []xmetrics.Metric

+ type Config struct

+ DefaultTTL time.Duration

+ MaxWorkers int

+ MetadataMaxSize int

+ PayloadMaxSize int

+ QueueSize int

+ RegexRules []rules.RuleConfig

+ type Measures struct

+ DroppedEventsCount metrics.Counter

+ ParsingQueue metrics.Gauge

+ func NewMeasures(p provider.Provider) *Measures

+ type RequestParser struct

+ func NewRequestParser(config Config, logger log.Logger, metricsRegistry provider.Provider, ...) (*RequestParser, error)

+ func (r *RequestParser) Parse(message wrp.Message) (err error)

+ func (r *RequestParser) Start()

+ func (r *RequestParser) Stop()