1 parent 8c309ae commit 0e05c17Copy full SHA for 0e05c17
1 file changed
internal/util/portforward.go
@@ -192,16 +192,20 @@ func (pf *PortForward) setupPortForward(podName string) error {
192
pf.forwarder = fw
193
194
// Start forwarding in background
195
+ errChan := make(chan error, 1)
196
go func() {
197
if err := fw.ForwardPorts(); err != nil {
198
pf.setStatus(StatusFailed, err)
199
+ errChan <- err
200
}
201
}()
202
- // Wait for ready or timeout
203
+ // Wait for ready, error, or timeout
204
select {
205
case <-pf.readyChan:
206
return nil
207
+ case err := <-errChan:
208
+ return fmt.Errorf("port-forward failed: %w", err)
209
case <-time.After(kubeAPITimeout):
210
return fmt.Errorf("timeout waiting for port-forward to be ready")
211
0 commit comments