alluxio.membership

Interface MembershipManager

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

EtcdMembershipManager, MasterMembershipManager, StaticMembershipManager

public interface MembershipManager
extends AutoCloseable

Interface for worker membership management module.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	MembershipManager.Factory Factory class to get or create a MembershipManager.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PATH_SEPARATOR

Method Summary

Modifier and Type	Method and Description
void	decommission(WorkerInfo worker) Decommision a worker.
List<WorkerInfo>	getAllMembers() Get all registered worker members.
List<WorkerInfo>	getFailedMembers() Get all failed workers.
List<WorkerInfo>	getLiveMembers() Get healthy workers.
void	join(WorkerInfo worker) An idempotent call to register to join the membership.
String	showAllMembers() Pretty printed members and its liveness status.
void	stopHeartBeat(WorkerInfo worker) Stop heartbeating for liveness for current worker.

Methods inherited from interface java.lang.AutoCloseable

close

Field Detail

PATH_SEPARATOR

static final String PATH_SEPARATOR

See Also:

Constant Field Values

Method Detail

join

void join(WorkerInfo worker)
   throws IOException

An idempotent call to register to join the membership.

Parameters:

worker -

Throws:

IOException

getAllMembers

List<WorkerInfo> getAllMembers()
                        throws IOException

Get all registered worker members.

Returns:

all registered workers

Throws:

IOException

getLiveMembers

List<WorkerInfo> getLiveMembers()
                         throws IOException

Get healthy workers.

Returns:

healthy worker list

Throws:

IOException

getFailedMembers

List<WorkerInfo> getFailedMembers()
                           throws IOException

Get all failed workers.

Returns:

failed worker list

Throws:

IOException

showAllMembers

String showAllMembers()

Pretty printed members and its liveness status.

Returns:

pretty-printed status string

stopHeartBeat

void stopHeartBeat(WorkerInfo worker)
            throws IOException

Stop heartbeating for liveness for current worker.

Parameters:

worker - WorkerInfo

Throws:

IOException

decommission

void decommission(WorkerInfo worker)
           throws IOException

Decommision a worker.

Parameters:

worker - WorkerInfo

Throws:

IOException