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_ */