Package com.linecorp.centraldogma.server.command

Class StandaloneCommandExecutor

java.lang.Object

com.linecorp.centraldogma.server.command.AbstractCommandExecutor

com.linecorp.centraldogma.server.command.StandaloneCommandExecutor

All Implemented Interfaces:

CommandExecutor

public class StandaloneCommandExecutor
extends AbstractCommandExecutor

A CommandExecutor implementation which performs operations on the local storage.

Constructor Summary

Constructors

Constructor	Description
StandaloneCommandExecutor(ProjectManager projectManager, Executor repositoryWorker, ServerStatusManager serverStatusManager, SessionManager sessionManager, EncryptionStorageManager encryptionStorageManager, Consumer<CommandExecutor> onTakeLeadership, Consumer<CommandExecutor> onReleaseLeadership, Consumer<CommandExecutor> onTakeZoneLeadership, Consumer<CommandExecutor> onReleaseZoneLeadership)	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
protected <T> CompletableFuture<T>	doExecute(Command<T> command)	Executes the specified Command.
protected void	doStart(Runnable onTakeLeadership, Runnable onReleaseLeadership, Runnable onTakeZoneLeadership, Runnable onReleaseZoneLeadership)	Starts the CommandExecutor.
protected void	doStop(Runnable onReleaseLeadership, Runnable onReleaseZoneLeadership)	Stops the CommandExecutor.
int	replicaId()	Returns the ID of a replica.

Methods inherited from class com.linecorp.centraldogma.server.command.AbstractCommandExecutor

execute, isStarted, isStopping, isWritable, setWritable, start, statusManager, stop, toString

Methods inherited from class java.lang.Object

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

Constructor Details

StandaloneCommandExecutor

public StandaloneCommandExecutor(ProjectManager projectManager,
 Executor repositoryWorker,
 ServerStatusManager serverStatusManager,
 @Nullable
 SessionManager sessionManager,
 EncryptionStorageManager encryptionStorageManager,
 @Nullable
 Consumer<CommandExecutor> onTakeLeadership,
 @Nullable
 Consumer<CommandExecutor> onReleaseLeadership,
 @Nullable
 Consumer<CommandExecutor> onTakeZoneLeadership,
 @Nullable
 Consumer<CommandExecutor> onReleaseZoneLeadership)

Creates a new instance.

Parameters:

projectManager - the project manager for accessing the storage

repositoryWorker - the executor which is used for performing storage operations

sessionManager - the session manager for creating/removing a session

onTakeLeadership - the callback to be invoked after the replica has taken the leadership

onReleaseLeadership - the callback to be invoked before the replica releases the leadership

onTakeZoneLeadership - the callback to be invoked after the replica has taken the zone leadership

onReleaseZoneLeadership - the callback to be invoked before the replica releases the zone leadership

Method Details

replicaId

public int replicaId()

Description copied from interface: CommandExecutor

Returns the ID of a replica.

doStart

protected void doStart(@Nullable
 Runnable onTakeLeadership,
 @Nullable
 Runnable onReleaseLeadership,
 @Nullable
 Runnable onTakeZoneLeadership,
 @Nullable
 Runnable onReleaseZoneLeadership)

Description copied from class: AbstractCommandExecutor

Starts the CommandExecutor.

Specified by:

doStart in class AbstractCommandExecutor

doStop

protected void doStop(@Nullable
 Runnable onReleaseLeadership,
 @Nullable
 Runnable onReleaseZoneLeadership)

Description copied from class: AbstractCommandExecutor

Stops the CommandExecutor.

Specified by:

doStop in class AbstractCommandExecutor

doExecute

protected <T> CompletableFuture<T> doExecute(Command<T> command)
                                      throws Exception

Description copied from class: AbstractCommandExecutor

Executes the specified Command.

Specified by:

doExecute in class AbstractCommandExecutor

Throws:

Exception