Package no.fintlabs

Class FlaisReconiler<T extends FlaisCrd<S>,S extends FlaisSpec>

java.lang.Object
no.fintlabs.FlaisReconiler<T,S>
Type Parameters:
T - the class representing the CustomResource object
S - the class providing the Spec part of this CustomResource
All Implemented Interfaces:
io.javaoperatorsdk.operator.api.reconciler.Cleaner<T>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<T>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<T>, io.javaoperatorsdk.operator.api.reconciler.Reconciler<T>

public abstract class FlaisReconiler<T extends FlaisCrd<S>,S extends FlaisSpec> extends Object implements io.javaoperatorsdk.operator.api.reconciler.Reconciler<T>, io.javaoperatorsdk.operator.api.reconciler.Cleaner<T>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<T>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<T>
Extending this class will give you the default FLAIS reconiler behavior.
  • Constructor Summary

    Constructors
    Constructor
    Description
    FlaisReconiler(FlaisWorkflow<T,S> workflow, List<? extends io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource<?,T>> eventSourceProviders, List<? extends io.javaoperatorsdk.operator.api.reconciler.dependent.Deleter<T>> deleters)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    io.javaoperatorsdk.operator.api.reconciler.DeleteControl
    cleanup(T resource, io.javaoperatorsdk.operator.api.reconciler.Context<T> context)
     
    createStatus(io.javaoperatorsdk.operator.processing.dependent.workflow.WorkflowReconcileResult reconcile, FlaisStatus status)
     
    boolean
    hasUpdates(io.javaoperatorsdk.operator.processing.dependent.workflow.WorkflowReconcileResult reconcile)
     
    boolean
    isCreated(io.javaoperatorsdk.operator.processing.dependent.workflow.WorkflowReconcileResult reconcile)
     
    Map<String,io.javaoperatorsdk.operator.processing.event.source.EventSource>
    prepareEventSources(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<T> context)
     
    io.javaoperatorsdk.operator.api.reconciler.UpdateControl<T>
    reconcile(T resource, io.javaoperatorsdk.operator.api.reconciler.Context<T> context)
     
    io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<T>
    updateErrorStatus(T resource, io.javaoperatorsdk.operator.api.reconciler.Context<T> context, Exception e)
     
    io.javaoperatorsdk.operator.api.reconciler.UpdateControl<T>
    updateStatus(io.javaoperatorsdk.operator.processing.dependent.workflow.WorkflowReconcileResult reconcile, T resource, FlaisStatus status)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • FlaisReconiler

      public FlaisReconiler(FlaisWorkflow<T,S> workflow, List<? extends io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource<?,T>> eventSourceProviders, List<? extends io.javaoperatorsdk.operator.api.reconciler.dependent.Deleter<T>> deleters)
  • Method Details

    • reconcile

      public io.javaoperatorsdk.operator.api.reconciler.UpdateControl<T> reconcile(T resource, io.javaoperatorsdk.operator.api.reconciler.Context<T> context)
      Specified by:
      reconcile in interface io.javaoperatorsdk.operator.api.reconciler.Reconciler<T extends FlaisCrd<S>>
    • updateStatus

      public io.javaoperatorsdk.operator.api.reconciler.UpdateControl<T> updateStatus(io.javaoperatorsdk.operator.processing.dependent.workflow.WorkflowReconcileResult reconcile, T resource, FlaisStatus status)
    • hasUpdates

      public boolean hasUpdates(io.javaoperatorsdk.operator.processing.dependent.workflow.WorkflowReconcileResult reconcile)
    • isCreated

      public boolean isCreated(io.javaoperatorsdk.operator.processing.dependent.workflow.WorkflowReconcileResult reconcile)
    • createStatus

      public FlaisStatus createStatus(io.javaoperatorsdk.operator.processing.dependent.workflow.WorkflowReconcileResult reconcile, FlaisStatus status)
    • cleanup

      public io.javaoperatorsdk.operator.api.reconciler.DeleteControl cleanup(T resource, io.javaoperatorsdk.operator.api.reconciler.Context<T> context)
      Specified by:
      cleanup in interface io.javaoperatorsdk.operator.api.reconciler.Cleaner<T extends FlaisCrd<S>>
    • updateErrorStatus

      public io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<T> updateErrorStatus(T resource, io.javaoperatorsdk.operator.api.reconciler.Context<T> context, Exception e)
      Specified by:
      updateErrorStatus in interface io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<T extends FlaisCrd<S>>
    • prepareEventSources

      public Map<String,io.javaoperatorsdk.operator.processing.event.source.EventSource> prepareEventSources(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<T> context)
      Specified by:
      prepareEventSources in interface io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<T extends FlaisCrd<S>>