Package org.apache.openjpa.event.kubernetes

Class KubernetesTCPRemoteCommitProvider

java.lang.Object

org.apache.openjpa.event.AbstractRemoteCommitProvider

org.apache.openjpa.event.TCPRemoteCommitProvider

org.apache.openjpa.event.DynamicTCPRemoteCommitProvider

org.apache.openjpa.event.kubernetes.KubernetesTCPRemoteCommitProvider

All Implemented Interfaces:

RemoteCommitProvider, Configurable, Closeable

public class KubernetesTCPRemoteCommitProvider
extends DynamicTCPRemoteCommitProvider

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.openjpa.event.TCPRemoteCommitProvider

TCPRemoteCommitProvider.HostAddress

Field Summary

Fields inherited from class org.apache.openjpa.event.TCPRemoteCommitProvider

_addresses, _addressesLock, _port

Fields inherited from class org.apache.openjpa.event.AbstractRemoteCommitProvider

eventManager, log

Constructor Summary

Constructors

Constructor	Description
KubernetesTCPRemoteCommitProvider()

Method Summary

Modifier and Type	Method	Description
protected List<String>	fetchDynamicAddresses()
String	getLabel()
String	getNamespace()
protected io.fabric8.kubernetes.client.KubernetesClient	kubernetesClient()
void	setLabel(String label)
void	setNamespace(String namespace)

Methods inherited from class org.apache.openjpa.event.DynamicTCPRemoteCommitProvider

endConfiguration, getCacheDurationMillis, setAddresses, setCacheDurationMillis

Methods inherited from class org.apache.openjpa.event.TCPRemoteCommitProvider

broadcast, close, getMaxIdle, getMaxTotal, getNumBroadcastThreads, getPort, getRecoveryTimeMillis, setMaxActive, setMaxIdle, setMaxTotal, setNumBroadcastThreads, setPort, setRecoveryTimeMillis

Methods inherited from class org.apache.openjpa.event.AbstractRemoteCommitProvider

fireEvent, setConfiguration, setRemoteCommitEventManager, startConfiguration

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.openjpa.lib.conf.Configurable

setConfiguration, startConfiguration

Constructor Details

KubernetesTCPRemoteCommitProvider

public KubernetesTCPRemoteCommitProvider()
                                  throws UnknownHostException

Throws:

UnknownHostException

Method Details

getNamespace

public String getNamespace()

setNamespace

public void setNamespace(String namespace)

getLabel

public String getLabel()

setLabel

public void setLabel(String label)

kubernetesClient

protected io.fabric8.kubernetes.client.KubernetesClient kubernetesClient()
                                                                  throws io.fabric8.kubernetes.client.KubernetesClientException

Throws:

io.fabric8.kubernetes.client.KubernetesClientException

fetchDynamicAddresses

protected List<String> fetchDynamicAddresses()

Specified by:

fetchDynamicAddresses in class DynamicTCPRemoteCommitProvider