Package org.jdrupes.vmoperator.manager

Class VmMonitor

java.lang.Object

org.jgrapes.core.internal.ComponentVertex

org.jgrapes.core.Component

org.jdrupes.vmoperator.manager.AbstractMonitor<VmDefinition,VmDefinitions,VmChannel>

org.jdrupes.vmoperator.manager.VmMonitor

All Implemented Interfaces:

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

public class VmMonitor
extends AbstractMonitor<VmDefinition,VmDefinitions,VmChannel>

Watches for changes of VM definitions.

When a VM definition (CR) becomes known, is is registered with a ChannelManager and thus gets an associated VmChannel and an associated EventPipeline.

The EventPipeline is used for submitting an action that processes the change data from kubernetes, eventually transforming it to a VmResourceChanged event that is handled by another EventPipeline associated with the VmChannel. This event pipeline should be used for all events related to changes of a particular VM.

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
VmMonitor(Channel componentChannel, ChannelManager<String,VmChannel,EventPipeline> channelManager)	Instantiates a new VM definition watcher.

Method Summary

Modifier and Type	Method	Description
protected void	handleChange(K8sClient client, io.kubernetes.client.util.Watch.Response<VmDefinition> response)	Handle an observed change.
void	onModifyVm(ModifyVm event, VmChannel channel)	On modify vm.
void	onPodChanged(PodChanged event, VmChannel channel)	On pod changed.
void	onUpdatedAssignment(UpdateAssignment event, VmChannel channel)	Attempt to Update the assignment information in the status of the VM CR.
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

VmMonitor

public VmMonitor(Channel componentChannel,
 ChannelManager<String,VmChannel,EventPipeline> channelManager)

Instantiates a new VM definition watcher.

Parameters:

componentChannel - the component channel

channelManager - the channel manager

Method Details

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<VmDefinition,VmDefinitions,VmChannel>

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<VmDefinition> 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<VmDefinition,VmDefinitions,VmChannel>

Parameters:

client - the client

response - the change

onPodChanged

@Handler
public void onPodChanged(PodChanged event,
 VmChannel channel)

On pod changed.

Parameters:

event - the event

channel - the channel

onModifyVm

@Handler
public void onModifyVm(ModifyVm event,
 VmChannel channel)
                throws io.kubernetes.client.openapi.ApiException,
IOException

On modify vm.

Parameters:

event - the event

Throws:

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

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

onUpdatedAssignment

@Handler
public void onUpdatedAssignment(UpdateAssignment event,
 VmChannel channel)
                         throws io.kubernetes.client.openapi.ApiException

Attempt to Update the assignment information in the status of the VM CR.

Returns true if successful. The handler does not attempt retries, because in case of failure it will be necessary to re-evaluate the chosen VM.

Parameters:

event - the event

channel - the channel

Throws:

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