Documentation
¶
Index ¶
Constants ¶
const (
DefaultRequeueAfterDuration time.Duration = 30 * time.Second
)
Variables ¶
This section is empty.
Functions ¶
func IsRequeueError ¶ added in v0.9.0
IsRequeueError reports whether err is a requeue signal (RequeueNeeded or RequeueNeededAfter). Returns false for nil.
Types ¶
type NoRequeue ¶
type NoRequeue struct {
// contains filtered or unexported fields
}
NoRequeue instructs the ACK runtime to process an error, but not requeue the object that raised it. This should be used when there was a non-terminal error, but one that cannot be fixed by requeuing. e.g. a FieldExport failed because the source resource wasn't found.
type RequeueNeeded ¶
type RequeueNeeded struct {
// contains filtered or unexported fields
}
RequeueNeeded instructs 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
}
RequeueNeededAfter instructs the ACK runtime to requeue the processing item after specified duration without been logged as error. This should be used when an "error condition" occurrence is sort of expected and can be resolved by retry. E.g., a dependency hasn'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