[−] List of all items
Structs
- _pulsar_authentication
- _pulsar_client
- _pulsar_client_configuration
- _pulsar_consumer
- _pulsar_consumer_configuration
- _pulsar_message
- _pulsar_message_id
- _pulsar_producer
- _pulsar_producer_configuration
- _pulsar_reader
- _pulsar_reader_configuration
- _pulsar_string_list
- _pulsar_string_map
- _pulsar_topic_metadata
Functions
- pulsar_authentication_athenz_create
- pulsar_authentication_create
- pulsar_authentication_free
- pulsar_authentication_oauth2_create
- pulsar_authentication_tls_create
- pulsar_authentication_token_create
- pulsar_authentication_token_create_with_supplier
- pulsar_client_close
- pulsar_client_close_async
- pulsar_client_configuration_create
- pulsar_client_configuration_free
- pulsar_client_configuration_get_concurrent_lookup_request
- pulsar_client_configuration_get_io_threads
- pulsar_client_configuration_get_message_listener_threads
- pulsar_client_configuration_get_operation_timeout_seconds
- pulsar_client_configuration_get_stats_interval_in_seconds
- pulsar_client_configuration_get_tls_trust_certs_file_path
- pulsar_client_configuration_is_tls_allow_insecure_connection
- pulsar_client_configuration_is_use_tls
- pulsar_client_configuration_is_validate_hostname
- pulsar_client_configuration_set_auth
- pulsar_client_configuration_set_concurrent_lookup_request
- pulsar_client_configuration_set_io_threads
- pulsar_client_configuration_set_logger
- pulsar_client_configuration_set_message_listener_threads
- pulsar_client_configuration_set_operation_timeout_seconds
- pulsar_client_configuration_set_stats_interval_in_seconds
- pulsar_client_configuration_set_tls_allow_insecure_connection
- pulsar_client_configuration_set_tls_trust_certs_file_path
- pulsar_client_configuration_set_use_tls
- pulsar_client_configuration_set_validate_hostname
- pulsar_client_create
- pulsar_client_create_producer
- pulsar_client_create_producer_async
- pulsar_client_create_reader
- pulsar_client_create_reader_async
- pulsar_client_free
- pulsar_client_get_topic_partitions
- pulsar_client_get_topic_partitions_async
- pulsar_client_subscribe
- pulsar_client_subscribe_async
- pulsar_client_subscribe_multi_topics_async
- pulsar_client_subscribe_pattern_async
- pulsar_configure_get_ack_grouping_max_size
- pulsar_configure_get_ack_grouping_time_ms
- pulsar_configure_get_negative_ack_redelivery_delay_ms
- pulsar_configure_set_ack_grouping_max_size
- pulsar_configure_set_ack_grouping_time_ms
- pulsar_configure_set_negative_ack_redelivery_delay_ms
- pulsar_consumer_acknowledge
- pulsar_consumer_acknowledge_async
- pulsar_consumer_acknowledge_async_id
- pulsar_consumer_acknowledge_cumulative
- pulsar_consumer_acknowledge_cumulative_async
- pulsar_consumer_acknowledge_cumulative_async_id
- pulsar_consumer_acknowledge_cumulative_id
- pulsar_consumer_acknowledge_id
- pulsar_consumer_close
- pulsar_consumer_close_async
- pulsar_consumer_configuration_create
- pulsar_consumer_configuration_free
- pulsar_consumer_configuration_get_consumer_type
- pulsar_consumer_configuration_get_receiver_queue_size
- pulsar_consumer_configuration_has_message_listener
- pulsar_consumer_configuration_set_consumer_type
- pulsar_consumer_configuration_set_message_listener
- pulsar_consumer_configuration_set_property
- pulsar_consumer_configuration_set_receiver_queue_size
- pulsar_consumer_configuration_set_schema_info
- pulsar_consumer_free
- pulsar_consumer_get_consumer_name
- pulsar_consumer_get_max_total_receiver_queue_size_across_partitions
- pulsar_consumer_get_subscription_initial_position
- pulsar_consumer_get_subscription_name
- pulsar_consumer_get_topic
- pulsar_consumer_get_unacked_messages_timeout_ms
- pulsar_consumer_is_encryption_enabled
- pulsar_consumer_is_read_compacted
- pulsar_consumer_negative_acknowledge
- pulsar_consumer_negative_acknowledge_id
- pulsar_consumer_pause_message_listener
- pulsar_consumer_receive
- pulsar_consumer_receive_with_timeout
- pulsar_consumer_redeliver_unacknowledged_messages
- pulsar_consumer_seek
- pulsar_consumer_seek_async
- pulsar_consumer_set_consumer_name
- pulsar_consumer_set_max_total_receiver_queue_size_across_partitions
- pulsar_consumer_set_read_compacted
- pulsar_consumer_set_subscription_initial_position
- pulsar_consumer_set_unacked_messages_timeout_ms
- pulsar_consumer_unsubscribe
- pulsar_consumer_unsubscribe_async
- pulsar_message_create
- pulsar_message_disable_replication
- pulsar_message_free
- pulsar_message_get_data
- pulsar_message_get_event_timestamp
- pulsar_message_get_length
- pulsar_message_get_message_id
- pulsar_message_get_orderingKey
- pulsar_message_get_partitionKey
- pulsar_message_get_properties
- pulsar_message_get_property
- pulsar_message_get_publish_timestamp
- pulsar_message_get_redelivery_count
- pulsar_message_get_schemaVersion
- pulsar_message_get_topic_name
- pulsar_message_has_ordering_key
- pulsar_message_has_partition_key
- pulsar_message_has_property
- pulsar_message_has_schema_version
- pulsar_message_id_deserialize
- pulsar_message_id_earliest
- pulsar_message_id_free
- pulsar_message_id_latest
- pulsar_message_id_serialize
- pulsar_message_id_str
- pulsar_message_set_allocated_content
- pulsar_message_set_content
- pulsar_message_set_deliver_after
- pulsar_message_set_deliver_at
- pulsar_message_set_event_timestamp
- pulsar_message_set_ordering_key
- pulsar_message_set_partition_key
- pulsar_message_set_property
- pulsar_message_set_replication_clusters
- pulsar_message_set_schema_version
- pulsar_message_set_sequence_id
- pulsar_producer_close
- pulsar_producer_close_async
- pulsar_producer_configuration_create
- pulsar_producer_configuration_free
- pulsar_producer_configuration_get_batching_enabled
- pulsar_producer_configuration_get_batching_max_allowed_size_in_bytes
- pulsar_producer_configuration_get_batching_max_messages
- pulsar_producer_configuration_get_batching_max_publish_delay_ms
- pulsar_producer_configuration_get_block_if_queue_full
- pulsar_producer_configuration_get_compression_type
- pulsar_producer_configuration_get_hashing_scheme
- pulsar_producer_configuration_get_initial_sequence_id
- pulsar_producer_configuration_get_max_pending_messages
- pulsar_producer_configuration_get_max_pending_messages_across_partitions
- pulsar_producer_configuration_get_partitions_routing_mode
- pulsar_producer_configuration_get_producer_name
- pulsar_producer_configuration_get_send_timeout
- pulsar_producer_configuration_set_batching_enabled
- pulsar_producer_configuration_set_batching_max_allowed_size_in_bytes
- pulsar_producer_configuration_set_batching_max_messages
- pulsar_producer_configuration_set_batching_max_publish_delay_ms
- pulsar_producer_configuration_set_block_if_queue_full
- pulsar_producer_configuration_set_compression_type
- pulsar_producer_configuration_set_hashing_scheme
- pulsar_producer_configuration_set_initial_sequence_id
- pulsar_producer_configuration_set_max_pending_messages
- pulsar_producer_configuration_set_max_pending_messages_across_partitions
- pulsar_producer_configuration_set_message_router
- pulsar_producer_configuration_set_partitions_routing_mode
- pulsar_producer_configuration_set_producer_name
- pulsar_producer_configuration_set_property
- pulsar_producer_configuration_set_schema_info
- pulsar_producer_configuration_set_send_timeout
- pulsar_producer_flush
- pulsar_producer_flush_async
- pulsar_producer_free
- pulsar_producer_get_last_sequence_id
- pulsar_producer_get_producer_name
- pulsar_producer_get_topic
- pulsar_producer_send
- pulsar_producer_send_async
- pulsar_reader_close
- pulsar_reader_close_async
- pulsar_reader_configuration_create
- pulsar_reader_configuration_free
- pulsar_reader_configuration_get_reader_name
- pulsar_reader_configuration_get_receiver_queue_size
- pulsar_reader_configuration_get_subscription_role_prefix
- pulsar_reader_configuration_has_reader_listener
- pulsar_reader_configuration_is_read_compacted
- pulsar_reader_configuration_set_read_compacted
- pulsar_reader_configuration_set_reader_listener
- pulsar_reader_configuration_set_reader_name
- pulsar_reader_configuration_set_receiver_queue_size
- pulsar_reader_configuration_set_subscription_role_prefix
- pulsar_reader_free
- pulsar_reader_get_topic
- pulsar_reader_has_message_available
- pulsar_reader_read_next
- pulsar_reader_read_next_with_timeout
- pulsar_result_str
- pulsar_string_list_append
- pulsar_string_list_create
- pulsar_string_list_free
- pulsar_string_list_get
- pulsar_string_list_size
- pulsar_string_map_create
- pulsar_string_map_free
- pulsar_string_map_get
- pulsar_string_map_get_key
- pulsar_string_map_get_value
- pulsar_string_map_put
- pulsar_string_map_size
- pulsar_topic_metadata_get_num_partitions
- resume_message_listener
Typedefs
- initial_position
- int_fast16_t
- int_fast32_t
- int_fast64_t
- int_fast8_t
- int_least16_t
- int_least32_t
- int_least64_t
- int_least8_t
- intmax_t
- max_align_t
- pulsar_authentication_t
- pulsar_client_configuration_t
- pulsar_client_t
- pulsar_close_callback
- pulsar_compression_type
- pulsar_consumer_configuration_t
- pulsar_consumer_t
- pulsar_consumer_type
- pulsar_create_producer_callback
- pulsar_flush_callback
- pulsar_get_partitions_callback
- pulsar_hashing_scheme
- pulsar_logger
- pulsar_logger_level_t
- pulsar_message_id_t
- pulsar_message_listener
- pulsar_message_router
- pulsar_message_t
- pulsar_partitions_routing_mode
- pulsar_producer_configuration_t
- pulsar_producer_t
- pulsar_reader_callback
- pulsar_reader_configuration_t
- pulsar_reader_listener
- pulsar_reader_t
- pulsar_result
- pulsar_result_callback
- pulsar_schema_type
- pulsar_send_callback
- pulsar_string_list_t
- pulsar_string_map_t
- pulsar_subscribe_callback
- pulsar_topic_metadata_t
- size_t
- token_supplier
- uint_fast16_t
- uint_fast32_t
- uint_fast64_t
- uint_fast8_t
- uint_least16_t
- uint_least32_t
- uint_least64_t
- uint_least8_t
- uintmax_t
- wchar_t
Constants
- initial_position_initial_position_earliest
- initial_position_initial_position_latest
- pulsar_compression_type_pulsar_CompressionLZ4
- pulsar_compression_type_pulsar_CompressionNone
- pulsar_compression_type_pulsar_CompressionSNAPPY
- pulsar_compression_type_pulsar_CompressionZLib
- pulsar_compression_type_pulsar_CompressionZSTD
- pulsar_consumer_type_pulsar_ConsumerExclusive
- pulsar_consumer_type_pulsar_ConsumerFailover
- pulsar_consumer_type_pulsar_ConsumerKeyShared
- pulsar_consumer_type_pulsar_ConsumerShared
- pulsar_hashing_scheme_pulsar_BoostHash
- pulsar_hashing_scheme_pulsar_JavaStringHash
- pulsar_hashing_scheme_pulsar_Murmur3_32Hash
- pulsar_logger_level_t_pulsar_DEBUG
- pulsar_logger_level_t_pulsar_ERROR
- pulsar_logger_level_t_pulsar_INFO
- pulsar_logger_level_t_pulsar_WARN
- pulsar_partitions_routing_mode_pulsar_CustomPartition
- pulsar_partitions_routing_mode_pulsar_RoundRobinDistribution
- pulsar_partitions_routing_mode_pulsar_UseSinglePartition
- pulsar_result_pulsar_result_AlreadyClosed
- pulsar_result_pulsar_result_AuthenticationError
- pulsar_result_pulsar_result_AuthorizationError
- pulsar_result_pulsar_result_BrokerMetadataError
- pulsar_result_pulsar_result_BrokerPersistenceError
- pulsar_result_pulsar_result_ChecksumError
- pulsar_result_pulsar_result_ConnectError
- pulsar_result_pulsar_result_ConsumerBusy
- pulsar_result_pulsar_result_ConsumerNotFound
- pulsar_result_pulsar_result_ConsumerNotInitialized
- pulsar_result_pulsar_result_CryptoError
- pulsar_result_pulsar_result_ErrorGettingAuthenticationData
- pulsar_result_pulsar_result_InvalidConfiguration
- pulsar_result_pulsar_result_InvalidMessage
- pulsar_result_pulsar_result_InvalidTopicName
- pulsar_result_pulsar_result_InvalidUrl
- pulsar_result_pulsar_result_LookupError
- pulsar_result_pulsar_result_MessageTooBig
- pulsar_result_pulsar_result_NotConnected
- pulsar_result_pulsar_result_Ok
- pulsar_result_pulsar_result_OperationNotSupported
- pulsar_result_pulsar_result_ProducerBlockedQuotaExceededError
- pulsar_result_pulsar_result_ProducerBlockedQuotaExceededException
- pulsar_result_pulsar_result_ProducerNotInitialized
- pulsar_result_pulsar_result_ProducerQueueIsFull
- pulsar_result_pulsar_result_ReadError
- pulsar_result_pulsar_result_ServiceUnitNotReady
- pulsar_result_pulsar_result_SubscriptionNotFound
- pulsar_result_pulsar_result_Timeout
- pulsar_result_pulsar_result_TooManyLookupRequestException
- pulsar_result_pulsar_result_TopicNotFound
- pulsar_result_pulsar_result_TopicTerminated
- pulsar_result_pulsar_result_UnknownError
- pulsar_result_pulsar_result_UnsupportedVersionError
- pulsar_schema_type_pulsar_AutoConsume
- pulsar_schema_type_pulsar_AutoPublish
- pulsar_schema_type_pulsar_Avro
- pulsar_schema_type_pulsar_Boolean
- pulsar_schema_type_pulsar_Bytes
- pulsar_schema_type_pulsar_Float32
- pulsar_schema_type_pulsar_Float64
- pulsar_schema_type_pulsar_Int16
- pulsar_schema_type_pulsar_Int32
- pulsar_schema_type_pulsar_Int64
- pulsar_schema_type_pulsar_Int8
- pulsar_schema_type_pulsar_Json
- pulsar_schema_type_pulsar_KeyValue
- pulsar_schema_type_pulsar_None
- pulsar_schema_type_pulsar_Protobuf
- pulsar_schema_type_pulsar_String