mirror of
https://github.com/open-policy-agent/opa.git
synced 2026-08-16 05:12:47 -06:00
Anders Eknert
55e87e79ae
And update code to conform to the rule. - Replace unnecessary fmt.Sprintf with string concatenation - Replace fmt.Sprint with more efficient strconv.Itoa - Replace static fmt.Errorf calls with more efficient errors.New Thanks @srenatus for pushing me down this rabbit hole! Signed-off-by: Anders Eknert <anders@styra.com>
35 lines
745 B
Go
35 lines
745 B
Go
// Copyright 2020 The OPA Authors. All rights reserved.
|
|
// Use of this source code is governed by an Apache2
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package util
|
|
|
|
import (
|
|
"errors"
|
|
"time"
|
|
)
|
|
|
|
// WaitFunc will call passed function at an interval and return nil
|
|
// as soon this function returns true.
|
|
// If timeout is reached before the passed in function returns true
|
|
// an error is returned.
|
|
func WaitFunc(fun func() bool, interval, timeout time.Duration) error {
|
|
if fun() {
|
|
return nil
|
|
}
|
|
ticker := time.NewTicker(interval)
|
|
timer := time.NewTimer(timeout)
|
|
defer ticker.Stop()
|
|
defer timer.Stop()
|
|
for {
|
|
select {
|
|
case <-timer.C:
|
|
return errors.New("timeout")
|
|
case <-ticker.C:
|
|
if fun() {
|
|
return nil
|
|
}
|
|
}
|
|
}
|
|
}
|