Package com.atlassian.bamboo

Class ClusterAwareLifecycleManagerImpl

java.lang.Object

com.atlassian.bamboo.ClusterAwareLifecycleManagerImpl

All Implemented Interfaces:

ClusterAwareLifecycleManager

public class ClusterAwareLifecycleManagerImpl
extends Object
implements ClusterAwareLifecycleManager

Constructor Summary

Constructors

Constructor

Description

ClusterAwareLifecycleManagerImpl(PlanExecutionLockService planExecutionLockService, BambooAuthenticationContext bambooAuthenticationContext, AuditLogService auditLogService, MessageListenerContainerController messageListenerContainerController, ChangeDetectionController changeDetectionController, IndexerManager indexerManager, org.quartz.Scheduler scheduler, ElasticInstanceManager elasticInstanceManager, AwsAccountBean awsAccountBean, BambooPluginManager bambooPluginManager, com.atlassian.plugin.metadata.PluginMetadataManager pluginMetadataManager, ElasticAccountBean elasticAccountBean, FlushableBuildLoggerManager buildLoggerManager, BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService, ClusterInfoManager clusterInfoManager, PluginClusterAwareService pluginClusterAwareService)

Method Summary

Modifier and Type	Method	Description
@NotNull NodeLifecycleState	getBufferedNodeLifecycleState()
@NotNull ClusterLifecycleState	getClusterLifecycleState()
@NotNull NodeLifecycleState	getNodeLifecycleState()
void	nodeRunning()	Puts the current node into the NodeLifecycleState.RUNNING state
void	nodeRunningAsSecondary()	Puts the current node into the NodeLifecycleState.RUNNING_AS_SECONDARY state
void	nodeStarting()	Puts the current node into the NodeLifecycleState.STARTING state
CompletableFuture<NodeLifecycleState>	pauseCluster()	Submits pause cluster request.
CompletableFuture<NodeLifecycleState>	pauseCluster(@NotNull NodeLifecycleState fakeNodeLifecycleState)	Submits pause cluster request with the context of the current node state being fakeNodeLifecycleState.
@NotNull NodeLifecycleState	prepareNodeForRestart()	Puts the current node into the NodeLifecycleState.PREPARING_FOR_RESTART state
boolean	refreshNodeLifecycleState()	Refreshes the cached NodeLifecycleState
@NotNull NodeLifecycleState	resumeCluster()	Puts the cluster into the NodeLifecycleState.RUNNING state

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterAwareLifecycleManagerImpl

public ClusterAwareLifecycleManagerImpl(PlanExecutionLockService planExecutionLockService,
                                        BambooAuthenticationContext bambooAuthenticationContext,
                                        AuditLogService auditLogService,
                                        MessageListenerContainerController messageListenerContainerController,
                                        ChangeDetectionController changeDetectionController,
                                        IndexerManager indexerManager,
                                        org.quartz.Scheduler scheduler,
                                        ElasticInstanceManager elasticInstanceManager,
                                        AwsAccountBean awsAccountBean,
                                        BambooPluginManager bambooPluginManager,
                                        com.atlassian.plugin.metadata.PluginMetadataManager pluginMetadataManager,
                                        ElasticAccountBean elasticAccountBean,
                                        FlushableBuildLoggerManager buildLoggerManager,
                                        BambooClusterNodeHeartbeatService bambooClusterNodeHeartbeatService,
                                        ClusterInfoManager clusterInfoManager,
                                        PluginClusterAwareService pluginClusterAwareService)

Method Detail

nodeStarting

public void nodeStarting()

Description copied from interface: ClusterAwareLifecycleManager

Puts the current node into the NodeLifecycleState.STARTING state

Specified by:

nodeStarting in interface ClusterAwareLifecycleManager

nodeRunning

public void nodeRunning()

Description copied from interface: ClusterAwareLifecycleManager

Puts the current node into the NodeLifecycleState.RUNNING state

Specified by:

nodeRunning in interface ClusterAwareLifecycleManager

nodeRunningAsSecondary

public void nodeRunningAsSecondary()

Description copied from interface: ClusterAwareLifecycleManager

Puts the current node into the NodeLifecycleState.RUNNING_AS_SECONDARY state

Specified by:

nodeRunningAsSecondary in interface ClusterAwareLifecycleManager

pauseCluster

public CompletableFuture<NodeLifecycleState> pauseCluster()

Description copied from interface: ClusterAwareLifecycleManager

Submits pause cluster request.

Specified by:

pauseCluster in interface ClusterAwareLifecycleManager

Returns:

Future for pause cluster operation

pauseCluster

public CompletableFuture<NodeLifecycleState> pauseCluster(@NotNull
                                                          @NotNull NodeLifecycleState fakeNodeLifecycleState)

Description copied from interface: ClusterAwareLifecycleManager

Submits pause cluster request with the context of the current node state being fakeNodeLifecycleState. This method is considered extremely unsafe because calling it might end up with an undermined node state.

Specified by:

pauseCluster in interface ClusterAwareLifecycleManager

Parameters:

fakeNodeLifecycleState - Node state in which context the pause cluster request is executed

Returns:

Future for force pause cluster operation

prepareNodeForRestart

@NotNull
public @NotNull NodeLifecycleState prepareNodeForRestart()

Description copied from interface: ClusterAwareLifecycleManager

Puts the current node into the NodeLifecycleState.PREPARING_FOR_RESTART state

Specified by:

prepareNodeForRestart in interface ClusterAwareLifecycleManager

Returns:

NodeLifecycleState of the current node

resumeCluster

@NotNull
public @NotNull NodeLifecycleState resumeCluster()

Description copied from interface: ClusterAwareLifecycleManager

Puts the cluster into the NodeLifecycleState.RUNNING state

Specified by:

resumeCluster in interface ClusterAwareLifecycleManager

Returns:

NodeLifecycleState of the current node

getNodeLifecycleState

@NotNull
public @NotNull NodeLifecycleState getNodeLifecycleState()

Specified by:

getNodeLifecycleState in interface ClusterAwareLifecycleManager

Returns:

gets the NodeLifecycleState of the current node

getBufferedNodeLifecycleState

@NotNull
public @NotNull NodeLifecycleState getBufferedNodeLifecycleState()

Specified by:

getBufferedNodeLifecycleState in interface ClusterAwareLifecycleManager

Returns:

gets the cached NodeLifecycleState of the current node, the result is eventually consistent

refreshNodeLifecycleState

public boolean refreshNodeLifecycleState()

Description copied from interface: ClusterAwareLifecycleManager

Refreshes the cached NodeLifecycleState

Specified by:

refreshNodeLifecycleState in interface ClusterAwareLifecycleManager

Returns:

whether the refresh was successfully performed

getClusterLifecycleState

@NotNull
public @NotNull ClusterLifecycleState getClusterLifecycleState()

Specified by:

getClusterLifecycleState in interface ClusterAwareLifecycleManager

Returns:

gets the ClusterLifecycleState of the cluster