Package org.jdrupes.vmoperator.manager.events

Class VmChannel

java.lang.Object

org.jgrapes.core.Subchannel.DefaultSubchannel

org.jdrupes.vmoperator.manager.events.VmChannel

All Implemented Interfaces:

Associator, Channel, Eligible, Subchannel

public class VmChannel
extends Subchannel.DefaultSubchannel

A subchannel used to send the events related to a specific VM.

Nested Class Summary

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

Channel.Default

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

Subchannel.DefaultSubchannel

Field Summary

Fields inherited from interface org.jgrapes.core.Channel

BROADCAST, SELF

Constructor Summary

Constructors

Constructor	Description
VmChannel(Channel mainChannel, EventPipeline pipeline, K8sClient client)	Instantiates a new watch channel.

Method Summary

Modifier and Type	Method	Description
K8sClient	client()	Returns the API client.
long	generation()	Gets the last processed generation.
EventPipeline	pipeline()	Returns the pipeline.
boolean	setGeneration(long generation)	Sets the last processed generation.
VmChannel	setVmDefinition(VmDefinitionModel definition)	Sets the last known definition of the resource.
VmDefinitionModel	vmDefinition()	Returns the last known definition of the VM.

Methods inherited from class org.jgrapes.core.Subchannel.DefaultSubchannel

associated, mainChannel, setAssociated, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgrapes.core.Associator

associated, associated, associated, associatedGet

Methods inherited from interface org.jgrapes.core.Subchannel

defaultCriterion, isEligibleFor

Constructor Details

VmChannel

public VmChannel(Channel mainChannel,
 EventPipeline pipeline,
 K8sClient client)

Instantiates a new watch channel.

Parameters:

mainChannel - the main channel

pipeline - the pipeline

client - the client

Method Details

setVmDefinition

public VmChannel setVmDefinition(VmDefinitionModel definition)

Sets the last known definition of the resource.

Parameters:

definition - the definition

Returns:

the watch channel

vmDefinition

public VmDefinitionModel vmDefinition()

Returns the last known definition of the VM.

Returns:

the json object

generation

public long generation()

Gets the last processed generation.

Returns -1 if no definition has been processed yet.

Returns:

the generation

setGeneration

public boolean setGeneration(long generation)

Sets the last processed generation.

Parameters:

generation - the generation to set

Returns:

true if value has changed

pipeline

public EventPipeline pipeline()

Returns the pipeline.

Returns:

the event pipeline

client

public K8sClient client()

Returns the API client.

Returns:

the API client