Package org.rostore.v2.container.async

Class ContainerShardExecutor

java.lang.Object

org.rostore.v2.container.async.ContainerShardExecutor

public class ContainerShardExecutor
extends Object

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ContainerShardExecutor(AsyncContainer asyncContainer, ContainerShard shard)

Method Summary

Modifier and Type	Method	Description
<R> Future<R>	execute(Operation<R> operation, boolean failInShutdown)
<R> Future<R>	executeAutonomousValue(int sessionId, OperationType opsType, long valueId, boolean failInShutdown, Runnable valueOp)
<R> Future<R>	executeKey(int sessionId, OperationType opsType, boolean failInShutdown, Function<ContainerShardKeyOperations,R> opsConsumer)
<R> Future<R>	executeValue(int sessionId, OperationType opsType, long valueId, boolean failInShutdown, Supplier<R> supplier)
AsyncContainers	getAsyncContainers()
ContainerShard	getShard()
boolean	isIdle()
void	shutdown()
void	shutdownAndWait()
void	shutdownIfHasTo()
void	waitForShutdown()

Methods inherited from class java.lang.Object

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

Constructor Details

ContainerShardExecutor

protected ContainerShardExecutor(AsyncContainer asyncContainer,
 ContainerShard shard)

Method Details

getShard

public ContainerShard getShard()

getAsyncContainers

public AsyncContainers getAsyncContainers()

shutdown

public void shutdown()

isIdle

public boolean isIdle()

executeKey

public <R> Future<R> executeKey(int sessionId,
 OperationType opsType,
 boolean failInShutdown,
 Function<ContainerShardKeyOperations,R> opsConsumer)

executeAutonomousValue

public <R> Future<R> executeAutonomousValue(int sessionId,
 OperationType opsType,
 long valueId,
 boolean failInShutdown,
 Runnable valueOp)

executeValue

public <R> Future<R> executeValue(int sessionId,
 OperationType opsType,
 long valueId,
 boolean failInShutdown,
 Supplier<R> supplier)

execute

public <R> Future<R> execute(Operation<R> operation,
 boolean failInShutdown)

shutdownIfHasTo

public void shutdownIfHasTo()

shutdownAndWait

public void shutdownAndWait()

waitForShutdown

public void waitForShutdown()