| <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "https://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> |
| <html xmlns="http://www.w3.org/1999/xhtml" lang="en-US"> |
| <head> |
| <meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/> |
| <meta http-equiv="X-UA-Compatible" content="IE=11"/> |
| <meta name="generator" content="Doxygen 1.9.7"/> |
| <meta name="viewport" content="width=device-width, initial-scale=1"/> |
| <title>pulsar-client-cpp: pulsar Namespace Reference</title> |
| <link href="tabs.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="jquery.js"></script> |
| <script type="text/javascript" src="dynsections.js"></script> |
| <link href="search/search.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="search/searchdata.js"></script> |
| <script type="text/javascript" src="search/search.js"></script> |
| <script type="text/javascript" src="darkmode_toggle.js"></script> |
| <link href="doxygen.css" rel="stylesheet" type="text/css" /> |
| </head> |
| <body> |
| <div id="top"><!-- do not remove this div, it is closed by doxygen! --> |
| <div id="titlearea"> |
| <table cellspacing="0" cellpadding="0"> |
| <tbody> |
| <tr id="projectrow"> |
| <td id="projectalign"> |
| <div id="projectname">pulsar-client-cpp |
| </div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </div> |
| <!-- end header part --> |
| <!-- Generated by Doxygen 1.9.7 --> |
| <script type="text/javascript"> |
| /* @license magnet:?xt=urn:btih:d3d9a9a6595521f9666a5e94cc830dab83b65699&dn=expat.txt MIT */ |
| var searchBox = new SearchBox("searchBox", "search/",'.html'); |
| /* @license-end */ |
| </script> |
| <script type="text/javascript" src="menudata.js"></script> |
| <script type="text/javascript" src="menu.js"></script> |
| <script type="text/javascript"> |
| /* @license magnet:?xt=urn:btih:d3d9a9a6595521f9666a5e94cc830dab83b65699&dn=expat.txt MIT */ |
| $(function() { |
| initMenu('',true,false,'search.php','Search'); |
| $(document).ready(function() { init_search(); }); |
| }); |
| /* @license-end */ |
| </script> |
| <div id="main-nav"></div> |
| <!-- window showing the filter options --> |
| <div id="MSearchSelectWindow" |
| onmouseover="return searchBox.OnSearchSelectShow()" |
| onmouseout="return searchBox.OnSearchSelectHide()" |
| onkeydown="return searchBox.OnSearchSelectKey(event)"> |
| </div> |
| |
| <!-- iframe showing the search results (closed by default) --> |
| <div id="MSearchResultsWindow"> |
| <div id="MSearchResults"> |
| <div class="SRPage"> |
| <div id="SRIndex"> |
| <div id="SRResults"></div> |
| <div class="SRStatus" id="Loading">Loading...</div> |
| <div class="SRStatus" id="Searching">Searching...</div> |
| <div class="SRStatus" id="NoMatches">No Matches</div> |
| </div> |
| </div> |
| </div> |
| </div> |
| |
| </div><!-- top --> |
| <div class="header"> |
| <div class="summary"> |
| <a href="#nested-classes">Classes</a> | |
| <a href="#typedef-members">Typedefs</a> | |
| <a href="#enum-members">Enumerations</a> | |
| <a href="#func-members">Functions</a> </div> |
| <div class="headertitle"><div class="title">pulsar Namespace Reference</div></div> |
| </div><!--header--> |
| <div class="contents"> |
| <table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a id="nested-classes" name="nested-classes"></a> |
| Classes</h2></td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_auth_athenz.html">AuthAthenz</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_auth_basic.html">AuthBasic</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_authentication.html">Authentication</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_authentication_data_provider.html">AuthenticationDataProvider</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_auth_factory.html">AuthFactory</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_auth_oauth2.html">AuthOauth2</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_auth_tls.html">AuthTls</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_auth_token.html">AuthToken</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_batch_receive_policy.html">BatchReceivePolicy</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_broker_consumer_stats.html">BrokerConsumerStats</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_cached_token.html">CachedToken</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client.html">Client</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_client_configuration.html">ClientConfiguration</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_console_logger_factory.html">ConsoleLoggerFactory</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_consumer.html">Consumer</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_consumer_configuration.html">ConsumerConfiguration</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_consumer_event_listener.html">ConsumerEventListener</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_consumer_interceptor.html">ConsumerInterceptor</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_crypto_key_reader.html">CryptoKeyReader</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_dead_letter_policy.html">DeadLetterPolicy</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_dead_letter_policy_builder.html">DeadLetterPolicyBuilder</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_default_crypto_key_reader.html">DefaultCryptoKeyReader</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_deprecated_exception.html">DeprecatedException</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_encryption_key_info.html">EncryptionKeyInfo</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_file_logger_factory.html">FileLoggerFactory</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_key_shared_policy.html">KeySharedPolicy</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_key_value.html">KeyValue</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_logger.html">Logger</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_logger_factory.html">LoggerFactory</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_message.html">Message</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_message_batch.html">MessageBatch</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_message_builder.html">MessageBuilder</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_message_id.html">MessageId</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_message_id_builder.html">MessageIdBuilder</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_message_routing_policy.html">MessageRoutingPolicy</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_oauth2_flow.html">Oauth2Flow</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_oauth2_token_result.html">Oauth2TokenResult</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_producer.html">Producer</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_producer_configuration.html">ProducerConfiguration</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_producer_interceptor.html">ProducerInterceptor</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_reader.html">Reader</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_reader_configuration.html">ReaderConfiguration</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_schema_info.html">SchemaInfo</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_table_view.html">TableView</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">struct  </td><td class="memItemRight" valign="bottom"><a class="el" href="structpulsar_1_1_table_view_configuration.html">TableViewConfiguration</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_topic_metadata.html">TopicMetadata</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_typed_message.html">TypedMessage</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_typed_message_builder.html">TypedMessageBuilder</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classpulsar_1_1_typed_message_builder_3_01std_1_1string_01_4.html">TypedMessageBuilder< std::string ></a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a id="typedef-members" name="typedef-members"></a> |
| Typedefs</h2></td></tr> |
| <tr class="memitem:ae4a704c6eebf25ef78adc99e66306119"><td class="memItemLeft" align="right" valign="top"><a id="ae4a704c6eebf25ef78adc99e66306119" name="ae4a704c6eebf25ef78adc99e66306119"></a> |
| typedef std::shared_ptr< <a class="el" href="classpulsar_1_1_authentication_data_provider.html">AuthenticationDataProvider</a> > </td><td class="memItemRight" valign="bottom"><b>AuthenticationDataPtr</b></td></tr> |
| <tr class="separator:ae4a704c6eebf25ef78adc99e66306119"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a58eee70a65197b2cdbfd98c6fa6d6153"><td class="memItemLeft" align="right" valign="top"><a id="a58eee70a65197b2cdbfd98c6fa6d6153" name="a58eee70a65197b2cdbfd98c6fa6d6153"></a> |
| typedef std::shared_ptr< <a class="el" href="classpulsar_1_1_authentication.html">Authentication</a> > </td><td class="memItemRight" valign="bottom"><b>AuthenticationPtr</b></td></tr> |
| <tr class="separator:a58eee70a65197b2cdbfd98c6fa6d6153"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a10fef2591223603936b7bd86e63ed1b2"><td class="memItemLeft" align="right" valign="top"><a id="a10fef2591223603936b7bd86e63ed1b2" name="a10fef2591223603936b7bd86e63ed1b2"></a> |
| typedef std::map< std::string, std::string > </td><td class="memItemRight" valign="bottom"><b>ParamMap</b></td></tr> |
| <tr class="separator:a10fef2591223603936b7bd86e63ed1b2"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a2eabcdf96ac5fd61e685919e7ef42f49"><td class="memItemLeft" align="right" valign="top"><a id="a2eabcdf96ac5fd61e685919e7ef42f49" name="a2eabcdf96ac5fd61e685919e7ef42f49"></a> |
| typedef std::function< std::string()> </td><td class="memItemRight" valign="bottom"><b>TokenSupplier</b></td></tr> |
| <tr class="separator:a2eabcdf96ac5fd61e685919e7ef42f49"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a038e38e4311d32270978b9ef9e188f63"><td class="memItemLeft" align="right" valign="top"><a id="a038e38e4311d32270978b9ef9e188f63" name="a038e38e4311d32270978b9ef9e188f63"></a> |
| typedef std::shared_ptr< <a class="el" href="classpulsar_1_1_oauth2_token_result.html">Oauth2TokenResult</a> > </td><td class="memItemRight" valign="bottom"><b>Oauth2TokenResultPtr</b></td></tr> |
| <tr class="separator:a038e38e4311d32270978b9ef9e188f63"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a2b89d3b7765002ab2cbfa2a88c5d9d41"><td class="memItemLeft" align="right" valign="top"><a id="a2b89d3b7765002ab2cbfa2a88c5d9d41" name="a2b89d3b7765002ab2cbfa2a88c5d9d41"></a> |
| typedef std::shared_ptr< <a class="el" href="classpulsar_1_1_oauth2_flow.html">Oauth2Flow</a> > </td><td class="memItemRight" valign="bottom"><b>FlowPtr</b></td></tr> |
| <tr class="separator:a2b89d3b7765002ab2cbfa2a88c5d9d41"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a3ea4abf665ae6f87909e0a57aa31f294"><td class="memItemLeft" align="right" valign="top"><a id="a3ea4abf665ae6f87909e0a57aa31f294" name="a3ea4abf665ae6f87909e0a57aa31f294"></a> |
| typedef std::shared_ptr< <a class="el" href="classpulsar_1_1_cached_token.html">CachedToken</a> > </td><td class="memItemRight" valign="bottom"><b>CachedTokenPtr</b></td></tr> |
| <tr class="separator:a3ea4abf665ae6f87909e0a57aa31f294"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aed95b2d6d7bc1b4fc4c888f77107ecec"><td class="memItemLeft" align="right" valign="top"><a id="aed95b2d6d7bc1b4fc4c888f77107ecec" name="aed95b2d6d7bc1b4fc4c888f77107ecec"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> result, <a class="el" href="classpulsar_1_1_broker_consumer_stats.html">BrokerConsumerStats</a> brokerConsumerStats)> </td><td class="memItemRight" valign="bottom"><b>BrokerConsumerStatsCallback</b></td></tr> |
| <tr class="separator:aed95b2d6d7bc1b4fc4c888f77107ecec"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a5d897b62a9960f1ab07332e828054285"><td class="memItemLeft" align="right" valign="top"><a id="a5d897b62a9960f1ab07332e828054285" name="a5d897b62a9960f1ab07332e828054285"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>, <a class="el" href="classpulsar_1_1_producer.html">Producer</a>)> </td><td class="memItemRight" valign="bottom"><b>CreateProducerCallback</b></td></tr> |
| <tr class="separator:a5d897b62a9960f1ab07332e828054285"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad19626f1ac8c73ec980d51dce9dcee8a"><td class="memItemLeft" align="right" valign="top"><a id="ad19626f1ac8c73ec980d51dce9dcee8a" name="ad19626f1ac8c73ec980d51dce9dcee8a"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>, <a class="el" href="classpulsar_1_1_consumer.html">Consumer</a>)> </td><td class="memItemRight" valign="bottom"><b>SubscribeCallback</b></td></tr> |
| <tr class="separator:ad19626f1ac8c73ec980d51dce9dcee8a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a37dccf5d32b277f5b23d417cfd540fff"><td class="memItemLeft" align="right" valign="top"><a id="a37dccf5d32b277f5b23d417cfd540fff" name="a37dccf5d32b277f5b23d417cfd540fff"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>, <a class="el" href="classpulsar_1_1_reader.html">Reader</a>)> </td><td class="memItemRight" valign="bottom"><b>ReaderCallback</b></td></tr> |
| <tr class="separator:a37dccf5d32b277f5b23d417cfd540fff"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a18349c9e8c0fd00a4546cdb6d4da5024"><td class="memItemLeft" align="right" valign="top"><a id="a18349c9e8c0fd00a4546cdb6d4da5024" name="a18349c9e8c0fd00a4546cdb6d4da5024"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>, <a class="el" href="classpulsar_1_1_table_view.html">TableView</a>)> </td><td class="memItemRight" valign="bottom"><b>TableViewCallback</b></td></tr> |
| <tr class="separator:a18349c9e8c0fd00a4546cdb6d4da5024"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a6558a56269a66386083fa35028c33ae3"><td class="memItemLeft" align="right" valign="top"><a id="a6558a56269a66386083fa35028c33ae3" name="a6558a56269a66386083fa35028c33ae3"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>, const std::vector< std::string > &)> </td><td class="memItemRight" valign="bottom"><b>GetPartitionsCallback</b></td></tr> |
| <tr class="separator:a6558a56269a66386083fa35028c33ae3"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:adfcf89a21faef208c17aa7ff52782819"><td class="memItemLeft" align="right" valign="top"><a id="adfcf89a21faef208c17aa7ff52782819" name="adfcf89a21faef208c17aa7ff52782819"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>)> </td><td class="memItemRight" valign="bottom"><b>CloseCallback</b></td></tr> |
| <tr class="separator:adfcf89a21faef208c17aa7ff52782819"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a21467a649c4ee5d26920f6ad15cf371c"><td class="memItemLeft" align="right" valign="top"><a id="a21467a649c4ee5d26920f6ad15cf371c" name="a21467a649c4ee5d26920f6ad15cf371c"></a> |
| typedef std::shared_ptr< ConsumerImplBase > </td><td class="memItemRight" valign="bottom"><b>ConsumerImplBasePtr</b></td></tr> |
| <tr class="separator:a21467a649c4ee5d26920f6ad15cf371c"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ac87806090d752fb2248e8da65727630a"><td class="memItemLeft" align="right" valign="top"><a id="ac87806090d752fb2248e8da65727630a" name="ac87806090d752fb2248e8da65727630a"></a> |
| typedef std::vector< <a class="el" href="classpulsar_1_1_message.html">Message</a> > </td><td class="memItemRight" valign="bottom"><b>Messages</b></td></tr> |
| <tr class="memdesc:ac87806090d752fb2248e8da65727630a"><td class="mdescLeft"> </td><td class="mdescRight">Callback definition for non-data operation. <br /></td></tr> |
| <tr class="separator:ac87806090d752fb2248e8da65727630a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ae5bf6401bfa8e3962e5c8f9fa2efbf4d"><td class="memItemLeft" align="right" valign="top"><a id="ae5bf6401bfa8e3962e5c8f9fa2efbf4d" name="ae5bf6401bfa8e3962e5c8f9fa2efbf4d"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> result)> </td><td class="memItemRight" valign="bottom"><b>ResultCallback</b></td></tr> |
| <tr class="memdesc:ae5bf6401bfa8e3962e5c8f9fa2efbf4d"><td class="mdescLeft"> </td><td class="mdescRight">Callback definition for non-data operation. <br /></td></tr> |
| <tr class="separator:ae5bf6401bfa8e3962e5c8f9fa2efbf4d"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a189352c47f577c4b6d3af9baf5d351d7"><td class="memItemLeft" align="right" valign="top"><a id="a189352c47f577c4b6d3af9baf5d351d7" name="a189352c47f577c4b6d3af9baf5d351d7"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>, const <a class="el" href="classpulsar_1_1_message.html">Message</a> &msg)> </td><td class="memItemRight" valign="bottom"><b>ReceiveCallback</b></td></tr> |
| <tr class="separator:a189352c47f577c4b6d3af9baf5d351d7"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a074cb01864a178608721b1dfa2f377cd"><td class="memItemLeft" align="right" valign="top"><a id="a074cb01864a178608721b1dfa2f377cd" name="a074cb01864a178608721b1dfa2f377cd"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>, const <a class="el" href="namespacepulsar.html#ac87806090d752fb2248e8da65727630a">Messages</a> &msgs)> </td><td class="memItemRight" valign="bottom"><b>BatchReceiveCallback</b></td></tr> |
| <tr class="separator:a074cb01864a178608721b1dfa2f377cd"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aa4dcd6f7d9b44d30979c53858e1de9fa"><td class="memItemLeft" align="right" valign="top"><a id="aa4dcd6f7d9b44d30979c53858e1de9fa" name="aa4dcd6f7d9b44d30979c53858e1de9fa"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> result, <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> messageId)> </td><td class="memItemRight" valign="bottom"><b>GetLastMessageIdCallback</b></td></tr> |
| <tr class="separator:aa4dcd6f7d9b44d30979c53858e1de9fa"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aa2439b1ef83202e8d35359d0134f2d56"><td class="memItemLeft" align="right" valign="top"><a id="aa2439b1ef83202e8d35359d0134f2d56" name="aa2439b1ef83202e8d35359d0134f2d56"></a> |
| typedef std::function< void(<a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> &consumer, const <a class="el" href="classpulsar_1_1_message.html">Message</a> &msg)> </td><td class="memItemRight" valign="bottom"><b>MessageListener</b></td></tr> |
| <tr class="memdesc:aa2439b1ef83202e8d35359d0134f2d56"><td class="mdescLeft"> </td><td class="mdescRight">Callback definition for MessageListener. <br /></td></tr> |
| <tr class="separator:aa2439b1ef83202e8d35359d0134f2d56"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a4ea432bf5b19fb368beb8c9cc5aaa97e"><td class="memItemLeft" align="right" valign="top"><a id="a4ea432bf5b19fb368beb8c9cc5aaa97e" name="a4ea432bf5b19fb368beb8c9cc5aaa97e"></a> |
| typedef std::shared_ptr< <a class="el" href="classpulsar_1_1_consumer_event_listener.html">ConsumerEventListener</a> > </td><td class="memItemRight" valign="bottom"><b>ConsumerEventListenerPtr</b></td></tr> |
| <tr class="separator:a4ea432bf5b19fb368beb8c9cc5aaa97e"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:abc56ae411ef526818e5fb7af5f5d1a4b"><td class="memItemLeft" align="right" valign="top"><a id="abc56ae411ef526818e5fb7af5f5d1a4b" name="abc56ae411ef526818e5fb7af5f5d1a4b"></a> |
| typedef std::shared_ptr< <a class="el" href="classpulsar_1_1_consumer_interceptor.html">ConsumerInterceptor</a> > </td><td class="memItemRight" valign="bottom"><b>ConsumerInterceptorPtr</b></td></tr> |
| <tr class="separator:abc56ae411ef526818e5fb7af5f5d1a4b"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a8e0375ee5e41c6a96b3f9462e500c679"><td class="memItemLeft" align="right" valign="top"><a id="a8e0375ee5e41c6a96b3f9462e500c679" name="a8e0375ee5e41c6a96b3f9462e500c679"></a> |
| typedef std::shared_ptr< <a class="el" href="classpulsar_1_1_crypto_key_reader.html">CryptoKeyReader</a> > </td><td class="memItemRight" valign="bottom"><b>CryptoKeyReaderPtr</b></td></tr> |
| <tr class="separator:a8e0375ee5e41c6a96b3f9462e500c679"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a3dc78de2c39f4e780fa9a6c18dde3550"><td class="memItemLeft" align="right" valign="top"><a id="a3dc78de2c39f4e780fa9a6c18dde3550" name="a3dc78de2c39f4e780fa9a6c18dde3550"></a> |
| typedef std::shared_ptr< EncryptionKeyInfoImpl > </td><td class="memItemRight" valign="bottom"><b>EncryptionKeyInfoImplPtr</b></td></tr> |
| <tr class="separator:a3dc78de2c39f4e780fa9a6c18dde3550"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:afdd93a06db72d7338464780c9b59ce13"><td class="memItemLeft" align="right" valign="top"><a id="afdd93a06db72d7338464780c9b59ce13" name="afdd93a06db72d7338464780c9b59ce13"></a> |
| typedef std::pair< int, int > </td><td class="memItemRight" valign="bottom"><b>StickyRange</b></td></tr> |
| <tr class="separator:afdd93a06db72d7338464780c9b59ce13"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a3f4e46a83626eb931e232821bdc94d97"><td class="memItemLeft" align="right" valign="top"><a id="a3f4e46a83626eb931e232821bdc94d97" name="a3f4e46a83626eb931e232821bdc94d97"></a> |
| typedef std::vector< StickyRange > </td><td class="memItemRight" valign="bottom"><b>StickyRanges</b></td></tr> |
| <tr class="separator:a3f4e46a83626eb931e232821bdc94d97"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:af743dfe2f3041a372997a1e39721fe48"><td class="memItemLeft" align="right" valign="top"><a id="af743dfe2f3041a372997a1e39721fe48" name="af743dfe2f3041a372997a1e39721fe48"></a> |
| typedef std::vector< <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> > </td><td class="memItemRight" valign="bottom"><b>MessageIdList</b></td></tr> |
| <tr class="separator:af743dfe2f3041a372997a1e39721fe48"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad54353980f71dfc9d1c8d5d918d39686"><td class="memItemLeft" align="right" valign="top"><a id="ad54353980f71dfc9d1c8d5d918d39686" name="ad54353980f71dfc9d1c8d5d918d39686"></a> |
| typedef std::shared_ptr< <a class="el" href="classpulsar_1_1_message_routing_policy.html">MessageRoutingPolicy</a> > </td><td class="memItemRight" valign="bottom"><b>MessageRoutingPolicyPtr</b></td></tr> |
| <tr class="separator:ad54353980f71dfc9d1c8d5d918d39686"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a01b4e9809030fcf5908827beeffc8b4c"><td class="memItemLeft" align="right" valign="top"><a id="a01b4e9809030fcf5908827beeffc8b4c" name="a01b4e9809030fcf5908827beeffc8b4c"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>)> </td><td class="memItemRight" valign="bottom"><b>FlushCallback</b></td></tr> |
| <tr class="separator:a01b4e9809030fcf5908827beeffc8b4c"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a4c0f05975c524a34914c3a99930eed0a"><td class="memItemLeft" align="right" valign="top"><a id="a4c0f05975c524a34914c3a99930eed0a" name="a4c0f05975c524a34914c3a99930eed0a"></a> |
| typedef std::shared_ptr< ProducerImplBase > </td><td class="memItemRight" valign="bottom"><b>ProducerImplBasePtr</b></td></tr> |
| <tr class="separator:a4c0f05975c524a34914c3a99930eed0a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aa0ce31476868349db6ac6ec56fffea9a"><td class="memItemLeft" align="right" valign="top"><a id="aa0ce31476868349db6ac6ec56fffea9a" name="aa0ce31476868349db6ac6ec56fffea9a"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a>, const <a class="el" href="classpulsar_1_1_message_id.html">MessageId</a> &messageId)> </td><td class="memItemRight" valign="bottom"><b>SendCallback</b></td></tr> |
| <tr class="separator:aa0ce31476868349db6ac6ec56fffea9a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a448885275aabdf7aa36a9304f75e2ac7"><td class="memItemLeft" align="right" valign="top"><a id="a448885275aabdf7aa36a9304f75e2ac7" name="a448885275aabdf7aa36a9304f75e2ac7"></a> |
| typedef std::shared_ptr< <a class="el" href="classpulsar_1_1_producer_interceptor.html">ProducerInterceptor</a> > </td><td class="memItemRight" valign="bottom"><b>ProducerInterceptorPtr</b></td></tr> |
| <tr class="separator:a448885275aabdf7aa36a9304f75e2ac7"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ab91637d30ead668d8bfe3294b57d9cb9"><td class="memItemLeft" align="right" valign="top"><a id="ab91637d30ead668d8bfe3294b57d9cb9" name="ab91637d30ead668d8bfe3294b57d9cb9"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> result, bool hasMessageAvailable)> </td><td class="memItemRight" valign="bottom"><b>HasMessageAvailableCallback</b></td></tr> |
| <tr class="separator:ab91637d30ead668d8bfe3294b57d9cb9"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad429c903c55a6c36100bb4c8801b676e"><td class="memItemLeft" align="right" valign="top"><a id="ad429c903c55a6c36100bb4c8801b676e" name="ad429c903c55a6c36100bb4c8801b676e"></a> |
| typedef std::function< void(<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> result, const <a class="el" href="classpulsar_1_1_message.html">Message</a> &message)> </td><td class="memItemRight" valign="bottom"><b>ReadNextCallback</b></td></tr> |
| <tr class="separator:ad429c903c55a6c36100bb4c8801b676e"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a9bddad6880419962bbc6af877209cd49"><td class="memItemLeft" align="right" valign="top"><a id="a9bddad6880419962bbc6af877209cd49" name="a9bddad6880419962bbc6af877209cd49"></a> |
| typedef std::function< void(<a class="el" href="classpulsar_1_1_reader.html">Reader</a> reader, const <a class="el" href="classpulsar_1_1_message.html">Message</a> &msg)> </td><td class="memItemRight" valign="bottom"><b>ReaderListener</b></td></tr> |
| <tr class="memdesc:a9bddad6880419962bbc6af877209cd49"><td class="mdescLeft"> </td><td class="mdescRight">Callback definition for MessageListener. <br /></td></tr> |
| <tr class="separator:a9bddad6880419962bbc6af877209cd49"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ac45eca185f9091000a98e83e006af9ba"><td class="memItemLeft" align="right" valign="top"><a id="ac45eca185f9091000a98e83e006af9ba" name="ac45eca185f9091000a98e83e006af9ba"></a> |
| typedef std::map< std::string, std::string > </td><td class="memItemRight" valign="bottom"><b>StringMap</b></td></tr> |
| <tr class="separator:ac45eca185f9091000a98e83e006af9ba"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a8c94ae82a3cfc885877c1bbdd4b3c7f8"><td class="memItemLeft" align="right" valign="top"><a id="a8c94ae82a3cfc885877c1bbdd4b3c7f8" name="a8c94ae82a3cfc885877c1bbdd4b3c7f8"></a> |
| typedef std::function< void(const std::string &key, const std::string &value)> </td><td class="memItemRight" valign="bottom"><b>TableViewAction</b></td></tr> |
| <tr class="separator:a8c94ae82a3cfc885877c1bbdd4b3c7f8"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a35c099fe49b51491fe48cd5c0d669135"><td class="memItemLeft" align="right" valign="top"><a id="a35c099fe49b51491fe48cd5c0d669135" name="a35c099fe49b51491fe48cd5c0d669135"></a> |
| using </td><td class="memItemRight" valign="bottom"><b>BytesMessageBuilder</b> = <a class="el" href="classpulsar_1_1_typed_message_builder.html">TypedMessageBuilder</a>< std::string ></td></tr> |
| <tr class="separator:a35c099fe49b51491fe48cd5c0d669135"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a id="enum-members" name="enum-members"></a> |
| Enumerations</h2></td></tr> |
| <tr class="memitem:ad6f0aaa7c0223ff1f3ff5a164f739ac5"><td class="memItemLeft" align="right" valign="top"><a id="ad6f0aaa7c0223ff1f3ff5a164f739ac5" name="ad6f0aaa7c0223ff1f3ff5a164f739ac5"></a>enum  </td><td class="memItemRight" valign="bottom"><b>CompressionType</b> { <br /> |
|   <b>CompressionNone</b> = 0 |
| , <b>CompressionLZ4</b> = 1 |
| , <b>CompressionZLib</b> = 2 |
| , <b>CompressionZSTD</b> = 3 |
| , <br /> |
|   <b>CompressionSNAPPY</b> = 4 |
| <br /> |
| }</td></tr> |
| <tr class="separator:ad6f0aaa7c0223ff1f3ff5a164f739ac5"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a828ec5e466f93f7b4061cc25d7e8ac35"><td class="memItemLeft" align="right" valign="top"><a id="a828ec5e466f93f7b4061cc25d7e8ac35" name="a828ec5e466f93f7b4061cc25d7e8ac35"></a>enum class  </td><td class="memItemRight" valign="bottom"><b>ConsumerCryptoFailureAction</b> { <b>FAIL</b> |
| , <b>DISCARD</b> |
| , <b>CONSUME</b> |
| }</td></tr> |
| <tr class="separator:a828ec5e466f93f7b4061cc25d7e8ac35"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ac3e442abe2558a2b257fc7344af61d40"><td class="memItemLeft" align="right" valign="top">enum  </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacepulsar.html#ac3e442abe2558a2b257fc7344af61d40">ConsumerType</a> { <a class="el" href="namespacepulsar.html#ac3e442abe2558a2b257fc7344af61d40a915cd237340dcd1d212f8d398f3d91ac">ConsumerExclusive</a> |
| , <a class="el" href="namespacepulsar.html#ac3e442abe2558a2b257fc7344af61d40ac55370821e835a03c2da742ab27e1705">ConsumerShared</a> |
| , <a class="el" href="namespacepulsar.html#ac3e442abe2558a2b257fc7344af61d40aadffd5f0d50b1da36685230cd3f910a1">ConsumerFailover</a> |
| , <a class="el" href="namespacepulsar.html#ac3e442abe2558a2b257fc7344af61d40acb902cf3781caf307d06e37dc447d5cc">ConsumerKeyShared</a> |
| }</td></tr> |
| <tr class="separator:ac3e442abe2558a2b257fc7344af61d40"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a616c9c251b20fa5da07a41c1584d0b55"><td class="memItemLeft" align="right" valign="top"><a id="a616c9c251b20fa5da07a41c1584d0b55" name="a616c9c251b20fa5da07a41c1584d0b55"></a>enum  </td><td class="memItemRight" valign="bottom"><b>InitialPosition</b> { <b>InitialPositionLatest</b> |
| , <b>InitialPositionEarliest</b> |
| }</td></tr> |
| <tr class="separator:a616c9c251b20fa5da07a41c1584d0b55"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a499d1327931169d068b9b353f106dd04"><td class="memItemLeft" align="right" valign="top">enum  </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacepulsar.html#a499d1327931169d068b9b353f106dd04">KeySharedMode</a> { <a class="el" href="namespacepulsar.html#a499d1327931169d068b9b353f106dd04a1dce3e502d8e018e90f97c07b37cde1f">AUTO_SPLIT</a> = 0 |
| , <a class="el" href="namespacepulsar.html#a499d1327931169d068b9b353f106dd04aed98d14aabee0f3bc70a0cc7723e5b16">STICKY</a> = 1 |
| }</td></tr> |
| <tr class="separator:a499d1327931169d068b9b353f106dd04"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a21fcd03916492b7597c0b59a352a0491"><td class="memItemLeft" align="right" valign="top"><a id="a21fcd03916492b7597c0b59a352a0491" name="a21fcd03916492b7597c0b59a352a0491"></a>enum class  </td><td class="memItemRight" valign="bottom"><b>ProducerCryptoFailureAction</b> { <b>FAIL</b> |
| , <b>SEND</b> |
| }</td></tr> |
| <tr class="separator:a21fcd03916492b7597c0b59a352a0491"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:abd9b21e56a6fb78e04cae2664ff0dbbd"><td class="memItemLeft" align="right" valign="top">enum  </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacepulsar.html#abd9b21e56a6fb78e04cae2664ff0dbbd">RegexSubscriptionMode</a> { <a class="el" href="namespacepulsar.html#abd9b21e56a6fb78e04cae2664ff0dbbda68931062ae96d4dcc4778eeac5fa3de4">PersistentOnly</a> = 0 |
| , <a class="el" href="namespacepulsar.html#abd9b21e56a6fb78e04cae2664ff0dbbda5af3d512f79ac90cacc326d86a230603">NonPersistentOnly</a> = 1 |
| , <a class="el" href="namespacepulsar.html#abd9b21e56a6fb78e04cae2664ff0dbbdaa30bab3d7d550e08f128647cbbd5b6ef">AllTopics</a> = 2 |
| }</td></tr> |
| <tr class="separator:abd9b21e56a6fb78e04cae2664ff0dbbd"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ae85314d6b9e8afd831cf8c66705f2dbb"><td class="memItemLeft" align="right" valign="top">enum  </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> { <br /> |
|   <b>ResultRetryable</b> = -1 |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba0aac5dae08c453e94161e28d7cd5a92f">ResultOk</a> = 0 |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba213e39d5c84b8794dd21ab4f60ff4b60">ResultUnknownError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbad3d7545107897e19819066fe42e81a06">ResultInvalidConfiguration</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbaeb1858ddf791b7288ab1cb066d70cfb4">ResultTimeout</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba42ae88341f22c34ed9baac35804f1b01">ResultLookupError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbab26ee1bb88fafefa107071fa1fd775bc">ResultConnectError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbaa084aea99a198f2d01c6c98eeb44ff9e">ResultReadError</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba2b40eba56a27dc5615338a0d988e2024">ResultAuthenticationError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba4db07aa497065f6cc0d8e314bf852057">ResultAuthorizationError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba8014344f94ba9ad55337f01767e0e30c">ResultErrorGettingAuthenticationData</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba2188e16c2e397cee5f64aef6799c419c">ResultBrokerMetadataError</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba3ac5992ae486593f5aee1538970b51a6">ResultBrokerPersistenceError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba60d3371f74155ecb5b11efbf217a2174">ResultChecksumError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba5cbe2e189b60f91ff0f2e82b973db31b">ResultConsumerBusy</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba00976fab0138d80c5fc621e3a44046b6">ResultNotConnected</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba6c11f7cd8f0bc274d12c5157157ad916">ResultAlreadyClosed</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba875234396481a34fb7f02d3ecd1936f0">ResultInvalidMessage</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba48d27a5310cda91d13a23324a08533e9">ResultConsumerNotInitialized</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba2b5f050c9b2aef10831927cece55b02a">ResultProducerNotInitialized</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbad0a7588cc2ac84de7fc17331ed59b544">ResultProducerBusy</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba024fa5ba9fac2cb81fd4e8f6853a81a5">ResultTooManyLookupRequestException</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbafcb0b43f04e494ba3784f6c259b5137f">ResultInvalidTopicName</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba685954a2aedb14c0f3669d579bfd1193">ResultInvalidUrl</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbaf8a459f352105f7e853e02ca2af193b0">ResultServiceUnitNotReady</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba60abb5ad06a78a3d6d40b2131534dfeb">ResultOperationNotSupported</a> |
| , <b>ResultProducerBlockedQuotaExceededError</b> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbab5cc52655496666d96f35edab07c9e7f">ResultProducerBlockedQuotaExceededException</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba1849c732b1ec8c7e1c0aa653de998d81">ResultProducerQueueIsFull</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba43765d6a6cab85363b2cad047371294b">ResultMessageTooBig</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbad1921e33dd6a45431a0209b70588cf48">ResultTopicNotFound</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba061d6c40bdf75ca172ffdb862aad7c51">ResultSubscriptionNotFound</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbac74e9fb1b2c25caf17ac3446303b7a71">ResultConsumerNotFound</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba888578f8569121606cfcfa6044c594c3">ResultUnsupportedVersionError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba62df217dec3d3f75c7099d1464c92750">ResultTopicTerminated</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbac131b27876dfd64d8e6b3355578a8f77">ResultCryptoError</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbafe509853528453adc4ca304ea9b1d79e">ResultIncompatibleSchema</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbac0f35889e7dd6cb7f634baedb8481e9e">ResultConsumerAssignError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba2e01cfc218b721cbd2e2a06bf3cb78b0">ResultCumulativeAcknowledgementNotAllowedError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba653a82475a2715f839ba52329a9b6414">ResultTransactionCoordinatorNotFoundError</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba742ada2f12ae5b2ca11fa674889dc186">ResultInvalidTxnStatusError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbad38a4ab387c0769f3c8c30fd2c7413a1">ResultNotAllowedError</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba39c2049f4e7e428d2a4473b68223a53c">ResultTransactionConflict</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbbaf4bfae37b494ea0a2599cc4596bccdf0">ResultTransactionNotFound</a> |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba6370706ff98bf4c513f11489679543cb">ResultProducerFenced</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba7eaf7df2c4a2ac2f874e044db02c6733">ResultMemoryBufferIsFull</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba67722ba0750e461ae03912f5dc10d03a">ResultInterrupted</a> |
| , <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbba287510a5c9a382f29f0cbdf3d32c0d59">ResultDisconnected</a> |
| <br /> |
| }</td></tr> |
| <tr class="separator:ae85314d6b9e8afd831cf8c66705f2dbb"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a0dca31b62c0207ea87e146cde0609595"><td class="memItemLeft" align="right" valign="top">enum class  </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacepulsar.html#a0dca31b62c0207ea87e146cde0609595">KeyValueEncodingType</a> { <a class="el" href="namespacepulsar.html#a0dca31b62c0207ea87e146cde0609595a561af55a6a824ae74125a6cf4eade06a">SEPARATED</a> |
| , <a class="el" href="namespacepulsar.html#a0dca31b62c0207ea87e146cde0609595acfbac07c6ae3e73f0e10ca60ad916bef">INLINE</a> |
| }</td></tr> |
| <tr class="separator:a0dca31b62c0207ea87e146cde0609595"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:abab5b1f233c9cc54c10d28cb5b973305"><td class="memItemLeft" align="right" valign="top">enum  </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305">SchemaType</a> { <br /> |
|   <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305af9377cb56d5b6973392d0fd2ca76009a">NONE</a> = 0 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305ab936a9dad2cbb5fca28fc477ff39fb70">STRING</a> = 1 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305a15f7910601e8d522f151f3129c753283">JSON</a> = 2 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305a5054f171f6c60b73043727ddc60698a0">PROTOBUF</a> = 3 |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305ac728ff4cb4de807c1b6fa8ca33f41d47">AVRO</a> = 4 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305a2c52dde965d6ba972179fa14116160e9">INT8</a> = 6 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305a9e5ed020cb2ca197a0918946352cf96e">INT16</a> = 7 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305ac048e1576ab161018f9e3c6eda6307d0">INT32</a> = 8 |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305a11fafed4115309cf1f33eac044e704a2">INT64</a> = 9 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305a5102395892b9d15d0a0483a27ca64777">FLOAT</a> = 10 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305a1b1684230ae9c15941cb3fe05bf972f0">DOUBLE</a> = 11 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305ab6fbe0f5b80de2aa67b68572e7a054d3">KEY_VALUE</a> = 15 |
| , <br /> |
|   <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305a24048f6ae2e1048989e69644edcdc8f6">PROTOBUF_NATIVE</a> = 20 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305a4dcbdcae67c5f78b7c4fff2c2135cba2">BYTES</a> = -1 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305a6a9078e01119bddf19aa24dc05390f99">AUTO_CONSUME</a> = -3 |
| , <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305ad1af93d272614c940d322497eb8e31f0">AUTO_PUBLISH</a> = -4 |
| <br /> |
| }</td></tr> |
| <tr class="separator:abab5b1f233c9cc54c10d28cb5b973305"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a id="func-members" name="func-members"></a> |
| Functions</h2></td></tr> |
| <tr class="memitem:a7dc480604aefdd4119b2e2ee2b9e7764"><td class="memItemLeft" align="right" valign="top">PULSAR_PUBLIC <a class="el" href="classpulsar_1_1_schema_info.html">SchemaInfo</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="namespacepulsar.html#a7dc480604aefdd4119b2e2ee2b9e7764">createProtobufNativeSchema</a> (const google::protobuf::Descriptor *descriptor)</td></tr> |
| <tr class="separator:a7dc480604aefdd4119b2e2ee2b9e7764"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a59df2e19aa66f67266b01331535798ac"><td class="memItemLeft" align="right" valign="top"><a id="a59df2e19aa66f67266b01331535798ac" name="a59df2e19aa66f67266b01331535798ac"></a> |
| PULSAR_PUBLIC const char * </td><td class="memItemRight" valign="bottom"><b>strResult</b> (<a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">Result</a> result)</td></tr> |
| <tr class="separator:a59df2e19aa66f67266b01331535798ac"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:adb7f7bf15bfc67127bb9268b1ae9de45"><td class="memItemLeft" align="right" valign="top"><a id="adb7f7bf15bfc67127bb9268b1ae9de45" name="adb7f7bf15bfc67127bb9268b1ae9de45"></a> |
| PULSAR_PUBLIC std::ostream & </td><td class="memItemRight" valign="bottom"><b>operator<<</b> (std::ostream &s, <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">pulsar::Result</a> result)</td></tr> |
| <tr class="separator:adb7f7bf15bfc67127bb9268b1ae9de45"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ac72692dcebb39fc34105646990c4cabe"><td class="memItemLeft" align="right" valign="top"><a id="ac72692dcebb39fc34105646990c4cabe" name="ac72692dcebb39fc34105646990c4cabe"></a> |
| PULSAR_PUBLIC const char * </td><td class="memItemRight" valign="bottom"><b>strEncodingType</b> (<a class="el" href="namespacepulsar.html#a0dca31b62c0207ea87e146cde0609595">pulsar::KeyValueEncodingType</a> encodingType)</td></tr> |
| <tr class="separator:ac72692dcebb39fc34105646990c4cabe"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ae91d7ebc2c73d84d1dec3848aff5d11d"><td class="memItemLeft" align="right" valign="top"><a id="ae91d7ebc2c73d84d1dec3848aff5d11d" name="ae91d7ebc2c73d84d1dec3848aff5d11d"></a> |
| PULSAR_PUBLIC <a class="el" href="namespacepulsar.html#a0dca31b62c0207ea87e146cde0609595">KeyValueEncodingType</a> </td><td class="memItemRight" valign="bottom"><b>enumEncodingType</b> (std::string encodingTypeStr)</td></tr> |
| <tr class="separator:ae91d7ebc2c73d84d1dec3848aff5d11d"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a976ee27b9f8d4b0b17643165291b28eb"><td class="memItemLeft" align="right" valign="top"><a id="a976ee27b9f8d4b0b17643165291b28eb" name="a976ee27b9f8d4b0b17643165291b28eb"></a> |
| PULSAR_PUBLIC const char * </td><td class="memItemRight" valign="bottom"><b>strSchemaType</b> (<a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305">SchemaType</a> schemaType)</td></tr> |
| <tr class="separator:a976ee27b9f8d4b0b17643165291b28eb"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aa68c463073c15526dcd1b4bbca36758d"><td class="memItemLeft" align="right" valign="top"><a id="aa68c463073c15526dcd1b4bbca36758d" name="aa68c463073c15526dcd1b4bbca36758d"></a> |
| PULSAR_PUBLIC <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305">SchemaType</a> </td><td class="memItemRight" valign="bottom"><b>enumSchemaType</b> (std::string schemaTypeStr)</td></tr> |
| <tr class="separator:aa68c463073c15526dcd1b4bbca36758d"><td class="memSeparator" colspan="2"> </td></tr> |
| </table> |
| <a name="details" id="details"></a><h2 class="groupheader">Detailed Description</h2> |
| <div class="textblock"><p>Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you 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</p> |
| <p><a href="http://www.apache.org/licenses/LICENSE-2.0">http://www.apache.org/licenses/LICENSE-2.0</a></p> |
| <p>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. </p> |
| </div><h2 class="groupheader">Enumeration Type Documentation</h2> |
| <a id="ac3e442abe2558a2b257fc7344af61d40" name="ac3e442abe2558a2b257fc7344af61d40"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#ac3e442abe2558a2b257fc7344af61d40">◆ </a></span>ConsumerType</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">enum <a class="el" href="namespacepulsar.html#ac3e442abe2558a2b257fc7344af61d40">pulsar::ConsumerType</a></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <table class="fieldtable"> |
| <tr><th colspan="2">Enumerator</th></tr><tr><td class="fieldname"><a id="ac3e442abe2558a2b257fc7344af61d40a915cd237340dcd1d212f8d398f3d91ac" name="ac3e442abe2558a2b257fc7344af61d40a915cd237340dcd1d212f8d398f3d91ac"></a>ConsumerExclusive </td><td class="fielddoc"><p>There can be only 1 consumer on the same topic with the same consumerName </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ac3e442abe2558a2b257fc7344af61d40ac55370821e835a03c2da742ab27e1705" name="ac3e442abe2558a2b257fc7344af61d40ac55370821e835a03c2da742ab27e1705"></a>ConsumerShared </td><td class="fielddoc"><p>Multiple consumers will be able to use the same consumerName and the messages will be dispatched according to a round-robin rotation between the connected consumers </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ac3e442abe2558a2b257fc7344af61d40aadffd5f0d50b1da36685230cd3f910a1" name="ac3e442abe2558a2b257fc7344af61d40aadffd5f0d50b1da36685230cd3f910a1"></a>ConsumerFailover </td><td class="fielddoc"><p>Only one consumer is active on the subscription; Subscription can have N consumers connected one of which will get promoted to master if the current master becomes inactive </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ac3e442abe2558a2b257fc7344af61d40acb902cf3781caf307d06e37dc447d5cc" name="ac3e442abe2558a2b257fc7344af61d40acb902cf3781caf307d06e37dc447d5cc"></a>ConsumerKeyShared </td><td class="fielddoc"><p>Multiple consumer will be able to use the same subscription and all messages with the same key will be dispatched to only one consumer </p> |
| </td></tr> |
| </table> |
| |
| </div> |
| </div> |
| <a id="a499d1327931169d068b9b353f106dd04" name="a499d1327931169d068b9b353f106dd04"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a499d1327931169d068b9b353f106dd04">◆ </a></span>KeySharedMode</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">enum <a class="el" href="namespacepulsar.html#a499d1327931169d068b9b353f106dd04">pulsar::KeySharedMode</a></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>KeyShared mode of KeyShared subscription. </p> |
| <table class="fieldtable"> |
| <tr><th colspan="2">Enumerator</th></tr><tr><td class="fieldname"><a id="a499d1327931169d068b9b353f106dd04a1dce3e502d8e018e90f97c07b37cde1f" name="a499d1327931169d068b9b353f106dd04a1dce3e502d8e018e90f97c07b37cde1f"></a>AUTO_SPLIT </td><td class="fielddoc"><p>Auto split while new consumer connected. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="a499d1327931169d068b9b353f106dd04aed98d14aabee0f3bc70a0cc7723e5b16" name="a499d1327931169d068b9b353f106dd04aed98d14aabee0f3bc70a0cc7723e5b16"></a>STICKY </td><td class="fielddoc"><p>New consumer with fixed hash range to attach the topic, if new consumer use conflict hash range with exits consumers, new consumer will be rejected. </p> |
| </td></tr> |
| </table> |
| |
| </div> |
| </div> |
| <a id="a0dca31b62c0207ea87e146cde0609595" name="a0dca31b62c0207ea87e146cde0609595"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a0dca31b62c0207ea87e146cde0609595">◆ </a></span>KeyValueEncodingType</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">enum class <a class="el" href="namespacepulsar.html#a0dca31b62c0207ea87e146cde0609595">pulsar::KeyValueEncodingType</a></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">strong</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Encoding types of supported KeyValueSchema for Pulsar messages. </p> |
| <table class="fieldtable"> |
| <tr><th colspan="2">Enumerator</th></tr><tr><td class="fieldname"><a id="a0dca31b62c0207ea87e146cde0609595a561af55a6a824ae74125a6cf4eade06a" name="a0dca31b62c0207ea87e146cde0609595a561af55a6a824ae74125a6cf4eade06a"></a>SEPARATED </td><td class="fielddoc"><p>Key is stored as message key, while value is stored as message payload. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="a0dca31b62c0207ea87e146cde0609595acfbac07c6ae3e73f0e10ca60ad916bef" name="a0dca31b62c0207ea87e146cde0609595acfbac07c6ae3e73f0e10ca60ad916bef"></a>INLINE </td><td class="fielddoc"><p>Key and value are stored as message payload. </p> |
| </td></tr> |
| </table> |
| |
| </div> |
| </div> |
| <a id="abd9b21e56a6fb78e04cae2664ff0dbbd" name="abd9b21e56a6fb78e04cae2664ff0dbbd"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#abd9b21e56a6fb78e04cae2664ff0dbbd">◆ </a></span>RegexSubscriptionMode</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">enum <a class="el" href="namespacepulsar.html#abd9b21e56a6fb78e04cae2664ff0dbbd">pulsar::RegexSubscriptionMode</a></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <table class="fieldtable"> |
| <tr><th colspan="2">Enumerator</th></tr><tr><td class="fieldname"><a id="abd9b21e56a6fb78e04cae2664ff0dbbda68931062ae96d4dcc4778eeac5fa3de4" name="abd9b21e56a6fb78e04cae2664ff0dbbda68931062ae96d4dcc4778eeac5fa3de4"></a>PersistentOnly </td><td class="fielddoc"><p>Only subscribe to persistent topics. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abd9b21e56a6fb78e04cae2664ff0dbbda5af3d512f79ac90cacc326d86a230603" name="abd9b21e56a6fb78e04cae2664ff0dbbda5af3d512f79ac90cacc326d86a230603"></a>NonPersistentOnly </td><td class="fielddoc"><p>Only subscribe to non-persistent topics. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abd9b21e56a6fb78e04cae2664ff0dbbdaa30bab3d7d550e08f128647cbbd5b6ef" name="abd9b21e56a6fb78e04cae2664ff0dbbdaa30bab3d7d550e08f128647cbbd5b6ef"></a>AllTopics </td><td class="fielddoc"><p>Subscribe to both persistent and non-persistent topics. </p> |
| </td></tr> |
| </table> |
| |
| </div> |
| </div> |
| <a id="ae85314d6b9e8afd831cf8c66705f2dbb" name="ae85314d6b9e8afd831cf8c66705f2dbb"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#ae85314d6b9e8afd831cf8c66705f2dbb">◆ </a></span>Result</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">enum <a class="el" href="namespacepulsar.html#ae85314d6b9e8afd831cf8c66705f2dbb">pulsar::Result</a></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Collection of return codes </p> |
| <table class="fieldtable"> |
| <tr><th colspan="2">Enumerator</th></tr><tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba0aac5dae08c453e94161e28d7cd5a92f" name="ae85314d6b9e8afd831cf8c66705f2dbba0aac5dae08c453e94161e28d7cd5a92f"></a>ResultOk </td><td class="fielddoc"><p>An internal error code used for retry. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba213e39d5c84b8794dd21ab4f60ff4b60" name="ae85314d6b9e8afd831cf8c66705f2dbba213e39d5c84b8794dd21ab4f60ff4b60"></a>ResultUnknownError </td><td class="fielddoc"><p>Operation successful. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbad3d7545107897e19819066fe42e81a06" name="ae85314d6b9e8afd831cf8c66705f2dbbad3d7545107897e19819066fe42e81a06"></a>ResultInvalidConfiguration </td><td class="fielddoc"><p>Unknown error happened on broker. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbaeb1858ddf791b7288ab1cb066d70cfb4" name="ae85314d6b9e8afd831cf8c66705f2dbbaeb1858ddf791b7288ab1cb066d70cfb4"></a>ResultTimeout </td><td class="fielddoc"><p>Invalid configuration. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba42ae88341f22c34ed9baac35804f1b01" name="ae85314d6b9e8afd831cf8c66705f2dbba42ae88341f22c34ed9baac35804f1b01"></a>ResultLookupError </td><td class="fielddoc"><p>Operation timed out. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbab26ee1bb88fafefa107071fa1fd775bc" name="ae85314d6b9e8afd831cf8c66705f2dbbab26ee1bb88fafefa107071fa1fd775bc"></a>ResultConnectError </td><td class="fielddoc"><p>Broker lookup failed. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbaa084aea99a198f2d01c6c98eeb44ff9e" name="ae85314d6b9e8afd831cf8c66705f2dbbaa084aea99a198f2d01c6c98eeb44ff9e"></a>ResultReadError </td><td class="fielddoc"><p>Failed to connect to broker. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba2b40eba56a27dc5615338a0d988e2024" name="ae85314d6b9e8afd831cf8c66705f2dbba2b40eba56a27dc5615338a0d988e2024"></a>ResultAuthenticationError </td><td class="fielddoc"><p>Failed to read from socket. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba4db07aa497065f6cc0d8e314bf852057" name="ae85314d6b9e8afd831cf8c66705f2dbba4db07aa497065f6cc0d8e314bf852057"></a>ResultAuthorizationError </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_authentication.html">Authentication</a> failed on broker. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba8014344f94ba9ad55337f01767e0e30c" name="ae85314d6b9e8afd831cf8c66705f2dbba8014344f94ba9ad55337f01767e0e30c"></a>ResultErrorGettingAuthenticationData </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_client.html">Client</a> is not authorized to create producer/consumer. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba2188e16c2e397cee5f64aef6799c419c" name="ae85314d6b9e8afd831cf8c66705f2dbba2188e16c2e397cee5f64aef6799c419c"></a>ResultBrokerMetadataError </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_client.html">Client</a> cannot find authorization data. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba3ac5992ae486593f5aee1538970b51a6" name="ae85314d6b9e8afd831cf8c66705f2dbba3ac5992ae486593f5aee1538970b51a6"></a>ResultBrokerPersistenceError </td><td class="fielddoc"><p>Broker failed in updating metadata. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba60d3371f74155ecb5b11efbf217a2174" name="ae85314d6b9e8afd831cf8c66705f2dbba60d3371f74155ecb5b11efbf217a2174"></a>ResultChecksumError </td><td class="fielddoc"><p>Broker failed to persist entry. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba5cbe2e189b60f91ff0f2e82b973db31b" name="ae85314d6b9e8afd831cf8c66705f2dbba5cbe2e189b60f91ff0f2e82b973db31b"></a>ResultConsumerBusy </td><td class="fielddoc"><p>Corrupt message checksum failure. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba00976fab0138d80c5fc621e3a44046b6" name="ae85314d6b9e8afd831cf8c66705f2dbba00976fab0138d80c5fc621e3a44046b6"></a>ResultNotConnected </td><td class="fielddoc"><p>Exclusive consumer is already connected. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba6c11f7cd8f0bc274d12c5157157ad916" name="ae85314d6b9e8afd831cf8c66705f2dbba6c11f7cd8f0bc274d12c5157157ad916"></a>ResultAlreadyClosed </td><td class="fielddoc"><p>Producer/Consumer is not currently connected to broker. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba875234396481a34fb7f02d3ecd1936f0" name="ae85314d6b9e8afd831cf8c66705f2dbba875234396481a34fb7f02d3ecd1936f0"></a>ResultInvalidMessage </td><td class="fielddoc"><p>Producer/Consumer is already closed and not accepting any operation. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba48d27a5310cda91d13a23324a08533e9" name="ae85314d6b9e8afd831cf8c66705f2dbba48d27a5310cda91d13a23324a08533e9"></a>ResultConsumerNotInitialized </td><td class="fielddoc"><p>Error in publishing an already used message. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba2b5f050c9b2aef10831927cece55b02a" name="ae85314d6b9e8afd831cf8c66705f2dbba2b5f050c9b2aef10831927cece55b02a"></a>ResultProducerNotInitialized </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> is not initialized. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbad0a7588cc2ac84de7fc17331ed59b544" name="ae85314d6b9e8afd831cf8c66705f2dbbad0a7588cc2ac84de7fc17331ed59b544"></a>ResultProducerBusy </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_producer.html">Producer</a> is not initialized. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba024fa5ba9fac2cb81fd4e8f6853a81a5" name="ae85314d6b9e8afd831cf8c66705f2dbba024fa5ba9fac2cb81fd4e8f6853a81a5"></a>ResultTooManyLookupRequestException </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_producer.html">Producer</a> with same name is already connected. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbafcb0b43f04e494ba3784f6c259b5137f" name="ae85314d6b9e8afd831cf8c66705f2dbbafcb0b43f04e494ba3784f6c259b5137f"></a>ResultInvalidTopicName </td><td class="fielddoc"><p>Too Many concurrent LookupRequest. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba685954a2aedb14c0f3669d579bfd1193" name="ae85314d6b9e8afd831cf8c66705f2dbba685954a2aedb14c0f3669d579bfd1193"></a>ResultInvalidUrl </td><td class="fielddoc"><p>Invalid topic name. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbaf8a459f352105f7e853e02ca2af193b0" name="ae85314d6b9e8afd831cf8c66705f2dbbaf8a459f352105f7e853e02ca2af193b0"></a>ResultServiceUnitNotReady </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_client.html">Client</a> Initialized with Invalid Broker Url (VIP Url passed to <a class="el" href="classpulsar_1_1_client.html">Client</a> Constructor) </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba60abb5ad06a78a3d6d40b2131534dfeb" name="ae85314d6b9e8afd831cf8c66705f2dbba60abb5ad06a78a3d6d40b2131534dfeb"></a>ResultOperationNotSupported </td><td class="fielddoc"><p>Service Unit unloaded between client did lookup and producer/consumer got created </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbab5cc52655496666d96f35edab07c9e7f" name="ae85314d6b9e8afd831cf8c66705f2dbbab5cc52655496666d96f35edab07c9e7f"></a>ResultProducerBlockedQuotaExceededException </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_producer.html">Producer</a> is blocked. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba1849c732b1ec8c7e1c0aa653de998d81" name="ae85314d6b9e8afd831cf8c66705f2dbba1849c732b1ec8c7e1c0aa653de998d81"></a>ResultProducerQueueIsFull </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_producer.html">Producer</a> is getting exception. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba43765d6a6cab85363b2cad047371294b" name="ae85314d6b9e8afd831cf8c66705f2dbba43765d6a6cab85363b2cad047371294b"></a>ResultMessageTooBig </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_producer.html">Producer</a> queue is full. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbad1921e33dd6a45431a0209b70588cf48" name="ae85314d6b9e8afd831cf8c66705f2dbbad1921e33dd6a45431a0209b70588cf48"></a>ResultTopicNotFound </td><td class="fielddoc"><p>Trying to send a messages exceeding the max size. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba061d6c40bdf75ca172ffdb862aad7c51" name="ae85314d6b9e8afd831cf8c66705f2dbba061d6c40bdf75ca172ffdb862aad7c51"></a>ResultSubscriptionNotFound </td><td class="fielddoc"><p>Topic not found. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbac74e9fb1b2c25caf17ac3446303b7a71" name="ae85314d6b9e8afd831cf8c66705f2dbbac74e9fb1b2c25caf17ac3446303b7a71"></a>ResultConsumerNotFound </td><td class="fielddoc"><p>Subscription not found. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba888578f8569121606cfcfa6044c594c3" name="ae85314d6b9e8afd831cf8c66705f2dbba888578f8569121606cfcfa6044c594c3"></a>ResultUnsupportedVersionError </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_consumer.html">Consumer</a> not found. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba62df217dec3d3f75c7099d1464c92750" name="ae85314d6b9e8afd831cf8c66705f2dbba62df217dec3d3f75c7099d1464c92750"></a>ResultTopicTerminated </td><td class="fielddoc"><p>Error when an older client/version doesn't support a required feature. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbac131b27876dfd64d8e6b3355578a8f77" name="ae85314d6b9e8afd831cf8c66705f2dbbac131b27876dfd64d8e6b3355578a8f77"></a>ResultCryptoError </td><td class="fielddoc"><p>Topic was already terminated. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbafe509853528453adc4ca304ea9b1d79e" name="ae85314d6b9e8afd831cf8c66705f2dbbafe509853528453adc4ca304ea9b1d79e"></a>ResultIncompatibleSchema </td><td class="fielddoc"><p>Error when crypto operation fails. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbac0f35889e7dd6cb7f634baedb8481e9e" name="ae85314d6b9e8afd831cf8c66705f2dbbac0f35889e7dd6cb7f634baedb8481e9e"></a>ResultConsumerAssignError </td><td class="fielddoc"><p>Specified schema is incompatible with the topic's schema. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba2e01cfc218b721cbd2e2a06bf3cb78b0" name="ae85314d6b9e8afd831cf8c66705f2dbba2e01cfc218b721cbd2e2a06bf3cb78b0"></a>ResultCumulativeAcknowledgementNotAllowedError </td><td class="fielddoc"><p>Error when a new consumer connected but can't assign messages to this consumer </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba653a82475a2715f839ba52329a9b6414" name="ae85314d6b9e8afd831cf8c66705f2dbba653a82475a2715f839ba52329a9b6414"></a>ResultTransactionCoordinatorNotFoundError </td><td class="fielddoc"><p>Not allowed to call cumulativeAcknowledgement in Shared and Key_Shared subscription mode </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba742ada2f12ae5b2ca11fa674889dc186" name="ae85314d6b9e8afd831cf8c66705f2dbba742ada2f12ae5b2ca11fa674889dc186"></a>ResultInvalidTxnStatusError </td><td class="fielddoc"><p>Transaction coordinator not found. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbad38a4ab387c0769f3c8c30fd2c7413a1" name="ae85314d6b9e8afd831cf8c66705f2dbbad38a4ab387c0769f3c8c30fd2c7413a1"></a>ResultNotAllowedError </td><td class="fielddoc"><p>Invalid txn status error. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba39c2049f4e7e428d2a4473b68223a53c" name="ae85314d6b9e8afd831cf8c66705f2dbba39c2049f4e7e428d2a4473b68223a53c"></a>ResultTransactionConflict </td><td class="fielddoc"><p>Not allowed. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbbaf4bfae37b494ea0a2599cc4596bccdf0" name="ae85314d6b9e8afd831cf8c66705f2dbbaf4bfae37b494ea0a2599cc4596bccdf0"></a>ResultTransactionNotFound </td><td class="fielddoc"><p>Transaction ack conflict. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba6370706ff98bf4c513f11489679543cb" name="ae85314d6b9e8afd831cf8c66705f2dbba6370706ff98bf4c513f11489679543cb"></a>ResultProducerFenced </td><td class="fielddoc"><p>Transaction not found. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba7eaf7df2c4a2ac2f874e044db02c6733" name="ae85314d6b9e8afd831cf8c66705f2dbba7eaf7df2c4a2ac2f874e044db02c6733"></a>ResultMemoryBufferIsFull </td><td class="fielddoc"><p><a class="el" href="classpulsar_1_1_producer.html">Producer</a> was fenced by broker. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba67722ba0750e461ae03912f5dc10d03a" name="ae85314d6b9e8afd831cf8c66705f2dbba67722ba0750e461ae03912f5dc10d03a"></a>ResultInterrupted </td><td class="fielddoc"><p>Client-wide memory limit has been reached. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="ae85314d6b9e8afd831cf8c66705f2dbba287510a5c9a382f29f0cbdf3d32c0d59" name="ae85314d6b9e8afd831cf8c66705f2dbba287510a5c9a382f29f0cbdf3d32c0d59"></a>ResultDisconnected </td><td class="fielddoc"><p>Interrupted while waiting to dequeue. </p> |
| </td></tr> |
| </table> |
| |
| </div> |
| </div> |
| <a id="abab5b1f233c9cc54c10d28cb5b973305" name="abab5b1f233c9cc54c10d28cb5b973305"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#abab5b1f233c9cc54c10d28cb5b973305">◆ </a></span>SchemaType</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">enum <a class="el" href="namespacepulsar.html#abab5b1f233c9cc54c10d28cb5b973305">pulsar::SchemaType</a></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <table class="fieldtable"> |
| <tr><th colspan="2">Enumerator</th></tr><tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305af9377cb56d5b6973392d0fd2ca76009a" name="abab5b1f233c9cc54c10d28cb5b973305af9377cb56d5b6973392d0fd2ca76009a"></a>NONE </td><td class="fielddoc"><p>No schema defined </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305ab936a9dad2cbb5fca28fc477ff39fb70" name="abab5b1f233c9cc54c10d28cb5b973305ab936a9dad2cbb5fca28fc477ff39fb70"></a>STRING </td><td class="fielddoc"><p>Simple String encoding with UTF-8 </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305a15f7910601e8d522f151f3129c753283" name="abab5b1f233c9cc54c10d28cb5b973305a15f7910601e8d522f151f3129c753283"></a>JSON </td><td class="fielddoc"><p>JSON object encoding and validation </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305a5054f171f6c60b73043727ddc60698a0" name="abab5b1f233c9cc54c10d28cb5b973305a5054f171f6c60b73043727ddc60698a0"></a>PROTOBUF </td><td class="fielddoc"><p>Protobuf message encoding and decoding </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305ac728ff4cb4de807c1b6fa8ca33f41d47" name="abab5b1f233c9cc54c10d28cb5b973305ac728ff4cb4de807c1b6fa8ca33f41d47"></a>AVRO </td><td class="fielddoc"><p>Serialize and deserialize via Avro </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305a2c52dde965d6ba972179fa14116160e9" name="abab5b1f233c9cc54c10d28cb5b973305a2c52dde965d6ba972179fa14116160e9"></a>INT8 </td><td class="fielddoc"><p>A 8-byte integer. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305a9e5ed020cb2ca197a0918946352cf96e" name="abab5b1f233c9cc54c10d28cb5b973305a9e5ed020cb2ca197a0918946352cf96e"></a>INT16 </td><td class="fielddoc"><p>A 16-byte integer. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305ac048e1576ab161018f9e3c6eda6307d0" name="abab5b1f233c9cc54c10d28cb5b973305ac048e1576ab161018f9e3c6eda6307d0"></a>INT32 </td><td class="fielddoc"><p>A 32-byte integer. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305a11fafed4115309cf1f33eac044e704a2" name="abab5b1f233c9cc54c10d28cb5b973305a11fafed4115309cf1f33eac044e704a2"></a>INT64 </td><td class="fielddoc"><p>A 64-byte integer. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305a5102395892b9d15d0a0483a27ca64777" name="abab5b1f233c9cc54c10d28cb5b973305a5102395892b9d15d0a0483a27ca64777"></a>FLOAT </td><td class="fielddoc"><p>A float number. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305a1b1684230ae9c15941cb3fe05bf972f0" name="abab5b1f233c9cc54c10d28cb5b973305a1b1684230ae9c15941cb3fe05bf972f0"></a>DOUBLE </td><td class="fielddoc"><p>A double number </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305ab6fbe0f5b80de2aa67b68572e7a054d3" name="abab5b1f233c9cc54c10d28cb5b973305ab6fbe0f5b80de2aa67b68572e7a054d3"></a>KEY_VALUE </td><td class="fielddoc"><p>A Schema that contains Key Schema and Value Schema. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305a24048f6ae2e1048989e69644edcdc8f6" name="abab5b1f233c9cc54c10d28cb5b973305a24048f6ae2e1048989e69644edcdc8f6"></a>PROTOBUF_NATIVE </td><td class="fielddoc"><p>Protobuf native schema based on Descriptor. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305a4dcbdcae67c5f78b7c4fff2c2135cba2" name="abab5b1f233c9cc54c10d28cb5b973305a4dcbdcae67c5f78b7c4fff2c2135cba2"></a>BYTES </td><td class="fielddoc"><p>A bytes array. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305a6a9078e01119bddf19aa24dc05390f99" name="abab5b1f233c9cc54c10d28cb5b973305a6a9078e01119bddf19aa24dc05390f99"></a>AUTO_CONSUME </td><td class="fielddoc"><p>Auto Consume Type. </p> |
| </td></tr> |
| <tr><td class="fieldname"><a id="abab5b1f233c9cc54c10d28cb5b973305ad1af93d272614c940d322497eb8e31f0" name="abab5b1f233c9cc54c10d28cb5b973305ad1af93d272614c940d322497eb8e31f0"></a>AUTO_PUBLISH </td><td class="fielddoc"><p>Auto Publish Type. </p> |
| </td></tr> |
| </table> |
| |
| </div> |
| </div> |
| <h2 class="groupheader">Function Documentation</h2> |
| <a id="a7dc480604aefdd4119b2e2ee2b9e7764" name="a7dc480604aefdd4119b2e2ee2b9e7764"></a> |
| <h2 class="memtitle"><span class="permalink"><a href="#a7dc480604aefdd4119b2e2ee2b9e7764">◆ </a></span>createProtobufNativeSchema()</h2> |
| |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">PULSAR_PUBLIC <a class="el" href="classpulsar_1_1_schema_info.html">SchemaInfo</a> pulsar::createProtobufNativeSchema </td> |
| <td>(</td> |
| <td class="paramtype">const google::protobuf::Descriptor * </td> |
| <td class="paramname"><em>descriptor</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Create a protobuf native schema using a descriptor.</p> |
| <dl class="params"><dt>Parameters</dt><dd> |
| <table class="params"> |
| <tr><td class="paramname">descriptor</td><td>the Descriptor object of the target class </td></tr> |
| </table> |
| </dd> |
| </dl> |
| <dl class="section return"><dt>Returns</dt><dd>the protobuf native schema </dd></dl> |
| <dl class="exception"><dt>Exceptions</dt><dd> |
| <table class="exception"> |
| <tr><td class="paramname">std::invalid_argument</td><td>if descriptor is nullptr </td></tr> |
| </table> |
| </dd> |
| </dl> |
| |
| </div> |
| </div> |
| </div><!-- contents --> |
| <!-- start footer part --> |
| <hr class="footer"/><address class="footer"><small> |
| Generated by <a href="https://www.doxygen.org/index.html"><img class="footer" src="doxygen.svg" width="104" height="31" alt="doxygen"/></a> 1.9.7 |
| </small></address> |
| </body> |
| </html> |
