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

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

{@inheritDoc} @param basePackage {@inheritDoc} @param classLoader {@inheritDoc} @param fromFairyIoCSingleton {@inheritDoc}

Resets all counters to zero.

Schedule a one-time {@link Runnable} task with a specified delay in ticks. @param task the task to be executed @param delayTicks the delay in t

Creates a test multi-level cache service.

Gets an interceptor instance by its class. @param interceptorClass the interceptor class @param <T> the interceptor type @return the int

Checks if the string is not null and not empty (""). @param inputString the string to check @return true if the string is not null and not empty, fal

Sets the transaction status. @param status the new transaction status

Adds a relationship between this entity and another entity. @param relationshipType the type of relationship @param targetEntityUuid the UUID of the

Executes a function with lock protection. @param getLockFunction the function to obtain the lock @param function the function to execute under

Gets the action name associated with this task. <p>This serves as a unique identifier or categorization for the specific type of task being processed

Generates a Redis stream key for entity-related operations. @param service the entity data service @return the generated Redis stream key

Retrieves the {@link LegacyEntityData} from the first-level (L1) cache. @param uuid the unique identifier of the entity @return an {@link Optional} c

Gets the total number of processed classes. @return the count of processed classes

Randomly returns an object based on the probability of all current random objects. <p>This method uses a standard Pseudo-Random Number Generator (PRN

Gets the participant type for classification and monitoring. @return the participant type

Increments the retry count for the specified key and returns the new count. <p>This operation must be atomic to ensure correct counting in concurrent

Invokes a function defined in a script. @param script Optional script string. If provided, this script will be executed first.

Creates a new {@link LegacyPlayerData} instance for the given player. @param player the Bukkit {@link Player} instance @return a new {@link LegacyPla

Creates a failure handler with a custom retry policy and compensation action. <p>This factory method allows full customization of both retry behavior

Cancels only the scheduled task without shutting down the executor service. <p>This method is safe to use with shared schedulers as it does not affec

Creates a {@link CaffeineCacheService} with custom configuration. @param cache the Caffeine cache @param <K> the cache key type @param <V> the ca

Execute all test methods in a test class

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

Gets the type of this retry counter. <p>This method helps identify the implementation strategy being used, which can be useful for monitoring, debugg

Retrieves a value from the Redis cache or computes it if not found, without using a lock. <p>This method will first attempt to retrieve the value fro

{@inheritDoc} @param rStream {@inheritDoc} @param streamMessageId {@inheritDoc} @param legacyEntityDataService {@inheritDoc}

Acknowledges the task after it has been successfully processed. <p>This method removes the task from the Redis stream, indicating that it has been ha

Adds an attribute to the current trace. @param key the attribute key @param value the attribute value

Builds the full Redis key by prepending the configured prefix. @param key the base key @return the full Redis key with prefix

Performs security check for randomization. @throws IllegalArgumentException if there are no objects to randomize or if total probability is 0

Gets the total number of failed method invocations. @return the failure count

Gets the method name for transaction identification. @param context the aspect context @return the method name

Get or create MongoDB connection configuration for tests. @return configured MongoDBConnectionConfig instance

Gets the currently authenticated principal. @return the principal, or null if not authenticated

Gets the number of classes processed. @return the processed count

Get or create Redis configuration for tests. @return configured Redis Config instance

{@inheritDoc} <p>Injects {@link VarHandle} instances into static fields of the given class that are annotated with {@link VarHandleAutoInjection}. Th

Checks if the cache item has expired. @return true if the item is expired, false otherwise

Logs a test start message. @param moduleName the name of the module being tested @param testName the name of the test being started

Ensures that the object is not null, throws {@link NullPointerException} if it is null. @param value object to check @param message exception messa

Resets all counters for fresh test execution.

Closes any resources associated with this retry counter. <p>Implementations should release any connections, clear caches, and perform necessary clean

Completes the trace with the specified status. @param status the completion status

Creates a new transaction log entry with the given parameters. @param transactionId the transaction ID @param logType the log type @param messa

Executes module tests with standardized logging and error handling. <p>This method provides a convenient way to execute test runners that extend {@li

Execute all test methods in a test class using reflection.

Checks if a retry counter exists for the specified key. <p>This can be useful for distinguishing between a counter that has been set to 0 and a count

Retrieves the cache level object (wrapped in an {@link Optional}) by the given level identifier. @param level the identifier of the level to look up

Retrieves the cache level object by the given level identifier, or throws an exception if not found. <p>This method attempts to retrieve a {@link Tie

Gets the number of finally after method invocations. @return the finally after count

Retrieves the {@link LegacyEntityData} from the second-level (L2) cache. @param uuid the unique identifier of the entity @return an {@link Optional}

Gets the value of a global variable from the engine's scope. @param name The name of the global variable @return The value of the global variable

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

Retrieves the {@link LegacyPlayerData} for a given player UUID using the multi-level cache and database. <p>This method queries the L1 cache first, t

Provides the {@link MCScheduler} instance used for scheduling tasks. <p>Only valid when the useVirtualThread method returns {@code false}. <p>By def

Provides an {@link ExecutorService} that uses a virtual thread per task execution model. <p>Only valid when the useVirtualThread method returns {@cod

Determines whether to limit task processing to prevent duplicates within a single server or connection. <p>If this method returns {@code true}, the t

Logs test execution statistics. @param moduleName the name of the module being tested @param totalTests the total number of tests @param successC

Logs a test completion message. @param moduleName the name of the module being tested @param testName the name of the test that completed @param du

Factory method to create a new {@link EntityDataPersistenceTask}. @param lockSettings the settings for lock acquisition @param service the {@lin

Factory method to create a new {@link L1ToL2PlayerDataSyncTask} without specifying a UUID. <p>This variant synchronizes all player data in the L1 cac

Creates a new {@link LegacyEntityDataService}. @param name the unique name of the service @param mongoDBConnectionConfig the M

Registers an interceptor instance. @param interceptor the interceptor to register

Resets the retry count for the specified key. <p>This operation removes the counter entirely, so subsequent calls to {@link #get(String)} will return

Resolves URLs for the given base packages and class loaders. This effectively gets all URLs on the classpath that are within the specified packages.

Schedules a recurring {@link Runnable} task to be executed in a virtual thread with a fixed delay between the end of the execution of one task and the

Sets the current security context. @param principal the principal @param roles the roles @param permissions the permissions

Shuts down the Redis client connection gracefully. <p>This method is responsible for closing the connection to the Redis server and releasing any res

Updates the version and last modified time of this entity. This method should be called whenever the entity is modified.

Determines whether to use virtual threads. <p>Defaults to {@code true}.If set to {@code false}, the task will be directly scheduled using the Bukkit

Creates a resilient wrapper with default failure handling. <p>Uses {@link FailureHandler#RETRY_ALWAYS} which implements a standard retry policy with

Creates a resilient wrapper with default failure handling. <p>Uses {@link FailureHandler#RETRY_ALWAYS} which implements a standard retry policy with

Applies a function to the underlying cache of a specific level (without lock). <p>This method looks up the {@link TieredCacheLevel} by the provided l

Creates a composite compensation action that executes multiple actions in sequence. <p>The composite action will attempt to execute all provided acti

Creates a distributed retry counter with the default key prefix. @param redissonClient the Redis client to use @return a new {@link DistributedRetryC

Returns a default TaskInterface instance with standard implementations. <p>This is useful when you just need to access the utility methods without im

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

Executes all test methods in a test class.

Gets the number of after method invocations. @return the after count

Gets the number of before method invocations. @return the before count

Retrieves the {@link LegacyPlayerData} from the first-level (L1) cache. @param uuid the unique identifier of the player @return an {@link Optional} c

Gets the singleton instance of the registry @return the registry instance