Logs general test information. @param moduleName the name of the module being tested @param message the information message @param replace form

Logs a test failure message. @param moduleName the name of the module being tested @param message the failure message @param replace format arg

Gets a configuration value by key. @param key the configuration key @param type the target type @param <T> the type parameter @return the configura

Checks if two objects are equal using {@link Objects#equals(Object, Object)}. @param object1 the first object @param object2 the second object @retur

Checks if a configuration key exists. @param key the configuration key @return true if the key exists

Gets the name of this custom executor @return the executor name

Sets a configuration value. @param key the configuration key @param value the configuration value @return true if the configuration was updated suc

Retrieves the current retry count for the specified key without modifying it. <p>If the key doesn't exist, implementations should return 0 rather tha

Retrieves a value from the cache or computes it if not found. <p>This method first attempts to retrieve the value from the cache using the {@code get

Logs a test validation result. @param moduleName the name of the module being tested @param testName the name of the test @param condition the

Checks if this registry is empty (contains no aspects and no metadata). @return true if the registry contains no aspects and no metadata, false other

Bootstraps the AOP module based on configuration flags and available aspects.

Creates an instance of the specified class with AOP capabilities. @param clazz the class to instantiate @param <T> the type of the object @return t

Adds an attribute to the entity. @param key the attribute key @param value the attribute value @return the current instance for method chaining

Gets the underlying resource. @return the resource

Creates a test result summary with custom metadata. @param moduleName the name of the module @param success whether tests passed @param message

Builds the TaskChain with all configured tasks and execution modes. <p>All tasks will have been started immediately when {@link ExecutionBuilder#exec

Executes a script. @param script The script string to execute @param scriptScope The script scope to use for the script execution.

Stops a named timer and records the result. @param timerName the name of the timer to stop @return the elapsed time in milliseconds, or -1 if timer w

Creates an instance of {@link LockSettings}. @param waitTime the maximum time to wait for the lock @param leaseTime the time to hold the lock after

Starts a named timer. @param timerName the name of the timer @return the timer start time in milliseconds

Registers enterprise-level aspects as class-specific interceptors for the supplied test classes.

Returns the total number of tasks in the chain. Includes all tasks added via {@link ExecutionBuilder#execute(Object)} or {@link ExecutionBuilder#run(O

Waits for all tasks in the chain to complete. <p>Since tasks execute immediately when {@link ExecutionBuilder#execute(Object)} or {@link ExecutionBui

Creates a new {@link LegacyEntityData} instance with the specified entity type. @param uuid the unique identifier for the entity @param entityT

Retrieves entity data using the multi-level cache and database. @param uuid the unique identifier of the entity @return the entity data, or {@code nu

Creates a new {@link RStreamTask} instance with the specified action name, data, and expiration time. @param actionName the name of the action as

Gets the current size of the counter map. <p>This method is useful for monitoring memory usage and debugging. @return the number of keys currently t

Create a new LegacyEntityDataService with a unique name for testing. @param testName the test name to create a unique service identifier @return new

Starts the task. Implementations should define the logic of the task within this method. <p>By default, overriding this method will schedule the task

Saves entity data to the L1 cache and schedules asynchronous persistence to L2 cache and database. <p>This method performs the following steps: <ol>

Creates a new TaskChain builder with default TaskInterface. <p>The default TaskInterface uses {@link io.fairyproject.mc.scheduler.MCSchedulers#getAsy

Tests whether this pointcut matches the given method on the target class. <p>This method is called to determine if an aspect should be applied to a s

Continues the execution of the interceptor chain or invokes the target method. @return the result of the method invocation from the next interceptor

Gets an attribute value. @param key the attribute key @return the attribute value, or {@code null} if not present

Registers a global interceptor.

Gets the duration of the trace in milliseconds. @return the duration, or 0 if the trace is still active

Create task request

Puts data into the shared context. @param key the data key @param value the data value

Retrieves the first-level (L1) cache service. @return the {@link CacheServiceInterface} used for the first-level cache (L1) @throws IllegalStateExcep

Validates test results and updates context metrics. <p>This helper method can be used by subclasses to validate test outcomes and update the executio

Clears all aspects and metadata from this registry. <p>This method removes all registered aspects and metadata, effectively resetting the registry to

Increments the processed count and returns the new value. @return the new processed count

Retrieves the second-level (L2) cache service using Redis. @return the {@link RedisCacheServiceInterface} used for the second-level cache (L2) @throw

Checks if the string is null or empty (""). @param inputString the string to check @return true if the string is null or empty, false otherwise

Connect to the server

{@inheritDoc} @param script {@inheritDoc} @param scriptScope {@inheritDoc} @return {@inheritDoc} @throws ScriptException {@inheritDoc}

Checks if the object is not null. @param value object to check @return true if the object is not null, false otherwise

Submits a value-returning task for execution in a virtual thread and returns a {@link CompletableFuture}. @param task the task to be executed @param

Clears all counters and expiration times. <p>This method removes all tracked retry counts but keeps the counter instance active for future use.

Compiles a script for later execution. This can improve performance if the same script will be executed multiple times. @param script The script stri

Finds a set of classes annotated with the specified annotation within the given package and its sub-packages. <p>This method scans the classes in the

Retrieves the final execution result of the task at the specified index. <p>Blocks until the task completes and returns the actual result value, not

Gets the status of this participant. @param context the transaction context @return a CompletableFuture that completes with the participant status

Increments the failure count and returns the new value. @return the new failure count

Gets all completed timer results. @return a map of timer results by name

Gets the arguments passed to the method. @return array of method arguments

Gets the result of a completed timer. @param timerName the name of the timer @return the timer result, or null if not found

Logs a test success message. @param moduleName the name of the module being tested @param message the success message @param replace format arg

Saves multiple entities to the L1 cache and schedules asynchronous persistence to L2 cache and database. <p>This method performs the following steps

Creates a {@link NashornScriptEngine}. @return a new {@link NashornScriptEngine} instance @see NashornScriptEngine

Retrieves the shared Gson instance. @return the shared Gson instance

Gets the unique identifier for this participant. @return the participant ID

Adds a key-value pair to the player's data. @param key the key for the data @param value the value to associate with the key @return the current in

Adds a random object with its corresponding probability to the utility class. @param object The random object @param probability The correspondi

Retrieves the value associated with the specified key. @param key the key whose associated value is to be returned @return the value associated with

Creates a summary map of current metrics. @return a map containing all current metrics

Retrieves the value associated with the specified key, or returns a default value if the key is not present. @param key the key whose associ

Creates a successful test result summary. @param moduleName the name of the module @param message the success message @param durationMs the test d

Handles the data contained in the task. <p>This method is the main processing logic for handling tasks received via RStream. It is expected to includ

Creates a {@link RhinoScriptEngine}. @return a new {@link RhinoScriptEngine} instance @see RhinoScriptEngine

Creates a validation failure exception. @param validInput the validation annotation @param message the error message @return the validation failur

Execute a {@link Runnable} task immediately, typically using the {@link MCScheduler#execute(Runnable)} method of the configured scheduler. This is use

Merges changes from another entity of the same UUID. <p>This method is used for conflict resolution when updates from different servers need to be me

Shuts down the trace service and releases any resources.

Defines the execution mode for the next task. <p>The mode function determines how the task will be executed (sync, async, virtual thread, etc.). This

Creates a dynamic proxy for the specified target object.

Creates a {@link V8ScriptEngine}. @return a new {@link V8ScriptEngine} instance @see V8ScriptEngine

Gets a system property by key. @param key the property key @return the property value, or null if not found

Creates a summary of all timing information. @return a formatted timing summary

Parses a pointcut expression string into a Pointcut object. @param expression the pointcut expression to parse @return the parsed Pointcut @throws Il

Submits a task to the scheduler synchronously (blocking). @param taskId a unique identifier for this task submission. Must not be {@code null} or emp