Skip to content

Commit

Permalink
Update network gateway
Browse files Browse the repository at this point in the history
  • Loading branch information
deadlycoconuts committed Aug 6, 2024
1 parent 752772c commit efb57f6
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions treatment-service/integration-test/fetch_treatment_it_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -388,7 +388,7 @@ func (suite *TreatmentServiceTestSuite) SetupSuite() {
}
fmt.Println(kafkaInfo.NetworkSettings.Networks)
fmt.Println(kafkaInfo.NetworkSettings.Networks["kafka_default"])
fmt.Println(kafkaInfo.NetworkSettings.Networks["kafka_default"].IPAddress)
fmt.Println(kafkaInfo.NetworkSettings.Networks["kafka_default"].Gateway)
fmt.Println(kafkaInfo.NetworkSettings.Ports)
fmt.Println(kafkaInfo.State)
kafkaHost, err := kafkaContainer.Host(ctx)
Expand All @@ -402,7 +402,7 @@ func (suite *TreatmentServiceTestSuite) SetupSuite() {
}
fmt.Println(kafkaPort)

os.Setenv("ASSIGNEDTREATMENTLOGGER_KAFKACONFIG_BROKERS", fmt.Sprintf("%s:%s", kafkaInfo.NetworkSettings.Networks["kafka_default"].IPAddress, kafkaPort.Port()))
os.Setenv("ASSIGNEDTREATMENTLOGGER_KAFKACONFIG_BROKERS", fmt.Sprintf("%s:%s", kafkaInfo.NetworkSettings.Networks["kafka_default"].Gateway, kafkaPort.Port()))

Check failure on line 405 in treatment-service/integration-test/fetch_treatment_it_test.go

View workflow job for this annotation

GitHub Actions / lint-go

line is 159 characters (lll)
}
suite.kafka = kafka

Expand Down

0 comments on commit efb57f6

Please sign in to comment.