requestParser

Documentation

Index

• Constants
• func Metrics() []xmetrics.Metric
• type Config
• type EventTypeMetrics
• type Measures
  • func NewMeasures(p provider.Provider) *Measures
• type RecordConfig
• type RequestParser
  • func NewRequestParser(config Config, logger log.Logger, metricsRegistry provider.Provider, ...) (*RequestParser, error)
  • func (r *RequestParser) Parse(wrpWithTime WrpWithTime) (err error)
  • func (r *RequestParser) Start()
  • func (r *RequestParser) Stop()
• type TimeTracker
• type WrpWithTime

Constants

const (
	ParsingQueueDepth    = "parsing_queue_depth"
	DroppedEventsCounter = "dropped_events_count"
	EventCounter         = "event_count"
)

Functions

func Metrics

func Metrics() []xmetrics.Metric

Types

type Config

type Config struct {
	MetadataMaxSize int
	PayloadMaxSize  int
	QueueSize       int
	MaxWorkers      int
	DefaultTTL      time.Duration
	RegexRules      []rules.RuleConfig
}

type EventTypeMetrics

type EventTypeMetrics struct {
	Regex          *regexp.Regexp
	EventTypeIndex int
}

type Measures

type Measures struct {
	ParsingQueue       metrics.Gauge
	DroppedEventsCount metrics.Counter
	EventsCount        metrics.Counter
}

func NewMeasures

func NewMeasures(p provider.Provider) *Measures

NewMeasures constructs a Measures given a go-kit metrics Provider

type RecordConfig

type RecordConfig struct {
	// contains filtered or unexported fields
}

type RequestParser

type RequestParser struct {
	// contains filtered or unexported fields
}

func NewRequestParser

func NewRequestParser(config Config, logger log.Logger, metricsRegistry provider.Provider, inserter inserter, blacklist blacklist.List, encrypter voynicrypto.Encrypt, timeTracker TimeTracker) (*RequestParser, error)

func (*RequestParser) Parse

func (r *RequestParser) Parse(wrpWithTime WrpWithTime) (err error)

func (*RequestParser) Start

func (r *RequestParser) Start()

func (*RequestParser) Stop

func (r *RequestParser) Stop()

type TimeTracker

type TimeTracker interface {
	TrackTime(time.Duration)
}

type WrpWithTime

type WrpWithTime struct {
	Message   wrp.Message
	Beginning time.Time
}