ClientProperties.h

/*
 * Copyright (c) 2008-2019, 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.
 */
//
// Created by sancar koyunlu on 21/08/14.
//

#ifndef HAZELCAST_ClientProperties
#define HAZELCAST_ClientProperties

#include <string>

#include "hazelcast/util/HazelcastDll.h"
#include "hazelcast/util/IOUtil.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 ClientConfig;

        class HAZELCAST_API ClientProperty {
        public:
            ClientProperty(const std::string &name, const std::string &defaultValue);

            const std::string &getName() const;

            const std::string &getDefaultValue() const;

            const char *getSystemProperty() const;

        private:
            std::string name;
            std::string defaultValue;
        };


        class HAZELCAST_API ClientProperties {
        public:
            ClientProperties(const std::map<std::string, std::string> &properties);

            const ClientProperty& getHeartbeatTimeout() const;

            const ClientProperty& getHeartbeatInterval() const;

            const ClientProperty& getAwsMemberPort() const;

            const ClientProperty &getCleanResourcesPeriodMillis() const;

            const ClientProperty &getInvocationRetryPauseMillis() const;

            const ClientProperty &getInvocationTimeoutSeconds() const;

            const ClientProperty &getEventThreadCount() const;

            const ClientProperty &getEventQueueCapacity() const;

            const ClientProperty &getInternalExecutorPoolSize() const;

            const ClientProperty &getShuffleMemberList() const;

            const ClientProperty &getMaxConcurrentInvocations() const;

            const ClientProperty &getBackpressureBackoffTimeoutMillis() const;

            const ClientProperty &getStatisticsEnabled() const;

            const ClientProperty &getStatisticsPeriodSeconds() const;

            static const std::string PROP_HEARTBEAT_TIMEOUT;
            static const std::string PROP_HEARTBEAT_TIMEOUT_DEFAULT;

            static const std::string PROP_HEARTBEAT_INTERVAL;
            static const std::string PROP_HEARTBEAT_INTERVAL_DEFAULT;

            static const std::string PROP_REQUEST_RETRY_COUNT;
            static const std::string PROP_REQUEST_RETRY_COUNT_DEFAULT;

            static const std::string PROP_REQUEST_RETRY_WAIT_TIME;
            static const std::string PROP_REQUEST_RETRY_WAIT_TIME_DEFAULT;

            static const std::string PROP_AWS_MEMBER_PORT;
            static const std::string PROP_AWS_MEMBER_PORT_DEFAULT;

            static const std::string CLEAN_RESOURCES_PERIOD_MILLIS;
            static const std::string CLEAN_RESOURCES_PERIOD_MILLIS_DEFAULT;

            static const std::string INVOCATION_RETRY_PAUSE_MILLIS;
            static const std::string INVOCATION_RETRY_PAUSE_MILLIS_DEFAULT;

            static const std::string INVOCATION_TIMEOUT_SECONDS;
            static const std::string INVOCATION_TIMEOUT_SECONDS_DEFAULT;

            static const std::string EVENT_THREAD_COUNT;
            static const std::string EVENT_THREAD_COUNT_DEFAULT;

            static const std::string EVENT_QUEUE_CAPACITY;
            static const std::string EVENT_QUEUE_CAPACITY_DEFAULT;

            static const std::string INTERNAL_EXECUTOR_POOL_SIZE;
            static const std::string INTERNAL_EXECUTOR_POOL_SIZE_DEFAULT;

            static const std::string SHUFFLE_MEMBER_LIST;
            static const std::string SHUFFLE_MEMBER_LIST_DEFAULT;

            static const std::string MAX_CONCURRENT_INVOCATIONS;
            static const std::string MAX_CONCURRENT_INVOCATIONS_DEFAULT;

            static const std::string BACKPRESSURE_BACKOFF_TIMEOUT_MILLIS;
            static const std::string BACKPRESSURE_BACKOFF_TIMEOUT_MILLIS_DEFAULT;

            static const std::string STATISTICS_ENABLED;
            static const std::string STATISTICS_ENABLED_DEFAULT;

            static const std::string STATISTICS_PERIOD_SECONDS;
            static const std::string STATISTICS_PERIOD_SECONDS_DEFAULT;

            bool getBoolean(const ClientProperty &property) const;

            int32_t getInteger(const ClientProperty &property) const;

            int64_t getLong(const ClientProperty &property) const;

            std::string getString(const ClientProperty &property) const;

        private:
            ClientProperty heartbeatTimeout;
            ClientProperty heartbeatInterval;
            ClientProperty retryCount;
            ClientProperty retryWaitTime;
            ClientProperty awsMemberPort;
            ClientProperty cleanResourcesPeriod;
            ClientProperty invocationRetryPauseMillis;
            ClientProperty invocationTimeoutSeconds;
            ClientProperty eventThreadCount;
            ClientProperty eventQueueCapacity;
            ClientProperty internalExecutorPoolSize;
            ClientProperty shuffleMemberList;
            ClientProperty maxConcurrentInvocations;
            ClientProperty backpressureBackoffTimeoutMillis;
            ClientProperty statisticsEnabled;
            ClientProperty statisticsPeriodSeconds;

            std::map<std::string, std::string> propertiesMap;
        };

    }
}

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

#endif //HAZELCAST_ClientProperties