Interface Reconciler<CR extends AbstractFlinkResource<?,?>>
-
- Type Parameters:
CR
- The custom resource to be reconciled.
- All Known Implementing Classes:
AbstractFlinkResourceReconciler
,AbstractJobReconciler
,ApplicationReconciler
,SessionJobReconciler
,SessionReconciler
public interface Reconciler<CR extends AbstractFlinkResource<?,?>>
The interface of reconciler.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description io.javaoperatorsdk.operator.api.reconciler.DeleteControl
cleanup(FlinkResourceContext<CR> context)
This is called when receiving the delete event of custom resource.void
reconcile(FlinkResourceContext<CR> context)
This is called when receiving the create or update event of the custom resource.
-
-
-
Method Detail
-
reconcile
void reconcile(FlinkResourceContext<CR> context) throws java.lang.Exception
This is called when receiving the create or update event of the custom resource.- Parameters:
context
- the context with which the operation is executed- Throws:
java.lang.Exception
- Error during reconciliation.
-
cleanup
io.javaoperatorsdk.operator.api.reconciler.DeleteControl cleanup(FlinkResourceContext<CR> context)
This is called when receiving the delete event of custom resource. This method is meant to cleanup the associated components like the Flink job components.- Parameters:
context
- the context with which the operation is executed- Returns:
- DeleteControl to manage the deletion behavior
-
-