Documentation
¶
Index ¶
- func EnsureNotReadyOnError(ctx context.Context, client client.Client, obj common_types.Object, err error) bool
- func Fetch(ctx context.Context, client client.Client, namespacedName types.NamespacedName, ...) error
- func FirstSetup(ctx context.Context, client client.Client, object common_types.Object) (bool, error)
- func GetEnvironment(object metav1.Object) (string, bool)
- func HandleError(ctx context.Context, err error, obj common_types.Object, ...) reconcile.Result
- func IsBeingDeleted(object metav1.Object) bool
- func NewRateLimiter[T reconcile.Request]() workqueue.TypedRateLimiter[T]
- type Controller
- type ControllerImpl
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnsureNotReadyOnError ¶
func EnsureNotReadyOnError(ctx context.Context, client client.Client, obj common_types.Object, err error) bool
EnsureNotReadyOnError sets the Ready condition to false on the object if the error is not nil and the Ready condition is not already set to false.
func FirstSetup ¶
func HandleError ¶
func HandleError(ctx context.Context, err error, obj common_types.Object, recorder record.EventRecorder) reconcile.Result
func IsBeingDeleted ¶
func NewRateLimiter ¶
func NewRateLimiter[T reconcile.Request]() workqueue.TypedRateLimiter[T]
Types ¶
type Controller ¶
type Controller[T common_types.Object] interface { Reconcile(context.Context, reconcile.Request, T) (reconcile.Result, error) }
func NewController ¶
func NewController[T common_types.Object](handler handler.Handler[T], client client.Client, recorder record.EventRecorder) Controller[T]
type ControllerImpl ¶
type ControllerImpl[T common_types.Object] struct { Client client.Client Scheme *runtime.Scheme Handler handler.Handler[T] Recorder record.EventRecorder }
func (*ControllerImpl[T]) Event ¶
func (c *ControllerImpl[T]) Event(ctx context.Context, object common_types.Object, eventType, reason, message string)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.