Index
All Classes and Interfaces|All Packages
A
- AbstractCallableByActionName - Class in com.scivicslab.pojoactor.core
-
Base class that provides automatic
@Actionannotation dispatch forCallableByActionNameimplementors running on the JVM. - AbstractCallableByActionName() - Constructor for class com.scivicslab.pojoactor.core.AbstractCallableByActionName
- Accumulator - Interface in com.scivicslab.pojoactor.core.accumulator
-
Interface for accumulating results from multiple sources.
- AccumulatorResult<T> - Record Class in com.scivicslab.pojoactor.core.accumulator
-
A result entry in an accumulator.
- AccumulatorResult(String, T, Instant) - Constructor for record class com.scivicslab.pojoactor.core.accumulator.AccumulatorResult
-
Creates an instance of a
AccumulatorResultrecord class. - Action - Annotation Interface in com.scivicslab.pojoactor.core
-
Marks a method as callable by action name from workflow YAML.
- ActionAnnotationProcessor - Class in com.scivicslab.pojoactor.core
-
Compile-time annotation processor for @Action annotation.
- ActionAnnotationProcessor() - Constructor for class com.scivicslab.pojoactor.core.ActionAnnotationProcessor
- ActionArgs - Class in com.scivicslab.pojoactor.core
-
Utility class for parsing arguments in
Action-annotated methods. - ActionArgs.ParsedArgs - Class in com.scivicslab.pojoactor.core
-
Unified accessor for action arguments.
- ActionBaseClassProvider - Interface in com.scivicslab.pojoactor.core
-
SPI interface for registering base classes that support the
Actionannotation. - ActionDispatcher - Class in com.scivicslab.pojoactor.core
-
Reflection-based dispatch helper for
@Action-annotated methods. - ActionDispatcher(Object) - Constructor for class com.scivicslab.pojoactor.core.ActionDispatcher
-
Creates a dispatcher that will scan and invoke
@Action-annotated methods ontarget. - ActionResult - Class in com.scivicslab.pojoactor.core
-
Represents the result of executing an action on an actor.
- ActionResult(boolean, String) - Constructor for class com.scivicslab.pojoactor.core.ActionResult
-
Constructs a new ActionResult.
- ActorMessage - Class in com.scivicslab.pojoactor.core.distributed
-
Message protocol for distributed actor invocation.
- ActorMessage(String, String, String) - Constructor for class com.scivicslab.pojoactor.core.distributed.ActorMessage
-
Constructs a new ActorMessage without reply address.
- ActorMessage(String, String, String, String, String) - Constructor for class com.scivicslab.pojoactor.core.distributed.ActorMessage
-
Constructs a new ActorMessage with specified parameters.
- actorName - Variable in class com.scivicslab.pojoactor.core.ActorRef
- actorOf(String, T) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Creates a new actor with the specified name and object.
- ActorProvider - Interface in com.scivicslab.pojoactor.core
-
Service provider interface for plugin-based actor registration.
- ActorRef<T> - Class in com.scivicslab.pojoactor.core
-
A reference to an actor that provides messaging capabilities and lifecycle management.
- ActorRef(String, T) - Constructor for class com.scivicslab.pojoactor.core.ActorRef
-
Constructs an ActorRef with the specified name and object.
- ActorRef(String, T, ActorSystem) - Constructor for class com.scivicslab.pojoactor.core.ActorRef
-
Constructs an ActorRef with the specified name, object, and actor system.
- actors - Variable in class com.scivicslab.pojoactor.core.ActorSystem
-
A name to an ActorRef correspondance.
- actorSystem - Variable in class com.scivicslab.pojoactor.core.ActorRef
- ActorSystem - Class in com.scivicslab.pojoactor.core
-
A lightweight actor system implementation that manages actor lifecycles and thread pools.
- ActorSystem(String) - Constructor for class com.scivicslab.pojoactor.core.ActorSystem
-
Constructs an ActorSystem with the specified name and default thread pool.
- ActorSystem(String, int) - Constructor for class com.scivicslab.pojoactor.core.ActorSystem
-
Constructs an ActorSystem with the specified name and thread count.
- ActorSystem.Builder - Class in com.scivicslab.pojoactor.core
-
Builder class for creating ActorSystem instances with custom configurations.
- add(String, String, String) - Method in interface com.scivicslab.pojoactor.core.accumulator.Accumulator
-
Adds a result to this accumulator.
- add(String, String, String) - Method in class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator
- add(String, String, String) - Method in class com.scivicslab.pojoactor.core.accumulator.JsonAccumulator
- add(String, String, String) - Method in class com.scivicslab.pojoactor.core.accumulator.StreamingAccumulator
- add(String, String, String) - Method in class com.scivicslab.pojoactor.core.accumulator.TableAccumulator
- addActor(ActorRef<T>) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Add the directly generated Actor to the ActorSystem.
- addActor(ActorRef<T>, String) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Add the directly generated Actor to the ActorSystem while changing the name used within the ActorSystem.
- addActor(String, ActorRef<T>) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Deprecated.
- addManagedThreadPool(int) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Adds a new managed thread pool to the actor system.
- addWorkStealingPool(int) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Deprecated.Use
ActorSystem.addManagedThreadPool(int)instead. - Argument Formats - Search tag in class com.scivicslab.pojoactor.core.ActionArgs
- Section
- asArray() - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets the underlying JSONArray (for array format).
- asArray(String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Parses the arguments as a JSONArray.
- ask(Function<T, R>) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Sends a message to actor and returns a CompletableFuture to be completed with the response value.
- ask(Function<T, R>, ExecutorService) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Sends a message to this actor and returns a response using a specific executor service.
- ask (request-response) - Search tag in class com.scivicslab.pojoactor.core.distributed.transport.KafkaTransport
- Section
- askNow(Function<T, R>) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Sends a message to the actor and returns a response, bypassing the mailbox and executing immediately.
- asObject() - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets the underlying JSONObject (for object format).
- asObject(String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Parses the arguments as a JSONObject.
- AttributeKey<T> - Class in com.scivicslab.pojoactor.core
-
A type-safe key for storing named attributes on an ActorRef.
- autoDetect() - Static method in class com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscoveryFactory
-
Automatically detects the execution environment and returns an appropriate NodeDiscovery implementation.
- autoDetect(int) - Static method in class com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscoveryFactory
-
Automatically detects the execution environment and returns an appropriate NodeDiscovery implementation with specified port.
- awaitTermination(long, TimeUnit) - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
B
- Basic Usage - Search tag in class com.scivicslab.pojoactor.core.DynamicActorLoader
- Section
- BufferedAccumulator - Class in com.scivicslab.pojoactor.core.accumulator
-
An accumulator that buffers results and outputs them on getSummary().
- BufferedAccumulator() - Constructor for class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator
- BufferedAccumulator.ResultEntry - Record Class in com.scivicslab.pojoactor.core.accumulator
-
A single result entry.
- build() - Method in class com.scivicslab.pojoactor.core.ActorSystem.Builder
-
Builds and returns a new ActorSystem instance.
- build() - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem.Builder
- builder() - Static method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem
- Builder() - Constructor for class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem.Builder
- Builder(String) - Constructor for class com.scivicslab.pojoactor.core.ActorSystem.Builder
-
Constructs a new Builder with the specified system name.
C
- CallableByActionName - Interface in com.scivicslab.pojoactor.core
-
Interface for actors that can be invoked dynamically by action name strings.
- callByActionName(String, String) - Method in class com.scivicslab.pojoactor.core.AbstractCallableByActionName
-
Dispatches to the matching
@Action-annotated method, or returns a failure result for unknown action names. - callByActionName(String, String) - Method in interface com.scivicslab.pojoactor.core.CallableByActionName
-
Executes an action identified by its name with the given arguments.
- callByActionName(String, String) - Method in class com.scivicslab.pojoactor.core.distributed.RemoteActorRef
-
Invokes an action on the remote actor and waits for the result.
- cancelJobsForActor(String) - Method in class com.scivicslab.pojoactor.core.ManagedThreadPool
-
Cancels all pending jobs for a specific actor.
- cancelJobsForActor(String) - Method in interface com.scivicslab.pojoactor.core.WorkerPool
-
Cancels all pending (not yet started) jobs submitted for the given actor.
- cancelTask(String) - Method in class com.scivicslab.pojoactor.core.scheduler.Scheduler
-
Cancels a scheduled task.
- clear() - Method in interface com.scivicslab.pojoactor.core.accumulator.Accumulator
-
Clears all accumulated results.
- clear() - Method in class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator
- clear() - Method in class com.scivicslab.pojoactor.core.accumulator.JsonAccumulator
- clear() - Method in class com.scivicslab.pojoactor.core.accumulator.StreamingAccumulator
- clear() - Method in class com.scivicslab.pojoactor.core.accumulator.TableAccumulator
- clear() - Method in class com.scivicslab.pojoactor.core.JsonState
-
Clears all values.
- clearJsonState() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Clears all JSON state for this actor.
- clearPendingMessages() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Clears all pending messages from this actor's message queue.
- close() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Destroys the actor and cleans up its resources.
- close() - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem
- close() - Method in class com.scivicslab.pojoactor.core.distributed.HttpActorServer
- close() - Method in class com.scivicslab.pojoactor.core.distributed.KafkaActorServer
- close() - Method in class com.scivicslab.pojoactor.core.distributed.transport.HttpTransport
- close() - Method in class com.scivicslab.pojoactor.core.distributed.transport.KafkaTransport
- close() - Method in interface com.scivicslab.pojoactor.core.distributed.transport.TransportLayer
-
Releases resources held by this transport (producers, consumers, threads).
- close() - Method in class com.scivicslab.pojoactor.core.scheduler.Scheduler
-
Shuts down the scheduler and cancels all scheduled tasks.
- com.scivicslab.pojoactor.core - package com.scivicslab.pojoactor.core
- com.scivicslab.pojoactor.core.accumulator - package com.scivicslab.pojoactor.core.accumulator
- com.scivicslab.pojoactor.core.distributed - package com.scivicslab.pojoactor.core.distributed
- com.scivicslab.pojoactor.core.distributed.discovery - package com.scivicslab.pojoactor.core.distributed.discovery
- com.scivicslab.pojoactor.core.distributed.transport - package com.scivicslab.pojoactor.core.distributed.transport
- com.scivicslab.pojoactor.core.scheduler - package com.scivicslab.pojoactor.core.scheduler
- com.scivicslab.pojoactor.doclet - package com.scivicslab.pojoactor.doclet
- Comparison with Reflection Approach - Search tag in interface com.scivicslab.pojoactor.core.CallableByActionName
- Section
- copy() - Method in class com.scivicslab.pojoactor.core.JsonState
-
Creates a deep copy of this JsonState.
- createChild(String, K) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Creates a child actor under this actor's supervision.
D
- data() - Method in record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry
-
Returns the value of the
datarecord component. - Design Philosophy - Search tag in interface com.scivicslab.pojoactor.core.CallableByActionName
- Section
- discovery(NodeDiscovery) - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem.Builder
-
Sets the node discovery strategy.
- DistributedActorSystem - Class in com.scivicslab.pojoactor.core.distributed
-
Extends a local
ActorSystemwith distributed capabilities. - DistributedActorSystem.Builder - Class in com.scivicslab.pojoactor.core.distributed
- Distributed System Support - Search tag in interface com.scivicslab.pojoactor.core.CallableByActionName
- Section
- DynamicActorLoader - Class in com.scivicslab.pojoactor.core
-
Dynamic actor loader for runtime-extensible actor system.
- DynamicActorLoader() - Constructor for class com.scivicslab.pojoactor.core.DynamicActorLoader
E
- Endpoint - Search tag in class com.scivicslab.pojoactor.core.distributed.HttpActorServer
- Section
- equals(Object) - Method in record class com.scivicslab.pojoactor.core.accumulator.AccumulatorResult
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in class com.scivicslab.pojoactor.core.AttributeKey
- equals(Object) - Method in class com.scivicslab.pojoactor.core.distributed.NodeInfo
- Example - Search tag in interface com.scivicslab.pojoactor.core.ActionBaseClassProvider
- Section
- Example Output - Search tag in class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator
- Section
- Example Output - Search tag in class com.scivicslab.pojoactor.core.accumulator.JsonAccumulator
- Section
- Example Output - Search tag in class com.scivicslab.pojoactor.core.accumulator.StreamingAccumulator
- Section
- Example Output - Search tag in class com.scivicslab.pojoactor.core.accumulator.TableAccumulator
- Section
- execute(Runnable) - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- expandVariables(String) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Expands variable references in a string.
F
- Features - Search tag in class com.scivicslab.pojoactor.core.DynamicActorLoader
- Section
- fieldNames() - Method in class com.scivicslab.pojoactor.core.JsonState
-
Returns an iterator over the top-level field names.
- ForkJoinPoolWrapper - Class in com.scivicslab.pojoactor.core
-
A WorkerPool implementation that wraps ForkJoinPool (work-stealing executor).
- ForkJoinPoolWrapper() - Constructor for class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
-
Creates a ForkJoinPoolWrapper with default parallelism.
- ForkJoinPoolWrapper(int) - Constructor for class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
-
Creates a ForkJoinPoolWrapper with specified parallelism.
- fromJson(String) - Static method in class com.scivicslab.pojoactor.core.distributed.ActorMessage
-
Deserializes an ActorMessage from JSON string.
G
- get(int) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets string at index (for array format).
- get(int, String) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets string at index with default (for array format).
- get(String) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets string by key (for object format).
- get(String) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Gets an Optional value at the path.
- get(String, String) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets string by key with default (for object format).
- getActionName() - Method in class com.scivicslab.pojoactor.core.distributed.ActorMessage
-
Returns the action name to invoke.
- getActor(String) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Retrieves an actor by name.
- getActorName() - Method in class com.scivicslab.pojoactor.core.distributed.ActorMessage
-
Returns the target actor name.
- getActorName() - Method in class com.scivicslab.pojoactor.core.distributed.RemoteActorRef
- getAddress() - Method in class com.scivicslab.pojoactor.core.distributed.NodeInfo
-
Returns the network address in "host:port" format.
- getAllNodes() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.GridEngineNodeDiscovery
- getAllNodes() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.K8sNodeDiscovery
- getAllNodes() - Method in interface com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscovery
-
Returns information about all nodes in the cluster.
- getAllNodes() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.SlurmNodeDiscovery
- getArgs() - Method in class com.scivicslab.pojoactor.core.distributed.ActorMessage
-
Returns the action arguments.
- getAttribute(AttributeKey<V>) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Returns the attribute value for the given key, or null if not set.
- getAttribute(AttributeKey<V>, V) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Returns the attribute value for the given key, or defaultValue if not set.
- getBaseClassName() - Method in interface com.scivicslab.pojoactor.core.ActionBaseClassProvider
-
Returns the fully qualified class name of a base class whose subclasses are allowed to use the
Actionannotation. - getBoolean(int) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets boolean at index (for array format).
- getBoolean(int, boolean) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets boolean at index with default (for array format).
- getBoolean(String) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets boolean by key (for object format).
- getBoolean(String, boolean) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets boolean by key with default (for object format).
- getBoolean(String, boolean) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Gets a boolean value at the path.
- getBoolean(String, int) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a boolean at the specified index from array arguments.
- getBoolean(String, int, boolean) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a boolean at the specified index from array arguments with default.
- getBoolean(String, String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a boolean for the specified key from object arguments.
- getBoolean(String, String, boolean) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a boolean for the specified key from object arguments with default.
- getCount() - Method in interface com.scivicslab.pojoactor.core.accumulator.Accumulator
-
Returns the number of results that have been added.
- getCount() - Method in class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator
- getCount() - Method in class com.scivicslab.pojoactor.core.accumulator.JsonAccumulator
- getCount() - Method in class com.scivicslab.pojoactor.core.accumulator.StreamingAccumulator
- getCount() - Method in class com.scivicslab.pojoactor.core.accumulator.TableAccumulator
- getDouble(String, double) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Gets a double value at the path.
- getDouble(String, int) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a double at the specified index from array arguments.
- getDouble(String, int, double) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a double at the specified index from array arguments with default.
- getDouble(String, String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a double for the specified key from object arguments.
- getDouble(String, String, double) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a double for the specified key from object arguments with default.
- getFirst(String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets the first string from array arguments.
- getHost() - Method in class com.scivicslab.pojoactor.core.distributed.NodeInfo
-
Returns the hostname or IP address.
- getInt(int) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets integer at index (for array format).
- getInt(int, int) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets integer at index with default (for array format).
- getInt(String) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets integer by key (for object format).
- getInt(String, int) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets an integer at the specified index from array arguments.
- getInt(String, int) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets integer by key with default (for object format).
- getInt(String, int) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Gets an integer value at the path.
- getInt(String, int, int) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets an integer at the specified index from array arguments with default.
- getInt(String, String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets an integer for the specified key from object arguments.
- getInt(String, String, int) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets an integer for the specified key from object arguments with default.
- getJsonBoolean(String, boolean) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Convenience method to get a boolean from the JSON state.
- getJsonInt(String, int) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Convenience method to get an integer from the JSON state.
- getJsonString(String) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Convenience method to get a string from the JSON state.
- getJsonString(String, String) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Convenience method to get a string from the JSON state with default.
- getLastResult() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Gets the last action result for this actor.
- getLocalActorSystem() - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem
-
Returns the underlying local actor system.
- getLogger() - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Gets the current logger instance.
- getLong(String, int) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a long at the specified index from array arguments.
- getLong(String, int, long) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a long at the specified index from array arguments with default.
- getLong(String, long) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Gets a long value at the path.
- getLong(String, String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a long for the specified key from object arguments.
- getLong(String, String, long) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a long for the specified key from object arguments with default.
- getManagedThreadPool() - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Returns the default managed thread pool of the actor system.
- getManagedThreadPool(int) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Returns a managed thread pool at the specified index.
- getMessageId() - Method in class com.scivicslab.pojoactor.core.distributed.ActorMessage
-
Returns the unique message identifier.
- getMyHost() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.GridEngineNodeDiscovery
- getMyHost() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.K8sNodeDiscovery
- getMyHost() - Method in interface com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscovery
-
Returns the hostname or IP address for the current node.
- getMyHost() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.SlurmNodeDiscovery
- getMyNode() - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem
-
Returns this node's identity.
- getMyNodeId() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.GridEngineNodeDiscovery
- getMyNodeId() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.K8sNodeDiscovery
- getMyNodeId() - Method in interface com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscovery
-
Returns the unique identifier for the current node.
- getMyNodeId() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.SlurmNodeDiscovery
- getMyPort() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.GridEngineNodeDiscovery
- getMyPort() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.K8sNodeDiscovery
- getMyPort() - Method in interface com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscovery
-
Returns the default port number for actor communication.
- getMyPort() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.SlurmNodeDiscovery
- getName() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Returns the name of this actor.
- getName() - Method in class com.scivicslab.pojoactor.doclet.TuringPluginDoclet
- getNamesOfChildren() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Returns the names of all child actors supervised by this actor.
- getNodeId() - Method in class com.scivicslab.pojoactor.core.distributed.NodeInfo
-
Returns the node identifier.
- getNodeInfo() - Method in class com.scivicslab.pojoactor.core.distributed.RemoteActorRef
- getNodes() - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem
-
Returns all nodes in the cluster (including this node).
- getParentName() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Returns the name of this actor's parent, if any.
- getPendingJobCountForActor(String) - Method in class com.scivicslab.pojoactor.core.ManagedThreadPool
-
Gets the number of pending jobs for a specific actor.
- getPendingJobCountForActor(String) - Method in interface com.scivicslab.pojoactor.core.WorkerPool
-
Returns the number of pending (not yet started) jobs for the given actor.
- getPluginName() - Method in interface com.scivicslab.pojoactor.core.ActorProvider
-
Returns the name of this plugin.
- getPluginVersion() - Method in interface com.scivicslab.pojoactor.core.ActorProvider
-
Returns the version of this plugin.
- getPort() - Method in class com.scivicslab.pojoactor.core.distributed.NodeInfo
-
Returns the HTTP port number.
- getReplyTo() - Method in class com.scivicslab.pojoactor.core.distributed.ActorMessage
-
Returns the reply address.
- getResult() - Method in class com.scivicslab.pojoactor.core.ActionResult
-
Returns the result message or data.
- getResults() - Method in class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator
-
Returns an unmodifiable list of all result entries.
- getResultsAsJson() - Method in class com.scivicslab.pojoactor.core.accumulator.JsonAccumulator
-
Returns the results as a JSONObject.
- getRoot() - Method in class com.scivicslab.pojoactor.core.JsonState
-
Returns the root ObjectNode for direct manipulation.
- getScheduledTaskCount() - Method in class com.scivicslab.pojoactor.core.scheduler.Scheduler
-
Returns the number of currently scheduled tasks.
- getString(String) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Gets a string value at the path.
- getString(String, int) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a string at the specified index from array arguments.
- getString(String, int, String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a string at the specified index from array arguments with default.
- getString(String, String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a string for the specified key from object arguments.
- getString(String, String) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Gets a string value at the path with default.
- getString(String, String, String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets a string for the specified key from object arguments with default.
- getSummary() - Method in interface com.scivicslab.pojoactor.core.accumulator.Accumulator
-
Returns a formatted summary of all accumulated results.
- getSummary() - Method in class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator
- getSummary() - Method in class com.scivicslab.pojoactor.core.accumulator.JsonAccumulator
- getSummary() - Method in class com.scivicslab.pojoactor.core.accumulator.StreamingAccumulator
- getSummary() - Method in class com.scivicslab.pojoactor.core.accumulator.TableAccumulator
- getSupportedOptions() - Method in class com.scivicslab.pojoactor.doclet.TuringPluginDoclet
- getSupportedSourceVersion() - Method in class com.scivicslab.pojoactor.doclet.TuringPluginDoclet
- getTrackedActorCount() - Method in class com.scivicslab.pojoactor.core.ManagedThreadPool
-
Gets the total number of actors currently tracked.
- getTransport() - Method in class com.scivicslab.pojoactor.core.distributed.RemoteActorRef
- getUrl() - Method in class com.scivicslab.pojoactor.core.distributed.NodeInfo
-
Returns the base URL for this node.
- getWorkStealingPool() - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Deprecated.Use
ActorSystem.getManagedThreadPool()instead. - getWorkStealingPool(int) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Deprecated.Use
ActorSystem.getManagedThreadPool(int)instead. - GraalVM Native Image - Search tag in annotation interface com.scivicslab.pojoactor.core.Action
- Section
- GridEngineNodeDiscovery - Class in com.scivicslab.pojoactor.core.distributed.discovery
-
Node discovery implementation for Grid Engine (SGE/UGE/OGE).
- GridEngineNodeDiscovery() - Constructor for class com.scivicslab.pojoactor.core.distributed.discovery.GridEngineNodeDiscovery
-
Constructs a GridEngineNodeDiscovery with default port 8080.
- GridEngineNodeDiscovery(int) - Constructor for class com.scivicslab.pojoactor.core.distributed.discovery.GridEngineNodeDiscovery
-
Constructs a GridEngineNodeDiscovery with specified port.
- Grid Engine Script Example - Search tag in class com.scivicslab.pojoactor.core.distributed.discovery.GridEngineNodeDiscovery
- Section
H
- has(String) - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Checks if key exists (for object format).
- has(String) - Method in class com.scivicslab.pojoactor.core.ActionDispatcher
-
Returns
trueif an@Action-annotated method is registered for the given name. - has(String) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Checks if a value exists at the path.
- hasActor(String) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Checks if an actor with the specified name exists in the system.
- hasAnnotatedAction(String) - Method in class com.scivicslab.pojoactor.core.AbstractCallableByActionName
-
Returns
trueif an@Action-annotated method is registered for the given name. - hasAtLeast(String, int) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Checks if array arguments have at least the required number of elements.
- hasAttribute(AttributeKey<?>) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Returns true if an attribute has been set for the given key.
- hashCode() - Method in record class com.scivicslab.pojoactor.core.accumulator.AccumulatorResult
-
Returns a hash code value for this object.
- hashCode() - Method in record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry
-
Returns a hash code value for this object.
- hashCode() - Method in class com.scivicslab.pojoactor.core.AttributeKey
- hashCode() - Method in class com.scivicslab.pojoactor.core.distributed.NodeInfo
- hasJson(String) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Convenience method to check if a path exists in the JSON state.
- hasJsonState() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Checks if this actor has any JSON state.
- hasKey(String, String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Checks if the specified key exists in object arguments.
- Helper Method - Search tag in class com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscoveryFactory
- Section
- HttpActorServer - Class in com.scivicslab.pojoactor.core.distributed
-
HTTP server that receives actor invocation requests from remote nodes and dispatches them to the local
ActorSystem. - HttpActorServer(ActorSystem, int) - Constructor for class com.scivicslab.pojoactor.core.distributed.HttpActorServer
-
Creates an HttpActorServer that listens on the given port.
- HttpTransport - Class in com.scivicslab.pojoactor.core.distributed.transport
-
HTTP-based transport for inter-node actor communication.
- HttpTransport() - Constructor for class com.scivicslab.pojoactor.core.distributed.transport.HttpTransport
I
- inboxTopic(String) - Static method in class com.scivicslab.pojoactor.core.distributed.transport.KafkaTransport
- init(Locale, Reporter) - Method in class com.scivicslab.pojoactor.doclet.TuringPluginDoclet
- initLogger(String) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Initializes the logger with the specified name.
- initLogger(String) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Initializes the system logger with the specified name.
- invoke(String, String) - Method in class com.scivicslab.pojoactor.core.ActionDispatcher
-
Invokes the
@Action-annotated method whose name matchesactionName. - invokeAll(Collection<? extends Callable<T>>) - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- invokeAll(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- invokeAnnotatedAction(String, String) - Method in class com.scivicslab.pojoactor.core.AbstractCallableByActionName
-
Invokes the
@Action-annotated method whose name matchesactionName. - invokeAny(Collection<? extends Callable<T>>) - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- invokeAny(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- isAlive() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Checks if this actor is still alive and able to process messages.
- isAlive() - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Checks if the actor system is alive (no thread pools are shut down).
- isAlive(String) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Checks if a specific actor is alive.
- isApplicable() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.GridEngineNodeDiscovery
- isApplicable() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.K8sNodeDiscovery
- isApplicable() - Method in interface com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscovery
-
Checks if this discovery implementation is applicable to the current environment.
- isApplicable() - Method in class com.scivicslab.pojoactor.core.distributed.discovery.SlurmNodeDiscovery
- isArray() - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Checks if arguments are in array format.
- isArray(String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Checks if arguments are in array format.
- isEmpty() - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Checks if arguments are empty.
- isEmpty() - Method in class com.scivicslab.pojoactor.core.JsonState
-
Checks if the state is empty.
- isEmpty(String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Checks if arguments are empty.
- isNotEmpty(String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Checks if arguments are not empty.
- isObject() - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Checks if arguments are in object format.
- isObject(String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Checks if arguments are in object format.
- isScheduled(String) - Method in class com.scivicslab.pojoactor.core.scheduler.Scheduler
-
Checks if a task with the given ID is currently scheduled.
- isShutdown() - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- isSuccess() - Method in class com.scivicslab.pojoactor.core.ActionResult
-
Returns whether the action completed successfully.
- isTerminated() - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
J
- json() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Returns the JSON state container for this actor, creating it if necessary.
- JsonAccumulator - Class in com.scivicslab.pojoactor.core.accumulator
-
An accumulator that outputs results in JSON format.
- JsonAccumulator() - Constructor for class com.scivicslab.pojoactor.core.accumulator.JsonAccumulator
- JsonState - Class in com.scivicslab.pojoactor.core
-
JSON state container with XPath-style path accessor.
- JsonState() - Constructor for class com.scivicslab.pojoactor.core.JsonState
-
Constructs an empty JsonState.
- JsonState(ObjectNode) - Constructor for class com.scivicslab.pojoactor.core.JsonState
-
Constructs a JsonState from an existing ObjectNode.
K
- K8s / Kafka Example - Search tag in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem
- Section
- K8sNodeDiscovery - Class in com.scivicslab.pojoactor.core.distributed.discovery
-
Node discovery implementation for Kubernetes StatefulSets.
- K8sNodeDiscovery() - Constructor for class com.scivicslab.pojoactor.core.distributed.discovery.K8sNodeDiscovery
-
Constructs a K8sNodeDiscovery with default port 8080 and default namespace.
- K8sNodeDiscovery(int, String) - Constructor for class com.scivicslab.pojoactor.core.distributed.discovery.K8sNodeDiscovery
-
Constructs a K8sNodeDiscovery with specified port and namespace.
- KafkaActorServer - Class in com.scivicslab.pojoactor.core.distributed
-
Server-side component that receives actor messages from Kafka and dispatches them to the local
ActorSystem. - KafkaActorServer(ActorSystem, NodeInfo, String) - Constructor for class com.scivicslab.pojoactor.core.distributed.KafkaActorServer
-
Creates a KafkaActorServer.
- KafkaTransport - Class in com.scivicslab.pojoactor.core.distributed.transport
-
Kafka-based transport for inter-node actor communication.
- KafkaTransport(NodeInfo, String) - Constructor for class com.scivicslab.pojoactor.core.distributed.transport.KafkaTransport
-
Creates a KafkaTransport for the given local node.
- Kubernetes Configuration Example - Search tag in class com.scivicslab.pojoactor.core.distributed.discovery.K8sNodeDiscovery
- Section
L
- length() - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets the number of elements (for array format).
- length(String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Gets the length of array arguments.
- Lifecycle - Search tag in class com.scivicslab.pojoactor.core.distributed.HttpActorServer
- Section
- Lifecycle - Search tag in class com.scivicslab.pojoactor.core.distributed.KafkaActorServer
- Section
- listActorNames() - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Returns a list of all actor names in the system.
- loadActor(Path, String, String) - Static method in class com.scivicslab.pojoactor.core.DynamicActorLoader
-
Loads a class from an external JAR file and wraps it as an ActorRef.
- loadActorIntoSystem(ActorSystem, Path, String, String) - Static method in class com.scivicslab.pojoactor.core.DynamicActorLoader
-
Loads a class from an external JAR file and wraps it as an ActorRef, registering it with the given ActorSystem.
- localActorSystem(ActorSystem) - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem.Builder
-
Sets the local actor system.
M
- ManagedThreadPool - Class in com.scivicslab.pojoactor.core
-
A managed thread pool for CPU-intensive tasks in POJO-actor.
- ManagedThreadPool(int) - Constructor for class com.scivicslab.pojoactor.core.ManagedThreadPool
-
Creates a ManagedThreadPool with the specified parallelism level.
- Message Format - Search tag in class com.scivicslab.pojoactor.core.distributed.ActorMessage
- Section
- Method Signature Requirements - Search tag in annotation interface com.scivicslab.pojoactor.core.Action
- Section
- Mixin Pattern with Interface Default Methods - Search tag in annotation interface com.scivicslab.pojoactor.core.Action
- Section
- Multiple arguments - Search tag in class com.scivicslab.pojoactor.core.ActionArgs
- Section
N
- name() - Method in class com.scivicslab.pojoactor.core.AttributeKey
- NodeDiscovery - Interface in com.scivicslab.pojoactor.core.distributed.discovery
-
Interface for node discovery in distributed actor systems.
- NodeDiscoveryFactory - Class in com.scivicslab.pojoactor.core.distributed.discovery
-
Factory for automatic node discovery based on runtime environment.
- NodeInfo - Class in com.scivicslab.pojoactor.core.distributed
-
Information about a node in the distributed actor system.
- NodeInfo(String, String, int) - Constructor for class com.scivicslab.pojoactor.core.distributed.NodeInfo
-
Constructs a new NodeInfo with specified parameters.
O
- object - Variable in class com.scivicslab.pojoactor.core.ActorRef
- Object arguments - Search tag in class com.scivicslab.pojoactor.core.ActionArgs
- Section
- of(String, Class<T>) - Static method in class com.scivicslab.pojoactor.core.AttributeKey
P
- parse(String) - Static method in class com.scivicslab.pojoactor.core.ActionArgs
-
Parses arguments into a unified accessor.
- Path Syntax - Search tag in class com.scivicslab.pojoactor.core.JsonState
- Section
- process(Set<? extends TypeElement>, RoundEnvironment) - Method in class com.scivicslab.pojoactor.core.ActionAnnotationProcessor
- put(String, Object) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Sets a value at the given path, creating intermediate nodes as needed.
- putAttribute(AttributeKey<V>, V) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Stores a typed attribute value.
- putJson(String, Object) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Convenience method to put a value into the JSON state.
R
- raw() - Method in class com.scivicslab.pojoactor.core.ActionArgs.ParsedArgs
-
Gets the raw JSON string.
- registerActors(ActorSystem) - Method in interface com.scivicslab.pojoactor.core.ActorProvider
-
Registers actors provided by this plugin into the given ActorSystem.
- remoteActorOf(NodeInfo, String) - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem
-
Returns a
RemoteActorReffor an actor on the given remote node. - RemoteActorRef - Class in com.scivicslab.pojoactor.core.distributed
-
Reference to an actor hosted on a remote node.
- RemoteActorRef(String, NodeInfo) - Constructor for class com.scivicslab.pojoactor.core.distributed.RemoteActorRef
-
Constructs a RemoteActorRef using the default HTTP transport.
- RemoteActorRef(String, NodeInfo, TransportLayer) - Constructor for class com.scivicslab.pojoactor.core.distributed.RemoteActorRef
-
Constructs a RemoteActorRef with an explicit transport layer.
- remove(String) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Removes a value at the given path.
- removeActor(String) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Removes an actor from the system.
- removeAttribute(AttributeKey<V>) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Removes and returns the attribute value for the given key, or null if not set.
- replyTopic(String) - Static method in class com.scivicslab.pojoactor.core.distributed.transport.KafkaTransport
- Requirements - Search tag in class com.scivicslab.pojoactor.core.DynamicActorLoader
- Section
- result() - Method in record class com.scivicslab.pojoactor.core.accumulator.AccumulatorResult
-
Returns the value of the
resultrecord component. - ResultEntry(String, String, String, Instant) - Constructor for record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry
-
Creates an instance of a
ResultEntryrecord class. - run(DocletEnvironment) - Method in class com.scivicslab.pojoactor.doclet.TuringPluginDoclet
S
- scheduleAtFixedRate(String, ActorRef<T>, Consumer<T>, long, long, TimeUnit) - Method in class com.scivicslab.pojoactor.core.scheduler.Scheduler
-
Schedules a task to execute periodically at a fixed rate.
- scheduleOnce(String, ActorRef<T>, Consumer<T>, long, TimeUnit) - Method in class com.scivicslab.pojoactor.core.scheduler.Scheduler
-
Schedules a task to execute once after a specified delay.
- Scheduler - Class in com.scivicslab.pojoactor.core.scheduler
-
A scheduler for periodic task execution with ActorRef.
- Scheduler() - Constructor for class com.scivicslab.pojoactor.core.scheduler.Scheduler
-
Constructs a new Scheduler with default thread pool size (2).
- Scheduler(int) - Constructor for class com.scivicslab.pojoactor.core.scheduler.Scheduler
-
Constructs a new Scheduler with the specified thread pool size.
- scheduleWithFixedDelay(String, ActorRef<T>, Consumer<T>, long, long, TimeUnit) - Method in class com.scivicslab.pojoactor.core.scheduler.Scheduler
-
Schedules a task to execute periodically with a fixed delay between executions.
- select(String) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Selects a JsonNode at the given path.
- send(NodeInfo, ActorMessage) - Method in class com.scivicslab.pojoactor.core.distributed.transport.HttpTransport
-
Sends a message without waiting for a response.
- send(NodeInfo, ActorMessage) - Method in class com.scivicslab.pojoactor.core.distributed.transport.KafkaTransport
- send(NodeInfo, ActorMessage) - Method in interface com.scivicslab.pojoactor.core.distributed.transport.TransportLayer
-
Sends a message to an actor on the target node without waiting for a result (fire-and-forget).
- sendAndWait(NodeInfo, ActorMessage, Duration) - Method in class com.scivicslab.pojoactor.core.distributed.transport.HttpTransport
-
Sends a message and waits synchronously for the result.
- sendAndWait(NodeInfo, ActorMessage, Duration) - Method in class com.scivicslab.pojoactor.core.distributed.transport.KafkaTransport
- sendAndWait(NodeInfo, ActorMessage, Duration) - Method in interface com.scivicslab.pojoactor.core.distributed.transport.TransportLayer
-
Sends a message to an actor on the target node and waits for the result.
- setLastResult(ActionResult) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Sets the last action result for this actor.
- setLogger(Logger) - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Sets the logger for the actor system.
- setParentName(String) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Sets the parent name for this actor.
- shutdown() - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- shutdownNow() - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- Simple Plugin - Search tag in interface com.scivicslab.pojoactor.core.CallableByActionName
- Section
- Single argument (most common) - Search tag in class com.scivicslab.pojoactor.core.ActionArgs
- Section
- size() - Method in class com.scivicslab.pojoactor.core.JsonState
-
Returns the number of top-level keys.
- Slurm / HTTP Example - Search tag in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem
- Section
- SlurmNodeDiscovery - Class in com.scivicslab.pojoactor.core.distributed.discovery
-
Node discovery implementation for Slurm workload manager.
- SlurmNodeDiscovery() - Constructor for class com.scivicslab.pojoactor.core.distributed.discovery.SlurmNodeDiscovery
-
Constructs a SlurmNodeDiscovery with default port 8080.
- SlurmNodeDiscovery(int) - Constructor for class com.scivicslab.pojoactor.core.distributed.discovery.SlurmNodeDiscovery
-
Constructs a SlurmNodeDiscovery with specified port.
- source() - Method in record class com.scivicslab.pojoactor.core.accumulator.AccumulatorResult
-
Returns the value of the
sourcerecord component. - source() - Method in record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry
-
Returns the value of the
sourcerecord component. - Standard Implementations - Search tag in interface com.scivicslab.pojoactor.core.accumulator.Accumulator
- Section
- start() - Method in class com.scivicslab.pojoactor.core.distributed.HttpActorServer
-
Starts the HTTP server.
- start() - Method in class com.scivicslab.pojoactor.core.distributed.KafkaActorServer
-
Starts the inbox consumer loop in a virtual thread.
- startHttpServer(int) - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem
-
Starts an
HttpActorServerto receive messages via HTTP. - startServer(String) - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem
-
Starts a
KafkaActorServerto receive messages from Kafka. - StreamingAccumulator - Class in com.scivicslab.pojoactor.core.accumulator
-
An accumulator that outputs results immediately as they are added.
- StreamingAccumulator() - Constructor for class com.scivicslab.pojoactor.core.accumulator.StreamingAccumulator
-
Constructs a StreamingAccumulator with default settings.
- StreamingAccumulator(PrintStream, String) - Constructor for class com.scivicslab.pojoactor.core.accumulator.StreamingAccumulator
-
Constructs a StreamingAccumulator with custom output and format.
- submit(Runnable) - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- submit(Runnable, T) - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- submit(Callable<T>) - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- submitForActor(String, Runnable) - Method in class com.scivicslab.pojoactor.core.ManagedThreadPool
-
Submits a task associated with a specific actor.
- submitUrgentForActor(String, Runnable) - Method in class com.scivicslab.pojoactor.core.ManagedThreadPool
-
Submits an urgent task to the front of the queue.
- Supported Environments - Search tag in class com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscoveryFactory
- Section
- supportsCancellation() - Method in class com.scivicslab.pojoactor.core.ForkJoinPoolWrapper
- supportsCancellation() - Method in class com.scivicslab.pojoactor.core.ManagedThreadPool
- supportsCancellation() - Method in interface com.scivicslab.pojoactor.core.WorkerPool
-
Returns whether this implementation supports per-actor job cancellation.
- system() - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Returns the actor system this actor belongs to.
- systemName - Variable in class com.scivicslab.pojoactor.core.ActorSystem
T
- TableAccumulator - Class in com.scivicslab.pojoactor.core.accumulator
-
An accumulator that formats results as a table.
- TableAccumulator() - Constructor for class com.scivicslab.pojoactor.core.accumulator.TableAccumulator
-
Constructs a TableAccumulator with default column width of 30 characters.
- TableAccumulator(int) - Constructor for class com.scivicslab.pojoactor.core.accumulator.TableAccumulator
-
Constructs a TableAccumulator with custom column width.
- tell(Consumer<T>) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Sends a message to the actor defined by this reference.
- tell(Consumer<T>, ExecutorService) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Sends a message to this actor using a specific executor service.
- tell (fire-and-forget) - Search tag in class com.scivicslab.pojoactor.core.distributed.transport.KafkaTransport
- Section
- tellNow(Consumer<T>) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Sends a message to the actor for immediate execution, bypassing the normal message queue.
- terminate() - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Terminates the actor system by closing all actors and shutting down thread pools.
- threadNum(int) - Method in class com.scivicslab.pojoactor.core.ActorSystem.Builder
-
Sets the number of threads for the actor system.
- timestamp() - Method in record class com.scivicslab.pojoactor.core.accumulator.AccumulatorResult
-
Returns the value of the
timestamprecord component. - timestamp() - Method in record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry
-
Returns the value of the
timestamprecord component. - toJson() - Method in class com.scivicslab.pojoactor.core.distributed.ActorMessage
-
Serializes this message to JSON string.
- Topic Naming Convention - Search tag in class com.scivicslab.pojoactor.core.distributed.transport.KafkaTransport
- Section
- toPrettyString() - Method in class com.scivicslab.pojoactor.core.JsonState
-
Returns a pretty-printed JSON string.
- toString() - Method in record class com.scivicslab.pojoactor.core.accumulator.AccumulatorResult
-
Returns a string representation of this record class.
- toString() - Method in record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry
-
Returns a string representation of this record class.
- toString() - Method in class com.scivicslab.pojoactor.core.ActionResult
- toString() - Method in class com.scivicslab.pojoactor.core.ActorSystem
-
Returns a string representation of the actor system.
- toString() - Method in class com.scivicslab.pojoactor.core.AttributeKey
- toString() - Method in class com.scivicslab.pojoactor.core.distributed.ActorMessage
- toString() - Method in class com.scivicslab.pojoactor.core.distributed.NodeInfo
- toString() - Method in class com.scivicslab.pojoactor.core.distributed.RemoteActorRef
- toString() - Method in class com.scivicslab.pojoactor.core.JsonState
-
Returns the JSON string representation.
- toStringOfJson(String) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Returns a pretty-printed JSON string for the subtree at the given path.
- toStringOfJson(String) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Returns a pretty-printed JSON string for the subtree at the given path.
- toStringOfYaml(String) - Method in class com.scivicslab.pojoactor.core.ActorRef
-
Returns a YAML string for the subtree at the given path.
- toStringOfYaml(String) - Method in class com.scivicslab.pojoactor.core.JsonState
-
Returns a YAML string for the subtree at the given path.
- transport(TransportLayer) - Method in class com.scivicslab.pojoactor.core.distributed.DistributedActorSystem.Builder
-
Sets the transport layer.
- TransportLayer - Interface in com.scivicslab.pojoactor.core.distributed.transport
-
Abstraction over the network transport used for inter-node actor communication.
- TuringPluginDoclet - Class in com.scivicslab.pojoactor.doclet
-
Javadoc doclet that generates META-INF/turing-plugin.json from @Action annotated methods.
- TuringPluginDoclet() - Constructor for class com.scivicslab.pojoactor.doclet.TuringPluginDoclet
- type() - Method in record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry
-
Returns the value of the
typerecord component. - type() - Method in class com.scivicslab.pojoactor.core.AttributeKey
U
- Usage - Search tag in annotation interface com.scivicslab.pojoactor.core.Action
- Section
- Usage - Search tag in class com.scivicslab.pojoactor.core.AbstractCallableByActionName
- Section
- Usage - Search tag in class com.scivicslab.pojoactor.core.ActionDispatcher
- Section
- Usage - Search tag in interface com.scivicslab.pojoactor.core.ActionBaseClassProvider
- Section
- Usage Example - Search tag in class com.scivicslab.pojoactor.core.ActionResult
- Section
- Usage Example - Search tag in class com.scivicslab.pojoactor.core.JsonState
- Section
- Usage Example - Search tag in class com.scivicslab.pojoactor.core.distributed.ActorMessage
- Section
- Usage Example - Search tag in class com.scivicslab.pojoactor.core.distributed.NodeInfo
- Section
- Usage Example - Search tag in class com.scivicslab.pojoactor.core.distributed.discovery.GridEngineNodeDiscovery
- Section
- Usage Example - Search tag in class com.scivicslab.pojoactor.core.distributed.discovery.K8sNodeDiscovery
- Section
- Usage Example - Search tag in class com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscoveryFactory
- Section
- Usage Example - Search tag in class com.scivicslab.pojoactor.core.distributed.discovery.SlurmNodeDiscovery
- Section
- Usage Example - Search tag in interface com.scivicslab.pojoactor.core.CallableByActionName
- Section
- Usage Example - Search tag in interface com.scivicslab.pojoactor.core.distributed.discovery.NodeDiscovery
- Section
- Usage Example (HTTP transport) - Search tag in class com.scivicslab.pojoactor.core.distributed.RemoteActorRef
- Section
- Usage Example (Kafka transport) - Search tag in class com.scivicslab.pojoactor.core.distributed.RemoteActorRef
- Section
- Usage Examples - Search tag in class com.scivicslab.pojoactor.core.ActionArgs
- Section
- Usage in Application - Search tag in interface com.scivicslab.pojoactor.core.ActorProvider
- Section
- Usage in Plugin - Search tag in interface com.scivicslab.pojoactor.core.ActorProvider
- Section
- Usage Pattern - Search tag in interface com.scivicslab.pojoactor.core.accumulator.Accumulator
- Section
V
- value() - Element in annotation interface com.scivicslab.pojoactor.core.Action
-
The action name used in workflow YAML to invoke this method.
W
- With Actor System - Search tag in interface com.scivicslab.pojoactor.core.CallableByActionName
- Section
- With static import - Search tag in class com.scivicslab.pojoactor.core.ActionArgs
- Section
- WorkerPool - Interface in com.scivicslab.pojoactor.core
-
Extension of ExecutorService that adds per-actor job management.
- workerPools - Variable in class com.scivicslab.pojoactor.core.ActorSystem
- Workflow YAML Example - Search tag in annotation interface com.scivicslab.pojoactor.core.Action
- Section
Y
- YAML Workflow Example - Search tag in interface com.scivicslab.pojoactor.core.CallableByActionName
- Section
All Classes and Interfaces|All Packages
ActorSystem.addActor(ActorRef)instead