ClientEvent.h

Go to the documentation of this file.

/*
 * ClientEvent.h
 *
 *  Created on: Aug 19, 2016
 *      Author: rigazilla
 */
 
#ifndef SRC_HOTROD_IMPL_EVENT_CLIENTEVENT_H_
#define SRC_HOTROD_IMPL_EVENT_CLIENTEVENT_H_
 
#include <vector>
#include <cstdint>
 
namespace infinispan {
namespace hotrod {
namespace event {
 
struct EventHeaderParams {
    uint8_t magic;
    uint64_t messageId;
    uint8_t opCode;
    uint8_t status;
};
 
class ClientEvent {
public:
   enum Type {
      CLIENT_CACHE_ENTRY_CREATED, CLIENT_CACHE_ENTRY_MODIFIED,
      CLIENT_CACHE_ENTRY_REMOVED, CLIENT_CACHE_ENTRY_EXPIRED, CLIENT_CACHE_ENTRY_CUSTOM,
      CLIENT_CACHE_FAILOVER
   };
 
   virtual uint8_t getType() = 0;
   virtual ~ClientEvent() {}
};
 
template <class K>
class ClientCacheEntryCreatedEvent : public ClientEvent
{
public:
           ClientCacheEntryCreatedEvent(K key, uint64_t version, int commandRetried) : key(key), version(version), commandRetried(commandRetried!=0) {}
           K getKey() { return key; }
 
           uint64_t getVersion() { return version; }
 
           bool isCommandRetried() { return commandRetried; }
           uint8_t getType() { return CLIENT_CACHE_ENTRY_CREATED; }
private:
           const K key;
           const uint64_t version;
           const bool commandRetried;
};
 
template <class K>
class ClientCacheEntryModifiedEvent : public ClientEvent {
public:
           ClientCacheEntryModifiedEvent(K key, uint64_t version, int commandRetried) : key(key), version(version), commandRetried(commandRetried!=0) {}
 
           K getKey() { return key; }
 
           uint64_t getVersion() { return version; }
 
           bool isCommandRetried() { return commandRetried; }
   uint8_t getType() { return CLIENT_CACHE_ENTRY_MODIFIED; }
private:
           const K key;
           const uint64_t version;
           const bool commandRetried;
};
 
template <class K>
class ClientCacheEntryExpiredEvent : public ClientEvent {
public:
           ClientCacheEntryExpiredEvent(K key): key(key) {}
           K getKey() { return key; }
 
           uint8_t getType() { return CLIENT_CACHE_ENTRY_EXPIRED; }
private:
   const K key;
};
 
template <class K>
class ClientCacheEntryRemovedEvent : ClientEvent {
public:
           ClientCacheEntryRemovedEvent(K key, int commandRetried) : key(key), commandRetried(commandRetried!=0) {}
           K getKey() { return key; }
 
           bool isCommandRetried() { return commandRetried; }
   uint8_t getType() { return CLIENT_CACHE_ENTRY_REMOVED; }
private:
   const K key;
   const bool commandRetried;
};
 
class ClientCacheEntryCustomEvent : ClientEvent {
public:
        ClientCacheEntryCustomEvent(std::vector<char> data, int commandRetried) : data(data), commandRetried(commandRetried!=0) {}
   std::vector<char> getEventData() { return data; }
 
   bool isCommandRetried() { return commandRetried; }
   uint8_t getType() { return CLIENT_CACHE_ENTRY_CUSTOM; }
private:
   const std::vector<char> data;
   bool commandRetried;
};
 
class ClientCacheFailoverEvent : ClientEvent {
           uint8_t getType() { return CLIENT_CACHE_FAILOVER; }
 
};
 
 
} /* namespace event */
} /* namespace hotrod */
} /* namespace infinispan */
 
#endif /* SRC_HOTROD_IMPL_EVENT_CLIENTEVENT_H_ */