Package me.ahoo.cosid.mongo.reactive

Class MongoReactiveMachineCollection

java.lang.Object

me.ahoo.cosid.mongo.reactive.MongoReactiveMachineCollection

All Implemented Interfaces:

MachineCollection

public class MongoReactiveMachineCollection
extends Object
implements MachineCollection

Field Summary

Fields inherited from interface me.ahoo.cosid.mongo.MachineCollection

COLLECTION_NAME

Constructor Summary

Constructors

Constructor	Description
MongoReactiveMachineCollection(com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document> machineCollection)

Method Summary

Modifier and Type	Method	Description
MachineState	distribute(String namespace, int machineBit, InstanceId instanceId)
MachineState	distributeByRevert(String namespace, InstanceId instanceId, Duration safeGuardDuration)
MachineState	distributeBySelf(String namespace, InstanceId instanceId, Duration safeGuardDuration)
void	guard(String namespace, InstanceId instanceId, MachineState machineState, Duration safeGuardDuration)
int	nextMachineId(String namespace)
void	revert(String namespace, InstanceId instanceId, MachineState machineState)

Methods inherited from class java.lang.Object

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

Constructor Details

MongoReactiveMachineCollection

public MongoReactiveMachineCollection(com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document> machineCollection)

Method Details

nextMachineId

public int nextMachineId(String namespace)

Specified by:

nextMachineId in interface MachineCollection

distribute

public MachineState distribute(String namespace,
 int machineBit,
 InstanceId instanceId)

Specified by:

distribute in interface MachineCollection

distributeByRevert

public MachineState distributeByRevert(String namespace,
 InstanceId instanceId,
 Duration safeGuardDuration)

Specified by:

distributeByRevert in interface MachineCollection

distributeBySelf

public MachineState distributeBySelf(String namespace,
 InstanceId instanceId,
 Duration safeGuardDuration)

Specified by:

distributeBySelf in interface MachineCollection

revert

public void revert(String namespace,
 InstanceId instanceId,
 MachineState machineState)
            throws MachineIdLostException

Specified by:

revert in interface MachineCollection

Throws:

MachineIdLostException

guard

public void guard(String namespace,
 InstanceId instanceId,
 MachineState machineState,
 Duration safeGuardDuration)
           throws MachineIdLostException

Specified by:

guard in interface MachineCollection

Throws:

MachineIdLostException