Package me.ahoo.cosid.mongo

Interface MachineOperates

public interface MachineOperates

Field Summary

Fields

Modifier and Type	Field	Description
static final String	COLLECTION_NAME	The collection of machine id leases.
static final String	DISTRIBUTE_TIME_FIELD
static final String	INSTANCE_ID_FIELD
static final String	LAST_TIMESTAMP_FIELD
static final String	MACHINE_ID_FIELD
static final String	MAX_MACHINE_ID_FIELD
static final String	NAMESPACE_FIELD
static final String	REVERT_TIME_FIELD
static final String	STABLE_FIELD	Whether the owner is a stable instance, whose machine id is never recycled by other instances.

Method Summary

Static Methods

Modifier and Type	Method	Description
static org.bson.conversions.Bson	distributeByRevertFilter(String namespace, InstanceId instanceId, Duration safeGuardDuration)
static org.bson.conversions.Bson	distributeByRevertUpdate(InstanceId instanceId, long lastTimestamp)
static org.bson.conversions.Bson	distributeBySelfFilter(String namespace, InstanceId instanceId, Duration safeGuardDuration)
static org.bson.conversions.Bson	distributeBySelfUpdate(long lastTimestamp)
static org.bson.conversions.Bson	distributeBySelfUpdate(InstanceId instanceId, long lastTimestamp)
static org.bson.Document	distributeDocument(String namespace, InstanceId instanceId, MachineState nextMachineState)
static org.bson.conversions.Bson	guardFilter(String namespace, InstanceId instanceId, MachineState machineState)
static org.bson.conversions.Bson	guardUpdate(long lastTimestamp)
static List<? extends org.bson.conversions.Bson>	nextMachineIdPipeline(String namespace)
static org.bson.conversions.Bson	revertFilter(String namespace, InstanceId instanceId, MachineState machineState)
static org.bson.conversions.Bson	revertUpdate(InstanceId instanceId, MachineState machineState)

Field Details

COLLECTION_NAME

static final String COLLECTION_NAME

The collection of machine id leases.

See Also:

• Constant Field Values

NAMESPACE_FIELD

static final String NAMESPACE_FIELD

See Also:

• Constant Field Values

MACHINE_ID_FIELD

static final String MACHINE_ID_FIELD

See Also:

• Constant Field Values

LAST_TIMESTAMP_FIELD

static final String LAST_TIMESTAMP_FIELD

See Also:

• Constant Field Values

INSTANCE_ID_FIELD

static final String INSTANCE_ID_FIELD

See Also:

• Constant Field Values

DISTRIBUTE_TIME_FIELD

static final String DISTRIBUTE_TIME_FIELD

See Also:

• Constant Field Values

REVERT_TIME_FIELD

static final String REVERT_TIME_FIELD

See Also:

• Constant Field Values

STABLE_FIELD

static final String STABLE_FIELD

Whether the owner is a stable instance, whose machine id is never recycled by other instances. Documents written before this field existed have none, which means not stable.

See Also:

• Constant Field Values

MAX_MACHINE_ID_FIELD

static final String MAX_MACHINE_ID_FIELD

See Also:

• Constant Field Values

Method Details

nextMachineIdPipeline

static List<? extends org.bson.conversions.Bson> nextMachineIdPipeline(String namespace)

distributeDocument

static org.bson.Document distributeDocument(String namespace,
 InstanceId instanceId,
 MachineState nextMachineState)

distributeByRevertFilter

static org.bson.conversions.Bson distributeByRevertFilter(String namespace,
 InstanceId instanceId,
 Duration safeGuardDuration)

distributeByRevertUpdate

static org.bson.conversions.Bson distributeByRevertUpdate(InstanceId instanceId,
 long lastTimestamp)

distributeBySelfFilter

static org.bson.conversions.Bson distributeBySelfFilter(String namespace,
 InstanceId instanceId,
 Duration safeGuardDuration)

distributeBySelfUpdate

static org.bson.conversions.Bson distributeBySelfUpdate(long lastTimestamp)

distributeBySelfUpdate

static org.bson.conversions.Bson distributeBySelfUpdate(InstanceId instanceId,
 long lastTimestamp)

revertFilter

static org.bson.conversions.Bson revertFilter(String namespace,
 InstanceId instanceId,
 MachineState machineState)

revertUpdate

static org.bson.conversions.Bson revertUpdate(InstanceId instanceId,
 MachineState machineState)

guardFilter

static org.bson.conversions.Bson guardFilter(String namespace,
 InstanceId instanceId,
 MachineState machineState)

guardUpdate

static org.bson.conversions.Bson guardUpdate(long lastTimestamp)