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

S

sadd(String, String) - Method in class titan.storage.TitanJRedisAdapter

Adds the specified member to the set stored at key in Redis.

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

Safely adds a member to a Redis set, catching and logging any IOException.

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

Safely sets a key-value pair in Redis, catching and logging any IOException.

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

Safely retrieves all members of a Redis set, catching and logging any exceptions.

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

Safely removes a member from a Redis set, catching and logging any exceptions.

satisfiedDeps - Variable in class titan.scheduler.Job

saveToDisk() - Static method in class titan.tasks.ProcessRegistry

Persists the current state of the in-memory process registry to the designated file.

scalerExecutor - Variable in class titan.scheduler.Scheduler

scalingInProgress - Variable in class titan.scheduler.Scheduler

scanner - Variable in class titan.TitanCLI

A `Scanner` object used to read user input from the console.

ScheduledJob - Class in titan.scheduler

Represents a job that is scheduled to run at a future time.

ScheduledJob(Job) - Constructor for class titan.scheduler.ScheduledJob

Constructs a new ScheduledJob with the specified job.

scheduledTime - Variable in class titan.scheduler.Job

scheduler - Static variable in class titan.manual.TitanDAGEndToEnd

scheduler - Variable in class titan.network.LogBatcher

scheduler - Variable in class titan.network.SchedulerServer

Scheduler - Class in titan.scheduler

The main Scheduler class responsible for managing workers, dispatching jobs, and maintaining system state.

Scheduler(int) - Constructor for class titan.scheduler.Scheduler

Constructs a new Scheduler instance, initializing its core components.

SCHEDULER_PORT - Static variable in class titan.manual.DeployCommandIntegrationTest

SCHEDULER_PORT - Static variable in class titan.manual.RunBatchLogTest

SCHEDULER_PORT - Static variable in class titan.manual.RunScriptTest

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

schedulerClient - Variable in class titan.scheduler.Scheduler

schedulerHost - Variable in class titan.network.RpcWorkerServer

The hostname or IP address of the scheduler server to which this worker registers and sends callbacks.

schedulerPort - Variable in class titan.network.RpcWorkerServer

The port number of the scheduler server to which this worker registers and sends callbacks.

schedulerServer - Variable in class titan.scheduler.Scheduler

SchedulerServer - Class in titan.network

The SchedulerServer class acts as the central network endpoint for the Titan distributed scheduling system.

SchedulerServer(int, Scheduler) - Constructor for class titan.network.SchedulerServer

Constructs a new SchedulerServer instance.

ScriptExecutorHandler - Class in titan.tasks

ScriptExecutorHandler is an implementation of TaskHandler responsible for executing scripts (Python, Shell, or standalone executables) on the worker node.

ScriptExecutorHandler(RpcWorkerServer) - Constructor for class titan.tasks.ScriptExecutorHandler

Constructs a new ScriptExecutorHandler.

selectBestWorker(Job, List<Worker>) - Method in class titan.scheduler.Scheduler

Selects the most suitable worker for a given job from a list of available workers.

send(DataOutputStream, byte, String) - Static method in class titan.network.TitanProtocol

Sends a message over the network using the Titan Protocol.

sendAndReceive(byte, String) - Method in class titan.TitanCLI

Establishes a socket connection to the Titan scheduler, sends a command with the specified operation code and payload, and then waits for and returns the server's response.

sendCallback(String, String, String) - Method in class titan.network.RpcWorkerServer

Sends a job completion or failure callback to the scheduler.

sendCommand(byte, String) - Static method in class titan.manual.RunBatchLogTest

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

sendCommand(String...) - Method in class titan.storage.TitanJRedisAdapter

Serializes and sends a Redis command to the server using the RESP protocol.

sendDag(String) - Static method in class titan.manual.TitanDAGEndToEnd

sendExecuteCommand(Worker, byte, String) - Method in class titan.scheduler.Scheduler

Sends an RPC command to a specific worker and handles the response.

sendRequest(String, int, byte, String) - Method in class titan.network.RpcClient

Sends a request to a specified host and port with a given operation code and payload.

sendRequest(String, int, String) - Method in class titan.network.RpcClient

Sends a request to a specified host and port with a default operation code.

sendSchedulerCommand(byte, String) - Static method in class titan.manual.DeployCommandIntegrationTest

sendSchedulerCommand(byte, String) - Static method in class titan.manual.RunScriptTest

serverExecutor - Variable in class titan.scheduler.Scheduler

serverSocket - Variable in class titan.network.SchedulerServer

ServiceHandler - Class in titan.tasks

ServiceHandler is an implementation of TaskHandler responsible for managing the lifecycle of services (processes) on a worker node.

ServiceHandler(String, RpcWorkerServer) - Constructor for class titan.tasks.ServiceHandler

Constructs a new ServiceHandler with a specified operation and a reference to its parent RPC server.

set(String, String) - Method in class titan.storage.TitanJRedisAdapter

Sets the string value of a key in Redis.

setAffinityRequired(boolean) - Method in class titan.scheduler.Job

setCurrentLoad(int) - Method in class titan.scheduler.Worker

Sets the current load of the worker.

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

setLogListener(Consumer<String>) - Method in interface titan.tasks.TaskHandler

Sets a listener to receive log messages generated during the task execution.

setMaxCap(int) - Method in class titan.scheduler.Worker

Sets the maximum capacity of the worker.

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

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

setStatus(Job.Status) - Method in class titan.scheduler.Job

setup() - Static method in class titan.manual.storage.TitanPersistenceIntegrationTest

setupChattyFile() - Static method in class titan.manual.RunBatchLogTest

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

setupRunFile() - Static method in class titan.manual.RunScriptTest

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

sharedWorkspace - Variable in class titan.tasks.ScriptExecutorHandler

The File object representing the shared workspace directory.

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

Initiates a graceful shutdown of a specific worker node.

smembers(String) - Method in class titan.storage.TitanJRedisAdapter

socket - Variable in class titan.storage.TitanJRedisAdapter

srem(String, String) - Method in class titan.storage.TitanJRedisAdapter

Removes the specified member from the set stored at key in Redis.

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

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

Starts the worker server, binding it to the specified port and beginning to listen for incoming client connections.

start() - Method in class titan.network.SchedulerServer

Starts the SchedulerServer, making it listen for incoming client connections.

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

Initiates the scheduler's operations.

start() - Method in class titan.TitanCLI

Initiates the main command-line interface loop.

START_ARCHIVE_SERVICE - Static variable in class titan.network.TitanProtocol

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

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

Activates the auto-scaling mechanism for the Titan cluster.

startProcess(String, String, String) - Method in class titan.tasks.ServiceHandler

Initiates the launch of a new service process.

startTime - Variable in class titan.scheduler.TaskExecution

The timestamp (in milliseconds) when the task execution started.

status - Variable in class titan.scheduler.Job

status - Variable in class titan.scheduler.TaskExecution

The current status of the task execution (e.g., Job.Status.RUNNING, Job.Status.COMPLETED, Job.Status.FAILED).

Status() - Constructor for enum class titan.scheduler.Job.Status

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

Initiates a graceful shutdown of the worker server.

stop() - Method in class titan.network.SchedulerServer

Shuts down the SchedulerServer gracefully.

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

Shuts down the scheduler and all its associated executor services.

stopProcess(String) - Method in class titan.tasks.ServiceHandler

Attempts to stop a running service identified by its serviceId.

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

Stops a remote service identified by its service ID.

STORAGE_DIR - Static variable in class titan.filesys.AssetManager

streamLogToMaster(String, String) - Method in class titan.network.RpcWorkerServer

Streams a single log line for a given job to the scheduler (master).

submitJob(String) - Static method in class titan.manual.CronAndPriorityTest

submitJob(String) - Static method in class titan.manual.FaultToleranceTest

submitJob(String) - Static method in class titan.manual.LoadBalancerTest

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

Submits a job to the scheduler using a raw string payload.

submitJob(Job) - Method in class titan.scheduler.Scheduler

Submits a Job to the scheduler for processing.

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