Package org.jdrupes.vmoperator.manager

Class PoolMonitor

java.lang.Object

org.jgrapes.core.internal.ComponentVertex

org.jgrapes.core.Component

org.jdrupes.vmoperator.manager.AbstractMonitor<K8sDynamicModel,K8sDynamicModels,Channel>

org.jdrupes.vmoperator.manager.PoolMonitor

All Implemented Interfaces:

Iterable<ComponentType>, Channel, ComponentType, Eligible, Manager

public class PoolMonitor
extends AbstractMonitor<K8sDynamicModel,K8sDynamicModels,Channel>

Watches for changes of VM pools.

Reports the changes using VmPoolChanged events fired on a special pipeline to avoid concurrent change informations.

Nested Class Summary

Nested classes/interfaces inherited from interface org.jgrapes.core.Channel

Channel.Default

Field Summary

Fields inherited from class org.jgrapes.core.Component

logger

Fields inherited from interface org.jgrapes.core.Channel

BROADCAST, SELF

Constructor Summary

Constructors

Constructor	Description
PoolMonitor(Channel componentChannel)	Instantiates a new VM pool manager.

Method Summary

Modifier and Type	Method	Description
protected void	handleChange(K8sClient client, io.kubernetes.client.util.Watch.Response<K8sDynamicModel> response)	Handle an observed change.
void	onAttached(Attached event)	On attached.
void	onGetPools(GetPools event)	Return the requested pools.
void	onVmResourceChanged(VmResourceChanged event)	Track VM definition changes.
protected void	prepareMonitoring()	Invoked by AbstractMonitor.onStart(Start) after the namespace has been configured and before starting the observer.

Methods inherited from class org.jdrupes.vmoperator.manager.AbstractMonitor

client, client, context, context, namespace, namespace, onConfigurationUpdate, onStart, options, options

Methods inherited from class org.jgrapes.core.Component

channel, component, defaultCriterion, isEligibleFor, setName

Methods inherited from class org.jgrapes.core.internal.ComponentVertex

activeEventPipeline, addHandler, attach, channelReplacements, children, componentPath, componentVertex, detach, fire, initComponentsHandlers, iterator, name, newEventPipeline, newEventPipeline, parent, registerAsGenerator, root, toString, unregisterAsGenerator

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.jgrapes.core.Manager

stream

Constructor Details

PoolMonitor

public PoolMonitor(Channel componentChannel)

Instantiates a new VM pool manager.

Parameters:

componentChannel - the component channel

Method Details

onAttached

@Handler
public void onAttached(Attached event)

On attached.

Parameters:

event - the event

prepareMonitoring

protected void prepareMonitoring()
                          throws IOException,
io.kubernetes.client.openapi.ApiException

Description copied from class: AbstractMonitor

Invoked by AbstractMonitor.onStart(Start) after the namespace has been configured and before starting the observer.

This is the last opportunity to invoke AbstractMonitor.context(APIResource).

Overrides:

prepareMonitoring in class AbstractMonitor<K8sDynamicModel,K8sDynamicModels,Channel>

Throws:

IOException - Signals that an I/O exception has occurred.

io.kubernetes.client.openapi.ApiException - the api exception

handleChange

protected void handleChange(K8sClient client,
 io.kubernetes.client.util.Watch.Response<K8sDynamicModel> response)

Description copied from class: AbstractMonitor

Handle an observed change.

The method is invoked by the observer thread(s). It is the responsibility of the implementing class to fire derived events on the appropriate event pipeline.

Specified by:

handleChange in class AbstractMonitor<K8sDynamicModel,K8sDynamicModels,Channel>

Parameters:

client - the client

response - the change

onVmResourceChanged

@Handler
public void onVmResourceChanged(VmResourceChanged event)
                         throws io.kubernetes.client.openapi.ApiException

Track VM definition changes.

Parameters:

event - the event

Throws:

io.kubernetes.client.openapi.ApiException

onGetPools

@Handler
public void onGetPools(GetPools event)

Return the requested pools.

Parameters:

event - the event