ClientConfig.h

/*
 * Copyright (c) 2008-2018, 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 <boost/shared_ptr.hpp>

#include "hazelcast/client/config/ClientConnectionStrategyConfig.h"
#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 InitialMembershipEvent;

        class HAZELCAST_API ClientConfig {
            friend class spi::impl::ClientClusterServiceImpl;
        public:

            ClientConfig();

            ClientConfig &addAddress(const Address &address);

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

            std::set<Address> getAddresses();

            ClientConfig &setGroupConfig(const 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);

            ClientConfig &addListener(const boost::shared_ptr<MembershipListener> &listener);

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

            const std::set<boost::shared_ptr<MembershipListener> > &getManagedMembershipListeners() const;

            ClientConfig &addListener(InitialMembershipListener *listener);

            ClientConfig &addListener(const boost::shared_ptr<InitialMembershipListener> &listener);

            LoadBalancer *const getLoadBalancer();

            ClientConfig &setLoadBalancer(LoadBalancer *loadBalancer);

            ClientConfig &setLogLevel(LogLevel loggerLevel);

            SerializationConfig &getSerializationConfig();

            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;
            }

            ClientConfig &addMixedNearCacheConfig(const boost::shared_ptr<mixedtype::config::MixedNearCacheConfig> nearCacheConfig) {
                nearCacheConfigMap.put(nearCacheConfig->getName(), nearCacheConfig);
                return *this;
            }

            template <typename K, typename V>
            const boost::shared_ptr<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);
            }

            const boost::shared_ptr<mixedtype::config::MixedNearCacheConfig> getMixedNearCacheConfig(const std::string &name);

            config::ClientNetworkConfig &getNetworkConfig();

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

            const boost::shared_ptr<std::string> &getInstanceName() const;

            void setInstanceName(const boost::shared_ptr<std::string> &instanceName);

            int32_t getExecutorPoolSize() const;

            void setExecutorPoolSize(int32_t executorPoolSize);

            config::ClientConnectionStrategyConfig &getConnectionStrategyConfig();

            ClientConfig &
            setConnectionStrategyConfig(const config::ClientConnectionStrategyConfig &connectionStrategyConfig);

        private:
            GroupConfig groupConfig;

            config::ClientNetworkConfig networkConfig;

            SerializationConfig serializationConfig;

            LoadBalancer *loadBalancer;

            impl::RoundRobinLB defaultLoadBalancer;

            std::set<MembershipListener *> membershipListeners;
            std::set<boost::shared_ptr<MembershipListener> > managedMembershipListeners;

            std::set<LifecycleListener *> lifecycleListeners;

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

            bool redoOperation;

            SocketInterceptor *socketInterceptor;

            Credentials *credentials;

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

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

            boost::shared_ptr<std::string> instanceName;

            int32_t executorPoolSize;

            config::ClientConnectionStrategyConfig connectionStrategyConfig;

            const boost::shared_ptr<config::NearCacheConfigBase> lookupByPattern(const std::string &name);
        };

    }
}

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

#endif /* HAZELCAST_CLIENT_CONFIG */