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, QuotaConfig writeQuota, Consumer<CommandExecutor> onTakeLeadership, Consumer<CommandExecutor> onReleaseLeadership, Consumer<CommandExecutor> onTakeZoneLeadership, Consumer<CommandExecutor> onReleaseZoneLeadership)	Creates a new instance.
StandaloneCommandExecutor(ProjectManager projectManager, Executor repositoryWorker, ServerStatusManager serverStatusManager, SessionManager sessionManager, 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)
protected void	doStart(Runnable onTakeLeadership, Runnable onReleaseLeadership, Runnable onTakeZoneLeadership, Runnable onReleaseZoneLeadership)
protected void	doStop(Runnable onReleaseLeadership, Runnable onReleaseZoneLeadership)
int	replicaId()	Returns the ID of a replica.
final void	setWriteQuota(String projectName, String repoName, QuotaConfig writeQuota)	Sets the specified write quota to the specified repoName in the specified projectName.

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,
 @Nullable
 QuotaConfig writeQuota,
 @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

serverStatusManager - the server status manager for updating the server status

sessionManager - the session manager for creating/removing a session

writeQuota - the write quota for limiting NormalizingPushCommand

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

StandaloneCommandExecutor

public StandaloneCommandExecutor(ProjectManager projectManager,
 Executor repositoryWorker,
 ServerStatusManager serverStatusManager,
 @Nullable
 SessionManager sessionManager,
 @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)

Specified by:

doStart in class AbstractCommandExecutor

doStop

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

Specified by:

doStop in class AbstractCommandExecutor

doExecute

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

Specified by:

doExecute in class AbstractCommandExecutor

Throws:

Exception

setWriteQuota

public final void setWriteQuota(String projectName,
 String repoName,
 @Nullable
 QuotaConfig writeQuota)

Description copied from interface: CommandExecutor

Sets the specified write quota to the specified repoName in the specified projectName.