Package org.apache.ignite.internal.processors.service

Class ServiceClusterDeploymentResultBatch

java.lang.Object

org.apache.ignite.internal.processors.service.ServiceClusterDeploymentResultBatch

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage

public class ServiceClusterDeploymentResultBatch
extends Object
implements DiscoveryCustomMessage

Batch of services cluster deployment result.

Contains collection of ServiceClusterDeploymentResult.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ServiceClusterDeploymentResultBatch(@NotNull ServiceDeploymentProcessId depId, @NotNull Collection<ServiceClusterDeploymentResult> results)

Method Summary

Modifier and Type	Method	Description
@Nullable DiscoveryCustomMessage	ackMessage()	Called when custom message has been handled by all nodes.
DiscoCache	createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)	Creates new discovery cache if message caused topology version change.
ServiceDeploymentProcessId	deploymentId()
IgniteUuid	id()
boolean	isMutable()
Collection<ServiceClusterDeploymentResult>	results()
@Nullable ServiceDeploymentActions	servicesDeploymentActions()
void	servicesDeploymentActions(ServiceDeploymentActions serviceDeploymentActions)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage

stopProcess

Constructor Detail

ServiceClusterDeploymentResultBatch

public ServiceClusterDeploymentResultBatch(@NotNull
                                           @NotNull ServiceDeploymentProcessId depId,
                                           @NotNull
                                           @NotNull Collection<ServiceClusterDeploymentResult> results)

Parameters:

depId - Deployment process id.

results - Services deployments results.

Method Detail

deploymentId

public ServiceDeploymentProcessId deploymentId()

Returns:

Deployment process id.

results

public Collection<ServiceClusterDeploymentResult> results()

Returns:

Services deployments results.

servicesDeploymentActions

@Nullable
public @Nullable ServiceDeploymentActions servicesDeploymentActions()

Returns:

Services deployment actions to be processed on services deployment process.

servicesDeploymentActions

public void servicesDeploymentActions(ServiceDeploymentActions serviceDeploymentActions)

Parameters:

serviceDeploymentActions - Services deployment actions to be processed on services deployment process.

id

public IgniteUuid id()

Specified by:

id in interface DiscoveryCustomMessage

Returns:

Unique custom message ID.

ackMessage

@Nullable
public @Nullable DiscoveryCustomMessage ackMessage()

Called when custom message has been handled by all nodes.

Specified by:

ackMessage in interface DiscoveryCustomMessage

Returns:

Ack message or null if ack is not required.

isMutable

public boolean isMutable()

Specified by:

isMutable in interface DiscoveryCustomMessage

Returns:

True if message can be modified during listener notification. Changes will be sent to next nodes.

createDiscoCache

public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
                                   AffinityTopologyVersion topVer,
                                   DiscoCache discoCache)

Creates new discovery cache if message caused topology version change.

Specified by:

createDiscoCache in interface DiscoveryCustomMessage

Parameters:

mgr - Discovery manager.

topVer - New topology version.

discoCache - Current discovery cache.

Returns:

Reused discovery cache.

toString

public String toString()

Overrides:

toString in class Object