Interface MachineOperates


public interface MachineOperates
  • Field Details

  • 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)
    • 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)