Package com.orientechnologies.orient.distributed.context.topology

Class OEnstablishTopology

java.lang.Object

com.orientechnologies.orient.distributed.context.topology.OEnstablishTopology

All Implemented Interfaces:

OOperationMessage

public class OEnstablishTopology
extends Object
implements OOperationMessage

Constructor Summary

Constructors

Constructor	Description
OEnstablishTopology(OGroupId groupId, Set<ONodeId> candidates)

Method Summary

Modifier and Type	Method	Description
void	apply(OrientDBDistributed ctx)
void	cancel(OrientDBDistributed ctx)
Set<ONodeId>	getCandidates()
OGroupId	getGroupId()
short	getType()
static OEnstablishTopology	readNetwork(DataInput input)
void	serialize(DataOutput out)
Optional<OAcceptResult>	validate(OrientDBDistributed ctx)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.distributed.db.OOperationMessage

writeNetwork

Constructor Details

OEnstablishTopology

public OEnstablishTopology(OGroupId groupId,
 Set<ONodeId> candidates)

Method Details

apply

public void apply(OrientDBDistributed ctx)

Specified by:

apply in interface OOperationMessage

validate

public Optional<OAcceptResult> validate(OrientDBDistributed ctx)

Specified by:

validate in interface OOperationMessage

cancel

public void cancel(OrientDBDistributed ctx)

Specified by:

cancel in interface OOperationMessage

readNetwork

public static OEnstablishTopology readNetwork(DataInput input)
                                       throws IOException

Throws:

IOException

getType

public short getType()

Specified by:

getType in interface OOperationMessage

serialize

public void serialize(DataOutput out)
               throws IOException

Specified by:

serialize in interface OOperationMessage

Throws:

IOException

getCandidates

public Set<ONodeId> getCandidates()

getGroupId

public OGroupId getGroupId()