Wait for host ports to be exposed for all Chip Ingress services (#2034)

Author: Tofel

framework/components/dockercompose/.changeset/v0.1.7.md

@@ -0,0 +1 @@
+- Wait for host ports to be exposed for all Chip Ingress services

framework/components/dockercompose/chip_ingress_set/chip_ingress.go

@@ -107,15 +107,22 @@ func New(in *Input) (*Output, error) {
 
 	stack.WaitForService(DEFAULT_CHIP_INGRESS_SERVICE_NAME,
 		wait.ForAll(
-			wait.ForLog("GRPC server is live").WithPollInterval(200*time.Millisecond),
-			wait.ForListeningPort(DEFAULT_CHIP_INGRESS_GRPC_PORT),
-		).WithDeadline(1*time.Minute),
+			wait.ForLog("GRPC server is live").WithPollInterval(100*time.Millisecond),
+			wait.ForListeningPort(DEFAULT_CHIP_INGRESS_GRPC_PORT).WithPollInterval(100*time.Millisecond),
+			wait.NewHostPortStrategy(DEFAULT_CHIP_INGRESS_GRPC_PORT).WithPollInterval(100*time.Millisecond),
+		).WithDeadline(2*time.Minute),
 	).WaitForService(DEFAULT_RED_PANDA_SERVICE_NAME,
 		wait.ForAll(
-			wait.ForListeningPort(DEFAULT_RED_PANDA_SCHEMA_REGISTRY_PORT).WithStartupTimeout(1*time.Minute),
-			wait.ForListeningPort(DEFAULT_RED_PANDA_KAFKA_PORT).WithStartupTimeout(1*time.Minute)),
+			wait.ForListeningPort(DEFAULT_RED_PANDA_SCHEMA_REGISTRY_PORT).WithPollInterval(100*time.Millisecond),
+			wait.ForListeningPort(DEFAULT_RED_PANDA_KAFKA_PORT).WithPollInterval(100*time.Millisecond),
+			wait.NewHostPortStrategy(DEFAULT_RED_PANDA_SCHEMA_REGISTRY_PORT).WithPollInterval(100*time.Millisecond),
+			wait.NewHostPortStrategy(DEFAULT_RED_PANDA_KAFKA_PORT).WithPollInterval(100*time.Millisecond),
+		).WithDeadline(2*time.Minute),
 	).WaitForService(DEFAULT_RED_PANDA_CONSOLE_SERVICE_NAME,
-		wait.ForListeningPort(DEFAULT_RED_PANDA_CONSOLE_PORT).WithStartupTimeout(1*time.Minute),
+		wait.ForAll(
+			wait.ForListeningPort(DEFAULT_RED_PANDA_CONSOLE_PORT).WithPollInterval(100*time.Millisecond),
+			wait.NewHostPortStrategy(DEFAULT_RED_PANDA_CONSOLE_PORT).WithPollInterval(100*time.Millisecond),
+		).WithDeadline(2*time.Minute),
 	)
 
 	chipIngressContainer, ingressErr := stack.ServiceContainer(ctx, DEFAULT_CHIP_INGRESS_SERVICE_NAME)