Package com.linecorp.centraldogma.server.command

Class ForwardingCommandExecutor

java.lang.Object

com.linecorp.centraldogma.server.command.ForwardingCommandExecutor

All Implemented Interfaces:

CommandExecutor

public class ForwardingCommandExecutor
extends Object
implements CommandExecutor

A CommandExecutor which forwards all its method calls to another CommandExecutor.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ForwardingCommandExecutor(CommandExecutor delegate)

Method Summary

Modifier and Type	Method	Description
protected final <T extends CommandExecutor> T	delegate()
<T> CompletableFuture<T>	execute(Command<T> command)	Executes the specified Command.
boolean	isStarted()	Returns true if the executor is started.
boolean	isWritable()	Returns true if the executor can accept the Commands making a change to the replica.
int	replicaId()	Returns the ID of a replica.
void	setWritable(boolean writable)	Makes the executor read/write mode or read-only mode.
void	setWriteQuota(String projectName, String repoName, QuotaConfig writeQuota)	Sets the specified write quota to the specified repoName in the specified projectName.
CompletableFuture<Void>	start()	Starts the executor.
CommandExecutorStatusManager	statusManager()	Returns the status manager of this executor.
CompletableFuture<Void>	stop()	Stops the executor.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ForwardingCommandExecutor

protected ForwardingCommandExecutor(CommandExecutor delegate)

Method Details

delegate

protected final <T extends CommandExecutor> T delegate()

replicaId

public int replicaId()

Description copied from interface: CommandExecutor

Returns the ID of a replica.

Specified by:

replicaId in interface CommandExecutor

isStarted

public boolean isStarted()

Description copied from interface: CommandExecutor

Returns true if the executor is started.

Specified by:

isStarted in interface CommandExecutor

start

public CompletableFuture<Void> start()

Description copied from interface: CommandExecutor

Starts the executor.

Specified by:

start in interface CommandExecutor

stop

public CompletableFuture<Void> stop()

Description copied from interface: CommandExecutor

Stops the executor.

Specified by:

stop in interface CommandExecutor

isWritable

public boolean isWritable()

Description copied from interface: CommandExecutor

Returns true if the executor can accept the Commands making a change to the replica. false would be returned if the replica is running as a read-only mode.

Specified by:

isWritable in interface CommandExecutor

setWritable

public void setWritable(boolean writable)

Description copied from interface: CommandExecutor

Makes the executor read/write mode or read-only mode.

Specified by:

setWritable in interface CommandExecutor

Parameters:

writable - true to make the executor read/write mode, or false to make it read-only mode

setWriteQuota

public void setWriteQuota(String projectName,
 String repoName,
 QuotaConfig writeQuota)

Description copied from interface: CommandExecutor

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

Specified by:

setWriteQuota in interface CommandExecutor

execute

public <T> CompletableFuture<T> execute(Command<T> command)

Description copied from interface: CommandExecutor

Executes the specified Command.

Specified by:

execute in interface CommandExecutor

Type Parameters:

T - the type of the result to be returned

Parameters:

command - the command which is supposed to be executed

statusManager

public CommandExecutorStatusManager statusManager()

Description copied from interface: CommandExecutor

Returns the status manager of this executor.

Specified by:

statusManager in interface CommandExecutor

toString

public String toString()

Overrides:

toString in class Object