eventParser

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

type EventSenderFunc func(deviceID string, event *wrp.Message)

type Measures struct {
	fx.In
	EventParsingQueue         metrics.Gauge   `name:"parsing_queue_depth"`
	DroppedEventsParsingCount metrics.Counter `name:"dropped_events_count"`
}

type ParserConfig struct {
	QueueSize  int
	MaxWorkers int
	RegexRules []rules.RuleConfig
}

type ParserIn struct {
	fx.In

	Lifecycle   fx.Lifecycle
	EventSender EventSenderFunc
	Logger      log.Logger
	Measures    Measures
}

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