requeue

package
Version: v0.19.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 22, 2022 License: Apache-2.0 Imports: 1 Imported by: 78

Documentation

Index

Constants

View Source
const (
	DefaultRequeueAfterDuration time.Duration = 30 * time.Second
)

Variables

This section is empty.

Functions

This section is empty.

Types

type NoRequeue added in v0.18.0

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.

func None added in v0.18.0

func None(err error) *NoRequeue

None returns a new NoRequeue to instruct the ACK runtime to not requeue the processing item but to continue logging the error.

func (*NoRequeue) Error added in v0.18.0

func (e *NoRequeue) Error() string

func (*NoRequeue) Unwrap added in v0.18.0

func (e *NoRequeue) Unwrap() error

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 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL