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

G

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

A private helper method to generate a consistent key for a worker.

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

Retrieves the string value associated with the specified key from Redis.

get(String, String) - Static method in class titan.TitanConfig

getActiveRoutes() - Method in interface titan.balancer.IngressAdapter

getActiveRoutes() - Method in class titan.balancer.NginxAdapter

getCurrentLoad() - Method in class titan.scheduler.Worker

Returns the current load of the worker.

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

Retrieves the map of jobs currently waiting for their DAG dependencies to be met.

getDelay(TimeUnit) - Method in class titan.scheduler.ScheduledJob

getDependenciesIds() - Method in class titan.scheduler.Job

getDuration() - Method in class titan.scheduler.TaskExecution

Calculates the duration of the task execution.

getId() - Method in class titan.scheduler.Job

getIdleDuration() - Method in class titan.scheduler.Worker

Calculates and returns the duration (in milliseconds) for which the worker has been idle.

getInt(String, int) - Static method in class titan.TitanConfig

getJob() - Method in class titan.scheduler.ScheduledJob

Returns the underlying Job instance associated with this scheduled job.

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

Retrieves the current status of a job based on its ID.

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

Retrieves the map of currently running services (identified by job ID) to their assigned worker.

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

Retrieves a snapshot of the recent log lines for a given job from the in-memory buffer.

getMaxCap() - Method in class titan.scheduler.Worker

Returns the maximum capacity of the worker.

getPayload() - Method in class titan.scheduler.Job

getPreferredWorkerId() - Method in class titan.scheduler.Job

getPriority() - Method in class titan.scheduler.Job

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

Retrieves the Redis adapter instance used by the scheduler.

getRetryCount() - Method in class titan.scheduler.Job

getScheduledTime() - Method in class titan.scheduler.Job

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

Retrieves the hostname of the scheduler this worker is connected to.

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

Retrieves the port number of the scheduler this worker is connected to.

getStatus() - Method in class titan.scheduler.Job

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

Generates a human-readable string containing various system statistics.

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

Generates a JSON string containing various system statistics.

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

Generates a unique key for a worker based on its host and port.

getWorkerMap() - Method in class titan.scheduler.WorkerRegistry

Returns the underlying map of workers.

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

Retrieves the worker registry instance used by the scheduler.

getWorkers() - Method in class titan.scheduler.WorkerRegistry

Retrieves a collection of all currently registered workers.

getWorkersByCapability(String) - Method in class titan.scheduler.WorkerRegistry

Retrieves a list of workers that possess a specific capability.

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