alluxio.worker

Interface WorkerProcess

All Superinterfaces:

Process

All Known Implementing Classes:

AlluxioWorkerProcess

public interface WorkerProcess
extends Process

A worker in the Alluxio system.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	WorkerProcess.Factory Factory for creating WorkerProcess.

Method Summary

Modifier and Type	Method and Description
WorkerNetAddress	getAddress()
String	getDataBindHost()
String	getDataDomainSocketPath()
int	getDataLocalPort()
int	getNettyDataLocalPort()
int	getRestS3LocalPort()
InetSocketAddress	getRpcAddress()
long	getStartTimeMs()
UfsManager	getUfsManager()
long	getUptimeMs()
String	getWebBindHost()
int	getWebLocalPort()
<T extends Worker> T	getWorker(Class<T> clazz)

Methods inherited from interface alluxio.Process

start, stop, waitForReady

Method Detail

getAddress

WorkerNetAddress getAddress()

Returns:

the connect information for this worker

getUfsManager

UfsManager getUfsManager()

Returns:

the block worker for this Alluxio worker

getDataBindHost

String getDataBindHost()

Returns:

the worker's data service bind host (used by unit test only)

getDataLocalPort

int getDataLocalPort()

Returns:

the worker's data service port (used by unit test only)

getNettyDataLocalPort

int getNettyDataLocalPort()

Returns:

the worker's netty data service port (used by unit test only)

getRestS3LocalPort

int getRestS3LocalPort()

Returns:

the worker's netty s3 data service port (used by unit test only)

getDataDomainSocketPath

String getDataDomainSocketPath()

Returns:

the worker's data service domain socket path if available or "" if not available

getRpcAddress

InetSocketAddress getRpcAddress()

Returns:

this worker's rpc address

getStartTimeMs

long getStartTimeMs()

Returns:

the start time of the worker in milliseconds

getUptimeMs

long getUptimeMs()

Returns:

the uptime of the worker in milliseconds

getWebBindHost

String getWebBindHost()

Returns:

the worker web service bind host (used by unit test only)

getWebLocalPort

int getWebLocalPort()

Returns:

the worker web service port (used by unit test only)

getWorker

<T extends Worker> T getWorker(Class<T> clazz)

Type Parameters:

T - the type of the worker to get

Parameters:

clazz - the class of the worker to get

Returns:

the given worker