19#ifndef PULSAR_CLIENTCONFIGURATION_H_
20#define PULSAR_CLIENTCONFIGURATION_H_
22#include <pulsar/Authentication.h>
23#include <pulsar/Logger.h>
24#include <pulsar/defines.h>
28struct ClientConfigurationImpl;
338 const std::string& getProxyServiceUrl()
const;
352 ProxyProtocol getProxyProtocol()
const;
359 friend class ClientImpl;
360 friend class PulsarWrapper;
363 const AuthenticationPtr& getAuthPtr()
const;
364 std::shared_ptr<ClientConfigurationImpl> impl_;
400 const std::string& getDescription() const noexcept;
Definition Authentication.h:88
Definition ClientConfiguration.h:29
int getConnectionsPerBroker() const
ClientConfiguration & setStatsIntervalInSeconds(const unsigned int &)
int getInitialBackoffIntervalMs() const
ClientConfiguration & setValidateHostName(bool validateHostName)
bool isTlsAllowInsecureConnection() const
ClientConfiguration & setLogger(LoggerFactory *loggerFactory)
const std::string & getTlsTrustCertsFilePath() const
ClientConfiguration & setAuth(const AuthenticationPtr &authentication)
const std::string & getListenerName() const
Authentication & getAuth() const
ClientConfiguration & setConnectionsPerBroker(int connectionsPerBroker)
const unsigned int & getStatsIntervalInSeconds() const
ClientConfiguration & setMaxBackoffIntervalMs(int maxBackoffIntervalMs)
const std::string & getTlsCertificateFilePath() const
ClientConfiguration & setPartititionsUpdateInterval(unsigned int intervalInSeconds)
ClientConfiguration & setMessageListenerThreads(int threads)
ClientConfiguration & setTlsTrustCertsFilePath(const std::string &tlsTrustCertsFilePath)
ClientConfiguration & setConnectionTimeout(int timeoutMs)
int getMaxBackoffIntervalMs() const
ClientConfiguration & setIOThreads(int threads)
int getOperationTimeoutSeconds() const
ClientConfiguration & setTlsCertificateFilePath(const std::string &tlsCertificateFilePath)
ClientConfiguration & setProxyServiceUrl(const std::string &proxyServiceUrl)
int getMessageListenerThreads() const
const std::string & getTlsPrivateKeyFilePath() const
ClientConfiguration & setTlsPrivateKeyFilePath(const std::string &tlsKeyFilePath)
ClientConfiguration & setConcurrentLookupRequest(int concurrentLookupRequest)
unsigned int getPartitionsUpdateInterval() const
ClientConfiguration & setTlsAllowInsecureConnection(bool allowInsecure)
uint64_t getMemoryLimit() const
int getConcurrentLookupRequest() const
int getConnectionTimeout() const
ClientConfiguration & setMaxLookupRedirects(int maxLookupRedirects)
ClientConfiguration & setOperationTimeoutSeconds(int timeout)
int getMaxLookupRedirects() const
ClientConfiguration & setListenerName(const std::string &listenerName)
ClientConfiguration & setProxyProtocol(ProxyProtocol proxyProtocol)
ClientConfiguration & setMemoryLimit(uint64_t memoryLimitBytes)
ClientConfiguration & setUseTls(bool useTls)
bool isValidateHostName() const
ClientConfiguration & setInitialBackoffIntervalMs(int initialBackoffIntervalMs)
Definition Authentication.h:31