ClientConfig.h

/*
 * Copyright (c) 2008-2017, Hazelcast, Inc. All Rights Reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
#ifndef HAZELCAST_CLIENT_CONFIG
#define HAZELCAST_CLIENT_CONFIG

#include <vector>
#include <set>
#include <memory>

#include "hazelcast/client/Address.h"
#include "hazelcast/client/GroupConfig.h"
#include "hazelcast/client/SerializationConfig.h"
#include "hazelcast/client/Credentials.h"
#include "hazelcast/client/SocketInterceptor.h"
#include "hazelcast/client/LoadBalancer.h"
#include "hazelcast/client/impl/RoundRobinLB.h"
#include "hazelcast/util/ILogger.h"
#include "hazelcast/client/config/ReliableTopicConfig.h"
#include "hazelcast/client/config/NearCacheConfig.h"
#include "hazelcast/client/config/ClientNetworkConfig.h"
#include "hazelcast/util/SynchronizedMap.h"

#if  defined(WIN32) || defined(_WIN32) || defined(WIN64) || defined(_WIN64)
#pragma warning(push)
#pragma warning(disable: 4251) //for dll export 
#endif

namespace hazelcast {
    namespace client {
        class MembershipListener;

        class InitialMembershipListener;

        class LifecycleListener;

        class HAZELCAST_API ClientConfig {
        public:

            ClientConfig();

            ClientConfig &addAddress(const Address &address);

            ClientConfig &addAddresses(const std::vector<Address> &addresses);

            std::set<Address, addressComparator> &getAddresses();

            ClientConfig &setGroupConfig(GroupConfig &groupConfig);

            GroupConfig &getGroupConfig();

            ClientConfig &setCredentials(Credentials *credentials);

            const Credentials *getCredentials();

            ClientConfig &setConnectionAttemptLimit(int connectionAttemptLimit);

            int getConnectionAttemptLimit() const;

            ClientConfig &setConnectionTimeout(int connectionTimeoutInMillis);

            int getConnectionTimeout() const;

            ClientConfig &setAttemptPeriod(int attemptPeriodInMillis);

            int getAttemptPeriod() const;

            ClientConfig &setRedoOperation(bool redoOperation);

            bool isRedoOperation() const;

            bool isSmart() const;

            ClientConfig &setSmart(bool smart);

            ClientConfig &setSocketInterceptor(SocketInterceptor *socketInterceptor);

            SocketInterceptor *getSocketInterceptor();

            ClientConfig &addListener(LifecycleListener *listener);

            const std::set<LifecycleListener *> &getLifecycleListeners() const;

            ClientConfig &addListener(MembershipListener *listener);

            const std::set<MembershipListener *> &getMembershipListeners() const;

            ClientConfig &addListener(InitialMembershipListener *listener);

            const std::set<InitialMembershipListener *> &getInitialMembershipListeners() const;

            LoadBalancer *const getLoadBalancer();

            ClientConfig &setLoadBalancer(LoadBalancer *loadBalancer);

            ClientConfig &setLogLevel(LogLevel loggerLevel);


            SerializationConfig const &getSerializationConfig() const;

            ClientConfig &setSerializationConfig(SerializationConfig const &serializationConfig);

            std::map<std::string, std::string> &getProperties();

            ClientConfig &setProperty(const std::string &name, const std::string &value);

            ClientConfig &addReliableTopicConfig(const config::ReliableTopicConfig &reliableTopicConfig);

            const config::ReliableTopicConfig *getReliableTopicConfig(const std::string &name);

            template <typename K, typename V>
            ClientConfig &addNearCacheConfig(const boost::shared_ptr<config::NearCacheConfig<K, V> > nearCacheConfig) {
                nearCacheConfigMap.put(nearCacheConfig->getName(), nearCacheConfig);
                return *this;
            }

            template <typename K, typename V>
            const config::NearCacheConfig<K, V> *getNearCacheConfig(const std::string &name) {
                boost::shared_ptr<config::NearCacheConfigBase> nearCacheConfig = lookupByPattern(name);
                if (nearCacheConfig.get() == NULL) {
                    nearCacheConfig = nearCacheConfigMap.get("default");
                }
                // not needed for c++ client since it is always native memory
                //initDefaultMaxSizeForOnHeapMaps(nearCacheConfig);
                return boost::static_pointer_cast<config::NearCacheConfig<K, V> >(nearCacheConfig).get();
            }

            config::ClientNetworkConfig &getNetworkConfig();

            ClientConfig &setNetworkConfig(const config::ClientNetworkConfig &networkConfig);

        private:

            GroupConfig groupConfig;

            config::ClientNetworkConfig networkConfig;

            SerializationConfig serializationConfig;

            std::set<Address, addressComparator> addressList;

            LoadBalancer *loadBalancer;

            std::auto_ptr<impl::RoundRobinLB> defaultLoadBalancer;

            std::set<MembershipListener *> membershipListeners;

            std::set<InitialMembershipListener *> initialMembershipListeners;

            std::set<LifecycleListener *> lifecycleListeners;

            std::map<std::string, std::string> properties;

            bool smart;

            bool redoOperation;

            int connectionAttemptLimit;

            int attemptPeriod;

            SocketInterceptor *socketInterceptor;

            Credentials *credentials;

            std::auto_ptr<Credentials> defaultCredentials;

            std::map<std::string, config::ReliableTopicConfig> reliableTopicConfigMap;

            util::SynchronizedMap<std::string, config::NearCacheConfigBase> nearCacheConfigMap;

            const boost::shared_ptr<config::NearCacheConfigBase> lookupByPattern(const std::string &name) {
                    // TODO: implement the lookup
                    return nearCacheConfigMap.get(name);
            }
        };

    }
}

#if  defined(WIN32) || defined(_WIN32) || defined(WIN64) || defined(_WIN64)
#pragma warning(pop)
#endif

#endif /* HAZELCAST_CLIENT_CONFIG */