Package it.unitn.disi.ds1.qtop

Class Utils

java.lang.Object
it.unitn.disi.ds1.qtop.Utils
public class Utils extends Object
Class that contains all the utility classes and messages used by the actors.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static final record 
    Utils.CountDown
    Message self-lopped by a node to trigger a timeout.
    static final record 
    Utils.CrashACK
    Message to acknowledge a CrashRequest.
    static final record 
    Utils.CrashRequest
    Message to ask for a crash.
    static enum 
    Utils.CrashType
    Enum to represent all the possible crashes that can be triggered.
    static enum 
    Utils.Decision
    Enum to represent all the possible decisions that can be taken by the coordinator.
    static final record 
    Utils.DecisionResponse
    Message to propagate the coordinator final decision regarding a certain epoch.
    static final record 
    Utils.Election
    Message to send election data
    static final record 
    Utils.ElectionACK
    Message to acknowledge an Election
    static final record 
    Utils.EpochPair
    Struct to represent and send an epoch and an iteration.
    static final record 
    Utils.HeartBeat
    Special message to multicast a heartbeat from a coordinator to all the nodes.
    static enum 
    Utils.LogLevel
    Enum to represent all the log levels, selected a level all the highest levels would be printed.
    static final record 
    Utils.MakeRequest
    Message used by a Client to generate a random request to a random Node.
    static final record 
    Utils.Quadruplet
    Struct cache the best candidate data during the election.
    static final record 
    Utils.ReadRequest
    Message used by a Client to ask for a read operation.
    static final record 
    Utils.ReadValue
    Message used by a Node to notify the Client that it received the ReadRequest, and reply to it.
    static final record 
    Utils.StartMessage
    Start message that sends the list of participants to everyone.
    static final record 
    Utils.Synchronisation
    Message to synchronise all the node after an election.
    static final record 
    Utils.TimeOut
    Message to notify a timeout.
    static enum 
    Utils.TimeOutReason
    Enum to represent all the possible reasons for a timeout.
    static enum 
    Utils.Vote
    Enum to represent all the possible votes that can be taken by a Node.
    static final record 
    Utils.VotePair
    Struct to represent the map of voters for every write, and the final decision taken for that write.
    static final record 
    Utils.VoteRequest
    Message that asks for a vote.
    static final record 
    Utils.VoteResponse
    Message to send the vote of a node to the coordinator.
    static final record 
    Utils.WriteRequest
    Message used by a Client to ask for a read operation.
    static final record 
    Utils.WriteValue
    Message used by a Node to notify the Client that it received the WriteRequest, and reply to it.

  • Constructor Summary

    Constructors
    Constructor
    Description
    Utils()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static String
    matchNodeID(akka.actor.ActorRef actorRefToMatch)
    Method to match the ID of a node and build a fancy string out of it.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • Utils

      public Utils()

  • Method Details

    • matchNodeID

      public static String matchNodeID(akka.actor.ActorRef actorRefToMatch)
      Method to match the ID of a node and build a fancy string out of it. There are two cases:
      • if the actor reference is a node, it will return [NODE-xyz]
      • if the actor reference is the coordinator, it will return [COORDINATOR]
      Parameters:
      actorRefToMatch - the actor reference to match
      Returns:
      the fancy String.