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 java.lang.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 and Description
IndexerComposite()

Method Summary

Modifier and Type	Method and Description
protected void	add(java.lang.String namespace, io.kubernetes.client.informer.cache.Indexer<ApiType> sharedIndexInformer) Add Indexer to the composite.
reactor.core.publisher.Mono<ApiType>	getResource(java.lang.String name, java.lang.String namespace) Get resource from the Indexer.
reactor.core.publisher.Flux<ApiType>	getResources(java.lang.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 Detail

IndexerComposite

public IndexerComposite()

Method Detail

add

protected void add(java.lang.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
                                                        java.lang.String name,
                                                        @NonNull
                                                        java.lang.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
                                                         java.lang.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