Documentation
¶
Index ¶
Constants ¶
const (
DefaultRequeueAfterDuration time.Duration = 30 * time.Second
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RequeueNeeded ¶
type RequeueNeeded struct {
// contains filtered or unexported fields
}
An error to instruct the ACK runtime to requeue the processing item without been logged as error. This should be used when a "error condition" occurrence is sort of expected and can be resolved by retry. e.g. a dependency haven't been fulfilled yet.
func Needed ¶
func Needed(err error) *RequeueNeeded
Needed returns a new RequeueNeeded to instruct the ACK runtime to requeue the processing item without been logged as error.
func (*RequeueNeeded) Error ¶
func (e *RequeueNeeded) Error() string
func (*RequeueNeeded) Unwrap ¶
func (e *RequeueNeeded) Unwrap() error
type RequeueNeededAfter ¶
type RequeueNeededAfter struct {
RequeueNeeded
// contains filtered or unexported fields
}
An error to instruct the ACK runtime to requeue the processing item after specified duration without been logged as error. This should be used when a "error condition" occurrence is sort of expected and can be resolved by retry. e.g. a dependency haven't been fulfilled yet, and expected it to be fulfilled after duration. Note: use this with care,a simple wait might suit your use case better.
func NeededAfter ¶
func NeededAfter( err error, duration time.Duration, ) *RequeueNeededAfter
NeededAfter returns a new RequeueNeededAfter to instruct controller-runtime to requeue the processing item after specified duration without been logged as error.
func (*RequeueNeededAfter) Duration ¶
func (e *RequeueNeededAfter) Duration() time.Duration
func (*RequeueNeededAfter) Error ¶
func (e *RequeueNeededAfter) Error() string
func (*RequeueNeededAfter) Unwrap ¶
func (e *RequeueNeededAfter) Unwrap() error
Source Files