| Package | Description |
|---|---|
| cloud.orbit.actors.peer | |
| cloud.orbit.actors.runtime |
| Modifier and Type | Method and Description |
|---|---|
protected Task<Object> |
PeerExecutor.performLocalInvocation(Invocation invocation,
ObjectInvoker invoker,
LocalObjects.LocalObjectEntry target) |
Task |
PeerExecutor.scheduleLocalInvocation(LocalObjects.LocalObjectEntry<Object> localObjectEntry,
Invocation invocation) |
| Modifier and Type | Class and Description |
|---|---|
class |
ActorBaseEntry<T extends AbstractActor> |
class |
ActorEntry<T extends AbstractActor> |
static class |
LocalObjects.NormalObjectEntry<T> |
class |
ObserverEntry<T> |
class |
StatelessActorEntry<T extends AbstractActor> |
| Modifier and Type | Method and Description |
|---|---|
protected <T> LocalObjects.LocalObjectEntry |
LocalObjects.createLocalObjectEntry(RemoteReference<T> reference,
T object)
This method must be overridden by the stage to create proper entries for Actors and Stateless Actors
|
LocalObjects.LocalObjectEntry |
LocalObjects.findLocalActor(Actor actor) |
LocalObjects.LocalObjectEntry |
LocalObjects.findLocalObject(NodeAddress address,
int interfaceId,
Object objectId) |
LocalObjects.LocalObjectEntry |
LocalObjects.findLocalObjectByObject(Object object) |
LocalObjects.LocalObjectEntry |
LocalObjects.findLocalObjectByReference(RemoteReference reference) |
| Modifier and Type | Method and Description |
|---|---|
java.util.stream.Stream<Map.Entry<Object,LocalObjects.LocalObjectEntry>> |
LocalObjects.stream() |
| Modifier and Type | Method and Description |
|---|---|
protected Task<Object> |
Execution.performInvocation(HandlerContext ctx,
Invocation invocation,
LocalObjects.LocalObjectEntry entry,
LocalObjects.LocalObjectEntry target) |
protected Task<Object> |
Execution.performInvocation(HandlerContext ctx,
Invocation invocation,
LocalObjects.LocalObjectEntry entry,
LocalObjects.LocalObjectEntry target) |
| Modifier and Type | Method and Description |
|---|---|
<R> Task<R> |
StatelessActorEntry.run(TaskFunction<LocalObjects.LocalObjectEntry<T>,R> function) |
<R> Task<R> |
ObserverEntry.run(TaskFunction<LocalObjects.LocalObjectEntry<T>,R> function) |
<R> Task<R> |
LocalObjects.LocalObjectEntry.run(TaskFunction<LocalObjects.LocalObjectEntry<T>,R> function) |
<R> Task<R> |
LocalObjects.NormalObjectEntry.run(TaskFunction<LocalObjects.LocalObjectEntry<T>,R> function) |
<R> Task<R> |
ActorEntry.run(TaskFunction<LocalObjects.LocalObjectEntry<T>,R> function) |
<R> Task<R> |
ActorBaseEntry.run(TaskFunction<LocalObjects.LocalObjectEntry<T>,R> function) |
Copyright © 2016 Electronic Arts Inc. All rights reserved.