com.hazelcast.cp.internal.raft.impl.task

Class MembershipChangeTask

java.lang.Object

com.hazelcast.cp.internal.raft.impl.task.MembershipChangeTask

All Implemented Interfaces:

Runnable

public class MembershipChangeTask
extends Object
implements Runnable

MembershipChangeTask is executed to add/remove a member to the Raft group.

If membership change type is ADD but the member already exists in the group, then future is notified with MemberAlreadyExistsException.

If membership change type is REMOVE but the member doesn't exist in the group, then future is notified with MemberDoesNotExistException.

UpdateRaftGroupMembersCmd Raft operation is created with members according to the member parameter and membership change and it's replicated via ReplicateTask.

See Also:

MembershipChangeMode

Constructor Summary

Constructors

Constructor and Description
MembershipChangeTask(RaftNodeImpl raftNode, SimpleCompletableFuture resultFuture, Endpoint member, MembershipChangeMode membershipChangeMode)
MembershipChangeTask(RaftNodeImpl raftNode, SimpleCompletableFuture resultFuture, Endpoint member, MembershipChangeMode membershipChangeMode, Long groupMembersCommitIndex)

Method Summary

Modifier and Type	Method and Description
void	run()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

MembershipChangeTask

public MembershipChangeTask(RaftNodeImpl raftNode,
                            SimpleCompletableFuture resultFuture,
                            Endpoint member,
                            MembershipChangeMode membershipChangeMode)

MembershipChangeTask

public MembershipChangeTask(RaftNodeImpl raftNode,
                            SimpleCompletableFuture resultFuture,
                            Endpoint member,
                            MembershipChangeMode membershipChangeMode,
                            Long groupMembersCommitIndex)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

toString

public String toString()

Overrides:

toString in class Object