A B C D E F G H I J K L M N O P R S T U V W _

A

AbstractExecution - Class in cloud.orbit.actors.runtime

AbstractExecution() - Constructor for class cloud.orbit.actors.runtime.AbstractExecution

activate() - Method in class cloud.orbit.actors.runtime.ActorEntry

activateAsync() - Method in class cloud.orbit.actors.runtime.ReminderControllerActor

activateAsync() - Method in class cloud.orbit.actors.streams.simple.SimpleStreamActor

ActorBaseEntry<T extends AbstractActor> - Class in cloud.orbit.actors.runtime

ActorBaseEntry(RemoteReference) - Constructor for class cloud.orbit.actors.runtime.ActorBaseEntry

ActorCountDeactivationExtension - Class in cloud.orbit.actors.extensions

Created by joeh on 2017-05-15.

ActorCountDeactivationExtension(int, int) - Constructor for class cloud.orbit.actors.extensions.ActorCountDeactivationExtension

actorDeactivated(RemoteReference) - Method in class cloud.orbit.actors.runtime.Hosting

ActorDeactivationExtension - Interface in cloud.orbit.actors.extensions

Created by joeh on 2017-05-15.

ActorEntry<T extends AbstractActor> - Class in cloud.orbit.actors.runtime

ActorEntry(RemoteReference) - Constructor for class cloud.orbit.actors.runtime.ActorEntry

ActorMemoryDeactivationExtension - Class in cloud.orbit.actors.extensions

Created by joeh on 2017-05-15.

ActorMemoryDeactivationExtension(int, int, Duration) - Constructor for class cloud.orbit.actors.extensions.ActorMemoryDeactivationExtension

ActorProfiler - Class in cloud.orbit.actors.runtime

A mini profile extension to measure the actor method cpu usage.

ActorProfiler() - Constructor for class cloud.orbit.actors.runtime.ActorProfiler

actorTTL(long, TimeUnit) - Method in class cloud.orbit.actors.Stage.Builder

addBasePackages(List<String>) - Method in class cloud.orbit.actors.Stage

addExtension(PeerExtension) - Method in class cloud.orbit.actors.peer.Peer

addExtension(ActorExtension) - Method in class cloud.orbit.actors.Stage

Installs extensions to the stage.

addFirst(String, Handler) - Method in class cloud.orbit.actors.net.DefaultPipeline

addHandlerAfter(String, String, Handler) - Method in class cloud.orbit.actors.net.DefaultPipeline

addHandlerBefore(String, String, Handler) - Method in class cloud.orbit.actors.net.DefaultPipeline

addLast(String, Handler) - Method in class cloud.orbit.actors.net.DefaultPipeline

addStickyHeaders(Collection<String>) - Method in class cloud.orbit.actors.Stage

addStreamSubscription(StreamSubscriptionHandle<T>, AsyncStream<T>) - Method in class cloud.orbit.actors.runtime.ActorEntry

addTimer(Registration) - Method in class cloud.orbit.actors.runtime.ActorEntry

afterInvoke(long, Invocation, Method) - Method in class cloud.orbit.actors.runtime.SimpleInvocationHandler

B

basePackages(String...) - Method in class cloud.orbit.actors.Stage.Builder

basePackages(Collection<String>) - Method in class cloud.orbit.actors.Stage.Builder

beforeInvoke(Invocation, Method) - Method in class cloud.orbit.actors.runtime.SimpleInvocationHandler

bind() - Method in class cloud.orbit.actors.peer.Peer

bind() - Method in class cloud.orbit.actors.Stage

Binds this stage to the current thread.

broadcastActorDeactivations(boolean) - Method in class cloud.orbit.actors.Stage.Builder

build() - Method in class cloud.orbit.actors.Stage.Builder

Builder() - Constructor for class cloud.orbit.actors.Stage.Builder

C

CACHING - Static variable in class cloud.orbit.actors.runtime.DefaultHandlers

canActivate(String) - Method in class cloud.orbit.actors.runtime.Hosting

canActivateActor(String) - Method in class cloud.orbit.actors.Stage

classForName(String) - Static method in class cloud.orbit.actors.runtime.InternalUtils

classForName(String, boolean) - Static method in class cloud.orbit.actors.runtime.InternalUtils

cleanStackTrack(StackTraceElement[]) - Method in class cloud.orbit.actors.runtime.ActorProfiler

cleanup() - Method in class cloud.orbit.actors.client.ClientPeer

cleanup() - Method in class cloud.orbit.actors.runtime.AbstractExecution

cleanup() - Method in class cloud.orbit.actors.runtime.DefaultLocalObjectsCleaner

cleanup() - Method in class cloud.orbit.actors.runtime.Execution

cleanup() - Method in interface cloud.orbit.actors.runtime.LocalObjectsCleaner

cleanup() - Method in class cloud.orbit.actors.runtime.Messaging

cleanup() - Method in class cloud.orbit.actors.Stage

cleanupActors(Collection<ActorBaseEntry<?>>, Set<ActorBaseEntry<?>>) - Method in class cloud.orbit.actors.extensions.ActorCountDeactivationExtension

cleanupActors(Collection<ActorBaseEntry<?>>, Set<ActorBaseEntry<?>>) - Method in interface cloud.orbit.actors.extensions.ActorDeactivationExtension

cleanupActors(Collection<ActorBaseEntry<?>>, Set<ActorBaseEntry<?>>) - Method in class cloud.orbit.actors.extensions.ActorMemoryDeactivationExtension

clear() - Method in class cloud.orbit.actors.runtime.ActorProfiler

clearStreamSubscriptions() - Method in class cloud.orbit.actors.runtime.ActorEntry

clearTimers() - Method in class cloud.orbit.actors.runtime.ActorEntry

ClientPeer - Class in cloud.orbit.actors.client

This works as a bridge to perform calls between the server and a client.

ClientPeer() - Constructor for class cloud.orbit.actors.client.ClientPeer

ClientSideStreamProxy - Interface in cloud.orbit.actors.peer.streams

ClientSideStreamProxyImpl - Class in cloud.orbit.actors.client.streams

ClientSideStreamProxyImpl() - Constructor for class cloud.orbit.actors.client.streams.ClientSideStreamProxyImpl

ClientStreamProxy - Class in cloud.orbit.actors.streams

ClientStreamProxy() - Constructor for class cloud.orbit.actors.streams.ClientStreamProxy

clock() - Method in class cloud.orbit.actors.peer.Peer

clock(Clock) - Method in class cloud.orbit.actors.Stage.Builder

clock() - Method in class cloud.orbit.actors.Stage

clone(T) - Method in class cloud.orbit.actors.cloner.JavaSerializationCloner

clone(T) - Method in class cloud.orbit.actors.runtime.KryoSerializer

CloneHelper - Class in cloud.orbit.actors.cloner

{$link CloneHelper} provides basic checks for whether an object requires cloning (is mutable).

CloneHelper() - Constructor for class cloud.orbit.actors.cloner.CloneHelper

close() - Method in class cloud.orbit.actors.net.DefaultHandlerContext

close() - Method in class cloud.orbit.actors.net.DefaultPipeline

close(HandlerContext) - Method in class cloud.orbit.actors.runtime.ClusterHandler

cloud.orbit.actors - package cloud.orbit.actors

cloud.orbit.actors.client - package cloud.orbit.actors.client

cloud.orbit.actors.client.streams - package cloud.orbit.actors.client.streams

cloud.orbit.actors.cloner - package cloud.orbit.actors.cloner

cloud.orbit.actors.concurrent - package cloud.orbit.actors.concurrent

cloud.orbit.actors.exceptions - package cloud.orbit.actors.exceptions

cloud.orbit.actors.extensions - package cloud.orbit.actors.extensions

cloud.orbit.actors.net - package cloud.orbit.actors.net

cloud.orbit.actors.peer - package cloud.orbit.actors.peer

cloud.orbit.actors.peer.streams - package cloud.orbit.actors.peer.streams

cloud.orbit.actors.runtime - package cloud.orbit.actors.runtime

cloud.orbit.actors.server - package cloud.orbit.actors.server

cloud.orbit.actors.server.streams - package cloud.orbit.actors.server.streams

cloud.orbit.actors.streams - package cloud.orbit.actors.streams

cloud.orbit.actors.streams.simple - package cloud.orbit.actors.streams.simple

ClusterHandler - Class in cloud.orbit.actors.runtime

ClusterHandler(ClusterPeer, String, String) - Constructor for class cloud.orbit.actors.runtime.ClusterHandler

clusterName(String) - Method in class cloud.orbit.actors.Stage.Builder

clusterPeer(ClusterPeer) - Method in class cloud.orbit.actors.Stage.Builder

collect() - Method in class cloud.orbit.actors.runtime.ActorProfiler

collectInterval - Variable in class cloud.orbit.actors.runtime.ActorProfiler

collectionCount - Variable in class cloud.orbit.actors.runtime.ActorProfiler

collectionTotalTimeNanos - Variable in class cloud.orbit.actors.runtime.ActorProfiler

collectTimeUnit - Variable in class cloud.orbit.actors.runtime.ActorProfiler

concurrentDeactivations(int) - Method in class cloud.orbit.actors.Stage.Builder

ConcurrentExecutionQueue - Class in cloud.orbit.actors.concurrent

Created by joeh on 2017-05-10.

ConcurrentExecutionQueue(ExecutorService, int) - Constructor for class cloud.orbit.actors.concurrent.ConcurrentExecutionQueue

ConcurrentExecutionQueue(ExecutorService, int, int) - Constructor for class cloud.orbit.actors.concurrent.ConcurrentExecutionQueue

connect(Object) - Method in class cloud.orbit.actors.net.DefaultHandlerContext

connect(Object) - Method in class cloud.orbit.actors.net.DefaultPipeline

connect(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.ClusterHandler

connect(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.Hosting

connect(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.Messaging

connectionClosed(ServerPeer) - Method in class cloud.orbit.actors.server.ServerExtension

connectionOpened(ServerPeer) - Method in class cloud.orbit.actors.server.ServerExtension

create(int) - Method in class cloud.orbit.actors.runtime.KryoOutputPool

createLocalObjectEntry(RemoteReference<T>, T) - Method in class cloud.orbit.actors.runtime.LocalObjects

This method must be overridden by the stage to create proper entries for Actors and Stateless Actors

createObjectInput(BasicRuntime, InputStream) - Method in class cloud.orbit.actors.runtime.JavaMessageSerializer

createObjectOutput(BasicRuntime, OutputStream) - Method in class cloud.orbit.actors.runtime.JavaMessageSerializer

createReference(NodeAddress, Class<T>, String) - Method in class cloud.orbit.actors.runtime.LocalObjects

D

deactivate() - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

This must not fail.

deactivate() - Method in class cloud.orbit.actors.runtime.ActorEntry

This must not fail.

deactivate(T) - Method in class cloud.orbit.actors.runtime.ActorEntry

deactivate() - Method in class cloud.orbit.actors.runtime.StatelessActorEntry

deactivateActor(Actor) - Method in class cloud.orbit.actors.runtime.DefaultLocalObjectsCleaner

deactivateActor(Actor) - Method in interface cloud.orbit.actors.runtime.LocalObjectsCleaner

deactivateActor(Actor) - Method in class cloud.orbit.actors.Stage

deactivateAsync() - Method in class cloud.orbit.actors.runtime.ReminderControllerActor

deactivateAsync() - Method in class cloud.orbit.actors.streams.simple.SimpleStreamActor

deactivationTimeout(long, TimeUnit) - Method in class cloud.orbit.actors.Stage.Builder

DefaultActorConstructionExtension - Class in cloud.orbit.actors.runtime

Created by joeh on 2017-05-29.

DefaultActorConstructionExtension() - Constructor for class cloud.orbit.actors.runtime.DefaultActorConstructionExtension

DefaultHandlerContext - Class in cloud.orbit.actors.net

DefaultHandlerContext(DefaultPipeline) - Constructor for class cloud.orbit.actors.net.DefaultHandlerContext

DefaultHandlers - Class in cloud.orbit.actors.runtime

DefaultHandlers() - Constructor for class cloud.orbit.actors.runtime.DefaultHandlers

DefaultInvocationHandler - Class in cloud.orbit.actors.runtime

Adds support for InvocationHandlerExtension.

DefaultInvocationHandler() - Constructor for class cloud.orbit.actors.runtime.DefaultInvocationHandler

DefaultLifetimeExtension - Class in cloud.orbit.actors.runtime

DefaultLifetimeExtension() - Constructor for class cloud.orbit.actors.runtime.DefaultLifetimeExtension

DefaultLocalObjectsCleaner - Class in cloud.orbit.actors.runtime

Created by joeh on 2017-05-10.

DefaultLocalObjectsCleaner(Hosting, Clock, ExecutorService, LocalObjects, long, int, long) - Constructor for class cloud.orbit.actors.runtime.DefaultLocalObjectsCleaner

DefaultLoggerExtension - Class in cloud.orbit.actors.extensions

DefaultLoggerExtension() - Constructor for class cloud.orbit.actors.extensions.DefaultLoggerExtension

DefaultPipeline - Class in cloud.orbit.actors.net

Protocol chain for orbit messages.

DefaultPipeline() - Constructor for class cloud.orbit.actors.net.DefaultPipeline

DefaultPipeline(BasicRuntime) - Constructor for class cloud.orbit.actors.net.DefaultPipeline

DefaultResponseCachingExtension - Class in cloud.orbit.actors.runtime

DefaultResponseCachingExtension() - Constructor for class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

deserializeMessage(BasicRuntime, byte[]) - Method in class cloud.orbit.actors.runtime.JavaMessageSerializer

deserializeMessage(BasicRuntime, byte[]) - Method in class cloud.orbit.actors.runtime.KryoSerializer

disconnect() - Method in class cloud.orbit.actors.net.DefaultHandlerContext

disconnect() - Method in class cloud.orbit.actors.net.DefaultPipeline

doDeactivate() - Method in class cloud.orbit.actors.runtime.ActorEntry

doInvoke(Stage, Invocation, LocalObjects.LocalObjectEntry, LocalObjects.LocalObjectEntry, Method, Boolean, ObjectInvoker) - Method in class cloud.orbit.actors.runtime.DefaultInvocationHandler

doInvoke(Stage, Invocation, LocalObjects.LocalObjectEntry, LocalObjects.LocalObjectEntry, Method, Boolean, ObjectInvoker) - Method in class cloud.orbit.actors.runtime.SimpleInvocationHandler

E

enableMessageLoopback(Boolean) - Method in class cloud.orbit.actors.Stage.Builder

enableShutdownHook(boolean) - Method in class cloud.orbit.actors.Stage.Builder

ensureStart() - Method in interface cloud.orbit.actors.runtime.ReminderController

ensureStart() - Method in class cloud.orbit.actors.runtime.ReminderControllerActor

ensureStart() - Method in interface cloud.orbit.actors.runtime.ShardedReminderController

equals(Object) - Method in class cloud.orbit.actors.runtime.ReminderEntry

equals(Object) - Method in class cloud.orbit.actors.runtime.RemoteKey

execute(Supplier<Task<R>>) - Method in class cloud.orbit.actors.concurrent.ConcurrentExecutionQueue

execute(Runnable) - Method in class cloud.orbit.actors.concurrent.ConcurrentExecutionQueue

execute(Runnable) - Method in class cloud.orbit.actors.concurrent.WaitFreeExecutionSerializer

executeSerialized(Supplier<Task<R>>, int) - Method in class cloud.orbit.actors.concurrent.WaitFreeExecutionSerializer

EXECUTION - Static variable in class cloud.orbit.actors.runtime.DefaultHandlers

Execution - Class in cloud.orbit.actors.runtime

Execution() - Constructor for class cloud.orbit.actors.runtime.Execution

execution(Execution) - Method in class cloud.orbit.actors.Stage.Builder

executionPool(ExecutorService) - Method in class cloud.orbit.actors.Stage.Builder

executionPoolSize(int) - Method in class cloud.orbit.actors.Stage.Builder

executionSerializer - Variable in class cloud.orbit.actors.runtime.AbstractExecution

extensions(Collection<ActorExtension>) - Method in class cloud.orbit.actors.Stage.Builder

extensions(ActorExtension...) - Method in class cloud.orbit.actors.Stage.Builder

F

FastActorClassFinder - Class in cloud.orbit.actors.runtime

FastActorClassFinder(String...) - Constructor for class cloud.orbit.actors.runtime.FastActorClassFinder

FastActorClassFinder(ExecutorService, int, String...) - Constructor for class cloud.orbit.actors.runtime.FastActorClassFinder

findActorImplementation(Class<T>) - Method in class cloud.orbit.actors.runtime.FastActorClassFinder

findActorImplementation(Class<T>) - Method in class cloud.orbit.actors.runtime.LazyActorClassFinder

findActorInterfaces(Predicate<Class<T>>) - Method in class cloud.orbit.actors.runtime.FastActorClassFinder

findActorInterfaces(Predicate<Class<T>>) - Method in class cloud.orbit.actors.runtime.LazyActorClassFinder

findLocalActor(Actor) - Method in class cloud.orbit.actors.runtime.LocalObjects

findLocalObject(NodeAddress, int, Object) - Method in class cloud.orbit.actors.runtime.LocalObjects

findLocalObjectByObject(Object) - Method in class cloud.orbit.actors.runtime.LocalObjects

findLocalObjectByReference(RemoteReference) - Method in class cloud.orbit.actors.runtime.LocalObjects

fireActive() - Method in class cloud.orbit.actors.net.DefaultHandlerContext

fireEventTriggered(Object) - Method in class cloud.orbit.actors.net.DefaultHandlerContext

fireExceptionCaught(Throwable) - Method in class cloud.orbit.actors.net.DefaultHandlerContext

fireInactive() - Method in class cloud.orbit.actors.net.DefaultHandlerContext

fireRead(Object) - Method in class cloud.orbit.actors.net.DefaultHandlerContext

flush(Actor) - Method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

flushPlacementGroupCache(boolean) - Method in class cloud.orbit.actors.Stage.Builder

flushWithoutWaiting(Actor) - Method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

G

get(Method, Pair<Addressable, String>) - Method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

Retrieves a cached value for an actor's method.

getActorCount() - Method in class cloud.orbit.actors.Stage

getAllNodes() - Method in class cloud.orbit.actors.runtime.Hosting

getAllNodes() - Method in class cloud.orbit.actors.Stage

getBeforeHandlerName() - Method in class cloud.orbit.actors.server.SecurityFilter

getBroadcastActorDeactivations() - Method in class cloud.orbit.actors.Stage

getCacheSizes() - Method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

getCloner() - Method in class cloud.orbit.actors.runtime.MessageLoopback

getClusterName() - Method in class cloud.orbit.actors.Stage

getClusterPeer() - Method in class cloud.orbit.actors.Stage

getCollectInterval() - Method in class cloud.orbit.actors.runtime.ActorProfiler

getCollectionCount() - Method in class cloud.orbit.actors.runtime.ActorProfiler

getCollectionTotalTimeNanos() - Method in class cloud.orbit.actors.runtime.ActorProfiler

getCollectTimeUnit() - Method in class cloud.orbit.actors.runtime.ActorProfiler

getCompletion() - Method in class cloud.orbit.actors.runtime.Invocation

getConsistentHashOwner(String) - Method in class cloud.orbit.actors.runtime.Hosting

Uses consistent hashing to determine the "owner" of a certain key.

getExecution() - Method in class cloud.orbit.actors.Stage

getExecutionPool() - Method in class cloud.orbit.actors.Stage

getExecutionPoolSize() - Method in class cloud.orbit.actors.Stage

getExtensions() - Method in class cloud.orbit.actors.peer.Peer

getExtensions() - Method in class cloud.orbit.actors.Stage

getFirstExtension(Class<T>) - Method in class cloud.orbit.actors.peer.Peer

getFlushPlacementGroupCache() - Method in class cloud.orbit.actors.runtime.Hosting

getFlushPlacementGroupCache() - Method in class cloud.orbit.actors.Stage

getFromNode() - Method in class cloud.orbit.actors.runtime.Invocation

getHeaders() - Method in class cloud.orbit.actors.runtime.Invocation

getHops() - Method in class cloud.orbit.actors.runtime.Invocation

getHosting() - Method in class cloud.orbit.actors.Stage

getId() - Method in class cloud.orbit.actors.streams.simple.SimpleHandle

getId() - Method in class cloud.orbit.actors.streams.simple.StreamReference.SimpleStreamHandle

getKey() - Method in class cloud.orbit.actors.runtime.ActorEntry

getLastAccess() - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

getLocalActorCount() - Method in class cloud.orbit.actors.runtime.LocalObjects

getLocalAddress() - Method in class cloud.orbit.actors.Stage

getLocalObjectCount() - Method in class cloud.orbit.actors.runtime.LocalObjects

getLocalObjectCount() - Method in class cloud.orbit.actors.Stage

getLocalObjectsCleaner() - Method in class cloud.orbit.actors.Stage

getLogger(Object) - Method in class cloud.orbit.actors.client.ClientPeer

getLogger(String) - Method in class cloud.orbit.actors.extensions.DefaultLoggerExtension

getLogger(Object) - Method in class cloud.orbit.actors.extensions.DefaultLoggerExtension

getLogger() - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

getLogger(Object) - Method in class cloud.orbit.actors.Stage

getMessageId() - Method in class cloud.orbit.actors.runtime.Invocation

getMessageSerializer() - Method in class cloud.orbit.actors.peer.Peer

getMessageSerializer() - Method in class cloud.orbit.actors.Stage

getMethod() - Method in class cloud.orbit.actors.runtime.Invocation

getMethodId() - Method in class cloud.orbit.actors.runtime.Invocation

getMode() - Method in class cloud.orbit.actors.Stage

getName() - Method in class cloud.orbit.actors.server.SecurityFilter

getName() - Method in class cloud.orbit.actors.streams.simple.SimpleStreamExtension

getNetwork() - Method in class cloud.orbit.actors.peer.Peer

getNodeAddress() - Method in class cloud.orbit.actors.runtime.Hosting

getNodeName() - Method in class cloud.orbit.actors.Stage

getObject() - Method in class cloud.orbit.actors.runtime.ActorEntry

getObject() - Method in interface cloud.orbit.actors.runtime.LocalObjects.LocalObjectEntry

getObject() - Method in class cloud.orbit.actors.runtime.LocalObjects.NormalObjectEntry

getObject() - Method in class cloud.orbit.actors.runtime.ObserverEntry

getObject() - Method in class cloud.orbit.actors.runtime.StatelessActorEntry

getObjectCloner() - Method in class cloud.orbit.actors.Stage

getOrAddLocalObjectReference(NodeAddress, Class<T>, String, T) - Method in class cloud.orbit.actors.runtime.LocalObjects

Installs this remote object into this node with the given id.

getParams() - Method in class cloud.orbit.actors.runtime.Invocation

getPeriod() - Method in class cloud.orbit.actors.runtime.ReminderEntry

getPipeline() - Method in class cloud.orbit.actors.peer.Peer

getPipeline() - Method in class cloud.orbit.actors.Stage

getPlacementGroup() - Method in class cloud.orbit.actors.runtime.Hosting

getPlacementGroup() - Method in class cloud.orbit.actors.Stage

getProfilerSnapshot() - Method in class cloud.orbit.actors.runtime.ActorProfiler

Interrupts the collection and takes a copy of the collected stats

getReference(BasicRuntime, NodeAddress, Class<T>, Object) - Method in class cloud.orbit.actors.peer.Peer

getReference() - Method in class cloud.orbit.actors.runtime.ReminderEntry

getReference(BasicRuntime, NodeAddress, Class<T>, Object) - Method in class cloud.orbit.actors.server.ServerPeer

getReference(BasicRuntime, NodeAddress, Class<T>, Object) - Method in class cloud.orbit.actors.Stage

getReminderControllerIdentity(String) - Method in class cloud.orbit.actors.Stage

getReminderName() - Method in class cloud.orbit.actors.runtime.ReminderEntry

getReminders(Remindable) - Method in interface cloud.orbit.actors.runtime.ReminderController

Gets all reminders tied to the actor actor.

getReminders(Remindable) - Method in class cloud.orbit.actors.runtime.ReminderControllerActor

getReminders() - Method in class cloud.orbit.actors.runtime.ReminderControllerActor

getReminders(Remindable) - Method in interface cloud.orbit.actors.runtime.ShardedReminderController

Gets all reminders tied to the actor actor.

getReminders() - Method in interface cloud.orbit.actors.runtime.ShardedReminderController

Gets all reminders.

getRemoteObserverReference(NodeAddress, Class<T>, Object) - Method in class cloud.orbit.actors.server.ServerPeer

getRemoteReference() - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

getRemoteReference() - Method in interface cloud.orbit.actors.runtime.LocalObjects.LocalObjectEntry

getRemoteReference() - Method in class cloud.orbit.actors.runtime.LocalObjects.NormalObjectEntry

getRemoteReference() - Method in class cloud.orbit.actors.runtime.ObserverEntry

getRuntime() - Method in class cloud.orbit.actors.net.DefaultHandlerContext

getRuntime() - Method in class cloud.orbit.actors.net.DefaultPipeline

getRuntime() - Method in class cloud.orbit.actors.runtime.MessageLoopback

getRuntime() - Method in class cloud.orbit.actors.runtime.Messaging

getRuntime() - Method in class cloud.orbit.actors.Stage

getSerializer(T) - Method in class cloud.orbit.actors.concurrent.WaitFreeMultiExecutionSerializer

getServerNodes() - Method in class cloud.orbit.actors.runtime.Hosting

getServerNodes() - Method in class cloud.orbit.actors.Stage

getStage() - Method in class cloud.orbit.actors.server.ServerPeer

getStartAt() - Method in class cloud.orbit.actors.runtime.ReminderEntry

getStartPromise() - Method in class cloud.orbit.actors.Stage

getState() - Method in class cloud.orbit.actors.Stage

getStickyHeaders() - Method in class cloud.orbit.actors.Stage

getStorageExtensionFor(Class) - Method in class cloud.orbit.actors.Stage

getStream(String, Class<T>, String) - Method in class cloud.orbit.actors.client.ClientPeer

getStream(String, Class<T>, String) - Method in class cloud.orbit.actors.client.streams.ClientSideStreamProxyImpl

getStream(String, Class<T>, String) - Method in class cloud.orbit.actors.peer.Peer

getStream(String, Class<T>, String) - Method in class cloud.orbit.actors.Stage

getStream(Class<T>, String) - Method in class cloud.orbit.actors.streams.simple.SimpleStreamExtension

getStreamProvider(String) - Method in class cloud.orbit.actors.Stage

getSubscriber(SimpleStream) - Method in class cloud.orbit.actors.streams.simple.SimpleStreamExtension

getTargetPlacementGroups() - Method in class cloud.orbit.actors.runtime.Hosting

getTimeToWaitForServersMillis() - Method in class cloud.orbit.actors.runtime.Hosting

getToNode() - Method in class cloud.orbit.actors.runtime.Invocation

getToReference() - Method in class cloud.orbit.actors.runtime.Invocation

H

hashCode() - Method in class cloud.orbit.actors.runtime.ReminderEntry

hashCode() - Method in class cloud.orbit.actors.runtime.RemoteKey

HEAD - Static variable in class cloud.orbit.actors.runtime.DefaultHandlers

hexDump(int, byte[], int, int) - Static method in class cloud.orbit.actors.runtime.InternalUtils

HOSTING - Static variable in class cloud.orbit.actors.runtime.DefaultHandlers

Hosting - Class in cloud.orbit.actors.runtime

Hosting(int, long) - Constructor for class cloud.orbit.actors.runtime.Hosting

I

installPipelineExtensions() - Method in class cloud.orbit.actors.peer.Peer

InternalUtils - Class in cloud.orbit.actors.runtime

Internal utility class.

InternalUtils() - Constructor for class cloud.orbit.actors.runtime.InternalUtils

Invocation - Class in cloud.orbit.actors.runtime

Invocation() - Constructor for class cloud.orbit.actors.runtime.Invocation

Invocation(RemoteReference, Method, boolean, int, Object[], Task) - Constructor for class cloud.orbit.actors.runtime.Invocation

InvocationHandler - Interface in cloud.orbit.actors.runtime

invocationHandler(InvocationHandler) - Method in class cloud.orbit.actors.Stage.Builder

invoke(RemoteReference, Method, boolean, int, Object[]) - Method in class cloud.orbit.actors.peer.Peer

invoke(Stage, Invocation, LocalObjects.LocalObjectEntry, LocalObjects.LocalObjectEntry, ObjectInvoker) - Method in interface cloud.orbit.actors.runtime.InvocationHandler

invoke(Stage, Invocation, LocalObjects.LocalObjectEntry, LocalObjects.LocalObjectEntry, ObjectInvoker) - Method in class cloud.orbit.actors.runtime.SimpleInvocationHandler

invoke(RemoteReference, Method, boolean, int, Object[]) - Method in class cloud.orbit.actors.Stage

isActive() - Method in class cloud.orbit.actors.net.DefaultPipeline

isBusy() - Method in class cloud.orbit.actors.concurrent.WaitFreeExecutionSerializer

isBusy() - Method in class cloud.orbit.actors.concurrent.WaitFreeMultiExecutionSerializer

isConsistentHashOwner(String) - Method in class cloud.orbit.actors.runtime.Hosting

Uses consistent hashing to determine this node is the "owner" of a certain key.

isDeactivated() - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

isDeactivated() - Method in interface cloud.orbit.actors.runtime.LocalObjects.LocalObjectEntry

isOneWay() - Method in class cloud.orbit.actors.runtime.Invocation

J

JavaMessageSerializer - Class in cloud.orbit.actors.runtime

A message serializer that uses java serialization.

JavaMessageSerializer() - Constructor for class cloud.orbit.actors.runtime.JavaMessageSerializer

JavaSerializationCloner - Class in cloud.orbit.actors.cloner

Java serialization based object cloning implementation.

JavaSerializationCloner() - Constructor for class cloud.orbit.actors.cloner.JavaSerializationCloner

K

KryoOutputPool - Class in cloud.orbit.actors.runtime

KryoOutputPool() - Constructor for class cloud.orbit.actors.runtime.KryoOutputPool

KryoSerializer - Class in cloud.orbit.actors.runtime

Kryo based message serializer and object cloning implementation.

KryoSerializer() - Constructor for class cloud.orbit.actors.runtime.KryoSerializer

KryoSerializer(Consumer<Kryo>) - Constructor for class cloud.orbit.actors.runtime.KryoSerializer

KryoSerializer(Consumer<Kryo>, ClassResolver) - Constructor for class cloud.orbit.actors.runtime.KryoSerializer

Deprecated.

Do not use this constructor, since it will share a single ClassResolver between Kryo instances in the Kryo pool which can cause concurrency issues.

KryoSerializer(Consumer<Kryo>, Supplier<ClassResolver>) - Constructor for class cloud.orbit.actors.runtime.KryoSerializer

L

lastAccess - Variable in class cloud.orbit.actors.runtime.ActorBaseEntry

LazyActorClassFinder - Class in cloud.orbit.actors.runtime

LazyActorClassFinder() - Constructor for class cloud.orbit.actors.runtime.LazyActorClassFinder

LENGTH_FIELD_ENCODING - Static variable in class cloud.orbit.actors.extensions.LengthFieldHandler

LengthFieldHandler - Class in cloud.orbit.actors.extensions

Prepends each message with a 4 byte big endian length field.

LengthFieldHandler() - Constructor for class cloud.orbit.actors.extensions.LengthFieldHandler

LengthFieldHandler(String, String, String) - Constructor for class cloud.orbit.actors.extensions.LengthFieldHandler

linkFutures(CompletableFuture, CompletableFuture) - Static method in class cloud.orbit.actors.runtime.InternalUtils

linkFuturesOnError(CompletableFuture, CompletableFuture) - Static method in class cloud.orbit.actors.runtime.InternalUtils

localAddressCacheMaximumSize(int) - Method in class cloud.orbit.actors.Stage.Builder

localAddressCacheTTL(long, TimeUnit) - Method in class cloud.orbit.actors.Stage.Builder

localIdentity - Variable in class cloud.orbit.actors.peer.Peer

LocalObjects - Class in cloud.orbit.actors.runtime

LocalObjects() - Constructor for class cloud.orbit.actors.runtime.LocalObjects

LocalObjects.LocalObjectEntry<T> - Interface in cloud.orbit.actors.runtime

LocalObjects.NormalObjectEntry<T> - Class in cloud.orbit.actors.runtime

LocalObjects.ObjectKey - Class in cloud.orbit.actors.runtime

LocalObjectsCleaner - Interface in cloud.orbit.actors.runtime

localObjectsCleaner(LocalObjectsCleaner) - Method in class cloud.orbit.actors.Stage.Builder

locateActor(RemoteReference, boolean) - Method in class cloud.orbit.actors.runtime.Hosting

locateActor(Addressable, boolean) - Method in class cloud.orbit.actors.Stage

logger - Variable in class cloud.orbit.actors.peer.PeerExecutor

logger - Variable in class cloud.orbit.actors.runtime.AbstractExecution

M

maxQueueSize - Variable in class cloud.orbit.actors.runtime.AbstractExecution

MESSAGE_LOOPBACK - Static variable in class cloud.orbit.actors.runtime.DefaultHandlers

MessageLoopback - Class in cloud.orbit.actors.runtime

Local messages traverse the protocol stack just beyond Messaging and then are bounced back.

MessageLoopback() - Constructor for class cloud.orbit.actors.runtime.MessageLoopback

messageLoopbackObjectCloner(ExecutionObjectCloner) - Method in class cloud.orbit.actors.Stage.Builder

messageSerializer(MessageSerializer) - Method in class cloud.orbit.actors.Stage.Builder

messagesHandled - Variable in class cloud.orbit.actors.runtime.AbstractExecution

messagesReceived - Variable in class cloud.orbit.actors.runtime.AbstractExecution

MESSAGING - Static variable in class cloud.orbit.actors.runtime.DefaultHandlers

Messaging - Class in cloud.orbit.actors.runtime

Handles matching requests with responses

Messaging() - Constructor for class cloud.orbit.actors.runtime.Messaging

messaging(Messaging) - Method in class cloud.orbit.actors.Stage.Builder

mode(Stage.StageMode) - Method in class cloud.orbit.actors.Stage.Builder

moved(RemoteReference, NodeAddress, NodeAddress) - Method in class cloud.orbit.actors.runtime.Hosting

N

needsCloning(Object) - Static method in class cloud.orbit.actors.cloner.CloneHelper

needsCloning(Message) - Method in class cloud.orbit.actors.runtime.MessageLoopback

NETWORK - Static variable in class cloud.orbit.actors.runtime.DefaultHandlers

newInstance(Class<T>) - Method in class cloud.orbit.actors.runtime.DefaultActorConstructionExtension

nodeModeChanged(NodeAddress, NodeCapabilities.NodeState) - Method in class cloud.orbit.actors.runtime.Hosting

nodeName(String) - Method in class cloud.orbit.actors.Stage.Builder

NormalObjectEntry() - Constructor for class cloud.orbit.actors.runtime.LocalObjects.NormalObjectEntry

notifyStateChange() - Method in class cloud.orbit.actors.runtime.Hosting

numReminderControllers(int) - Method in class cloud.orbit.actors.Stage.Builder

O

object - Variable in class cloud.orbit.actors.runtime.LocalObjects.NormalObjectEntry

objectCloner(ExecutionObjectCloner) - Method in class cloud.orbit.actors.Stage.Builder

ObjectKey(int, Object) - Constructor for class cloud.orbit.actors.runtime.LocalObjects.ObjectKey

objects - Variable in class cloud.orbit.actors.peer.Peer

objects - Variable in class cloud.orbit.actors.peer.PeerExecutor

ObserverEntry<T> - Class in cloud.orbit.actors.runtime

ObserverEntry(RemoteReference, T) - Constructor for class cloud.orbit.actors.runtime.ObserverEntry

ObserverNotFound - Exception in cloud.orbit.actors.exceptions

ObserverNotFound() - Constructor for exception cloud.orbit.actors.exceptions.ObserverNotFound

ObserverNotFound(Throwable) - Constructor for exception cloud.orbit.actors.exceptions.ObserverNotFound

ObserverNotFound(String) - Constructor for exception cloud.orbit.actors.exceptions.ObserverNotFound

ObserverNotFound(String, Throwable) - Constructor for exception cloud.orbit.actors.exceptions.ObserverNotFound

ObserverNotFound(String, Throwable, boolean, boolean) - Constructor for exception cloud.orbit.actors.exceptions.ObserverNotFound

offerJob(T, Supplier<Task<R>>, int) - Method in class cloud.orbit.actors.concurrent.WaitFreeMultiExecutionSerializer

Only accepts if the queue size is not exceeded.

onActive(HandlerContext) - Method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

onActive(HandlerContext) - Method in class cloud.orbit.actors.runtime.Hosting

onError(Exception) - Method in interface cloud.orbit.actors.streams.simple.SimpleStreamProxy

onError(Exception) - Method in class cloud.orbit.actors.streams.simple.SimpleStreamProxyObject

onInvocation(HandlerContext, Invocation) - Method in class cloud.orbit.actors.runtime.Execution

onInvoke(HandlerContext, Invocation) - Method in class cloud.orbit.actors.peer.PeerExecutor

onMessageReceived(HandlerContext, Message) - Method in class cloud.orbit.actors.runtime.Messaging

onNext(String, String, Object) - Method in class cloud.orbit.actors.client.streams.ClientSideStreamProxyImpl

onNext(String, String, Object) - Method in interface cloud.orbit.actors.peer.streams.ClientSideStreamProxy

onNext(T, StreamSequenceToken) - Method in interface cloud.orbit.actors.streams.simple.SimpleStreamProxy

onNext(T, StreamSequenceToken) - Method in class cloud.orbit.actors.streams.simple.SimpleStreamProxyObject

onRead(HandlerContext, Object) - Method in class cloud.orbit.actors.extensions.LengthFieldHandler

onRead(HandlerContext, Object) - Method in class cloud.orbit.actors.peer.PeerExecutor

onRead(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.Execution

onRead(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.Hosting

onRead(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.Messaging

onRead(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.SerializationHandler

onRead(HandlerContext, Object) - Method in class cloud.orbit.actors.server.SecurityFilter

OrbitObjectInputStream - Class in cloud.orbit.actors.runtime

OrbitObjectInputStream(InputStream, BasicRuntime) - Constructor for class cloud.orbit.actors.runtime.OrbitObjectInputStream

OrbitObjectOutputStream - Class in cloud.orbit.actors.runtime

OrbitObjectOutputStream(OutputStream, BasicRuntime) - Constructor for class cloud.orbit.actors.runtime.OrbitObjectOutputStream

P

Peer - Class in cloud.orbit.actors.peer

This works as a bridge to perform calls between the server and a client.

Peer() - Constructor for class cloud.orbit.actors.peer.Peer

PeerExecutor - Class in cloud.orbit.actors.peer

PeerExecutor() - Constructor for class cloud.orbit.actors.peer.PeerExecutor

performInvocation(HandlerContext, Invocation, LocalObjects.LocalObjectEntry, LocalObjects.LocalObjectEntry) - Method in class cloud.orbit.actors.runtime.Execution

performLocalInvocation(Invocation, ObjectInvoker, LocalObjects.LocalObjectEntry) - Method in class cloud.orbit.actors.peer.PeerExecutor

placementGroup(String) - Method in class cloud.orbit.actors.Stage.Builder

publish(T) - Method in interface cloud.orbit.actors.streams.simple.SimpleStream

publish(T) - Method in class cloud.orbit.actors.streams.simple.SimpleStreamActor

publish(T) - Method in class cloud.orbit.actors.streams.simple.StreamReference

pulse() - Method in class cloud.orbit.actors.runtime.Hosting

pulse() - Method in class cloud.orbit.actors.Stage

put(Method, Pair<Addressable, String>, Task<?>) - Method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

Caches a value for an actor's method.

putIfAbsentAndGet(ConcurrentMap<K, V>, K, V) - Static method in class cloud.orbit.actors.runtime.InternalUtils

If the specified key is not already associated with a value, associate it with the given value.

R

RandomSelectorExtension - Class in cloud.orbit.actors.runtime

RandomSelectorExtension() - Constructor for class cloud.orbit.actors.runtime.RandomSelectorExtension

recycle(ByteArrayOutput) - Method in class cloud.orbit.actors.runtime.KryoOutputPool

reference - Variable in class cloud.orbit.actors.runtime.LocalObjects.NormalObjectEntry

refusedExecutions - Variable in class cloud.orbit.actors.runtime.AbstractExecution

registerObserver(Class<T>, String, T) - Method in class cloud.orbit.actors.peer.Peer

registerObserver(Class<T>, String, T) - Method in class cloud.orbit.actors.Stage

registerOrUpdateReminder(Remindable, String, Date, long, TimeUnit) - Method in interface cloud.orbit.actors.runtime.ReminderController

Adds or updates a reminder

registerOrUpdateReminder(Remindable, String, Date, long, TimeUnit) - Method in class cloud.orbit.actors.runtime.ReminderControllerActor

registerOrUpdateReminder(Remindable, String, Date, long, TimeUnit) - Method in interface cloud.orbit.actors.runtime.ShardedReminderController

Adds or updates a reminder

registerReminder(Remindable, String, long, long, TimeUnit) - Method in class cloud.orbit.actors.Stage

registerTimer(AbstractActor<?>, Callable<Task<?>>, long, long, TimeUnit) - Method in class cloud.orbit.actors.Stage

ReminderController - Interface in cloud.orbit.actors.runtime

ReminderControllerActor - Class in cloud.orbit.actors.runtime

ReminderControllerActor() - Constructor for class cloud.orbit.actors.runtime.ReminderControllerActor

ReminderControllerActor.State - Class in cloud.orbit.actors.runtime

ReminderEntry - Class in cloud.orbit.actors.runtime

ReminderEntry() - Constructor for class cloud.orbit.actors.runtime.ReminderEntry

reminders - Variable in class cloud.orbit.actors.runtime.ReminderControllerActor.State

RemoteKey - Class in cloud.orbit.actors.runtime

RemoteKey(String, String) - Constructor for class cloud.orbit.actors.runtime.RemoteKey

remove(RemoteReference<?>) - Method in class cloud.orbit.actors.runtime.Hosting

remove(Object, Object) - Method in class cloud.orbit.actors.runtime.LocalObjects

removeStreamSubscription(StreamSubscriptionHandle<T>, AsyncStream<T>) - Method in class cloud.orbit.actors.runtime.ActorEntry

replaceObject(Object) - Method in class cloud.orbit.actors.runtime.OrbitObjectOutputStream

resolveObject(Object) - Method in class cloud.orbit.actors.runtime.OrbitObjectInputStream

run(TaskFunction<LocalObjects.LocalObjectEntry<T>, R>) - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

run(TaskFunction<LocalObjects.LocalObjectEntry<T>, R>) - Method in class cloud.orbit.actors.runtime.ActorEntry

run(TaskFunction<LocalObjects.LocalObjectEntry<T>, R>) - Method in interface cloud.orbit.actors.runtime.LocalObjects.LocalObjectEntry

run(TaskFunction<LocalObjects.LocalObjectEntry<T>, R>) - Method in class cloud.orbit.actors.runtime.LocalObjects.NormalObjectEntry

run(TaskFunction<LocalObjects.LocalObjectEntry<T>, R>) - Method in class cloud.orbit.actors.runtime.ObserverEntry

run(TaskFunction<LocalObjects.LocalObjectEntry<T>, R>) - Method in class cloud.orbit.actors.runtime.StatelessActorEntry

runtime - Variable in class cloud.orbit.actors.peer.PeerExecutor

runtime - Variable in class cloud.orbit.actors.runtime.ActorBaseEntry

runtimeIdentity() - Method in class cloud.orbit.actors.Stage

S

safeInvoke(Supplier<Task<R>>) - Static method in class cloud.orbit.actors.runtime.InternalUtils

scheduleLocalInvocation(LocalObjects.LocalObjectEntry<Object>, Invocation) - Method in class cloud.orbit.actors.peer.PeerExecutor

SecurityFilter - Class in cloud.orbit.actors.server

SecurityFilter() - Constructor for class cloud.orbit.actors.server.SecurityFilter

select(String, NodeAddress, List<NodeInfo>) - Method in class cloud.orbit.actors.runtime.RandomSelectorExtension

sendResponseAndLogError(HandlerContext, NodeAddress, int, int, int, Object, Throwable) - Method in class cloud.orbit.actors.runtime.Messaging

SERIALIZATION - Static variable in class cloud.orbit.actors.runtime.DefaultHandlers

SerializationHandler - Class in cloud.orbit.actors.runtime

SerializationHandler(BasicRuntime, MessageSerializer) - Constructor for class cloud.orbit.actors.runtime.SerializationHandler

serializeMessage(BasicRuntime, Message) - Method in class cloud.orbit.actors.runtime.JavaMessageSerializer

serializeMessage(BasicRuntime, Message) - Method in class cloud.orbit.actors.runtime.KryoSerializer

ServerExtension - Class in cloud.orbit.actors.server

ServerExtension() - Constructor for class cloud.orbit.actors.server.ServerExtension

ServerPeer - Class in cloud.orbit.actors.server

ServerPeer() - Constructor for class cloud.orbit.actors.server.ServerPeer

ServerSideStreamProxy - Interface in cloud.orbit.actors.peer.streams

ServerSideStreamProxyImpl - Class in cloud.orbit.actors.server.streams

ServerSideStreamProxyImpl() - Constructor for class cloud.orbit.actors.server.streams.ServerSideStreamProxyImpl

setActorDeactivationExtensions(List<ActorDeactivationExtension>) - Method in class cloud.orbit.actors.runtime.DefaultLocalObjectsCleaner

setActorDeactivationExtensions(List<ActorDeactivationExtension>) - Method in interface cloud.orbit.actors.runtime.LocalObjectsCleaner

setBroadcastActorDeactivations(boolean) - Method in class cloud.orbit.actors.Stage

setCacheExecutor(Executor) - Static method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

setClock(Clock) - Method in class cloud.orbit.actors.peer.Peer

setClock(Clock) - Static method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

setClock(Clock) - Method in class cloud.orbit.actors.Stage

setCloner(ExecutionObjectCloner) - Method in class cloud.orbit.actors.runtime.MessageLoopback

setClusterName(String) - Method in class cloud.orbit.actors.Stage

setClusterPeer(ClusterPeer) - Method in class cloud.orbit.actors.runtime.Hosting

setClusterPeer(ClusterPeer) - Method in class cloud.orbit.actors.Stage

setCollectInterval(int) - Method in class cloud.orbit.actors.runtime.ActorProfiler

setCollectTimeUnit(TimeUnit) - Method in class cloud.orbit.actors.runtime.ActorProfiler

setCompletion(Task) - Method in class cloud.orbit.actors.runtime.Invocation

setConcreteClass(Class<T>) - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

setConcurrentDeactivations(int) - Method in class cloud.orbit.actors.Stage

setDeactivated(boolean) - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

setDeactivationTimeout(long) - Method in class cloud.orbit.actors.Stage

setDefaultActorTTL(long) - Method in class cloud.orbit.actors.Stage

setEnableMessageLoopback(boolean) - Method in class cloud.orbit.actors.Stage

setEnableShutdownHook(boolean) - Method in class cloud.orbit.actors.Stage

setExecution(Execution) - Method in class cloud.orbit.actors.Stage

setExecutionPool(ExecutorService) - Method in class cloud.orbit.actors.Stage

setExecutionPoolSize(int) - Method in class cloud.orbit.actors.Stage

setExecutionSerializer(MultiExecutionSerializer<Object>) - Method in class cloud.orbit.actors.runtime.AbstractExecution

setExecutionSerializer(MultiExecutionSerializer<Object>) - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

setExecutionSerializer(MultiExecutionSerializer<Object>) - Method in class cloud.orbit.actors.runtime.ObserverEntry

setFlushPlacementGroupCache(boolean) - Method in class cloud.orbit.actors.runtime.Hosting

setFlushPlacementGroupCache(boolean) - Method in class cloud.orbit.actors.Stage

setFromNode(NodeAddress) - Method in class cloud.orbit.actors.runtime.Invocation

setHeaders(Map<String, Object>) - Method in class cloud.orbit.actors.runtime.Invocation

setHops(int) - Method in class cloud.orbit.actors.runtime.Invocation

setInvocationHandler(InvocationHandler) - Method in class cloud.orbit.actors.runtime.Execution

setInvocationHandler(InvocationHandler) - Method in class cloud.orbit.actors.Stage

setKey(Object) - Method in class cloud.orbit.actors.runtime.ActorEntry

setLocalAddressCacheMaximumSize(int) - Method in class cloud.orbit.actors.Stage

setLocalAddressCacheTTL(long) - Method in class cloud.orbit.actors.Stage

setLocalObjectsCleaner(LocalObjectsCleaner) - Method in class cloud.orbit.actors.Stage

setLoggerExtension(LoggerExtension) - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

setMessageId(int) - Method in class cloud.orbit.actors.runtime.Invocation

setMessageLoopbackObjectCloner(ExecutionObjectCloner) - Method in class cloud.orbit.actors.Stage

setMessageSerializer(MessageSerializer) - Method in class cloud.orbit.actors.peer.Peer

setMessageSerializer(MessageSerializer) - Method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

setMessageSerializer(MessageSerializer) - Method in class cloud.orbit.actors.Stage

setMessaging(Messaging) - Method in class cloud.orbit.actors.Stage

setMode(Stage.StageMode) - Method in class cloud.orbit.actors.Stage

setName(String) - Method in class cloud.orbit.actors.streams.simple.SimpleStreamExtension

setNetworkHandler(Handler) - Method in class cloud.orbit.actors.peer.Peer

setNodeName(String) - Method in class cloud.orbit.actors.Stage

setNodeSelector(NodeSelectorExtension) - Method in class cloud.orbit.actors.runtime.Hosting

setNodeType(NodeCapabilities.NodeTypeEnum) - Method in class cloud.orbit.actors.runtime.Hosting

setNumReminderControllers(int) - Method in class cloud.orbit.actors.Stage

setObjectCloner(ExecutionObjectCloner) - Method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

setObjectCloner(ExecutionObjectCloner) - Method in class cloud.orbit.actors.Stage

setObjects(LocalObjects) - Method in class cloud.orbit.actors.peer.PeerExecutor

setObjects(LocalObjects) - Method in class cloud.orbit.actors.runtime.Execution

setPeer(ServerPeer) - Method in class cloud.orbit.actors.server.streams.ServerSideStreamProxyImpl

setPerformanceLoggingEnabled(boolean) - Method in class cloud.orbit.actors.runtime.SimpleInvocationHandler

setPeriod(long) - Method in class cloud.orbit.actors.runtime.ReminderEntry

setPlacementGroup(String) - Method in class cloud.orbit.actors.Stage

setReference(Remindable) - Method in class cloud.orbit.actors.runtime.ReminderEntry

setReminderName(String) - Method in class cloud.orbit.actors.runtime.ReminderEntry

setResponseTimeoutMillis(long) - Method in class cloud.orbit.actors.runtime.Messaging

setRuntime(BasicRuntime) - Method in class cloud.orbit.actors.client.streams.ClientSideStreamProxyImpl

setRuntime(BasicRuntime) - Method in class cloud.orbit.actors.peer.PeerExecutor

setRuntime(ActorRuntime) - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

setRuntime(BasicRuntime) - Method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

setRuntime(Stage) - Method in class cloud.orbit.actors.runtime.Execution

setRuntime(ActorRuntime) - Method in class cloud.orbit.actors.runtime.MessageLoopback

setRuntime(BasicRuntime) - Method in class cloud.orbit.actors.runtime.Messaging

setSlowInvokeThresholdMs(double) - Method in class cloud.orbit.actors.runtime.SimpleInvocationHandler

setSlowTaskThresholdMs(double) - Method in class cloud.orbit.actors.runtime.SimpleInvocationHandler

setStage(Stage) - Method in class cloud.orbit.actors.runtime.Hosting

setStage(Stage) - Method in class cloud.orbit.actors.server.ServerPeer

setStage(Stage) - Method in class cloud.orbit.actors.server.streams.ServerSideStreamProxyImpl

setStartAt(Date) - Method in class cloud.orbit.actors.runtime.ReminderEntry

setStorageExtension(StorageExtension) - Method in class cloud.orbit.actors.runtime.ActorBaseEntry

setTargetPlacementGroups(Set<String>) - Method in class cloud.orbit.actors.runtime.Hosting

setTimer(Timer) - Method in class cloud.orbit.actors.Stage

setTimeToWaitForServersMillis(long) - Method in class cloud.orbit.actors.runtime.Hosting

setToNode(NodeAddress) - Method in class cloud.orbit.actors.runtime.Invocation

ShardedReminderController - Interface in cloud.orbit.actors.runtime

shutdown() - Method in class cloud.orbit.actors.concurrent.WaitFreeMultiExecutionSerializer

shutdown() - Method in class cloud.orbit.actors.runtime.DefaultLocalObjectsCleaner

shutdown() - Method in interface cloud.orbit.actors.runtime.LocalObjectsCleaner

SimpleHandle<T> - Class in cloud.orbit.actors.streams.simple

SimpleHandle() - Constructor for class cloud.orbit.actors.streams.simple.SimpleHandle

SimpleHandle(String) - Constructor for class cloud.orbit.actors.streams.simple.SimpleHandle

SimpleInvocationHandler - Class in cloud.orbit.actors.runtime

Simple InvocationHandler with no support for InvocationHandlerExtension.

SimpleInvocationHandler() - Constructor for class cloud.orbit.actors.runtime.SimpleInvocationHandler

SimpleStream - Interface in cloud.orbit.actors.streams.simple

Internal implementation of of the simple stream provider.

SimpleStreamActor - Class in cloud.orbit.actors.streams.simple

SimpleStreamActor() - Constructor for class cloud.orbit.actors.streams.simple.SimpleStreamActor

SimpleStreamActor.State - Class in cloud.orbit.actors.streams.simple

SimpleStreamExtension - Class in cloud.orbit.actors.streams.simple

SimpleStreamExtension() - Constructor for class cloud.orbit.actors.streams.simple.SimpleStreamExtension

SimpleStreamExtension(String) - Constructor for class cloud.orbit.actors.streams.simple.SimpleStreamExtension

SimpleStreamHandle() - Constructor for class cloud.orbit.actors.streams.simple.StreamReference.SimpleStreamHandle

SimpleStreamHandle(String) - Constructor for class cloud.orbit.actors.streams.simple.StreamReference.SimpleStreamHandle

SimpleStreamProxy<T> - Interface in cloud.orbit.actors.streams.simple

SimpleStreamProxyObject<T> - Class in cloud.orbit.actors.streams.simple

SimpleStreamProxyObject(SimpleStreamExtension, SimpleStream) - Constructor for class cloud.orbit.actors.streams.simple.SimpleStreamProxyObject

sleep(long) - Static method in class cloud.orbit.actors.runtime.InternalUtils

Invokes Thread.sleep().

Stage - Class in cloud.orbit.actors

Stage() - Constructor for class cloud.orbit.actors.Stage

Stage.Builder - Class in cloud.orbit.actors

Stage.StageMode - Enum in cloud.orbit.actors

start() - Method in class cloud.orbit.actors.client.ClientPeer

start() - Method in class cloud.orbit.actors.client.streams.ClientSideStreamProxyImpl

start() - Method in class cloud.orbit.actors.runtime.FastActorClassFinder

start() - Method in class cloud.orbit.actors.runtime.Hosting

start() - Method in class cloud.orbit.actors.server.ServerPeer

start() - Method in class cloud.orbit.actors.server.streams.ServerSideStreamProxyImpl

start() - Method in class cloud.orbit.actors.Stage

State() - Constructor for class cloud.orbit.actors.runtime.ReminderControllerActor.State

State() - Constructor for class cloud.orbit.actors.streams.simple.SimpleStreamActor.State

StatelessActorEntry<T extends AbstractActor> - Class in cloud.orbit.actors.runtime

StatelessActorEntry(LocalObjects, RemoteReference) - Constructor for class cloud.orbit.actors.runtime.StatelessActorEntry

stickyHeaders(String...) - Method in class cloud.orbit.actors.Stage.Builder

stop() - Method in class cloud.orbit.actors.client.ClientPeer

stop() - Method in class cloud.orbit.actors.server.ServerPeer

stop() - Method in class cloud.orbit.actors.server.streams.ServerSideStreamProxyImpl

stop() - Method in class cloud.orbit.actors.Stage

stream() - Method in class cloud.orbit.actors.runtime.LocalObjects

StreamReference<T> - Class in cloud.orbit.actors.streams.simple

StreamReference(SimpleStreamExtension, Class<T>, String) - Constructor for class cloud.orbit.actors.streams.simple.StreamReference

StreamReference.SimpleStreamHandle<T> - Class in cloud.orbit.actors.streams.simple

subscribe(String, Class<T>, String, AsyncObserver<T>) - Method in class cloud.orbit.actors.client.streams.ClientSideStreamProxyImpl

subscribe(String, int, String, ClientSideStreamProxy) - Method in interface cloud.orbit.actors.peer.streams.ServerSideStreamProxy

subscribe(String, int, String, ClientSideStreamProxy) - Method in class cloud.orbit.actors.server.streams.ServerSideStreamProxyImpl

subscribe(String, Class, String) - Method in class cloud.orbit.actors.streams.ClientStreamProxy

subscribe(SimpleStreamProxy<T>) - Method in interface cloud.orbit.actors.streams.simple.SimpleStream

subscribe(SimpleStreamProxy) - Method in class cloud.orbit.actors.streams.simple.SimpleStreamActor

subscribe(AsyncObserver<T>) - Method in class cloud.orbit.actors.streams.simple.SimpleStreamProxyObject

subscribe(AsyncObserver<T>, StreamSequenceToken) - Method in class cloud.orbit.actors.streams.simple.StreamReference

T

TAIL - Static variable in class cloud.orbit.actors.runtime.DefaultHandlers

taskComplete(long, Invocation, Method) - Method in class cloud.orbit.actors.runtime.SimpleInvocationHandler

timer(Timer) - Method in class cloud.orbit.actors.Stage.Builder

toString() - Method in class cloud.orbit.actors.client.ClientPeer

toString() - Method in class cloud.orbit.actors.concurrent.ConcurrentExecutionQueue

toString() - Method in class cloud.orbit.actors.runtime.Invocation

toString() - Method in class cloud.orbit.actors.runtime.ReminderEntry

toString() - Method in class cloud.orbit.actors.runtime.RemoteKey

toString() - Method in class cloud.orbit.actors.server.ServerPeer

toString() - Method in class cloud.orbit.actors.Stage

U

unregisterReminder(Remindable, String) - Method in interface cloud.orbit.actors.runtime.ReminderController

Cancels a reminder registration.

unregisterReminder(Remindable, String) - Method in class cloud.orbit.actors.runtime.ReminderControllerActor

unregisterReminder(Remindable, String) - Method in interface cloud.orbit.actors.runtime.ShardedReminderController

Cancels a reminder registration.

unregisterReminder(Remindable, String) - Method in class cloud.orbit.actors.Stage

unsubscribe(StreamSubscriptionHandle<T>) - Method in class cloud.orbit.actors.client.streams.ClientSideStreamProxyImpl

unsubscribe(StreamSubscriptionHandle<T>) - Method in interface cloud.orbit.actors.peer.streams.ServerSideStreamProxy

unsubscribe(StreamSubscriptionHandle<T>) - Method in class cloud.orbit.actors.server.streams.ServerSideStreamProxyImpl

unsubscribe(String) - Method in class cloud.orbit.actors.streams.ClientStreamProxy

unsubscribe(String) - Method in interface cloud.orbit.actors.streams.simple.SimpleStream

unsubscribe(String) - Method in class cloud.orbit.actors.streams.simple.SimpleStreamActor

unsubscribe(String) - Method in class cloud.orbit.actors.streams.simple.SimpleStreamProxyObject

unsubscribe(StreamSubscriptionHandle<T>) - Method in class cloud.orbit.actors.streams.simple.StreamReference

updateLastAccessTime() - Method in class cloud.orbit.actors.runtime.ActorEntry

updateLastAccessTime() - Method in interface cloud.orbit.actors.runtime.LocalObjects.LocalObjectEntry

V

valueOf(String) - Static method in enum cloud.orbit.actors.Stage.StageMode

Returns the enum constant of this type with the specified name.

values() - Static method in enum cloud.orbit.actors.Stage.StageMode

Returns an array containing the constants of this enum type, in the order they are declared.

W

WaitFreeExecutionSerializer - Class in cloud.orbit.actors.concurrent

Ensures that only a single task is executed at each time.

WaitFreeExecutionSerializer(ExecutorService) - Constructor for class cloud.orbit.actors.concurrent.WaitFreeExecutionSerializer

WaitFreeExecutionSerializer(ExecutorService, Object) - Constructor for class cloud.orbit.actors.concurrent.WaitFreeExecutionSerializer

WaitFreeMultiExecutionSerializer<T> - Class in cloud.orbit.actors.concurrent

Ensures that only a single task is executed at each time per key.

WaitFreeMultiExecutionSerializer() - Constructor for class cloud.orbit.actors.concurrent.WaitFreeMultiExecutionSerializer

WaitFreeMultiExecutionSerializer(ExecutorService) - Constructor for class cloud.orbit.actors.concurrent.WaitFreeMultiExecutionSerializer

withFromNode(NodeAddress) - Method in class cloud.orbit.actors.runtime.Invocation

withHeaders(Map<String, Object>) - Method in class cloud.orbit.actors.runtime.Invocation

withMethod(Method) - Method in class cloud.orbit.actors.runtime.Invocation

withMethodId(int) - Method in class cloud.orbit.actors.runtime.Invocation

withOneWay(boolean) - Method in class cloud.orbit.actors.runtime.Invocation

withParams(Object[]) - Method in class cloud.orbit.actors.runtime.Invocation

withToNode(NodeAddress) - Method in class cloud.orbit.actors.runtime.Invocation

withToReference(RemoteReference) - Method in class cloud.orbit.actors.runtime.Invocation

write(HandlerContext, Object) - Method in class cloud.orbit.actors.extensions.LengthFieldHandler

write(Object) - Method in class cloud.orbit.actors.net.DefaultHandlerContext

write(Object) - Method in class cloud.orbit.actors.net.DefaultPipeline

write(HandlerContext, Object) - Method in class cloud.orbit.actors.peer.PeerExecutor

write(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.ClusterHandler

write(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.DefaultResponseCachingExtension

write(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.Execution

write(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.Hosting

write(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.MessageLoopback

write(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.Messaging

write(HandlerContext, Object) - Method in class cloud.orbit.actors.runtime.SerializationHandler

writeInvocation(HandlerContext, Invocation) - Method in class cloud.orbit.actors.peer.PeerExecutor

writeInvocation(HandlerContext, Invocation) - Method in class cloud.orbit.actors.runtime.Hosting

writeInvocation(HandlerContext, Invocation) - Method in class cloud.orbit.actors.runtime.Messaging

writeMessage(HandlerContext, Message) - Method in class cloud.orbit.actors.runtime.Messaging

_

_interfaceClass() - Method in class cloud.orbit.actors.runtime.LocalObjects.ObjectKey

_interfaceId() - Method in class cloud.orbit.actors.runtime.LocalObjects.ObjectKey

A B C D E F G H I J K L M N O P R S T U V W _