Enum Class MessageType

java.lang.Object
java.lang.Enum<MessageType>
com.loomcache.common.protocol.MessageType
All Implemented Interfaces:
Serializable, Comparable<MessageType>, Constable
public enum MessageType extends Enum<MessageType>
All operation codes for the LoomCache binary protocol.

Wire format (16-byte fixed header): ┌────────┬────────┬──────────┬──────────┐ │ magic │opcode │ corrId │ bodyLen │ │ 1 byte │1 byte │ 4 bytes │ 4 bytes │ ├────────┼────────┼──────────┼──────────┤ │ flags │keyLen │ status │ reserved │ │ 1 byte │2 bytes │ 1 byte │ 2 bytes │ └────────────────────────────────────────┘ Body: [key bytes][value bytes]

  • Enum Constant Details

    • MAP_GET

      public static final MessageType MAP_GET

    • MAP_PUT

      public static final MessageType MAP_PUT

    • MAP_DELETE

      public static final MessageType MAP_DELETE

    • MAP_CONTAINS

      public static final MessageType MAP_CONTAINS

    • MAP_SIZE

      public static final MessageType MAP_SIZE

    • MAP_KEYS

      public static final MessageType MAP_KEYS

    • MAP_VALUES

      public static final MessageType MAP_VALUES

    • MAP_PUT_IF_ABSENT

      public static final MessageType MAP_PUT_IF_ABSENT

    • MAP_REPLACE

      public static final MessageType MAP_REPLACE

    • MAP_CLEAR

      public static final MessageType MAP_CLEAR

    • MAP_GET_ALL

      public static final MessageType MAP_GET_ALL

    • MAP_PUT_ALL

      public static final MessageType MAP_PUT_ALL

    • MAP_EXECUTE_ON_KEY

      public static final MessageType MAP_EXECUTE_ON_KEY

    • MAP_EXECUTE_ON_KEYS

      public static final MessageType MAP_EXECUTE_ON_KEYS

    • MAP_EXECUTE_ON_ENTRIES

      public static final MessageType MAP_EXECUTE_ON_ENTRIES

    • MAP_COMPARE_DELETE

      public static final MessageType MAP_COMPARE_DELETE

    • MAP_PUT_WITH_TTL

      public static final MessageType MAP_PUT_WITH_TTL

    • MAP_REPLACE_CAS

      public static final MessageType MAP_REPLACE_CAS

    • MAP_COMPUTE_IF_ABSENT

      public static final MessageType MAP_COMPUTE_IF_ABSENT

    • CLIENT_STATS_UPLOAD

      public static final MessageType CLIENT_STATS_UPLOAD

    • QUEUE_OFFER

      public static final MessageType QUEUE_OFFER

    • QUEUE_POLL

      public static final MessageType QUEUE_POLL

    • QUEUE_PEEK

      public static final MessageType QUEUE_PEEK

    • QUEUE_SIZE

      public static final MessageType QUEUE_SIZE

    • QUEUE_DRAIN

      public static final MessageType QUEUE_DRAIN

    • QUEUE_OFFER_ALL

      public static final MessageType QUEUE_OFFER_ALL

    • QUEUE_POLL_N

      public static final MessageType QUEUE_POLL_N

    • QUEUE_DRAIN_TO

      public static final MessageType QUEUE_DRAIN_TO

    • TOPIC_PUBLISH

      public static final MessageType TOPIC_PUBLISH

    • TOPIC_SUBSCRIBE

      public static final MessageType TOPIC_SUBSCRIBE

    • TOPIC_UNSUBSCRIBE

      public static final MessageType TOPIC_UNSUBSCRIBE

    • TOPIC_EVENT

      public static final MessageType TOPIC_EVENT

    • SET_ADD

      public static final MessageType SET_ADD

    • SET_REMOVE

      public static final MessageType SET_REMOVE

    • SET_CONTAINS

      public static final MessageType SET_CONTAINS

    • SET_SIZE

      public static final MessageType SET_SIZE

    • SET_CLEAR

      public static final MessageType SET_CLEAR

    • SET_MEMBERS

      public static final MessageType SET_MEMBERS

    • LISTENER_REGISTER

      public static final MessageType LISTENER_REGISTER

    • LISTENER_DEREGISTER

      public static final MessageType LISTENER_DEREGISTER

    • LISTENER_EVENT

      public static final MessageType LISTENER_EVENT

    • NEAR_CACHE_INVALIDATE

      public static final MessageType NEAR_CACHE_INVALIDATE

    • NEAR_CACHE_SUBSCRIBE

      public static final MessageType NEAR_CACHE_SUBSCRIBE

    • NEAR_CACHE_UNSUBSCRIBE

      public static final MessageType NEAR_CACHE_UNSUBSCRIBE

    • CQC_SUBSCRIBE

      public static final MessageType CQC_SUBSCRIBE

    • CQC_EVENT

      public static final MessageType CQC_EVENT

    • CQC_UNSUBSCRIBE

      public static final MessageType CQC_UNSUBSCRIBE

    • CLUSTER_JOIN

      public static final MessageType CLUSTER_JOIN

    • CLUSTER_LEAVE

      public static final MessageType CLUSTER_LEAVE

    • CLUSTER_PING

      public static final MessageType CLUSTER_PING

    • CLUSTER_PONG

      public static final MessageType CLUSTER_PONG

    • CLUSTER_STATE

      public static final MessageType CLUSTER_STATE

    • PARTITION_TABLE

      public static final MessageType PARTITION_TABLE

    • CLUSTER_INFO

      public static final MessageType CLUSTER_INFO

    • CLUSTER_NODES

      public static final MessageType CLUSTER_NODES

    • CLUSTER_HEALTH

      public static final MessageType CLUSTER_HEALTH

    • PARTITION_MIGRATE_START

      public static final MessageType PARTITION_MIGRATE_START

    • PARTITION_MIGRATE_DATA

      public static final MessageType PARTITION_MIGRATE_DATA

    • PARTITION_MIGRATE_COMPLETE

      public static final MessageType PARTITION_MIGRATE_COMPLETE

    • PARTITION_OWNERSHIP_UPDATE

      public static final MessageType PARTITION_OWNERSHIP_UPDATE

    • PARTITION_MIGRATE_DATA_ACK

      public static final MessageType PARTITION_MIGRATE_DATA_ACK

    • CONFIG_ADD_SERVER

      public static final MessageType CONFIG_ADD_SERVER

    • CONFIG_REMOVE_SERVER

      public static final MessageType CONFIG_REMOVE_SERVER

    • RAFT_VOTE_REQUEST

      public static final MessageType RAFT_VOTE_REQUEST

    • RAFT_VOTE_RESPONSE

      public static final MessageType RAFT_VOTE_RESPONSE

    • RAFT_APPEND_ENTRIES

      public static final MessageType RAFT_APPEND_ENTRIES

    • RAFT_APPEND_RESPONSE

      public static final MessageType RAFT_APPEND_RESPONSE

    • RAFT_HEARTBEAT

      public static final MessageType RAFT_HEARTBEAT

    • RAFT_PRE_VOTE_REQUEST

      public static final MessageType RAFT_PRE_VOTE_REQUEST

    • RAFT_PRE_VOTE_RESPONSE

      public static final MessageType RAFT_PRE_VOTE_RESPONSE

    • RAFT_INSTALL_SNAPSHOT

      public static final MessageType RAFT_INSTALL_SNAPSHOT

    • RAFT_INSTALL_SNAPSHOT_RESPONSE

      public static final MessageType RAFT_INSTALL_SNAPSHOT_RESPONSE

    • RAFT_TIMEOUT_NOW

      public static final MessageType RAFT_TIMEOUT_NOW

    • RAFT_TIMEOUT_NOW_RESPONSE

      public static final MessageType RAFT_TIMEOUT_NOW_RESPONSE

    • REPL_SYNC

      public static final MessageType REPL_SYNC

    • REPL_ACK

      public static final MessageType REPL_ACK

    • AUTH

      public static final MessageType AUTH

    • AUTH_RESPONSE

      public static final MessageType AUTH_RESPONSE

    • CP_LOCK_ACQUIRE

      public static final MessageType CP_LOCK_ACQUIRE

    • CP_LOCK_RELEASE

      public static final MessageType CP_LOCK_RELEASE

    • CP_SEMAPHORE_ACQUIRE

      public static final MessageType CP_SEMAPHORE_ACQUIRE

    • CP_SEMAPHORE_RELEASE

      public static final MessageType CP_SEMAPHORE_RELEASE

    • CP_ATOMIC_GET

      public static final MessageType CP_ATOMIC_GET

    • CP_ATOMIC_SET

      public static final MessageType CP_ATOMIC_SET

    • CP_ATOMIC_INCREMENT_AND_GET

      public static final MessageType CP_ATOMIC_INCREMENT_AND_GET

    • CP_ATOMIC_DECREMENT_AND_GET

      public static final MessageType CP_ATOMIC_DECREMENT_AND_GET

    • CP_ATOMIC_ADD_AND_GET

      public static final MessageType CP_ATOMIC_ADD_AND_GET

    • CP_ATOMIC_GET_AND_INCREMENT

      public static final MessageType CP_ATOMIC_GET_AND_INCREMENT

    • CP_ATOMIC_GET_AND_DECREMENT

      public static final MessageType CP_ATOMIC_GET_AND_DECREMENT

    • CP_ATOMIC_GET_AND_ADD

      public static final MessageType CP_ATOMIC_GET_AND_ADD

    • CP_ATOMIC_CAS

      public static final MessageType CP_ATOMIC_CAS

    • CP_SEMAPHORE_AVAILABLE_PERMITS

      public static final MessageType CP_SEMAPHORE_AVAILABLE_PERMITS

    • SQL_QUERY_EXECUTE

      public static final MessageType SQL_QUERY_EXECUTE

    • SQL_QUERY_RESULT

      public static final MessageType SQL_QUERY_RESULT

    • MAP_SCAN

      public static final MessageType MAP_SCAN

    • SET_SCAN

      public static final MessageType SET_SCAN

    • MULTIMAP_PUT

      public static final MessageType MULTIMAP_PUT

    • MULTIMAP_GET

      public static final MessageType MULTIMAP_GET

    • MULTIMAP_REMOVE

      public static final MessageType MULTIMAP_REMOVE

    • MULTIMAP_SIZE

      public static final MessageType MULTIMAP_SIZE

    • MULTIMAP_KEYS

      public static final MessageType MULTIMAP_KEYS

    • MULTIMAP_VALUES

      public static final MessageType MULTIMAP_VALUES

    • MULTIMAP_CLEAR

      public static final MessageType MULTIMAP_CLEAR

    • LIST_ADD

      public static final MessageType LIST_ADD

    • LIST_GET

      public static final MessageType LIST_GET

    • LIST_SET

      public static final MessageType LIST_SET

    • LIST_REMOVE

      public static final MessageType LIST_REMOVE

    • LIST_SIZE

      public static final MessageType LIST_SIZE

    • LIST_SUBLIST

      public static final MessageType LIST_SUBLIST

    • LIST_CLEAR

      public static final MessageType LIST_CLEAR

    • PQ_OFFER

      public static final MessageType PQ_OFFER

    • PQ_POLL

      public static final MessageType PQ_POLL

    • PQ_PEEK

      public static final MessageType PQ_PEEK

    • PQ_SIZE

      public static final MessageType PQ_SIZE

    • PQ_CLEAR

      public static final MessageType PQ_CLEAR

    • RB_ADD

      public static final MessageType RB_ADD

    • RB_READ_ONE

      public static final MessageType RB_READ_ONE

    • RB_READ_MANY

      public static final MessageType RB_READ_MANY

    • RB_HEAD_SEQ

      public static final MessageType RB_HEAD_SEQ

    • RB_TAIL_SEQ

      public static final MessageType RB_TAIL_SEQ

    • RB_CAPACITY

      public static final MessageType RB_CAPACITY

    • RTOPIC_PUBLISH

      public static final MessageType RTOPIC_PUBLISH

    • RTOPIC_SUBSCRIBE

      public static final MessageType RTOPIC_SUBSCRIBE

    • RTOPIC_UNSUBSCRIBE

      public static final MessageType RTOPIC_UNSUBSCRIBE

    • RTOPIC_EVENT

      public static final MessageType RTOPIC_EVENT

    • TX_BEGIN

      public static final MessageType TX_BEGIN

    • TX_OPERATION

      public static final MessageType TX_OPERATION

    • TX_COMMIT

      public static final MessageType TX_COMMIT

    • TX_ROLLBACK

      public static final MessageType TX_ROLLBACK

    • TX_PREPARE_GROUP

      public static final MessageType TX_PREPARE_GROUP

    • TX_PREPARE_ACK

      public static final MessageType TX_PREPARE_ACK

    • TX_DECIDE_GROUP

      public static final MessageType TX_DECIDE_GROUP

    • TX_DECIDE_ACK

      public static final MessageType TX_DECIDE_ACK

    • TX_DECIDE_QUERY

      public static final MessageType TX_DECIDE_QUERY

    • TX_COORD_PREPARE

      public static final MessageType TX_COORD_PREPARE

    • TX_COORD_DECIDE

      public static final MessageType TX_COORD_DECIDE

    • TX_LOCK_KEY

      public static final MessageType TX_LOCK_KEY

    • BATCH_EXECUTE

      public static final MessageType BATCH_EXECUTE

    • GOING_AWAY

      public static final MessageType GOING_AWAY

    • TOO_MANY_CONNECTIONS

      public static final MessageType TOO_MANY_CONNECTIONS

    • EXECUTOR_SUBMIT

      public static final MessageType EXECUTOR_SUBMIT

    • EXECUTOR_SUBMIT_TO_KEY

      public static final MessageType EXECUTOR_SUBMIT_TO_KEY

    • EXECUTOR_SUBMIT_TO_MEMBER

      public static final MessageType EXECUTOR_SUBMIT_TO_MEMBER

    • EXECUTOR_SUBMIT_TO_ALL

      public static final MessageType EXECUTOR_SUBMIT_TO_ALL

    • EXECUTOR_CANCEL

      public static final MessageType EXECUTOR_CANCEL

    • EXECUTOR_STATUS

      public static final MessageType EXECUTOR_STATUS

    • EXECUTOR_RESULT

      public static final MessageType EXECUTOR_RESULT

    • EXECUTOR_SHUTDOWN

      public static final MessageType EXECUTOR_SHUTDOWN

    • CP_LATCH_TRY_SET

      public static final MessageType CP_LATCH_TRY_SET

    • CP_LATCH_COUNT_DOWN

      public static final MessageType CP_LATCH_COUNT_DOWN

    • CP_LATCH_AWAIT

      public static final MessageType CP_LATCH_AWAIT

    • CP_LATCH_GET_COUNT

      public static final MessageType CP_LATCH_GET_COUNT

    • CP_ATOMICREF_GET

      public static final MessageType CP_ATOMICREF_GET

    • CP_ATOMICREF_SET

      public static final MessageType CP_ATOMICREF_SET

    • CP_ATOMICREF_CAS

      public static final MessageType CP_ATOMICREF_CAS

    • WAN_SYNC

      public static final MessageType WAN_SYNC

    • WAN_BATCH

      public static final MessageType WAN_BATCH

    • WAN_ACK

      public static final MessageType WAN_ACK

    • WAN_STATUS

      public static final MessageType WAN_STATUS

    • WAN_PAUSE

      public static final MessageType WAN_PAUSE

    • WAN_RESUME

      public static final MessageType WAN_RESUME

    • PNCTR_GET

      public static final MessageType PNCTR_GET

    • PNCTR_INC

      public static final MessageType PNCTR_INC

    • PNCTR_DEC

      public static final MessageType PNCTR_DEC

    • PNCTR_ADD

      public static final MessageType PNCTR_ADD

    • PNCTR_SUB

      public static final MessageType PNCTR_SUB

    • PNCTR_RESET

      public static final MessageType PNCTR_RESET

    • IDGEN_NEXT

      public static final MessageType IDGEN_NEXT

    • IDGEN_NEXT_BATCH

      public static final MessageType IDGEN_NEXT_BATCH

    • PROTOCOL_HELLO

      public static final MessageType PROTOCOL_HELLO

    • PROTOCOL_HELLO_ACK

      public static final MessageType PROTOCOL_HELLO_ACK

    • PARTITION_TABLE_REQUEST

      public static final MessageType PARTITION_TABLE_REQUEST

    • PARTITION_TABLE_RESPONSE

      public static final MessageType PARTITION_TABLE_RESPONSE

    • GSET_ADD

      public static final MessageType GSET_ADD

    • GSET_CONTAINS

      public static final MessageType GSET_CONTAINS

    • GSET_MEMBERS

      public static final MessageType GSET_MEMBERS

    • GSET_SIZE

      public static final MessageType GSET_SIZE

    • ORSET_ADD

      public static final MessageType ORSET_ADD

    • ORSET_REMOVE

      public static final MessageType ORSET_REMOVE

    • ORSET_CONTAINS

      public static final MessageType ORSET_CONTAINS

    • ORSET_MEMBERS

      public static final MessageType ORSET_MEMBERS

    • ORSET_SIZE

      public static final MessageType ORSET_SIZE

    • LWW_GET

      public static final MessageType LWW_GET

    • LWW_SET

      public static final MessageType LWW_SET

    • LWW_TIMESTAMP

      public static final MessageType LWW_TIMESTAMP

    • RESPONSE_OK

      public static final MessageType RESPONSE_OK

    • RESPONSE_ERROR

      public static final MessageType RESPONSE_ERROR

    • RESPONSE_NOT_FOUND

      public static final MessageType RESPONSE_NOT_FOUND

    • RESPONSE_REDIRECT

      public static final MessageType RESPONSE_REDIRECT

    • RESPONSE_SERVER_BUSY

      public static final MessageType RESPONSE_SERVER_BUSY

    • RESPONSE_SEQUENCE_LOST

      public static final MessageType RESPONSE_SEQUENCE_LOST

  • Method Details

    • values

      public static MessageType[] 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 MessageType 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

    • code

      public byte code()

    • fromCode

      public static @Nullable MessageType fromCode(byte code)
      O(1) lookup from wire byte to enum. Returns null if unknown.