client_config.h

/*
 * Copyright (c) 2008-2021, 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.
 */
#pragma once

#include <vector>
#include <unordered_set>
#include <unordered_map>
#include <memory>
#include <boost/optional.hpp>

#include "hazelcast/client/address.h"
#include "hazelcast/client/serialization_config.h"
#include "hazelcast/client/socket_interceptor.h"
#include "hazelcast/client/load_balancer.h"
#include "hazelcast/util/SynchronizedMap.h"
#include "hazelcast/client/config/reliable_topic_config.h"
#include "hazelcast/client/config/near_cache_config.h"
#include "hazelcast/client/config/client_network_config.h"
#include "hazelcast/client/config/client_connection_strategy_config.h"
#include "hazelcast/client/config/client_flake_id_generator_config.h"
#include "hazelcast/client/config/matcher/matching_point_config_pattern_matcher.h"
#include "hazelcast/client/internal/config/ConfigUtils.h"
#include "hazelcast/client/config/logger_config.h"
#include "hazelcast/client/serialization/serialization.h"
#include "hazelcast/client/lifecycle_listener.h"
#include "hazelcast/client/membership_listener.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 initial_membership_event;

        namespace connection {
             class ClientConnectionManagerImpl;
        };

        namespace security {
            class HAZELCAST_API credentials {
            public:
                enum credential_type {
                    username_password,
                    token
                };

                credentials(const std::string &name);

                virtual ~credentials();

                const std::string &name() const;

                virtual const credential_type type() const = 0;

            private:
                std::string name_;
            };

            class HAZELCAST_API username_password_credentials : public credentials {
            public:
                username_password_credentials(const std::string &name, const std::string &password);

                const std::string &password() const;

                const credential_type type() const override;

            private:
                std::string password_;
            };

            class HAZELCAST_API token_credentials : public credentials {
            public:
                token_credentials(const std::vector<byte> &token);

                const std::vector<byte> &token() const;

                const credential_type type() const override;

            private:
                std::vector<byte> token_;
            };
        };

        class HAZELCAST_API client_config {
            friend class spi::impl::ClientClusterServiceImpl;
            friend class connection::ClientConnectionManagerImpl;
        public:

            client_config();

            client_config(const client_config &rhs) = delete;

            client_config &operator=(const client_config &rhs) = delete;

            client_config(client_config &&rhs);

            client_config &operator=(client_config &&rhs);

            const std::string &get_cluster_name() const;

            client_config &set_cluster_name(const std::string &cluster_name);

            client_config &set_credentials(const std::shared_ptr<security::credentials> &credential);

            const std::shared_ptr<security::credentials> &get_credentials() const;

            client_config &set_redo_operation(bool redo_operation);

            bool is_redo_operation() const;

            client_config &set_socket_interceptor(socket_interceptor &&interceptor);

            const socket_interceptor &get_socket_interceptor() const;

            client_config &add_listener(lifecycle_listener &&listener);

            const std::vector<lifecycle_listener> &get_lifecycle_listeners() const;

            client_config &add_listener(membership_listener &&listener);

            const std::vector<membership_listener> &get_membership_listeners() const;

            load_balancer &get_load_balancer();

            client_config &set_load_balancer(load_balancer &&load_balancer);

            serialization_config &get_serialization_config();

            client_config &set_serialization_config(serialization_config const &serialization_config);

            const std::unordered_map<std::string, std::string> &get_properties() const;

            client_config &set_property(const std::string &name, const std::string &value);

            client_config &add_reliable_topic_config(const config::reliable_topic_config &reliable_topic_config);

            const config::reliable_topic_config &get_reliable_topic_config(const std::string &name);

            client_config &add_near_cache_config(const config::near_cache_config &near_cache_config);

            const config::near_cache_config *get_near_cache_config(const std::string &name) const;

            config::client_network_config &get_network_config();

            client_config &set_network_config(const config::client_network_config &network_config);

            const boost::optional<std::string> &get_instance_name() const;

            client_config &set_instance_name(const std::string &instance_name);

            int32_t get_executor_pool_size() const;

            void set_executor_pool_size(int32_t executor_pool_size);

            config::client_connection_strategy_config &get_connection_strategy_config();

            client_config &
            set_connection_strategy_config(const config::client_connection_strategy_config &connection_strategy_config);

            const config::client_flake_id_generator_config *find_flake_id_generator_config(const std::string &name);

            const config::client_flake_id_generator_config *get_flake_id_generator_config(const std::string &name);

            client_config &add_flake_id_generator_config(const config::client_flake_id_generator_config &config);

            config::logger_config &get_logger_config();

            const std::unordered_set<std::string> &get_labels() const;

            client_config &set_labels(const std::unordered_set<std::string> &labels);

            client_config &add_label(const std::string &label);

            client_config &backup_acks_enabled(bool enabled);

            bool backup_acks_enabled();

        private:
            std::string cluster_name_;

            config::client_network_config network_config_;

            serialization_config serialization_config_;

            boost::optional<load_balancer> load_balancer_;

            std::vector<membership_listener> membership_listeners_;

            std::vector<lifecycle_listener> lifecycle_listeners_;

            std::unordered_map<std::string, std::string> properties_;

            bool redo_operation_;

            socket_interceptor socket_interceptor_;

            std::shared_ptr<security::credentials> credentials_;

            std::unordered_map<std::string, config::reliable_topic_config> reliable_topic_config_map_;

            std::unordered_map<std::string, config::near_cache_config> near_cache_config_map_;

            boost::optional<std::string> instance_name_;

            int32_t executor_pool_size_;

            config::client_connection_strategy_config connection_strategy_config_;

            std::unordered_map<std::string, config::client_flake_id_generator_config> flake_id_generator_config_map_;

            config::matcher::matching_point_config_pattern_matcher config_pattern_matcher_;

            config::logger_config logger_config_;

            std::unordered_set<std::string> labels_;

            bool backup_acks_enabled_ = true;
        };

    }
}

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