Index

A B C D E F G H I J K L M N O P R S T U V W Y
All Classes and Interfaces|All Packages

A

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 AccumulatorResult record 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 Action annotation.

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.

Use ActorSystem.addActor(ActorRef) instead

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.

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.

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.

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

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 jobs for a specific 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.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.scheduler - package com.scivicslab.pojoactor.core.scheduler

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 data record component.

Design Philosophy - Search tag in interface com.scivicslab.pojoactor.core.CallableByActionName

Section

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

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

Returns the name of the remote actor.

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.

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 Action annotation.

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.

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

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.

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

Returns information about the node hosting this actor.

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

Gets the number of pending jobs for a specific 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

getTrackedActorCount() - Method in class com.scivicslab.pojoactor.core.ManagedThreadPool

Gets the total number of actors currently tracked.

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

hasAtLeast(String, int) - Static method in class com.scivicslab.pojoactor.core.ActionArgs

Checks if array arguments have at least the required number of elements.

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

I

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.

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

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

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.

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.

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.

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

Network Protocol - Search tag in class com.scivicslab.pojoactor.core.distributed.RemoteActorRef

Section

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

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.

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.

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 new RemoteActorRef.

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.

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 result record component.

ResultEntry(String, String, String, Instant) - Constructor for record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry

Creates an instance of a ResultEntry record class.

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.

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.

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 source record component.

source() - Method in record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry

Returns the value of the source record component.

Standard Implementations - Search tag in interface com.scivicslab.pojoactor.core.accumulator.Accumulator

Section

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

Checks if this worker pool supports job cancellation per actor.

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.

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 timestamp record component.

timestamp() - Method in record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry

Returns the value of the timestamp record component.

toJson() - Method in class com.scivicslab.pojoactor.core.distributed.ActorMessage

Serializes this message to JSON string.

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

type() - Method in record class com.scivicslab.pojoactor.core.accumulator.BufferedAccumulator.ResultEntry

Returns the value of the type record component.

U

Usage - Search tag in annotation interface com.scivicslab.pojoactor.core.Action

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

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

Interface for worker pools that execute CPU-bound jobs for actors.

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

A B C D E F G H I J K L M N O P R S T U V W Y
All Classes and Interfaces|All Packages