- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for UntilComplete (0.16 sec)
-
pkg/test/util/retry/retry.go
} if cfg.error == "" { return ErrConditionNotMet } return errors.New(cfg.error) } // UntilComplete retries the given function, until there is a timeout, or until the function indicates that it has completed. // Once complete, the returned value and error are returned. func UntilComplete(fn RetriableFunc, options ...Option) (any, error) { cfg := defaultConfig for _, option := range options { option(&cfg)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 5.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/common/call.go
}() return sendAndValidate() } // Retry the call until it succeeds or times out. var result echo.CallResult var err error _, _ = retry.UntilComplete(func() (any, bool, error) { result, err = sendAndValidate() if err != nil { return nil, false, err } return nil, true, nil }, opts.Retry.Options...) return result, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 6.7K bytes - Viewed (0) -
pkg/test/framework/components/istio/ingress.go
// the returned list will contain will have the externally reachable NodePort address and port. func (c *ingressImpl) getAddressesInner(port int) ([]string, []int, error) { attempts := 0 remoteAddrs, err := retry.UntilComplete(func() (addrs any, completed bool, err error) { attempts++ addrs, completed, err = getRemoteServiceAddresses(c.env.Settings(), c.cluster, c.service.Namespace, c.labelSelector, c.service.Name, port)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 17:13:34 UTC 2024 - 8K bytes - Viewed (0)