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

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

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

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

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

actorSupported_no - Static variable in interface cloud.orbit.actors.runtime.NodeCapabilities

actorSupported_noneSupported - Static variable in interface cloud.orbit.actors.runtime.NodeCapabilities

actorSupported_yes - Static variable in interface cloud.orbit.actors.runtime.NodeCapabilities

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

B

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

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

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

Binds this stage to the current thread.

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

canActivate(String) - Method in interface cloud.orbit.actors.runtime.NodeCapabilities

Asked a single time or infrequently to find out if this node knows and is able to serve this kind of actor.

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.Execution

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

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

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

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

Deprecated.

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.cloner.KryoCloner

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

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

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

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

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

DefaultLifetimeExtension - Class in cloud.orbit.actors.runtime

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

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

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

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

E

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

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

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

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

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

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

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

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

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

findRemoteInterface(Class<?>, Object) - 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.ResponseCaching

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

G

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

Retrieves a cached value for an actor's method.

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

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.

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

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

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

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

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

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

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

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

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

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() - 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

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

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

KryoCloner - Class in cloud.orbit.actors.cloner

Kyro based object cloning implementation.

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

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

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

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

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

moved(RemoteReference<?>, NodeAddress, NodeAddress) - Method in interface cloud.orbit.actors.runtime.NodeCapabilities

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

NodeCapabilities - Interface in cloud.orbit.actors.runtime

NodeCapabilities.NodeState - Enum in cloud.orbit.actors.runtime

NodeCapabilities.NodeTypeEnum - Enum in cloud.orbit.actors.runtime

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

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

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

O

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

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

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.Hosting

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

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

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

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.Stage

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

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

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

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

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

registerLocalObject(RemoteReference, T) - Method in class cloud.orbit.actors.runtime.LocalObjects

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

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(Object, Object) - Method in class cloud.orbit.actors.runtime.LocalObjects

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

ResponseCaching - Class in cloud.orbit.actors.runtime

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

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

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, OutputStream, Message) - Method in class cloud.orbit.actors.runtime.JavaMessageSerializer

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

SESSION_ID - Static variable in class cloud.orbit.actors.runtime.TraceConstants

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

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

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

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

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

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

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

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

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

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

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

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

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

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.ResponseCaching

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

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

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

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

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

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(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

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

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

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

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

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

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

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.runtime.Invocation

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

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

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

TRACE_ID - Static variable in class cloud.orbit.actors.runtime.TraceConstants

TraceConstants - Class in cloud.orbit.actors.runtime

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

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 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

V

valueOf(String) - Static method in enum cloud.orbit.actors.runtime.NodeCapabilities.NodeState

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

valueOf(String) - Static method in enum cloud.orbit.actors.runtime.NodeCapabilities.NodeTypeEnum

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

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.runtime.NodeCapabilities.NodeState

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

values() - Static method in enum cloud.orbit.actors.runtime.NodeCapabilities.NodeTypeEnum

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

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<?, ?>) - 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.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.ResponseCaching

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

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