RemoteCacheManagerAdmin.h

Go to the documentation of this file.

/*
 * RemoteCacheManagerAdmin.h
 *
 *  Created on: Apr 10, 2018
 *      Author: rigazilla
 */
 
#ifndef INCLUDE_INFINISPAN_HOTROD_REMOTECACHEMANAGERADMIN_H_
#define INCLUDE_INFINISPAN_HOTROD_REMOTECACHEMANAGERADMIN_H_
 
#include "infinispan/hotrod/ImportExport.h"
#include "infinispan/hotrod/RemoteCache.h"
#include "infinispan/hotrod/RemoteCacheManager.h"
#include <vector>
#include <set>
 
namespace infinispan {
namespace hotrod {
namespace transport {
class TransportFactory;
}
 
namespace operations {
class OperationsFactory;
}
 
namespace protocol {
class Codec;
}
 
using namespace transport;
using namespace operations;
using namespace protocol;
 
enum AdminFlag {
    PERMANENT=0
};
 
class HR_EXTERN RemoteCacheManagerAdmin {
public:
    RemoteCacheManagerAdmin(RemoteCacheManager& cacheManager, std::function<void(std::string&)> remover, std::shared_ptr<OperationsFactory> of);
    template <class K, class V> RemoteCache<K, V>& createCache(const std::string name, std::string model) {
        createCache(name, model, "@@cache@create");
        return cacheManager.getCache<K,V>(name);
    }
 
    template <class K, class V> RemoteCache<K, V>& createCacheWithXml(const std::string name, std::string conf) {
        createCacheWithXml(name, conf, "@@cache@create");
        return cacheManager.getCache<K,V>(name);
 
    }
 
    template <class K, class V> RemoteCache<K, V>& getOrCreateCache(const std::string name, std::string model) {
        createCache(name, model, "@@cache@getorcreate");
        return cacheManager.getCache<K,V>(name);
    }
 
    template <class K, class V> RemoteCache<K, V>& getOrCreateCacheWithXml(const std::string name, std::string conf) {
        createCacheWithXml(name, conf, "@@cache@getorcreate");
        return cacheManager.getCache<K,V>(name);
    }
 
    void removeCache(std::string name);
 
    void reindexCache(std::string name);
 
    std::set<std::string> getCacheNames();
 
    RemoteCacheManagerAdmin& withFlags(std::set<AdminFlag> flags);
    void createCache(const std::string name, std::string model, std::string command);
    void createCacheWithXml(const std::string name, std::string conf, std::string command);
 
private:
    std::string flags2Params(const std::set<AdminFlag>& flags) const;
 
    std::vector<char> executeAdminOperation(std::string adminCmd, std::map<std::string, std::string >& param);
 
    static const std::vector<char> CACHE_NAME;
    static const std::vector<char> CACHE_TEMPLATE;
    static const std::vector<char> CACHE_CONFIGURATION;
    static const std::vector<char> CACHE_FLAGS;
    static const std::string FLAG_LABELS[];
    std::shared_ptr<OperationsFactory> operationsFactory;
    std::function<void(std::string&)> remover;
 
    RemoteCacheManager& cacheManager;
#ifdef SWIGJAVA           // Swig needs public access to flags
public:
#endif
    std::set<AdminFlag> flags;
};
 
}} // namespace infinispan::hotrod
 
 
 
#endif /* INCLUDE_INFINISPAN_HOTROD_REMOTECACHEMANAGERADMIN_H_ */