Function waitForGateway

examples/internal/integration/main_test.go:36–54

(ctx context.Context, port uint16)

}

func waitForGateway(ctx context.Context, port uint16) error {
	ch := time.After(10 * time.Second)

	for {
		r, err := http.Get(fmt.Sprintf("http://localhost:%d/healthz", port))
		if err == nil && r.StatusCode == http.StatusOK {
			return nil
		}

		grpclog.Infof("Waiting for localhost:%d to get ready", port)
		select {
		case <-ctx.Done():
			return err
		case <-ch:
			return err
		case <-time.After(10 * time.Millisecond):
		}
	}
}

func runServers(ctx context.Context) <-chan error {
	ch := make(chan error, 3)