requestParser

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

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

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

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

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

type TimeTracker interface {
	TrackTime(time.Duration)
}

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