Package org.apache.flink.kubernetes.operator.controller

Class FlinkDeploymentController

java.lang.Object

org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

All Implemented Interfaces:

io.javaoperatorsdk.operator.api.reconciler.Cleaner<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.Reconciler<FlinkDeployment>

public class FlinkDeploymentController
extends java.lang.Object
implements io.javaoperatorsdk.operator.api.reconciler.Reconciler<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<FlinkDeployment>, io.javaoperatorsdk.operator.api.reconciler.Cleaner<FlinkDeployment>

Controller that runs the main reconcile loop for Flink deployments.

Constructor Summary

Constructors

Constructor	Description
FlinkDeploymentController(java.util.Set<FlinkResourceValidator> validators, FlinkResourceContextFactory ctxFactory, ReconcilerFactory reconcilerFactory, FlinkDeploymentObserverFactory observerFactory, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, EventRecorder eventRecorder, CanaryResourceManager<FlinkDeployment> canaryResourceManager)

Method Summary

Modifier and Type	Method	Description
io.javaoperatorsdk.operator.api.reconciler.DeleteControl	cleanup(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
java.util.Map<java.lang.String,io.javaoperatorsdk.operator.processing.event.source.EventSource>	prepareEventSources(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)
io.javaoperatorsdk.operator.api.reconciler.UpdateControl<FlinkDeployment>	reconcile(FlinkDeployment flinkApp, io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<FlinkDeployment>	updateErrorStatus(FlinkDeployment flinkDeployment, io.javaoperatorsdk.operator.api.reconciler.Context<FlinkDeployment> context, java.lang.Exception e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkDeploymentController

public FlinkDeploymentController(java.util.Set<FlinkResourceValidator> validators,
                                 FlinkResourceContextFactory ctxFactory,
                                 ReconcilerFactory reconcilerFactory,
                                 FlinkDeploymentObserverFactory observerFactory,
                                 StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder,
                                 EventRecorder eventRecorder,
                                 CanaryResourceManager<FlinkDeployment> canaryResourceManager)

Method Detail

cleanup

public io.javaoperatorsdk.operator.api.reconciler.DeleteControl cleanup(FlinkDeployment flinkApp,
                                                                        io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)

Specified by:

cleanup in interface io.javaoperatorsdk.operator.api.reconciler.Cleaner<FlinkDeployment>

reconcile

public io.javaoperatorsdk.operator.api.reconciler.UpdateControl<FlinkDeployment> reconcile(FlinkDeployment flinkApp,
                                                                                           io.javaoperatorsdk.operator.api.reconciler.Context josdkContext)
                                                                                    throws java.lang.Exception

Specified by:

reconcile in interface io.javaoperatorsdk.operator.api.reconciler.Reconciler<FlinkDeployment>

Throws:

java.lang.Exception

prepareEventSources

public java.util.Map<java.lang.String,io.javaoperatorsdk.operator.processing.event.source.EventSource> prepareEventSources(io.javaoperatorsdk.operator.api.reconciler.EventSourceContext<FlinkDeployment> context)

Specified by:

prepareEventSources in interface io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<FlinkDeployment>

updateErrorStatus

public io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<FlinkDeployment> updateErrorStatus(FlinkDeployment flinkDeployment,
                                                                                                              io.javaoperatorsdk.operator.api.reconciler.Context<FlinkDeployment> context,
                                                                                                              java.lang.Exception e)

Specified by:

updateErrorStatus in interface io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<FlinkDeployment>