| <?xml version="1.0" encoding="utf-8"?> |
| <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" |
| "DTD/xhtml1-strict.dtd"> |
| <html> |
| |
| |
| <head> |
| |
| <title>Class Hierarchy</title> |
| <meta name="generator" content="pydoctor 25.4.0"> |
| |
| </meta> |
| <meta http-equiv="Content-Type" content="text/html;charset=utf-8" /> |
| <meta name="viewport" content="width=device-width, initial-scale=1 maximum-scale=1" /> |
| <link rel="stylesheet" type="text/css" href="apidocs.css" /> |
| <link rel="stylesheet" type="text/css" href="readthedocstheme.css" /> |
| <link rel="stylesheet" type="text/css" href="extra.css" /> |
| |
| </head> |
| |
| <body> |
| |
| |
| |
| <nav class="navbar navbar-default mainnavbar"> |
| |
| |
| <div class="container-fluid"> |
| |
| |
| <div class="navbar-header"> |
| |
| <div class="navlinks"> |
| <span class="navbar-brand"> |
| _pulsar/pulsar <a href="index.html">API Documentation</a> |
| </span> |
| |
| <a href="moduleIndex.html"> |
| Modules |
| </a> |
| |
| <a href="classIndex.html"> |
| Classes |
| </a> |
| |
| <a href="nameIndex.html"> |
| Names |
| </a> |
| |
| <div id="search-box-container"> |
| <div class="input-group"> |
| <input id="search-box" type="search" name="search-query" placeholder="Search..." aria-label="Search" minlength="2" class="form-control" autocomplete="off" /> |
| |
| <span class="input-group-btn"> |
| <a style="display: none;" class="btn btn-default" id="search-clear-button" title="Clear" onclick="clearSearch()"><img src="fonts/x-circle.svg" alt="Clear" /></a> |
| <a class="btn btn-default" id="apidocs-help-button" title="Help" href="apidocs-help.html"><img src="fonts/info.svg" alt="Help" /></a> |
| </span> |
| </div> |
| </div> |
| |
| </div> |
| |
| <div id="search-results-container" style="display: none;"> |
| |
| <div id="search-buttons"> |
| <span class="label label-default" id="search-docstrings-button"> |
| <label class="checkbox-inline"> |
| <input type="checkbox" id="toggle-search-in-docstrings-checkbox" value="false" onclick="toggleSearchInDocstrings()"> |
| search in docstrings |
| </input> |
| </label> |
| </span> |
| |
| </div> |
| |
| <noscript> |
| <h1>Cannot search: JavaScript is not supported/enabled in your browser.</h1> |
| </noscript> |
| |
| <div id="search-status"> </div> |
| |
| <div class="warning" id="search-warn-box" style="display: none;"> |
| <p class="rst-last"><span id="search-warn"></span></p> |
| </div> |
| |
| <table id="search-results"> |
| <!-- Filled dynamically by JS --> |
| </table> |
| |
| <div style="margin-top: 10px;"> |
| <p>For more information on the search, visit the <a href="apidocs-help.html#rst-search">help page</a>.</p> |
| </div> |
| </div> |
| |
| </div> |
| |
| |
| </div> |
| </nav> |
| |
| <div class="container-fluid"> |
| |
| <div class="page-header"> |
| <h1>Class Hierarchy</h1> |
| <div id="showPrivate"> |
| <button class="btn btn-link" onclick="togglePrivate()">Toggle Private API</button> |
| </div> |
| </div> |
| |
| <ul id="summaryTree"> |
| <li class="private"><a name="_pulsar.AbstractCryptoKeyReader"></a><div><code><a href="_pulsar.AbstractCryptoKeyReader.html" class="internal-link">_pulsar.AbstractCryptoKeyReader</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.AlreadyClosed"></a><div><code><a href="_pulsar.AlreadyClosed.html" class="internal-link">_pulsar.AlreadyClosed</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.Authentication"></a><div><code><a href="_pulsar.Authentication.html" class="internal-link">_pulsar.Authentication</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.AuthenticationAthenz"></a><div><code><a href="_pulsar.AuthenticationAthenz.html" class="internal-link">_pulsar.AuthenticationAthenz</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.AuthenticationBasic"></a><div><code><a href="_pulsar.AuthenticationBasic.html" class="internal-link">_pulsar.AuthenticationBasic</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.AuthenticationError"></a><div><code><a href="_pulsar.AuthenticationError.html" class="internal-link">_pulsar.AuthenticationError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.AuthenticationOauth2"></a><div><code><a href="_pulsar.AuthenticationOauth2.html" class="internal-link">_pulsar.AuthenticationOauth2</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.AuthenticationTLS"></a><div><code><a href="_pulsar.AuthenticationTLS.html" class="internal-link">_pulsar.AuthenticationTLS</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.AuthenticationToken"></a><div><code><a href="_pulsar.AuthenticationToken.html" class="internal-link">_pulsar.AuthenticationToken</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.AuthorizationError"></a><div><code><a href="_pulsar.AuthorizationError.html" class="internal-link">_pulsar.AuthorizationError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.BatchingType"></a><div><code><a href="_pulsar.BatchingType.html" class="internal-link">_pulsar.BatchingType</a></code> - Supported batching types</div></li><li class="private"><a name="_pulsar.BatchReceivePolicy"></a><div><code><a href="_pulsar.BatchReceivePolicy.html" class="internal-link">_pulsar.BatchReceivePolicy</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.BrokerMetadataError"></a><div><code><a href="_pulsar.BrokerMetadataError.html" class="internal-link">_pulsar.BrokerMetadataError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.BrokerPersistenceError"></a><div><code><a href="_pulsar.BrokerPersistenceError.html" class="internal-link">_pulsar.BrokerPersistenceError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ChecksumError"></a><div><code><a href="_pulsar.ChecksumError.html" class="internal-link">_pulsar.ChecksumError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.Client"></a><div><code><a href="_pulsar.Client.html" class="internal-link">_pulsar.Client</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ClientConfiguration"></a><div><code><a href="_pulsar.ClientConfiguration.html" class="internal-link">_pulsar.ClientConfiguration</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.CompressionType"></a><div><code><a href="_pulsar.CompressionType.html" class="internal-link">_pulsar.CompressionType</a></code> - Members:</div></li><li class="private"><a name="_pulsar.ConnectError"></a><div><code><a href="_pulsar.ConnectError.html" class="internal-link">_pulsar.ConnectError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.Consumer"></a><div><code><a href="_pulsar.Consumer.html" class="internal-link">_pulsar.Consumer</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ConsumerAssignError"></a><div><code><a href="_pulsar.ConsumerAssignError.html" class="internal-link">_pulsar.ConsumerAssignError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ConsumerBusy"></a><div><code><a href="_pulsar.ConsumerBusy.html" class="internal-link">_pulsar.ConsumerBusy</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ConsumerConfiguration"></a><div><code><a href="_pulsar.ConsumerConfiguration.html" class="internal-link">_pulsar.ConsumerConfiguration</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ConsumerCryptoFailureAction"></a><div><code><a href="_pulsar.ConsumerCryptoFailureAction.html" class="internal-link">_pulsar.ConsumerCryptoFailureAction</a></code> - Members:</div></li><li class="private"><a name="_pulsar.ConsumerNotFound"></a><div><code><a href="_pulsar.ConsumerNotFound.html" class="internal-link">_pulsar.ConsumerNotFound</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ConsumerNotInitialized"></a><div><code><a href="_pulsar.ConsumerNotInitialized.html" class="internal-link">_pulsar.ConsumerNotInitialized</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ConsumerType"></a><div><code><a href="_pulsar.ConsumerType.html" class="internal-link">_pulsar.ConsumerType</a></code> - Members:</div></li><li class="private"><a name="_pulsar.CryptoError"></a><div><code><a href="_pulsar.CryptoError.html" class="internal-link">_pulsar.CryptoError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.CryptoKeyReader"></a><div><code><a href="_pulsar.CryptoKeyReader.html" class="internal-link">_pulsar.CryptoKeyReader</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.CumulativeAcknowledgementNotAllowedError"></a><div><code><a href="_pulsar.CumulativeAcknowledgementNotAllowedError.html" class="internal-link">_pulsar.CumulativeAcknowledgementNotAllowedError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.DeadLetterPolicy"></a><div><code><a href="_pulsar.DeadLetterPolicy.html" class="internal-link">_pulsar.DeadLetterPolicy</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.DeadLetterPolicyBuilder"></a><div><code><a href="_pulsar.DeadLetterPolicyBuilder.html" class="internal-link">_pulsar.DeadLetterPolicyBuilder</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.EncryptionContext"></a><div><code><a href="_pulsar.EncryptionContext.html" class="internal-link">_pulsar.EncryptionContext</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.EncryptionKey"></a><div><code><a href="_pulsar.EncryptionKey.html" class="internal-link">_pulsar.EncryptionKey</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ErrorGettingAuthenticationData"></a><div><code><a href="_pulsar.ErrorGettingAuthenticationData.html" class="internal-link">_pulsar.ErrorGettingAuthenticationData</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.IncompatibleSchema"></a><div><code><a href="_pulsar.IncompatibleSchema.html" class="internal-link">_pulsar.IncompatibleSchema</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.InitialPosition"></a><div><code><a href="_pulsar.InitialPosition.html" class="internal-link">_pulsar.InitialPosition</a></code> - Supported initial position</div></li><li class="private"><a name="_pulsar.Interrupted"></a><div><code><a href="_pulsar.Interrupted.html" class="internal-link">_pulsar.Interrupted</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.InvalidConfiguration"></a><div><code><a href="_pulsar.InvalidConfiguration.html" class="internal-link">_pulsar.InvalidConfiguration</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.InvalidMessage"></a><div><code><a href="_pulsar.InvalidMessage.html" class="internal-link">_pulsar.InvalidMessage</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.InvalidTopicName"></a><div><code><a href="_pulsar.InvalidTopicName.html" class="internal-link">_pulsar.InvalidTopicName</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.InvalidTxnStatusError"></a><div><code><a href="_pulsar.InvalidTxnStatusError.html" class="internal-link">_pulsar.InvalidTxnStatusError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.InvalidUrl"></a><div><code><a href="_pulsar.InvalidUrl.html" class="internal-link">_pulsar.InvalidUrl</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.KeySharedMode"></a><div><code><a href="_pulsar.KeySharedMode.html" class="internal-link">_pulsar.KeySharedMode</a></code> - Members:</div></li><li class="private"><a name="_pulsar.KeySharedPolicy"></a><div><code><a href="_pulsar.KeySharedPolicy.html" class="internal-link">_pulsar.KeySharedPolicy</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.LoggerLevel"></a><div><code><a href="_pulsar.LoggerLevel.html" class="internal-link">_pulsar.LoggerLevel</a></code> - Members:</div></li><li class="private"><a name="_pulsar.LookupError"></a><div><code><a href="_pulsar.LookupError.html" class="internal-link">_pulsar.LookupError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.MemoryBufferIsFull"></a><div><code><a href="_pulsar.MemoryBufferIsFull.html" class="internal-link">_pulsar.MemoryBufferIsFull</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.Message"></a><div><code><a href="_pulsar.Message.html" class="internal-link">_pulsar.Message</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.MessageBatch"></a><div><code><a href="_pulsar.MessageBatch.html" class="internal-link">_pulsar.MessageBatch</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.MessageBuilder"></a><div><code><a href="_pulsar.MessageBuilder.html" class="internal-link">_pulsar.MessageBuilder</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.MessageId"></a><div><code><a href="_pulsar.MessageId.html" class="internal-link">_pulsar.MessageId</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.MessageTooBig"></a><div><code><a href="_pulsar.MessageTooBig.html" class="internal-link">_pulsar.MessageTooBig</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.NotAllowedError"></a><div><code><a href="_pulsar.NotAllowedError.html" class="internal-link">_pulsar.NotAllowedError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.NotConnected"></a><div><code><a href="_pulsar.NotConnected.html" class="internal-link">_pulsar.NotConnected</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.OperationNotSupported"></a><div><code><a href="_pulsar.OperationNotSupported.html" class="internal-link">_pulsar.OperationNotSupported</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.PartitionsRoutingMode"></a><div><code><a href="_pulsar.PartitionsRoutingMode.html" class="internal-link">_pulsar.PartitionsRoutingMode</a></code> - Members:</div></li><li class="private"><a name="_pulsar.Producer"></a><div><code><a href="_pulsar.Producer.html" class="internal-link">_pulsar.Producer</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ProducerAccessMode"></a><div><code><a href="_pulsar.ProducerAccessMode.html" class="internal-link">_pulsar.ProducerAccessMode</a></code> - Producer Access Mode</div></li><li class="private"><a name="_pulsar.ProducerBlockedQuotaExceededError"></a><div><code><a href="_pulsar.ProducerBlockedQuotaExceededError.html" class="internal-link">_pulsar.ProducerBlockedQuotaExceededError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ProducerBlockedQuotaExceededException"></a><div><code><a href="_pulsar.ProducerBlockedQuotaExceededException.html" class="internal-link">_pulsar.ProducerBlockedQuotaExceededException</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ProducerBusy"></a><div><code><a href="_pulsar.ProducerBusy.html" class="internal-link">_pulsar.ProducerBusy</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ProducerConfiguration"></a><div><code><a href="_pulsar.ProducerConfiguration.html" class="internal-link">_pulsar.ProducerConfiguration</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ProducerFenced"></a><div><code><a href="_pulsar.ProducerFenced.html" class="internal-link">_pulsar.ProducerFenced</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ProducerNotInitialized"></a><div><code><a href="_pulsar.ProducerNotInitialized.html" class="internal-link">_pulsar.ProducerNotInitialized</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ProducerQueueIsFull"></a><div><code><a href="_pulsar.ProducerQueueIsFull.html" class="internal-link">_pulsar.ProducerQueueIsFull</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.PulsarException"></a><div><code><a href="_pulsar.PulsarException.html" class="internal-link">_pulsar.PulsarException</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.Reader"></a><div><code><a href="_pulsar.Reader.html" class="internal-link">_pulsar.Reader</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ReaderConfiguration"></a><div><code><a href="_pulsar.ReaderConfiguration.html" class="internal-link">_pulsar.ReaderConfiguration</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ReadError"></a><div><code><a href="_pulsar.ReadError.html" class="internal-link">_pulsar.ReadError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.RegexSubscriptionMode"></a><div><code><a href="_pulsar.RegexSubscriptionMode.html" class="internal-link">_pulsar.RegexSubscriptionMode</a></code> - Regex subscription mode</div></li><li class="private"><a name="_pulsar.Result"></a><div><code><a href="_pulsar.Result.html" class="internal-link">_pulsar.Result</a></code> - Collection of return codes</div></li><li class="private"><a name="_pulsar.SchemaInfo"></a><div><code><a href="_pulsar.SchemaInfo.html" class="internal-link">_pulsar.SchemaInfo</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.SchemaType"></a><div><code><a href="_pulsar.SchemaType.html" class="internal-link">_pulsar.SchemaType</a></code> - Supported schema types</div></li><li class="private"><a name="_pulsar.ServiceInfo"></a><div><code><a href="_pulsar.ServiceInfo.html" class="internal-link">_pulsar.ServiceInfo</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.ServiceUnitNotReady"></a><div><code><a href="_pulsar.ServiceUnitNotReady.html" class="internal-link">_pulsar.ServiceUnitNotReady</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.SubscriptionNotFound"></a><div><code><a href="_pulsar.SubscriptionNotFound.html" class="internal-link">_pulsar.SubscriptionNotFound</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.TableView"></a><div><code><a href="_pulsar.TableView.html" class="internal-link">_pulsar.TableView</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.TableViewConfiguration"></a><div><code><a href="_pulsar.TableViewConfiguration.html" class="internal-link">_pulsar.TableViewConfiguration</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.Timeout"></a><div><code><a href="_pulsar.Timeout.html" class="internal-link">_pulsar.Timeout</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.TooManyLookupRequestException"></a><div><code><a href="_pulsar.TooManyLookupRequestException.html" class="internal-link">_pulsar.TooManyLookupRequestException</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.TopicNotFound"></a><div><code><a href="_pulsar.TopicNotFound.html" class="internal-link">_pulsar.TopicNotFound</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.TopicTerminated"></a><div><code><a href="_pulsar.TopicTerminated.html" class="internal-link">_pulsar.TopicTerminated</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.TransactionConflict"></a><div><code><a href="_pulsar.TransactionConflict.html" class="internal-link">_pulsar.TransactionConflict</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.TransactionCoordinatorNotFoundError"></a><div><code><a href="_pulsar.TransactionCoordinatorNotFoundError.html" class="internal-link">_pulsar.TransactionCoordinatorNotFoundError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.TransactionNotFound"></a><div><code><a href="_pulsar.TransactionNotFound.html" class="internal-link">_pulsar.TransactionNotFound</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.UnknownError"></a><div><code><a href="_pulsar.UnknownError.html" class="internal-link">_pulsar.UnknownError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li class="private"><a name="_pulsar.UnsupportedVersionError"></a><div><code><a href="_pulsar.UnsupportedVersionError.html" class="internal-link">_pulsar.UnsupportedVersionError</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><code><a href="https://docs.python.org/3/library/exceptions.html#BaseException" class="intersphinx-link">BaseException</a></code><ul><li><a name="pulsar.asyncio.PulsarException"></a><div><code><a href="pulsar.asyncio.PulsarException.html" class="internal-link">pulsar.asyncio.PulsarException</a></code> - The exception that wraps the Pulsar error code</div></li></ul></li><li><code><a href="https://docs.python.org/3/library/functions.html#object" class="intersphinx-link">object</a></code><ul><li><a name="pulsar.functions.context.Context"></a><div><code><a href="pulsar.functions.context.Context.html" class="internal-link">pulsar.functions.context.Context</a></code> - Interface defining information available at process time</div></li><li><a name="pulsar.functions.function.Function"></a><div><code><a href="pulsar.functions.function.Function.html" class="internal-link">pulsar.functions.function.Function</a></code> - Interface for Pulsar Function</div></li><li><a name="pulsar.functions.serde.SerDe"></a><div><code><a href="pulsar.functions.serde.SerDe.html" class="internal-link">pulsar.functions.serde.SerDe</a></code> - Interface for Serialization/Deserialization</div><ul><li><a name="pulsar.functions.serde.IdentitySerDe"></a><div><code><a href="pulsar.functions.serde.IdentitySerDe.html" class="internal-link">pulsar.functions.serde.IdentitySerDe</a></code> - Simple Serde that just conversion to string and back</div></li><li><a name="pulsar.functions.serde.PickleSerDe"></a><div><code><a href="pulsar.functions.serde.PickleSerDe.html" class="internal-link">pulsar.functions.serde.PickleSerDe</a></code> - Pickle based serializer</div></li></ul></li><li><a name="pulsar.schema.definition.Field"></a><div><code><a href="pulsar.schema.definition.Field.html" class="internal-link">pulsar.schema.definition.Field</a></code> - <span class="rst-undocumented">Undocumented</span></div><ul><li><a name="pulsar.schema.definition.Array"></a><div><code><a href="pulsar.schema.definition.Array.html" class="internal-link">pulsar.schema.definition.Array</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.definition.Boolean"></a><div><code><a href="pulsar.schema.definition.Boolean.html" class="internal-link">pulsar.schema.definition.Boolean</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.definition.Bytes"></a><div><code><a href="pulsar.schema.definition.Bytes.html" class="internal-link">pulsar.schema.definition.Bytes</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.definition.CustomEnum"></a><div><code><a href="pulsar.schema.definition.CustomEnum.html" class="internal-link">pulsar.schema.definition.CustomEnum</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.definition.Double"></a><div><code><a href="pulsar.schema.definition.Double.html" class="internal-link">pulsar.schema.definition.Double</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.definition.Float"></a><div><code><a href="pulsar.schema.definition.Float.html" class="internal-link">pulsar.schema.definition.Float</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.definition.Integer"></a><div><code><a href="pulsar.schema.definition.Integer.html" class="internal-link">pulsar.schema.definition.Integer</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.definition.Long"></a><div><code><a href="pulsar.schema.definition.Long.html" class="internal-link">pulsar.schema.definition.Long</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.definition.Map"></a><div><code><a href="pulsar.schema.definition.Map.html" class="internal-link">pulsar.schema.definition.Map</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.definition.Null"></a><div><code><a href="pulsar.schema.definition.Null.html" class="internal-link">pulsar.schema.definition.Null</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.definition.String"></a><div><code><a href="pulsar.schema.definition.String.html" class="internal-link">pulsar.schema.definition.String</a></code> - <span class="rst-undocumented">Undocumented</span></div></li></ul></li><li><a name="pulsar.schema.schema.Schema"></a><div><code><a href="pulsar.schema.schema.Schema.html" class="internal-link">pulsar.schema.schema.Schema</a></code> - <span class="rst-undocumented">Undocumented</span></div><ul><li><a name="pulsar.schema.schema.BytesSchema"></a><div><code><a href="pulsar.schema.schema.BytesSchema.html" class="internal-link">pulsar.schema.schema.BytesSchema</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.schema.JsonSchema"></a><div><code><a href="pulsar.schema.schema.JsonSchema.html" class="internal-link">pulsar.schema.schema.JsonSchema</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.schema.StringSchema"></a><div><code><a href="pulsar.schema.schema.StringSchema.html" class="internal-link">pulsar.schema.schema.StringSchema</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.schema.schema_avro.AvroSchema"></a><div><code><a href="pulsar.schema.schema_avro.AvroSchema.html" class="internal-link">pulsar.schema.schema_avro.AvroSchema</a></code> - <span class="rst-undocumented">Undocumented</span></div></li></ul></li></ul></li><li><a name="pulsar.asyncio.Client"></a><div><code><a href="pulsar.asyncio.Client.html" class="internal-link">pulsar.asyncio.Client</a></code> - The asynchronous version of <code><a href="pulsar.Client.html" class="internal-link">pulsar.Client</a></code>.</div></li><li><a name="pulsar.asyncio.Consumer"></a><div><code><a href="pulsar.asyncio.Consumer.html" class="internal-link">pulsar.asyncio.Consumer</a></code> - The Pulsar message consumer, used to subscribe to messages from a topic.</div></li><li><a name="pulsar.asyncio.Producer"></a><div><code><a href="pulsar.asyncio.Producer.html" class="internal-link">pulsar.asyncio.Producer</a></code> - The Pulsar message producer, used to publish messages on a topic.</div></li><li><a name="pulsar.Authentication"></a><div><code><a href="pulsar.Authentication.html" class="internal-link">pulsar.Authentication</a></code> - Authentication provider object. Used to load authentication from an external shared library.</div><ul><li><a name="pulsar.AuthenticationAthenz"></a><div><code><a href="pulsar.AuthenticationAthenz.html" class="internal-link">pulsar.AuthenticationAthenz</a></code> - Athenz Authentication implementation</div></li><li><a name="pulsar.AuthenticationBasic"></a><div><code><a href="pulsar.AuthenticationBasic.html" class="internal-link">pulsar.AuthenticationBasic</a></code> - Basic Authentication implementation</div></li><li><a name="pulsar.AuthenticationOauth2"></a><div><code><a href="pulsar.AuthenticationOauth2.html" class="internal-link">pulsar.AuthenticationOauth2</a></code> - Oauth2 Authentication implementation</div></li><li><a name="pulsar.AuthenticationTLS"></a><div><code><a href="pulsar.AuthenticationTLS.html" class="internal-link">pulsar.AuthenticationTLS</a></code> - TLS Authentication implementation</div></li><li><a name="pulsar.AuthenticationToken"></a><div><code><a href="pulsar.AuthenticationToken.html" class="internal-link">pulsar.AuthenticationToken</a></code> - Token based authentication implementation</div></li></ul></li><li><a name="pulsar.AutoClusterFailover"></a><div><code><a href="pulsar.AutoClusterFailover.html" class="internal-link">pulsar.AutoClusterFailover</a></code> - Cluster-level automatic failover configuration for <code><a href="pulsar.Client.html" class="internal-link" title="pulsar.Client">Client</a></code>.</div></li><li><a name="pulsar.Client"></a><div><code><a href="pulsar.Client.html" class="internal-link">pulsar.Client</a></code> - The Pulsar client. A single client instance can be used to create producers and consumers on multiple topics.</div></li><li><a name="pulsar.ConsoleLogger"></a><div><code><a href="pulsar.ConsoleLogger.html" class="internal-link">pulsar.ConsoleLogger</a></code> - Logger that writes on standard output</div></li><li><a name="pulsar.Consumer"></a><div><code><a href="pulsar.Consumer.html" class="internal-link">pulsar.Consumer</a></code> - Pulsar consumer.</div></li><li><a name="pulsar.ConsumerBatchReceivePolicy"></a><div><code><a href="pulsar.ConsumerBatchReceivePolicy.html" class="internal-link">pulsar.ConsumerBatchReceivePolicy</a></code> - Batch receive policy can limit the number and bytes of messages in a single batch, and can specify a timeout for waiting for enough messages for this batch.</div></li><li><a name="pulsar.ConsumerDeadLetterPolicy"></a><div><code><a href="pulsar.ConsumerDeadLetterPolicy.html" class="internal-link">pulsar.ConsumerDeadLetterPolicy</a></code> - Configuration for the "dead letter queue" feature in consumer.</div></li><li><a name="pulsar.ConsumerKeySharedPolicy"></a><div><code><a href="pulsar.ConsumerKeySharedPolicy.html" class="internal-link">pulsar.ConsumerKeySharedPolicy</a></code> - Consumer key shared policy is used to configure the consumer behaviour when the ConsumerType is KeyShared.</div></li><li><a name="pulsar.CryptoKeyReader"></a><div><code><a href="pulsar.CryptoKeyReader.html" class="internal-link">pulsar.CryptoKeyReader</a></code> - Default crypto key reader implementation</div></li><li><a name="pulsar.EncryptionContext"></a><div><code><a href="pulsar.EncryptionContext.html" class="internal-link">pulsar.EncryptionContext</a></code> - It contains encryption and compression information in it using which application can decrypt consumed message with encrypted-payload.</div></li><li><a name="pulsar.EncryptionKey"></a><div><code><a href="pulsar.EncryptionKey.html" class="internal-link">pulsar.EncryptionKey</a></code> - The key used for encryption.</div></li><li><a name="pulsar.FileLogger"></a><div><code><a href="pulsar.FileLogger.html" class="internal-link">pulsar.FileLogger</a></code> - Logger that writes into a file</div></li><li><a name="pulsar.Message"></a><div><code><a href="pulsar.Message.html" class="internal-link">pulsar.Message</a></code> - Message objects are returned by a consumer, either by calling <code><a href="pulsar.Consumer.html#receive" class="internal-link" title="pulsar.Consumer.receive">receive</a></code> or through a listener.</div></li><li><a name="pulsar.MessageBatch"></a><div><code><a href="pulsar.MessageBatch.html" class="internal-link">pulsar.MessageBatch</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.MessageId"></a><div><code><a href="pulsar.MessageId.html" class="internal-link">pulsar.MessageId</a></code> - Represents a message id.</div></li><li><a name="pulsar.Producer"></a><div><code><a href="pulsar.Producer.html" class="internal-link">pulsar.Producer</a></code> - The Pulsar message producer, used to publish messages on a topic.</div></li><li><a name="pulsar.Reader"></a><div><code><a href="pulsar.Reader.html" class="internal-link">pulsar.Reader</a></code> - Pulsar topic reader.</div></li><li><a name="pulsar.schema.definition.Record"></a><div><code><a href="pulsar.schema.definition.Record.html" class="internal-link">pulsar.schema.definition.Record</a></code> - <span class="rst-undocumented">Undocumented</span></div></li><li><a name="pulsar.ServiceInfo"></a><div><code><a href="pulsar.ServiceInfo.html" class="internal-link">pulsar.ServiceInfo</a></code> - Connection information for one Pulsar cluster endpoint.</div></li><li><a name="pulsar.ServiceInfoProvider"></a><div><code><a href="pulsar.ServiceInfoProvider.html" class="internal-link">pulsar.ServiceInfoProvider</a></code> - Base class for Python-defined service discovery and failover providers.</div></li><li><a name="pulsar.tableview.TableView"></a><div><code><a href="pulsar.tableview.TableView.html" class="internal-link">pulsar.tableview.TableView</a></code> - <span class="rst-undocumented">No class docstring; 0/4 instance variable, 5/8 methods documented</span></div></li><li><code><a href="https://docs.python.org/3/library/functions.html#type" class="intersphinx-link">type</a></code><ul><li><a name="pulsar.schema.definition.RecordMeta"></a><div><code><a href="pulsar.schema.definition.RecordMeta.html" class="internal-link">pulsar.schema.definition.RecordMeta</a></code> - <span class="rst-undocumented">Undocumented</span></div></li></ul></li></ul> |
| |
| </div> |
| |
| <footer class="navbar navbar-default"> |
| <hr /> |
| |
| |
| <div class="container-fluid"> |
| <a href="index.html">API Documentation</a> for _pulsar/pulsar, |
| generated by <a href="https://github.com/twisted/pydoctor/">pydoctor</a> |
| 25.4.0 at 2026-04-16 16:39:30. |
| </div> |
| |
| <script src="ajax.js" type="text/javascript"></script> |
| <script src="searchlib.js" type="text/javascript"></script> |
| <script src="search.js" type="text/javascript"></script> |
| |
| </footer> |
| |
| <script src="pydoctor.js" type="text/javascript"></script> |
| |
| </body> |
| </html> |
