Index

C D E G H I K M N P R S U V
All Classes and Interfaces|All Packages|Constant Field Values

C

call() - Method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource

clone() - Method in interface io.confluent.remote.config.poller.RemoteConfiguration

CONFIG_MAP_NAME_CONFIG - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

CONFIG_MAP_NAME_DOC - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

ConfigSet - Class in io.confluent.remote.config.poller.kubernetes

This class is used to parse the ConfigMap returned from the Kubernetes API.

ConnectLogEventsConfig - Class in io.confluent.remote.config.poller

ConnectLogEventsConfig(String, String) - Constructor for class io.confluent.remote.config.poller.ConnectLogEventsConfig

createDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig) - Static method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource

createEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig, String) - Static method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource

D

DEFAULT_ENABLED - Static variable in class io.confluent.remote.config.poller.RemoteConfigConfiguration

DEFAULT_MAX_RETRY_BACKOFF_MS - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

DEFAULT_REFRESH_INTERVAL - Static variable in class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

DEFAULT_RETRY_BACKOFF_MS - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

defineConfigs(ConfigDef) - Static method in class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

E

ENABLED_CONFIG - Static variable in class io.confluent.remote.config.poller.RemoteConfigConfiguration

ENABLED_CONFIG_DOC - Static variable in class io.confluent.remote.config.poller.RemoteConfigConfiguration

equals(Object) - Method in class io.confluent.remote.config.poller.ConnectLogEventsConfig

equals(Object) - Method in class io.confluent.remote.config.poller.kubernetes.ConfigSet

G

getBootstrapServers() - Method in class io.confluent.remote.config.poller.ConnectLogEventsConfig

getCompatibleConfigVersion(String, Class) - Method in class io.confluent.remote.config.poller.kubernetes.ConfigSet

The ConfigMap will hold 1 remote configuration objects for each major API schema version.

getConfig() - Method in class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

This method is used to get the current configuration before starting the polling.

getConfig() - Method in interface io.confluent.remote.config.poller.RemoteConfigurationSource

Returns the latest received configuration from this source.

getData() - Method in class io.confluent.remote.config.poller.kubernetes.V1ConfigMap

getJaasConfig() - Method in class io.confluent.remote.config.poller.ConnectLogEventsConfig

getMaxRetryBackoffMs() - Method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

getMetadata() - Method in class io.confluent.remote.config.poller.kubernetes.V1ConfigMap

getName() - Method in class io.confluent.remote.config.poller.kubernetes.V1ObjectMeta

getNamespace() - Method in class io.confluent.remote.config.poller.kubernetes.V1ObjectMeta

getObjectMapper() - Static method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource

getRefreshIntervalMs() - Method in class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

getRegion() - Method in enum class io.confluent.remote.config.poller.Region

getResourceVersion() - Method in class io.confluent.remote.config.poller.kubernetes.V1ObjectMeta

getRetryBackoffMs() - Method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

getSchemaVersion() - Method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

H

hashCode() - Method in class io.confluent.remote.config.poller.ConnectLogEventsConfig

hashCode() - Method in class io.confluent.remote.config.poller.kubernetes.ConfigSet

I

io.confluent.remote.config.poller - package io.confluent.remote.config.poller

io.confluent.remote.config.poller.kubernetes - package io.confluent.remote.config.poller.kubernetes

isEnabled() - Method in class io.confluent.remote.config.poller.RemoteConfigConfiguration

K

KubernetesConfigMapRemoteConfigurationConfig - Class in io.confluent.remote.config.poller.kubernetes

KubernetesConfigMapRemoteConfigurationConfig(Map, boolean) - Constructor for class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

KubernetesConfigMapRemoteConfigurationSource<T> - Class in io.confluent.remote.config.poller.kubernetes

This RemoteConfigurationSource will continuously poll the Kubernetes API for a ConfigMap containing the RemoteConfiguration object.

KubernetesConfigMapRemoteConfigurationSource(KubernetesConfigMapRemoteConfigurationConfig, Optional, Consumer, Class) - Constructor for class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource

M

MAX_RETRY_BACKOFF_MS - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

MAX_RETRY_BACKOFF_MS_DOC - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

N

NAMESPACE_CONFIG - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

NAMESPACE_DOC - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

P

parseConfigYaml(String) - Static method in class io.confluent.remote.config.poller.kubernetes.ConfigSet

We need to provide this convoluted way of parsing configs returned from the ConfigMap because k8s only allows us to specify ConfigMaps of Map<String, String>; so we're unable to interpret the yaml directly.

PollingRemoteConfigConfiguration - Class in io.confluent.remote.config.poller

PollingRemoteConfigConfiguration(ConfigDef, Map, boolean) - Constructor for class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

Constructor for child classes

PollingRemoteConfigurationSource<T> - Class in io.confluent.remote.config.poller

This PollingRemoteConfigurationSource class provides a generic polling implementation for remote configuration sources.

PollingRemoteConfigurationSource(long, Consumer, Class) - Constructor for class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

R

REFRESH_INTERVAL_SEC_CONFIG - Static variable in class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

REFRESH_INTERVAL_SEC_DOC - Static variable in class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

Region - Enum Class in io.confluent.remote.config.poller

RemoteConfigConfiguration - Class in io.confluent.remote.config.poller

RemoteConfigConfiguration(ConfigDef, Map, boolean) - Constructor for class io.confluent.remote.config.poller.RemoteConfigConfiguration

RemoteConfiguration - Interface in io.confluent.remote.config.poller

RemoteConfigurationSource<T> - Interface in io.confluent.remote.config.poller

RETRY_BACKOFF_MS - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

RETRY_BACKOFF_MS_DOC - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

S

SCHEMA_VERSION_CONFIG - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

SCHEMA_VERSION_DOC - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

setConfigurationChangeCallback(Consumer) - Method in class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

Only one callback can be registered.

setConfigurationChangeCallback(Consumer) - Method in interface io.confluent.remote.config.poller.RemoteConfigurationSource

Registers a callback to be called when the remote configuration has changed

start() - Method in class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

start() - Method in interface io.confluent.remote.config.poller.RemoteConfigurationSource

stop() - Method in class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

stop() - Method in interface io.confluent.remote.config.poller.RemoteConfigurationSource

U

useast1 - Enum constant in enum class io.confluent.remote.config.poller.Region

usgoveast1 - Enum constant in enum class io.confluent.remote.config.poller.Region

usgovwest1 - Enum constant in enum class io.confluent.remote.config.poller.Region

uswest2 - Enum constant in enum class io.confluent.remote.config.poller.Region

V

V1ConfigMap - Class in io.confluent.remote.config.poller.kubernetes

Custom object for Kubernetes V1ConfigMap We define the fields we need here instead of pulling all K8s APIs to keep the size of the jar small

V1ConfigMap(Map, V1ObjectMeta) - Constructor for class io.confluent.remote.config.poller.kubernetes.V1ConfigMap

V1ObjectMeta - Class in io.confluent.remote.config.poller.kubernetes

Custom object for Kubernetes configmap metadata name: The name of the kubernetes resource namespace: The namespace of the kubernetes resource resourceVersion: The version of the kubernetes resource

V1ObjectMeta(String, String, String) - Constructor for class io.confluent.remote.config.poller.kubernetes.V1ObjectMeta

valueOf(String) - Static method in enum class io.confluent.remote.config.poller.Region

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.confluent.remote.config.poller.Region

Returns an array containing the constants of this enum class, in the order they are declared.

C D E G H I K M N P R S U V
All Classes and Interfaces|All Packages|Constant Field Values