com.hazelcast.cp.internal.raftop.metadata

Class MetadataRaftGroupOp

java.lang.Object

com.hazelcast.cp.internal.RaftOp

com.hazelcast.cp.internal.raftop.metadata.MetadataRaftGroupOp

All Implemented Interfaces:

DataSerializable

Direct Known Subclasses:

AddCPMemberOp, CompleteDestroyRaftGroupsOp, CompleteRaftGroupMembershipChangesOp, CreateRaftGroupOp, ForceDestroyRaftGroupOp, GetActiveCPMembersOp, GetActiveRaftGroupByNameOp, GetActiveRaftGroupIdsOp, GetDestroyingRaftGroupIdsOp, GetMembershipChangeScheduleOp, GetRaftGroupIdsOp, GetRaftGroupOp, InitMetadataRaftGroupOp, RemoveCPMemberOp, TriggerDestroyRaftGroupOp

public abstract class MetadataRaftGroupOp
extends RaftOp

Base class for the RaftOp impls that are committed to the Metadata group. It verifies that the operation is actually committed to the Metadata group.

Constructor Summary

Constructors

Constructor and Description
MetadataRaftGroupOp()

Method Summary

Modifier and Type	Method and Description
String	getServiceName()
Object	run(CPGroupId groupId, long commitIndex) Contains actual Raft operation logic.
abstract Object	run(MetadataRaftGroupManager metadataGroupManager, long commitIndex)

Methods inherited from class com.hazelcast.cp.internal.RaftOp

getLogger, getNodeEngine, getService, logFailure, setNodeEngine, toString, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.nio.serialization.DataSerializable

readData, writeData

Constructor Detail

MetadataRaftGroupOp

public MetadataRaftGroupOp()

Method Detail

run

public final Object run(CPGroupId groupId,
                        long commitIndex)
                 throws Exception

Description copied from class: RaftOp

Contains actual Raft operation logic. State change represented by this operation should be applied and execution result should be returned to the caller.

Specified by:

run in class RaftOp

Parameters:

groupId - groupId of the specific Raft group

commitIndex - commitIndex of the log entry keeping this operation

Returns:

result of the operation execution

Throws:

Exception

run

public abstract Object run(MetadataRaftGroupManager metadataGroupManager,
                           long commitIndex)
                    throws Exception

Throws:

Exception

getServiceName

public final String getServiceName()

Specified by:

getServiceName in class RaftOp