crate.operator.utils.crate.on module

crate.operator.utils.crate.on.error(*, error_handler)

The @crate.on.error() decorator for kopf handlers or StateBasedSubHandler. It catches permanent errors in handlers and runs a given coroutine. It re-raises the exception for further processing by kopf.

Parameters:

error_handler (Callable) – a coroutine which is run on fatal errors

Return type:

Callable

async crate.operator.utils.crate.on.send_create_failed_notification(*args, **kwargs)

async crate.operator.utils.crate.on.send_feedback_notification(*, namespace, name, message, operation, status, logger, action=WebhookAction.UNKNOWN, **kwargs)

Parameters:

• namespace (str)

• name (str)

• message (str)

• operation (WebhookOperation)

• status (WebhookStatus)

• logger (Logger)

• action (WebhookAction)

Return type:

None

async crate.operator.utils.crate.on.send_update_failed_notification(*args, **kwargs)

crate.operator.utils.crate.on.timeout(*, timeout)

The @crate.timeout() decorator for kopf handlers or StateBasedSubHandler. It checks if the runtime passed as kwarg to all handlers exceeded the given timeout and raises a kopf.HandlerTimeoutError accordingly.

Parameters:

timeout (float) – the overall runtime of the decorated handler

Return type:

Callable