in src/config.cc [124:343]
void export_config(py::module_& m) {
using namespace py;
class_<KeySharedPolicy, std::shared_ptr<KeySharedPolicy>>(m, "KeySharedPolicy")
.def(init<>())
.def("set_key_shared_mode", &KeySharedPolicy::setKeySharedMode, return_value_policy::reference)
.def("get_key_shared_mode", &KeySharedPolicy::getKeySharedMode)
.def("set_allow_out_of_order_delivery", &KeySharedPolicy::setAllowOutOfOrderDelivery, return_value_policy::reference)
.def("is_allow_out_of_order_delivery", &KeySharedPolicy::isAllowOutOfOrderDelivery)
.def("set_sticky_ranges", static_cast<KeySharedPolicy& (KeySharedPolicy::*)(const StickyRanges&)>(&KeySharedPolicy::setStickyRanges), return_value_policy::reference)
.def("get_sticky_ranges", &KeySharedPolicy::getStickyRanges);
class_<CryptoKeyReader, std::shared_ptr<CryptoKeyReader>>(m, "AbstractCryptoKeyReader")
.def("getPublicKey", &CryptoKeyReader::getPublicKey)
.def("getPrivateKey", &CryptoKeyReader::getPrivateKey);
class_<DefaultCryptoKeyReader, CryptoKeyReader, std::shared_ptr<DefaultCryptoKeyReader>>(
m, "CryptoKeyReader")
.def(init<const std::string&, const std::string&>());
class_<ClientConfiguration, std::shared_ptr<ClientConfiguration>>(m, "ClientConfiguration")
.def(init<>())
.def("authentication", &ClientConfiguration::setAuth, return_value_policy::reference)
.def("operation_timeout_seconds", &ClientConfiguration::getOperationTimeoutSeconds)
.def("operation_timeout_seconds", &ClientConfiguration::setOperationTimeoutSeconds,
return_value_policy::reference)
.def("connection_timeout", &ClientConfiguration::getConnectionTimeout)
.def("connection_timeout", &ClientConfiguration::setConnectionTimeout, return_value_policy::reference)
.def("io_threads", &ClientConfiguration::getIOThreads)
.def("io_threads", &ClientConfiguration::setIOThreads, return_value_policy::reference)
.def("message_listener_threads", &ClientConfiguration::getMessageListenerThreads)
.def("message_listener_threads", &ClientConfiguration::setMessageListenerThreads,
return_value_policy::reference)
.def("concurrent_lookup_requests", &ClientConfiguration::getConcurrentLookupRequest)
.def("concurrent_lookup_requests", &ClientConfiguration::setConcurrentLookupRequest,
return_value_policy::reference)
.def("stats_interval_in_seconds", &ClientConfiguration::getStatsIntervalInSeconds)
.def("stats_interval_in_seconds", &ClientConfiguration::setStatsIntervalInSeconds,
return_value_policy::reference)
.def("use_tls", &ClientConfiguration::isUseTls)
.def("use_tls", &ClientConfiguration::setUseTls, return_value_policy::reference)
.def("tls_trust_certs_file_path", &ClientConfiguration::getTlsTrustCertsFilePath,
return_value_policy::copy)
.def("tls_trust_certs_file_path", &ClientConfiguration::setTlsTrustCertsFilePath,
return_value_policy::reference)
.def("tls_private_key_file_path", &ClientConfiguration::getTlsPrivateKeyFilePath,
return_value_policy::copy)
.def("tls_private_key_file_path", &ClientConfiguration::setTlsPrivateKeyFilePath,
return_value_policy::reference)
.def("tls_certificate_file_path", &ClientConfiguration::getTlsCertificateFilePath,
return_value_policy::copy)
.def("tls_certificate_file_path", &ClientConfiguration::setTlsCertificateFilePath,
return_value_policy::reference)
.def("tls_allow_insecure_connection", &ClientConfiguration::isTlsAllowInsecureConnection)
.def("tls_allow_insecure_connection", &ClientConfiguration::setTlsAllowInsecureConnection,
return_value_policy::reference)
.def("tls_validate_hostname", &ClientConfiguration::setValidateHostName,
return_value_policy::reference)
.def("listener_name", &ClientConfiguration::setListenerName, return_value_policy::reference)
.def("set_logger", &ClientConfiguration_setLogger, return_value_policy::reference)
.def("set_console_logger", &ClientConfiguration_setConsoleLogger, return_value_policy::reference)
.def("set_file_logger", &ClientConfiguration_setFileLogger, return_value_policy::reference);
class_<ProducerConfiguration, std::shared_ptr<ProducerConfiguration>>(m, "ProducerConfiguration")
.def(init<>())
.def("producer_name", &ProducerConfiguration::getProducerName, return_value_policy::copy)
.def("producer_name", &ProducerConfiguration::setProducerName, return_value_policy::reference)
.def("schema", &ProducerConfiguration::getSchema, return_value_policy::copy)
.def("schema", &ProducerConfiguration::setSchema, return_value_policy::reference)
.def("send_timeout_millis", &ProducerConfiguration::getSendTimeout)
.def("send_timeout_millis", &ProducerConfiguration::setSendTimeout, return_value_policy::reference)
.def("initial_sequence_id", &ProducerConfiguration::getInitialSequenceId)
.def("initial_sequence_id", &ProducerConfiguration::setInitialSequenceId,
return_value_policy::reference)
.def("compression_type", &ProducerConfiguration::getCompressionType)
.def("compression_type", &ProducerConfiguration::setCompressionType, return_value_policy::reference)
.def("max_pending_messages", &ProducerConfiguration::getMaxPendingMessages)
.def("max_pending_messages", &ProducerConfiguration::setMaxPendingMessages,
return_value_policy::reference)
.def("max_pending_messages_across_partitions",
&ProducerConfiguration::getMaxPendingMessagesAcrossPartitions)
.def("max_pending_messages_across_partitions",
&ProducerConfiguration::setMaxPendingMessagesAcrossPartitions, return_value_policy::reference)
.def("block_if_queue_full", &ProducerConfiguration::getBlockIfQueueFull)
.def("block_if_queue_full", &ProducerConfiguration::setBlockIfQueueFull,
return_value_policy::reference)
.def("partitions_routing_mode", &ProducerConfiguration::getPartitionsRoutingMode)
.def("partitions_routing_mode", &ProducerConfiguration::setPartitionsRoutingMode,
return_value_policy::reference)
.def("lazy_start_partitioned_producers", &ProducerConfiguration::getLazyStartPartitionedProducers)
.def("lazy_start_partitioned_producers", &ProducerConfiguration::setLazyStartPartitionedProducers,
return_value_policy::reference)
.def("batching_enabled", &ProducerConfiguration::getBatchingEnabled, return_value_policy::copy)
.def("batching_enabled", &ProducerConfiguration::setBatchingEnabled, return_value_policy::reference)
.def("batching_max_messages", &ProducerConfiguration::getBatchingMaxMessages,
return_value_policy::copy)
.def("batching_max_messages", &ProducerConfiguration::setBatchingMaxMessages,
return_value_policy::reference)
.def("batching_max_allowed_size_in_bytes", &ProducerConfiguration::getBatchingMaxAllowedSizeInBytes,
return_value_policy::copy)
.def("batching_max_allowed_size_in_bytes", &ProducerConfiguration::setBatchingMaxAllowedSizeInBytes,
return_value_policy::reference)
.def("batching_max_publish_delay_ms", &ProducerConfiguration::getBatchingMaxPublishDelayMs,
return_value_policy::copy)
.def("batching_max_publish_delay_ms", &ProducerConfiguration::setBatchingMaxPublishDelayMs,
return_value_policy::reference)
.def("chunking_enabled", &ProducerConfiguration::isChunkingEnabled)
.def("chunking_enabled", &ProducerConfiguration::setChunkingEnabled, return_value_policy::reference)
.def("property", &ProducerConfiguration::setProperty, return_value_policy::reference)
.def("batching_type", &ProducerConfiguration::setBatchingType, return_value_policy::reference)
.def("batching_type", &ProducerConfiguration::getBatchingType)
.def("encryption_key", &ProducerConfiguration::addEncryptionKey, return_value_policy::reference)
.def("crypto_key_reader", &ProducerConfiguration::setCryptoKeyReader, return_value_policy::reference)
.def("access_mode", &ProducerConfiguration::setAccessMode, return_value_policy::reference)
.def("access_mode", &ProducerConfiguration::getAccessMode, return_value_policy::copy);
class_<BatchReceivePolicy>(m, "BatchReceivePolicy")
.def(init<int, int, long>())
.def("getTimeoutMs", &BatchReceivePolicy::getTimeoutMs)
.def("getMaxNumMessages", &BatchReceivePolicy::getMaxNumMessages)
.def("getMaxNumBytes", &BatchReceivePolicy::getMaxNumBytes);
class_<DeadLetterPolicy>(m, "DeadLetterPolicy")
.def(init<>())
.def("getDeadLetterTopic", &DeadLetterPolicy::getDeadLetterTopic)
.def("getMaxRedeliverCount", &DeadLetterPolicy::getMaxRedeliverCount)
.def("getInitialSubscriptionName", &DeadLetterPolicy::getInitialSubscriptionName);
class_<DeadLetterPolicyBuilder>(m, "DeadLetterPolicyBuilder")
.def(init<>())
.def("deadLetterTopic", &DeadLetterPolicyBuilder::deadLetterTopic, return_value_policy::reference)
.def("maxRedeliverCount", &DeadLetterPolicyBuilder::maxRedeliverCount, return_value_policy::reference)
.def("initialSubscriptionName", &DeadLetterPolicyBuilder::initialSubscriptionName, return_value_policy::reference)
.def("build", &DeadLetterPolicyBuilder::build, return_value_policy::reference)
.def("build", &DeadLetterPolicyBuilder::build, return_value_policy::reference);
class_<ConsumerConfiguration, std::shared_ptr<ConsumerConfiguration>>(m, "ConsumerConfiguration")
.def(init<>())
.def("key_shared_policy", &ConsumerConfiguration::getKeySharedPolicy)
.def("key_shared_policy", &ConsumerConfiguration::setKeySharedPolicy, return_value_policy::reference)
.def("consumer_type", &ConsumerConfiguration::getConsumerType)
.def("consumer_type", &ConsumerConfiguration::setConsumerType, return_value_policy::reference)
.def("schema", &ConsumerConfiguration::getSchema, return_value_policy::copy)
.def("schema", &ConsumerConfiguration::setSchema, return_value_policy::reference)
.def("message_listener", &ConsumerConfiguration::setMessageListener, return_value_policy::reference)
.def("receiver_queue_size", &ConsumerConfiguration::getReceiverQueueSize)
.def("receiver_queue_size", &ConsumerConfiguration::setReceiverQueueSize)
.def("max_total_receiver_queue_size_across_partitions",
&ConsumerConfiguration::getMaxTotalReceiverQueueSizeAcrossPartitions)
.def("max_total_receiver_queue_size_across_partitions",
&ConsumerConfiguration::setMaxTotalReceiverQueueSizeAcrossPartitions)
.def("batch_receive_policy", &ConsumerConfiguration::getBatchReceivePolicy, return_value_policy::copy)
.def("batch_receive_policy", &ConsumerConfiguration::setBatchReceivePolicy)
.def("consumer_name", &ConsumerConfiguration::getConsumerName, return_value_policy::copy)
.def("consumer_name", &ConsumerConfiguration::setConsumerName)
.def("unacked_messages_timeout_ms", &ConsumerConfiguration::getUnAckedMessagesTimeoutMs)
.def("unacked_messages_timeout_ms", &ConsumerConfiguration::setUnAckedMessagesTimeoutMs)
.def("negative_ack_redelivery_delay_ms", &ConsumerConfiguration::getNegativeAckRedeliveryDelayMs)
.def("negative_ack_redelivery_delay_ms", &ConsumerConfiguration::setNegativeAckRedeliveryDelayMs)
.def("broker_consumer_stats_cache_time_ms",
&ConsumerConfiguration::getBrokerConsumerStatsCacheTimeInMs)
.def("broker_consumer_stats_cache_time_ms",
&ConsumerConfiguration::setBrokerConsumerStatsCacheTimeInMs)
.def("pattern_auto_discovery_period", &ConsumerConfiguration::getPatternAutoDiscoveryPeriod)
.def("pattern_auto_discovery_period", &ConsumerConfiguration::setPatternAutoDiscoveryPeriod)
.def("read_compacted", &ConsumerConfiguration::isReadCompacted)
.def("read_compacted", &ConsumerConfiguration::setReadCompacted)
.def("property", &ConsumerConfiguration::setProperty, return_value_policy::reference)
.def("subscription_initial_position", &ConsumerConfiguration::getSubscriptionInitialPosition)
.def("subscription_initial_position", &ConsumerConfiguration::setSubscriptionInitialPosition)
.def("regex_subscription_mode", &ConsumerConfiguration::setRegexSubscriptionMode)
.def("regex_subscription_mode", &ConsumerConfiguration::getRegexSubscriptionMode, return_value_policy::reference)
.def("crypto_key_reader", &ConsumerConfiguration::setCryptoKeyReader, return_value_policy::reference)
.def("replicate_subscription_state_enabled",
&ConsumerConfiguration::setReplicateSubscriptionStateEnabled)
.def("replicate_subscription_state_enabled",
&ConsumerConfiguration::isReplicateSubscriptionStateEnabled)
.def("max_pending_chunked_message", &ConsumerConfiguration::getMaxPendingChunkedMessage)
.def("max_pending_chunked_message", &ConsumerConfiguration::setMaxPendingChunkedMessage,
return_value_policy::reference)
.def("auto_ack_oldest_chunked_message_on_queue_full",
&ConsumerConfiguration::isAutoAckOldestChunkedMessageOnQueueFull)
.def("auto_ack_oldest_chunked_message_on_queue_full",
&ConsumerConfiguration::setAutoAckOldestChunkedMessageOnQueueFull,
return_value_policy::reference)
.def("start_message_id_inclusive", &ConsumerConfiguration::isStartMessageIdInclusive)
.def("start_message_id_inclusive", &ConsumerConfiguration::setStartMessageIdInclusive,
return_value_policy::reference)
.def("batch_index_ack_enabled", &ConsumerConfiguration::isBatchIndexAckEnabled)
.def("batch_index_ack_enabled", &ConsumerConfiguration::setBatchIndexAckEnabled,
return_value_policy::reference)
.def("dead_letter_policy", &ConsumerConfiguration::setDeadLetterPolicy)
.def("dead_letter_policy", &ConsumerConfiguration::getDeadLetterPolicy, return_value_policy::copy)
.def("crypto_failure_action", &ConsumerConfiguration::getCryptoFailureAction,
return_value_policy::copy)
.def("crypto_failure_action", &ConsumerConfiguration::setCryptoFailureAction,
return_value_policy::reference);
class_<ReaderConfiguration, std::shared_ptr<ReaderConfiguration>>(m, "ReaderConfiguration")
.def(init<>())
.def("reader_listener", &ReaderConfiguration::setReaderListener, return_value_policy::reference)
.def("schema", &ReaderConfiguration::getSchema, return_value_policy::copy)
.def("schema", &ReaderConfiguration::setSchema, return_value_policy::reference)
.def("receiver_queue_size", &ReaderConfiguration::getReceiverQueueSize)
.def("receiver_queue_size", &ReaderConfiguration::setReceiverQueueSize)
.def("reader_name", &ReaderConfiguration::getReaderName, return_value_policy::copy)
.def("reader_name", &ReaderConfiguration::setReaderName)
.def("subscription_role_prefix", &ReaderConfiguration::getSubscriptionRolePrefix,
return_value_policy::copy)
.def("subscription_role_prefix", &ReaderConfiguration::setSubscriptionRolePrefix)
.def("read_compacted", &ReaderConfiguration::isReadCompacted)
.def("read_compacted", &ReaderConfiguration::setReadCompacted)
.def("crypto_key_reader", &ReaderConfiguration::setCryptoKeyReader, return_value_policy::reference)
.def("start_message_id_inclusive", &ReaderConfiguration::isStartMessageIdInclusive)
.def("start_message_id_inclusive", &ReaderConfiguration::setStartMessageIdInclusive, return_value_policy::reference)
.def("crypto_failure_action", &ReaderConfiguration::getCryptoFailureAction,
return_value_policy::copy)
.def("crypto_failure_action", &ReaderConfiguration::setCryptoFailureAction,
return_value_policy::reference);
}