Package io.micronaut.kubernetes.discovery.informer

Class IndexerComposite<ApiType extends io.kubernetes.client.common.KubernetesObject>

java.lang.Object

io.micronaut.kubernetes.discovery.informer.IndexerComposite<ApiType>

Type Parameters:

ApiType - api type of the cache

@Internal
public class IndexerComposite<ApiType extends io.kubernetes.client.common.KubernetesObject>
extends Object

The Indexer composite for the given ApiType that provides access to the Store resources.

Since:

3.2

Author:

Pavol Gressa

Constructor Summary

Constructors

Constructor	Description
IndexerComposite()

Method Summary

Modifier and Type	Method	Description
protected void	add(String namespace, io.kubernetes.client.informer.cache.Indexer<ApiType> sharedIndexInformer)	Add Indexer to the composite.
reactor.core.publisher.Mono<ApiType>	getResource(@NonNull String name, @NonNull String namespace)	Get resource from the Indexer.
reactor.core.publisher.Flux<ApiType>	getResources(@NonNull String namespace)	Get all resources from the Indexer for given namespace.

Methods inherited from class java.lang.Object

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

Constructor Details

IndexerComposite

public IndexerComposite()

Method Details

add

protected void add(String namespace,
 io.kubernetes.client.informer.cache.Indexer<ApiType> sharedIndexInformer)

Add Indexer to the composite.

Parameters:

namespace - namespace of indexer

sharedIndexInformer - indexer

getResource

public reactor.core.publisher.Mono<ApiType> getResource(@NonNull
 @NonNull String name,
 @NonNull
 @NonNull String namespace)

Get resource from the Indexer.

Parameters:

name - resource name

namespace - resource namesapce

Returns:

mono with the resource or empty mono

getResources

public reactor.core.publisher.Flux<ApiType> getResources(@NonNull
 @NonNull String namespace)

Get all resources from the Indexer for given namespace.

Parameters:

namespace - namespace name or null to get resources from all namespaces

Returns:

mono with resources or empty mono