Index

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

R

read(DataInputStream) - Static method in class titan.network.TitanProtocol

Reads an incoming message from the network, parsing the Titan Protocol header and payload.

readArray() - Method in class titan.storage.TitanJRedisAdapter

Reads a RESP Array response from the input stream.

readBulkString() - Method in class titan.storage.TitanJRedisAdapter

Reads a RESP Bulk String response from the input stream.

readLine() - Method in class titan.storage.TitanJRedisAdapter

Reads a line from the input stream until a CR-LF sequence is encountered.

readResponse() - Method in class titan.storage.TitanJRedisAdapter

Reads and deserializes a single RESP response from the Redis server.

reconcileClusters() - Method in class titan.scheduler.Scheduler

Periodically checks the cluster's health and load to determine if scaling actions (up or down) are needed.

recoverState() - Method in class titan.scheduler.Scheduler

Recovers the scheduler's state from Redis upon startup.

redis - Variable in class titan.scheduler.Scheduler

REDIS_HOST - Static variable in class titan.manual.storage.TitanPersistenceIntegrationTest

REDIS_PORT - Static variable in class titan.manual.storage.TitanPersistenceIntegrationTest

redisHost - Variable in class titan.scheduler.Scheduler

redisKVGet(String) - Method in class titan.scheduler.Scheduler

Retrieves the value associated with a given key from Redis.

redisKVSet(String, String) - Method in class titan.scheduler.Scheduler

Sets a key-value pair in Redis.

redisPort - Variable in class titan.scheduler.Scheduler

redisSetAdd(String, String) - Method in class titan.scheduler.Scheduler

Adds a member to a Redis set.

register(String, long) - Static method in class titan.tasks.ProcessRegistry

Registers a new process with the registry.

registerService(String, String, int) - Method in interface titan.balancer.IngressAdapter

Called by the Master when a worker successfully starts a long-running service.

registerService(String, String, int) - Method in class titan.balancer.NginxAdapter

registerWithScheduler() - Method in class titan.network.RpcWorkerServer

Registers this worker server with the central scheduler.

registerWorker(String, int, String, boolean) - Method in class titan.scheduler.Scheduler

Registers a new worker with the scheduler.

removeWorker(String, int) - Method in class titan.scheduler.WorkerRegistry

A private helper method to remove a worker from the registry based on its host and port.

resolveDependencies(String) - Method in class titan.scheduler.Job

resolvePath(String, String) - Static method in class titan.filesys.WorkspaceManager

resolvePointer(String) - Static method in class titan.filesys.AssetManager

Resolves a pointer string (e.g., "my_project.zip/src/main.py") into the raw Base64 data needed for the worker.

retryCount - Variable in class titan.scheduler.Job

ROOT_DIR - Static variable in class titan.filesys.WorkspaceManager

rootWorkspace - Variable in class titan.tasks.ScriptExecutorHandler

The root File object representing the base directory for all script executions.

routeTable - Variable in class titan.balancer.NginxAdapter

RpcClient - Class in titan.network

RpcClient provides functionality for making Remote Procedure Calls (RPC) to a server.

RpcClient(WorkerRegistry) - Constructor for class titan.network.RpcClient

Constructs a new RpcClient instance.

RpcWorkerServer - Class in titan.network

Represents a worker server in the Titan distributed system.

RpcWorkerServer(int, String, int, String, boolean) - Constructor for class titan.network.RpcWorkerServer

Constructs a new RpcWorkerServer instance.

RpcWorkerTest - Class in titan.manual

RpcWorkerTest() - Constructor for class titan.manual.RpcWorkerTest

RUN_ARCHIVE - Static variable in class titan.network.TitanProtocol

String identifier for the 'run archive' job type, typically used within payload data.

RunBatchLogTest - Class in titan.manual

RunBatchLogTest() - Constructor for class titan.manual.RunBatchLogTest

runDispatchLoop() - Method in class titan.scheduler.Scheduler

The main dispatch loop of the scheduler.

RUNNING - Enum constant in enum class titan.scheduler.Job.Status

runningJobs - Variable in class titan.scheduler.Scheduler

runningServices - Static variable in class titan.tasks.ServiceHandler

A static, thread-safe map that stores references to currently running Process objects, keyed by their unique service IDs.

RunScriptTest - Class in titan.manual

RunScriptTest() - Constructor for class titan.manual.RunScriptTest

runTestInSeparateJvm(Class<?>) - Static method in class titan.manual.TitanTestSuite

runTestScenario() - Static method in class test.java.titan.manual.WorkerScriptIntegrationTest

runTestScenario() - Static method in class titan.manual.DeployCommandIntegrationTest

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