fix(backend): fixed bug with group name in heuristics service

This commit is contained in:
Alexander Zavorotynskiy 2022-05-23 17:42:28 +02:00
parent 07072f74b0
commit d29416fd48
3 changed files with 6 additions and 5 deletions

View file

@ -41,6 +41,7 @@ ENV TZ=UTC \
GROUP_DB=db \
GROUP_ENDER=ender \
GROUP_CACHE=cache \
GROUP_HEURISTICS=heuristics \
AWS_REGION_WEB=eu-central-1 \
AWS_REGION_IOS=eu-west-1 \
AWS_REGION_ASSETS=eu-central-1 \

View file

@ -3,7 +3,7 @@ package main
import (
"log"
"openreplay/backend/internal/builder"
"openreplay/backend/internal/config/ender"
"openreplay/backend/internal/config/heuristics"
"openreplay/backend/internal/handlers"
"openreplay/backend/internal/handlers/custom"
"openreplay/backend/internal/handlers/ios"
@ -23,7 +23,7 @@ func main() {
log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
// Load service configuration
cfg := ender.New()
cfg := heuristics.New()
// HandlersFabric returns the list of message handlers we want to be applied to each incoming message.
handlersFabric := func() []handlers.MessageProcessor {
@ -53,7 +53,7 @@ func main() {
// Init producer and consumer for data bus
producer := queue.NewProducer()
consumer := queue.NewMessageConsumer(
cfg.GroupEvents,
cfg.GroupHeuristics,
[]string{
cfg.TopicRawWeb,
cfg.TopicRawIOS,

View file

@ -5,7 +5,7 @@ import (
)
type Config struct {
GroupEvents string
GroupEnder string
TopicTrigger string
LoggerTimeout int
TopicRawWeb string
@ -15,7 +15,7 @@ type Config struct {
func New() *Config {
return &Config{
GroupEvents: env.String("GROUP_ENDER"),
GroupEnder: env.String("GROUP_ENDER"),
TopicTrigger: env.String("TOPIC_TRIGGER"),
LoggerTimeout: env.Int("LOG_QUEUE_STATS_INTERVAL_SEC"),
TopicRawWeb: env.String("TOPIC_RAW_WEB"),