Enum Class Decision.Action

java.lang.Object
java.lang.Enum<Decision.Action>
io.krabka.streams.coordination.Decision.Action
All Implemented Interfaces:
Serializable, Comparable<Decision.Action>, Constable
Enclosing class:
Decision
public static enum Decision.Action extends Enum<Decision.Action>
The step that one member takes about a role.

Example

if (decision.action() == Decision.Action.CHALLENGE) {
    transport.acquireEpoch(role);
}

  • Enum Constant Details

    • NOT_REGISTERED

      public static final Decision.Action NOT_REGISTERED
      This member is not in the roster of the role, so it has no rank. It registers first, reads the partition again, and evaluates again.

    • HOLD

      public static final Decision.Action HOLD
      This member holds the role and its lease is live. It renews the lease, and it calls InitProducerId for nothing.

    • CHALLENGE

      public static final Decision.Action CHALLENGE
      This member calls InitProducerId now.

    • WAIT

      public static final Decision.Action WAIT
      This member waits, and then it evaluates the role state again. Decision.waitUntilMillis() carries the instant.

  • Method Details

    • values

      public static Decision.Action[] values()
      Returns an array containing the constants of this enum class, in the order they are declared.
      Returns:
      an array containing the constants of this enum class, in the order they are declared

    • valueOf

      public static Decision.Action valueOf(String name)
      Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)
      Parameters:
      name - the name of the enum constant to be returned.
      Returns:
      the enum constant with the specified name
      Throws:
      IllegalArgumentException - if this enum class has no constant with the specified name
      NullPointerException - if the argument is null