io.micronaut.kubernetes.client.informer

Class DefaultSharedIndexInformerFactory

java.lang.Object

io.kubernetes.client.informer.SharedInformerFactory

io.micronaut.kubernetes.client.informer.DefaultSharedIndexInformerFactory

All Implemented Interfaces:

SharedIndexInformerFactory

@Requires(property="kubernetes.client.informer.enabled",
          notEquals="false",
          defaultValue="true")
 @Singleton
public class DefaultSharedIndexInformerFactory
extends io.kubernetes.client.informer.SharedInformerFactory
implements SharedIndexInformerFactory

Default implementation of the SharedIndexInformerFactory. The created SharedIndexInformer is shared in scope of the namespace.

Since:

3.1

Author:

Pavol Gressa

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	INFORMER_ENABLED

Fields inherited from class io.kubernetes.client.informer.SharedInformerFactory

informers

Constructor Summary

Constructors

Constructor and Description
DefaultSharedIndexInformerFactory(InformerConfiguration informerConfiguration, io.kubernetes.client.openapi.ApiClient apiClient) Creates DefaultSharedIndexInformer.

Method Summary

Modifier and Type	Method and Description
<ApiType extends io.kubernetes.client.common.KubernetesObject> io.kubernetes.client.informer.SharedIndexInformer<ApiType>	getExistingSharedIndexInformer(java.lang.String namespace, java.lang.Class<ApiType> apiTypeClass) Get existing SharedIndexInformer.
java.util.List<io.kubernetes.client.informer.SharedIndexInformer>	getExistingSharedIndexInformers() Get all existing SharedIndexInformer.
<ApiType extends io.kubernetes.client.common.KubernetesObject,ApiListType extends io.kubernetes.client.common.KubernetesListObject> io.kubernetes.client.informer.SharedIndexInformer<ApiType>	sharedIndexInformerFor(java.lang.Class<ApiType> apiType, java.lang.Class<ApiListType> apiListType, java.lang.String resourcePlural, java.lang.String apiGroup, java.lang.String namespace, java.lang.String labelSelector, java.lang.Long resyncCheckPeriod, boolean waitForSync) Creates new SharedIndexInformer.
<ApiType extends io.kubernetes.client.common.KubernetesObject,ApiListType extends io.kubernetes.client.common.KubernetesListObject> java.util.List<io.kubernetes.client.informer.SharedIndexInformer<? extends io.kubernetes.client.common.KubernetesObject>>	sharedIndexInformersFor(java.lang.Class<ApiType> apiTypeClass, java.lang.Class<ApiListType> apiListTypeClass, java.lang.String resourcePlural, java.lang.String apiGroup, java.util.List<java.lang.String> namespaces, java.lang.String labelSelector, java.lang.Long resyncCheckPeriod, boolean waitForSync) Creates new SharedIndexInformers for every namespace from namespaces param.
void	stopAllRegisteredInformers() Stop all registered informers.

Methods inherited from class io.kubernetes.client.informer.SharedInformerFactory

getExistingSharedIndexInformer, sharedIndexInformerFor, sharedIndexInformerFor, sharedIndexInformerFor, sharedIndexInformerFor, sharedIndexInformerFor, startAllRegisteredInformers, stopAllRegisteredInformers

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.kubernetes.client.informer.SharedIndexInformerFactory

startAllRegisteredInformers

Field Detail

INFORMER_ENABLED

public static final java.lang.String INFORMER_ENABLED

See Also:

Constant Field Values

Constructor Detail

DefaultSharedIndexInformerFactory

public DefaultSharedIndexInformerFactory(InformerConfiguration informerConfiguration,
                                         io.kubernetes.client.openapi.ApiClient apiClient)

Creates DefaultSharedIndexInformer.

Parameters:

informerConfiguration - informer configuration

apiClient - api client

Method Detail

sharedIndexInformerFor

public <ApiType extends io.kubernetes.client.common.KubernetesObject,ApiListType extends io.kubernetes.client.common.KubernetesListObject> io.kubernetes.client.informer.SharedIndexInformer<ApiType> sharedIndexInformerFor(java.lang.Class<ApiType> apiType,
                                                                                                                                                                                                                             java.lang.Class<ApiListType> apiListType,
                                                                                                                                                                                                                             java.lang.String resourcePlural,
                                                                                                                                                                                                                             java.lang.String apiGroup,
                                                                                                                                                                                                                             @Nullable
                                                                                                                                                                                                                             java.lang.String namespace,
                                                                                                                                                                                                                             @Nullable
                                                                                                                                                                                                                             java.lang.String labelSelector,
                                                                                                                                                                                                                             @Nullable
                                                                                                                                                                                                                             java.lang.Long resyncCheckPeriod,
                                                                                                                                                                                                                             boolean waitForSync)

Description copied from interface: SharedIndexInformerFactory

Creates new SharedIndexInformer.

Specified by:

sharedIndexInformerFor in interface SharedIndexInformerFactory

Type Parameters:

ApiType - api type

ApiListType - api list type

Parameters:

apiType - api type class

apiListType - api list type class

resourcePlural - resource api group

apiGroup - resource plural

namespace - namespace

labelSelector - label selector

resyncCheckPeriod - resync check period

waitForSync - wait to let informer sync the resources

Returns:

list of informers

sharedIndexInformersFor

public <ApiType extends io.kubernetes.client.common.KubernetesObject,ApiListType extends io.kubernetes.client.common.KubernetesListObject> java.util.List<io.kubernetes.client.informer.SharedIndexInformer<? extends io.kubernetes.client.common.KubernetesObject>> sharedIndexInformersFor(java.lang.Class<ApiType> apiTypeClass,
                                                                                                                                                                                                                                                                                             java.lang.Class<ApiListType> apiListTypeClass,
                                                                                                                                                                                                                                                                                             java.lang.String resourcePlural,
                                                                                                                                                                                                                                                                                             java.lang.String apiGroup,
                                                                                                                                                                                                                                                                                             @Nullable
                                                                                                                                                                                                                                                                                             java.util.List<java.lang.String> namespaces,
                                                                                                                                                                                                                                                                                             @Nullable
                                                                                                                                                                                                                                                                                             java.lang.String labelSelector,
                                                                                                                                                                                                                                                                                             @Nullable
                                                                                                                                                                                                                                                                                             java.lang.Long resyncCheckPeriod,
                                                                                                                                                                                                                                                                                             boolean waitForSync)

Description copied from interface: SharedIndexInformerFactory

Creates new SharedIndexInformers for every namespace from namespaces param.

Specified by:

sharedIndexInformersFor in interface SharedIndexInformerFactory

Type Parameters:

ApiType - api type

ApiListType - api list type

Parameters:

apiTypeClass - api type class

apiListTypeClass - api list type class

resourcePlural - resource plural

apiGroup - resource api group

namespaces - namespaces

labelSelector - label selector

resyncCheckPeriod - resync check period

waitForSync - wait to let informer sync the resources

Returns:

list of informers

stopAllRegisteredInformers

public void stopAllRegisteredInformers()

Description copied from interface: SharedIndexInformerFactory

Stop all registered informers.

Specified by:

stopAllRegisteredInformers in interface SharedIndexInformerFactory

Overrides:

stopAllRegisteredInformers in class io.kubernetes.client.informer.SharedInformerFactory

getExistingSharedIndexInformer

public <ApiType extends io.kubernetes.client.common.KubernetesObject> io.kubernetes.client.informer.SharedIndexInformer<ApiType> getExistingSharedIndexInformer(java.lang.String namespace,
                                                                                                                                                                java.lang.Class<ApiType> apiTypeClass)

Description copied from interface: SharedIndexInformerFactory

Get existing SharedIndexInformer.

Specified by:

getExistingSharedIndexInformer in interface SharedIndexInformerFactory

Type Parameters:

ApiType - api type

Parameters:

namespace - namespace

apiTypeClass - api type class

Returns:

shared index informer or null if not found

getExistingSharedIndexInformers

public java.util.List<io.kubernetes.client.informer.SharedIndexInformer> getExistingSharedIndexInformers()

Description copied from interface: SharedIndexInformerFactory

Get all existing SharedIndexInformer.

Specified by:

getExistingSharedIndexInformers in interface SharedIndexInformerFactory

Returns:

list of existing shared informers