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

Class FlinkControllerConfig<CR extends io.fabric8.kubernetes.api.model.HasMetadata>

  • All Implemented Interfaces:
    io.javaoperatorsdk.operator.api.config.ControllerConfiguration<CR>, io.javaoperatorsdk.operator.api.config.ResourceConfiguration<CR>
    public class FlinkControllerConfig<CR extends io.fabric8.kubernetes.api.model.HasMetadata>
extends io.javaoperatorsdk.operator.config.runtime.AnnotationControllerConfiguration<CR>
    Custom config for FlinkDeploymentController.

    • Field Summary

      • Fields inherited from class io.javaoperatorsdk.operator.api.config.AnnotationControllerConfiguration

        reconciler

      • Fields inherited from interface io.javaoperatorsdk.operator.api.config.ControllerConfiguration

        DEFAULT_RATE_LIMITER

    • Constructor Summary

      Constructors 
      Constructor Description
      FlinkControllerConfig​(io.javaoperatorsdk.operator.api.reconciler.Reconciler<CR> reconciler, java.util.Set<java.lang.String> watchedNamespaces)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.Set<java.lang.String> getEffectiveNamespaces()  
      java.util.Set<java.lang.String> getNamespaces()  

      • Methods inherited from class io.javaoperatorsdk.operator.config.runtime.AnnotationControllerConfiguration

        getResourceClass

      • Methods inherited from class io.javaoperatorsdk.operator.api.config.AnnotationControllerConfiguration

        genericFilter, getAssociatedReconcilerClassName, getDependentResources, getEventFilter, getFinalizerName, getLabelSelector, getName, getRateLimiter, getRetry, isGenerationAware, maxReconciliationInterval, onAddFilter, onUpdateFilter, valueOrDefault

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface io.javaoperatorsdk.operator.api.config.ControllerConfiguration

        getConfigurationService, getRetryConfiguration

      • Methods inherited from interface io.javaoperatorsdk.operator.api.config.ResourceConfiguration

        getResourceTypeName, watchAllNamespaces, watchCurrentNamespace

    • Constructor Detail

      • FlinkControllerConfig

        public FlinkControllerConfig​(io.javaoperatorsdk.operator.api.reconciler.Reconciler<CR> reconciler,
                             java.util.Set<java.lang.String> watchedNamespaces)

    • Method Detail

      • getNamespaces

        public java.util.Set<java.lang.String> getNamespaces()
        Specified by:
        getNamespaces in interface io.javaoperatorsdk.operator.api.config.ResourceConfiguration<CR extends io.fabric8.kubernetes.api.model.HasMetadata>
        Overrides:
        getNamespaces in class io.javaoperatorsdk.operator.api.config.AnnotationControllerConfiguration<CR extends io.fabric8.kubernetes.api.model.HasMetadata>

      • getEffectiveNamespaces

        public java.util.Set<java.lang.String> getEffectiveNamespaces()