Package org.apache.ignite.internal.cluster

Class DistributedBaselineConfiguration

java.lang.Object

org.apache.ignite.internal.cluster.DistributedBaselineConfiguration

All Implemented Interfaces:

IgniteChangeGlobalStateSupport

public class DistributedBaselineConfiguration
extends Object
implements IgniteChangeGlobalStateSupport

Distributed baseline configuration.

Constructor Summary

Constructors

Constructor	Description
DistributedBaselineConfiguration(GridInternalSubscriptionProcessor isp, GridKernalContext ctx, IgniteLogger log)

Method Summary

Modifier and Type	Method	Description
long	getBaselineAutoAdjustTimeout()
boolean	isBaselineAutoAdjustEnabled()
void	listenAutoAdjustEnabled(DistributePropertyListener<? super Boolean> lsnr)
void	listenAutoAdjustTimeout(DistributePropertyListener<? super Long> lsnr)
void	onActivate(GridKernalContext kctx)	Called when cluster performing activation.
void	onDeActivate(GridKernalContext kctx)	Called when cluster performing deactivation.
GridFutureAdapter<?>	updateBaselineAutoAdjustEnabledAsync(boolean baselineAutoAdjustEnabled)
GridFutureAdapter<?>	updateBaselineAutoAdjustTimeoutAsync(long baselineAutoAdjustTimeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedBaselineConfiguration

public DistributedBaselineConfiguration(GridInternalSubscriptionProcessor isp,
                                        GridKernalContext ctx,
                                        IgniteLogger log)

Parameters:

isp - Subscription processor.

ctx - Kernal context.

Method Detail

listenAutoAdjustEnabled

public void listenAutoAdjustEnabled(DistributePropertyListener<? super Boolean> lsnr)

listenAutoAdjustTimeout

public void listenAutoAdjustTimeout(DistributePropertyListener<? super Long> lsnr)

onActivate

public void onActivate(GridKernalContext kctx)
                throws IgniteCheckedException

Called when cluster performing activation.

Specified by:

onActivate in interface IgniteChangeGlobalStateSupport

Parameters:

kctx - Kernal context.

Throws:

IgniteCheckedException - If failed.

onDeActivate

public void onDeActivate(GridKernalContext kctx)

Called when cluster performing deactivation.

Specified by:

onDeActivate in interface IgniteChangeGlobalStateSupport

Parameters:

kctx - Kernal context.

isBaselineAutoAdjustEnabled

public boolean isBaselineAutoAdjustEnabled()

Returns:

Value of manual baseline control or auto adjusting baseline.

updateBaselineAutoAdjustEnabledAsync

public GridFutureAdapter<?> updateBaselineAutoAdjustEnabledAsync(boolean baselineAutoAdjustEnabled)
                                                          throws IgniteCheckedException

Parameters:

baselineAutoAdjustEnabled - Value of manual baseline control or auto adjusting baseline.

Throws:

IgniteCheckedException - if failed.

getBaselineAutoAdjustTimeout

public long getBaselineAutoAdjustTimeout()

Returns:

Value of time which we would wait before the actual topology change since last discovery event(node join/exit).

updateBaselineAutoAdjustTimeoutAsync

public GridFutureAdapter<?> updateBaselineAutoAdjustTimeoutAsync(long baselineAutoAdjustTimeout)
                                                          throws IgniteCheckedException

Parameters:

baselineAutoAdjustTimeout - Value of time which we would wait before the actual topology change since last discovery event(node join/exit).

Throws:

IgniteCheckedException - If failed.