requestParser

Documentation

Index

• Constants
• func Metrics() []xmetrics.Metric
• type Config
• type Measures
  • func NewMeasures(p provider.Provider) *Measures
• type RequestParser
  • 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()

Constants

const (
	ParsingQueueDepth    = "parsing_queue_depth"
	DroppedEventsCounter = "dropped_events_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 Measures

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

func NewMeasures

func NewMeasures(p provider.Provider) *Measures

NewMeasures constructs a Measures given a go-kit metrics Provider

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 cipher.Encrypt) (*RequestParser, error)

func (*RequestParser) Parse

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

func (*RequestParser) Start

func (r *RequestParser) Start()

func (*RequestParser) Stop

func (r *RequestParser) Stop()