Skip to content

Commit 40f1c14

Browse files
committed
feat: integrate ThreadWinds ingestion service into UTMStack installer
1 parent b0ec2bd commit 40f1c14

File tree

2 files changed

+32
-0
lines changed

2 files changed

+32
-0
lines changed

installer/types/compose.go

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -596,6 +596,37 @@ func (c *Compose) Populate(conf *Config, stack *StackConfig) *Compose {
596596
},
597597
}
598598

599+
threadwindsIngestionMem := stack.ServiceResources["threadwinds-ingestion"].AssignedMemory
600+
c.Services["threadwinds-ingestion"] = Service{
601+
Image: utils.Str("ghcr.io/utmstack/utmstack/threadwinds-ingestion:" + conf.Branch),
602+
DependsOn: []string{
603+
"postgres",
604+
"node1",
605+
"backend",
606+
},
607+
Environment: []string{
608+
"INTERNAL_KEY=" + conf.InternalKey,
609+
"BACKEND_URL=http://backend:8080",
610+
"ENV=" + conf.Branch,
611+
"OPENSEARCH_HOST=node1",
612+
"OPENSEARCH_PORT=9200",
613+
"DB_HOST=postgres",
614+
"DB_PORT=5432",
615+
"DB_USER=postgres",
616+
"DB_PASS=" + conf.Password,
617+
"DB_NAME=utmstack",
618+
},
619+
Logging: &dLogging,
620+
Deploy: &Deploy{
621+
Placement: &pManager,
622+
Resources: &Resources{
623+
Limits: &Res{
624+
Memory: utils.Str(fmt.Sprintf("%vM", threadwindsIngestionMem)),
625+
},
626+
},
627+
},
628+
}
629+
599630
webPDFMem := stack.ServiceResources["web-pdf"].AssignedMemory
600631
c.Services["web-pdf"] = Service{
601632
Image: utils.Str("ghcr.io/utmstack/utmstack/web-pdf:" + conf.Branch),

installer/types/stack.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ var Services = []utils.ServiceConfig{
3939
{Name: "socai", Priority: 3, MinMemory: 30, MaxMemory: 512},
4040
{Name: "bitdefender", Priority: 3, MinMemory: 30, MaxMemory: 100},
4141
{Name: "office365", Priority: 3, MinMemory: 30, MaxMemory: 100},
42+
{Name: "threadwinds-ingestion", Priority: 3, MinMemory: 50, MaxMemory: 256},
4243
}
4344

4445
func (s *StackConfig) Populate(c *Config) error {

0 commit comments

Comments
 (0)