alluxio.membership

Class MasterMembershipManager

java.lang.Object

alluxio.membership.MasterMembershipManager

All Implemented Interfaces:

MembershipManager, AutoCloseable

public class MasterMembershipManager
extends Object
implements MembershipManager

A bypass no-op membership manager to disable MembershipManager module if used, the original way of using master for registration is leveraged for regression compatibility purpose.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.membership.MembershipManager

MembershipManager.Factory

Field Summary

Fields inherited from interface alluxio.membership.MembershipManager

PATH_SEPARATOR

Constructor Summary

Constructors

Constructor and Description
MasterMembershipManager()

Method Summary

Modifier and Type	Method and Description
void	close()
static MasterMembershipManager	create()
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 class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MasterMembershipManager

public MasterMembershipManager()

Method Detail

create

public static MasterMembershipManager create()

Returns:

MasterMembershipManager

join

public void join(WorkerInfo worker)
          throws IOException

Description copied from interface: MembershipManager

An idempotent call to register to join the membership.

Specified by:

join in interface MembershipManager

Throws:

IOException

getAllMembers

public List<WorkerInfo> getAllMembers()
                               throws IOException

Description copied from interface: MembershipManager

Get all registered worker members.

Specified by:

getAllMembers in interface MembershipManager

Returns:

all registered workers

Throws:

IOException

getLiveMembers

public List<WorkerInfo> getLiveMembers()
                                throws IOException

Description copied from interface: MembershipManager

Get healthy workers.

Specified by:

getLiveMembers in interface MembershipManager

Returns:

healthy worker list

Throws:

IOException

getFailedMembers

public List<WorkerInfo> getFailedMembers()
                                  throws IOException

Description copied from interface: MembershipManager

Get all failed workers.

Specified by:

getFailedMembers in interface MembershipManager

Returns:

failed worker list

Throws:

IOException

showAllMembers

public String showAllMembers()

Description copied from interface: MembershipManager

Pretty printed members and its liveness status.

Specified by:

showAllMembers in interface MembershipManager

Returns:

pretty-printed status string

stopHeartBeat

public void stopHeartBeat(WorkerInfo worker)
                   throws IOException

Description copied from interface: MembershipManager

Stop heartbeating for liveness for current worker.

Specified by:

stopHeartBeat in interface MembershipManager

Parameters:

worker - WorkerInfo

Throws:

IOException

decommission

public void decommission(WorkerInfo worker)
                  throws IOException

Description copied from interface: MembershipManager

Decommision a worker.

Specified by:

decommission in interface MembershipManager

Parameters:

worker - WorkerInfo

Throws:

IOException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception