io.micronaut.kubernetes.discovery

Class AbstractKubernetesServiceInstanceProvider

java.lang.Object

io.micronaut.kubernetes.discovery.AbstractKubernetesServiceInstanceProvider

All Implemented Interfaces:

KubernetesServiceInstanceProvider

Direct Known Subclasses:

KubernetesServiceInstanceEndpointProvider, KubernetesServiceInstanceServiceProvider

public abstract class AbstractKubernetesServiceInstanceProvider
extends java.lang.Object
implements KubernetesServiceInstanceProvider

Abstract implementation of kubernetes service instance provider.

Since:

2.3

Author:

Pavol Gressa

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
AbstractKubernetesServiceInstanceProvider()

Method Summary

Modifier and Type	Method and Description
io.micronaut.discovery.ServiceInstance	buildServiceInstance(java.lang.String serviceId, Port port, java.net.InetAddress address, Metadata metadata) Builds service instance.
io.reactivex.functions.Predicate<KubernetesObject>	compositePredicate(io.reactivex.functions.Predicate<KubernetesObject>... predicates) Creates composite of predicates.
boolean	hasValidPortConfiguration(java.util.List<Port> ports, KubernetesServiceConfiguration serviceConfiguration) Validates the necessity of having port configuration based on numbe of ports.

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.discovery.KubernetesServiceInstanceProvider

getInstances, getMode

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

AbstractKubernetesServiceInstanceProvider

public AbstractKubernetesServiceInstanceProvider()

Method Detail

hasValidPortConfiguration

public boolean hasValidPortConfiguration(java.util.List<Port> ports,
                                         KubernetesServiceConfiguration serviceConfiguration)

Validates the necessity of having port configuration based on numbe of ports.

Parameters:

ports - list of ports

serviceConfiguration - service configuration

Returns:

true if the port configuration is valid otherwise false

Throws:

java.lang.IllegalArgumentException - if the configuration is invalid e.g. is missing port configuration

buildServiceInstance

public io.micronaut.discovery.ServiceInstance buildServiceInstance(java.lang.String serviceId,
                                                                   Port port,
                                                                   java.net.InetAddress address,
                                                                   Metadata metadata)

Builds service instance.

Parameters:

serviceId - service id

port - port

address - address

metadata - metadata

Returns:

service instance

compositePredicate

@SafeVarargs
public final io.reactivex.functions.Predicate<KubernetesObject> compositePredicate(io.reactivex.functions.Predicate<KubernetesObject>... predicates)

Creates composite of predicates.

Parameters:

predicates - predicates

Returns:

predicate