Package com.illumon.iris.db.v2.logaggregator

Enum Class CommandHelper.LasCommandId

java.lang.Object
java.lang.Enum<CommandHelper.LasCommandId>
com.illumon.iris.db.v2.logaggregator.CommandHelper.LasCommandId
All Implemented Interfaces:
Serializable, Comparable<CommandHelper.LasCommandId>, java.lang.constant.Constable
Enclosing class:
CommandHelper
public static enum CommandHelper.LasCommandId extends Enum<CommandHelper.LasCommandId>
These commands are passed between BinaryStoreAggregatorWriter implementations and the LogAggregator service.

  • Enum Constant Details

    • LAS_DATA

      public static final CommandHelper.LasCommandId LAS_DATA

    • LAS_COMMAND

      public static final CommandHelper.LasCommandId LAS_COMMAND

    • CLIENT_INITIATE

      public static final CommandHelper.LasCommandId CLIENT_INITIATE
      client:server open a connection. Identifiers and binary header to follow.

    • CLIENT_INITIATE2

      public static final CommandHelper.LasCommandId CLIENT_INITIATE2
      client:server open a connection. Identifiers, auth token, and binary header to follow.

    • ACCEPT_HEADER

      public static final CommandHelper.LasCommandId ACCEPT_HEADER
      server:client: the connection is accepted.

    • REJECT_HEADER

      public static final CommandHelper.LasCommandId REJECT_HEADER
      server:client the connection is rejected.

    • REJECT_AUTH_TOKEN

      public static final CommandHelper.LasCommandId REJECT_AUTH_TOKEN
      server:client the connection is rejected due to bad auth token.

    • REJECT_PERMISSIONS

      public static final CommandHelper.LasCommandId REJECT_PERMISSIONS
      server:client the connection is rejected, user does not have write permission.

    • SERVER_TERMINATE

      public static final CommandHelper.LasCommandId SERVER_TERMINATE
      server:client the connection is going to be closed immediately.

    • FLUSH_ACK

      public static final CommandHelper.LasCommandId FLUSH_ACK
      server:client all records received prior to the CLIENT_REQUEST_FLUSH message have been processed.

    • CLIENT_FINISHED_ACK

      public static final CommandHelper.LasCommandId CLIENT_FINISHED_ACK
      server:client ack for CLIENT_FINISHED.

    • CLIENT_DELETE_PARTITION_ACK

      public static final CommandHelper.LasCommandId CLIENT_DELETE_PARTITION_ACK
      server:client the delete partition request has been processed.

    • BATCH_DATA

      public static final CommandHelper.LasCommandId BATCH_DATA
      client:server batched row data. to support deferred rows from TableWriter

  • Field Details

    • name

      public final String name

    • wireValue

      public final byte wireValue

  • Method Details

    • values

      public static CommandHelper.LasCommandId[] 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 CommandHelper.LasCommandId 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

    • equals

      public boolean equals(byte val)