Package org.apache.flink.kubernetes.operator.admission.mutator

Class FlinkMutator

java.lang.Object

org.apache.flink.kubernetes.operator.admission.mutator.FlinkMutator

All Implemented Interfaces:

io.javaoperatorsdk.webhook.admission.mutation.Mutator<io.fabric8.kubernetes.api.model.HasMetadata>

public class FlinkMutator
extends java.lang.Object
implements io.javaoperatorsdk.webhook.admission.mutation.Mutator<io.fabric8.kubernetes.api.model.HasMetadata>

The default mutator.

Constructor Summary

Constructors

Constructor	Description
FlinkMutator(java.util.Set<FlinkResourceMutator> mutators, InformerManager informerManager)

Method Summary

Modifier and Type	Method	Description
io.fabric8.kubernetes.api.model.HasMetadata	mutate(io.fabric8.kubernetes.api.model.HasMetadata resource, io.javaoperatorsdk.webhook.admission.Operation operation)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkMutator

public FlinkMutator(java.util.Set<FlinkResourceMutator> mutators,
                    InformerManager informerManager)

Method Detail

mutate

public io.fabric8.kubernetes.api.model.HasMetadata mutate(io.fabric8.kubernetes.api.model.HasMetadata resource,
                                                          io.javaoperatorsdk.webhook.admission.Operation operation)
                                                   throws io.javaoperatorsdk.webhook.admission.NotAllowedException

Specified by:

mutate in interface io.javaoperatorsdk.webhook.admission.mutation.Mutator<io.fabric8.kubernetes.api.model.HasMetadata>

Throws:

io.javaoperatorsdk.webhook.admission.NotAllowedException