Package org.apache.flink.kubernetes.operator.listener

Class AuditUtils

java.lang.Object

org.apache.flink.kubernetes.operator.listener.AuditUtils

public class AuditUtils
extends java.lang.Object

Responsible for logging resource event/status updates.

Constructor Summary

Constructors

Constructor	Description
AuditUtils()

Method Summary

Modifier and Type	Method	Description
static java.lang.String	format(@NonNull io.fabric8.kubernetes.api.model.Event event)
static <R extends AbstractFlinkResource<?,?>> void	logContext(FlinkResourceListener.ResourceEventContext<R> ctx)
static <R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>> void	logContext(FlinkResourceListener.StatusUpdateContext<R,S> ctx)

Methods inherited from class java.lang.Object

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

Constructor Detail

AuditUtils

public AuditUtils()

Method Detail

logContext

public static <R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>> void logContext(FlinkResourceListener.StatusUpdateContext<R,S> ctx)

logContext

public static <R extends AbstractFlinkResource<?,?>> void logContext(FlinkResourceListener.ResourceEventContext<R> ctx)

format

@VisibleForTesting
public static java.lang.String format(@NonNull
                                      @NonNull io.fabric8.kubernetes.api.model.Event event)