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, @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.

Method Summary

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

Methods inherited from class AbstractCommandExecutor

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

Methods inherited from class Object

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

Methods inherited from interface CommandExecutor

execute

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(ExecutionContext ctx,
 Command<T> command)
                                      throws Exception

Description copied from class: AbstractCommandExecutor

Executes the specified Command.

Specified by:

doExecute in class AbstractCommandExecutor

Throws:

Exception