Class KubernetesApiDiscovery

java.lang.Object

com.loomcache.server.discovery.KubernetesApiDiscovery

All Implemented Interfaces:

DiscoveryStrategy

public final class KubernetesApiDiscovery
extends Object
implements DiscoveryStrategy

Kubernetes API-backed peer discovery.

This implementation stays within the existing discovery surface: it talks directly to the Kubernetes API server, discovers peer pod addresses, and periodically refreshes the cached peer list. It does not assume any operator, Helm chart, or external control plane.

Constructor Summary

Constructors

Constructor	Description
KubernetesApiDiscovery(KubernetesApiDiscoveryConfig config)
KubernetesApiDiscovery(KubernetesApiDiscoveryConfig config, @Nullable io.micrometer.core.instrument.MeterRegistry meterRegistry)

Method Summary

Modifier and Type	Method	Description
List<PeerAddress>	discoverPeers()	Discover available peers.
String	getName()	Get the name of this discovery strategy.
void	start()	Start the discovery strategy.
void	stop()	Stop the discovery strategy and release resources.

Methods inherited from class Object

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

Constructor Details

KubernetesApiDiscovery

public KubernetesApiDiscovery(KubernetesApiDiscoveryConfig config)

KubernetesApiDiscovery

public KubernetesApiDiscovery(KubernetesApiDiscoveryConfig config,
 @Nullable io.micrometer.core.instrument.MeterRegistry meterRegistry)

Method Details

discoverPeers

public List<PeerAddress> discoverPeers()

Description copied from interface: DiscoveryStrategy

Discover available peers.

Returns a snapshot of currently known peers. If no peers are available, an empty list is returned (not null). The returned list is mutable and modifications should not affect internal strategy state.

Specified by:

discoverPeers in interface DiscoveryStrategy

Returns:

list of discovered peer addresses; empty list if none available

start

public void start()
           throws IOException,
GeneralSecurityException

Description copied from interface: DiscoveryStrategy

Start the discovery strategy.

Initializes the discovery mechanism and starts any background threads or I/O operations (e.g., watching files, listening to multicast, resolving DNS). Implementations must handle errors gracefully and should not leave resources in an inconsistent state if startup fails.

Specified by:

start in interface DiscoveryStrategy

Throws:

IOException

GeneralSecurityException

stop

public void stop()

Description copied from interface: DiscoveryStrategy

Stop the discovery strategy and release resources.

Cleanly shuts down the discovery mechanism, including stopping any background threads and closing I/O resources. Safe to call multiple times and must be idempotent (calling twice should have no additional effect).

Specified by:

stop in interface DiscoveryStrategy

getName

public String getName()

Description copied from interface: DiscoveryStrategy

Get the name of this discovery strategy.

Used for logging, metrics, and debugging purposes.

Specified by:

getName in interface DiscoveryStrategy

Returns:

human-readable strategy name (e.g., "FileBasedDiscovery", "MulticastDiscovery")