HazelcastClient.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
#define HAZELCAST_CLIENT

#include <memory>

#include "hazelcast/client/map/impl/ClientMapProxyFactory.h"
#include "hazelcast/client/internal/nearcache/NearCacheManager.h"
#include "hazelcast/client/proxy/RingbufferImpl.h"
#include "hazelcast/client/IMap.h"
#include "hazelcast/client/MultiMap.h"
#include "hazelcast/client/IQueue.h"
#include "hazelcast/client/ISet.h"
#include "hazelcast/client/IList.h"
#include "hazelcast/client/ITopic.h"
#include "hazelcast/client/TransactionOptions.h"
#include "hazelcast/client/TransactionContext.h"
#include "hazelcast/client/Cluster.h"
#include "hazelcast/client/ClientConfig.h"
#include "hazelcast/client/ClientProperties.h"
#include "hazelcast/client/spi/InvocationService.h"
#include "hazelcast/client/spi/PartitionService.h"
#include "hazelcast/client/spi/ServerListenerService.h"
#include "hazelcast/client/spi/LifecycleService.h"
#include "hazelcast/client/spi/ProxyManager.h"
#include "hazelcast/client/Ringbuffer.h"
#include "hazelcast/client/ReliableTopic.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 {
        namespace connection {
            class ConnectionManager;
        }

        namespace serialization {
            namespace pimpl {
                class SerializationService;
            }
        }
        namespace spi {
            class ClientContext;

            class InvocationService;

            class ClusterService;

            class PartitionService;

            class LifecycleService;

            class ServerListenerService;

            class ClientProxyFactory;

        }

        class ClientConfig;

        class IdGenerator;

        class IAtomicLong;

        class ICountDownLatch;

        class ISemaphore;

        class ILock;

        class TransactionContext;

        class TransactionOptions;

        class Cluster;

        class HAZELCAST_API HazelcastClient {
            friend class spi::ClientContext;

        public:
            HazelcastClient(ClientConfig&);

            ~HazelcastClient();

            template<typename T>
            T getDistributedObject(const std::string& name) {
                T t(name, &(clientContext));
                return t;
            }

            template<typename K, typename V>
            IMap<K, V> getMap(const std::string &name) {
                map::impl::ClientMapProxyFactory<K, V> factory(&clientContext);
                boost::shared_ptr<spi::ClientProxy> proxy =
                        getDistributedObjectForService(IMap<K, V>::SERVICE_NAME, name, factory);

                return IMap<K, V>(proxy);
            }

            template<typename K, typename V>
            MultiMap<K, V> getMultiMap(const std::string& name) {
                return getDistributedObject<MultiMap<K, V> >(name);
            }

            template<typename E>
            IQueue<E> getQueue(const std::string& name) {
                return getDistributedObject<IQueue<E> >(name);
            }

            template<typename E>
            ISet<E> getSet(const std::string& name) {
                return getDistributedObject<ISet<E> >(name);
            }

            template<typename E>
            IList<E> getList(const std::string& name) {
                return getDistributedObject<IList<E> >(name);
            }

            template<typename E>
            ITopic<E> getTopic(const std::string& name) {
                return getDistributedObject<ITopic<E> >(name);
            };

            template<typename E>
            boost::shared_ptr<ReliableTopic<E> > getReliableTopic(const std::string& name) {
                boost::shared_ptr<Ringbuffer<topic::impl::reliable::ReliableTopicMessage> > rb =
                        getRingbuffer<topic::impl::reliable::ReliableTopicMessage>(TOPIC_RB_PREFIX + name);
                return boost::shared_ptr<ReliableTopic<E> >(new ReliableTopic<E>(name, &clientContext, rb));
            }

            IdGenerator getIdGenerator(const std::string& name);

            IAtomicLong getIAtomicLong(const std::string& name);

            ICountDownLatch getICountDownLatch(const std::string& name);

            ILock getILock(const std::string& name);

            template <typename E>
            boost::shared_ptr<Ringbuffer<E> > getRingbuffer(const std::string& name) {
                return boost::shared_ptr<Ringbuffer<E> >(new proxy::RingbufferImpl<E>(name, &clientContext));
            }

            ISemaphore getISemaphore(const std::string& name);

            ClientConfig& getClientConfig();

            TransactionContext newTransactionContext();

            TransactionContext newTransactionContext(const TransactionOptions& options);

            Cluster& getCluster();

            void addLifecycleListener(LifecycleListener *lifecycleListener);

            bool removeLifecycleListener(LifecycleListener *lifecycleListener);

            void shutdown();

            internal::nearcache::NearCacheManager &getNearCacheManager();

            serialization::pimpl::SerializationService &getSerializationService();
        private:
            boost::shared_ptr<spi::ClientProxy> getDistributedObjectForService(const std::string &serviceName,
                                                                               const std::string &name,
                                                                               spi::ClientProxyFactory &factory);

            ClientConfig clientConfig;
            ClientProperties clientProperties;
            util::CountDownLatch shutdownLatch;
            spi::ClientContext clientContext;
            spi::LifecycleService lifecycleService;
            serialization::pimpl::SerializationService serializationService;
            std::auto_ptr<connection::ConnectionManager> connectionManager;
            internal::nearcache::NearCacheManager nearCacheManager;
            spi::ClusterService clusterService;
            spi::PartitionService partitionService;
            spi::InvocationService invocationService;
            spi::ServerListenerService serverListenerService;
            Cluster cluster;
            spi::ProxyManager proxyManager;

            HazelcastClient(const HazelcastClient& rhs);

            void operator=(const HazelcastClient& rhs);

            const std::string TOPIC_RB_PREFIX;
        };

    }
}

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

#endif /* HAZELCAST_CLIENT */