| <?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 23.4.1"> |
| |
| </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="search-help-button" title="Help" onclick="toggleSearchHelpText()"><img src="fonts/info.svg" alt="Help" /></a> |
| </span> |
| </div> |
| </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><code><a href="_pulsar.AbstractCryptoKeyReader.html" class="internal-link">_pulsar.AbstractCryptoKeyReader</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.AlreadyClosed"></a><code><a href="_pulsar.AlreadyClosed.html" class="internal-link">_pulsar.AlreadyClosed</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.Authentication"></a><code><a href="_pulsar.Authentication.html" class="internal-link">_pulsar.Authentication</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.AuthenticationAthenz"></a><code><a href="_pulsar.AuthenticationAthenz.html" class="internal-link">_pulsar.AuthenticationAthenz</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.AuthenticationBasic"></a><code><a href="_pulsar.AuthenticationBasic.html" class="internal-link">_pulsar.AuthenticationBasic</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.AuthenticationError"></a><code><a href="_pulsar.AuthenticationError.html" class="internal-link">_pulsar.AuthenticationError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.AuthenticationOauth2"></a><code><a href="_pulsar.AuthenticationOauth2.html" class="internal-link">_pulsar.AuthenticationOauth2</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.AuthenticationTLS"></a><code><a href="_pulsar.AuthenticationTLS.html" class="internal-link">_pulsar.AuthenticationTLS</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.AuthenticationToken"></a><code><a href="_pulsar.AuthenticationToken.html" class="internal-link">_pulsar.AuthenticationToken</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.AuthorizationError"></a><code><a href="_pulsar.AuthorizationError.html" class="internal-link">_pulsar.AuthorizationError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.BatchingType"></a><code><a href="_pulsar.BatchingType.html" class="internal-link">_pulsar.BatchingType</a></code> - Supported batching types</li><li class="private"><a name="_pulsar.BatchReceivePolicy"></a><code><a href="_pulsar.BatchReceivePolicy.html" class="internal-link">_pulsar.BatchReceivePolicy</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.BrokerMetadataError"></a><code><a href="_pulsar.BrokerMetadataError.html" class="internal-link">_pulsar.BrokerMetadataError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.BrokerPersistenceError"></a><code><a href="_pulsar.BrokerPersistenceError.html" class="internal-link">_pulsar.BrokerPersistenceError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ChecksumError"></a><code><a href="_pulsar.ChecksumError.html" class="internal-link">_pulsar.ChecksumError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.Client"></a><code><a href="_pulsar.Client.html" class="internal-link">_pulsar.Client</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ClientConfiguration"></a><code><a href="_pulsar.ClientConfiguration.html" class="internal-link">_pulsar.ClientConfiguration</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.CompressionType"></a><code><a href="_pulsar.CompressionType.html" class="internal-link">_pulsar.CompressionType</a></code> - Members:</li><li class="private"><a name="_pulsar.ConnectError"></a><code><a href="_pulsar.ConnectError.html" class="internal-link">_pulsar.ConnectError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.Consumer"></a><code><a href="_pulsar.Consumer.html" class="internal-link">_pulsar.Consumer</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ConsumerAssignError"></a><code><a href="_pulsar.ConsumerAssignError.html" class="internal-link">_pulsar.ConsumerAssignError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ConsumerBusy"></a><code><a href="_pulsar.ConsumerBusy.html" class="internal-link">_pulsar.ConsumerBusy</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ConsumerConfiguration"></a><code><a href="_pulsar.ConsumerConfiguration.html" class="internal-link">_pulsar.ConsumerConfiguration</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ConsumerNotFound"></a><code><a href="_pulsar.ConsumerNotFound.html" class="internal-link">_pulsar.ConsumerNotFound</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ConsumerNotInitialized"></a><code><a href="_pulsar.ConsumerNotInitialized.html" class="internal-link">_pulsar.ConsumerNotInitialized</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ConsumerType"></a><code><a href="_pulsar.ConsumerType.html" class="internal-link">_pulsar.ConsumerType</a></code> - Members:</li><li class="private"><a name="_pulsar.CryptoError"></a><code><a href="_pulsar.CryptoError.html" class="internal-link">_pulsar.CryptoError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.CryptoKeyReader"></a><code><a href="_pulsar.CryptoKeyReader.html" class="internal-link">_pulsar.CryptoKeyReader</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.CumulativeAcknowledgementNotAllowedError"></a><code><a href="_pulsar.CumulativeAcknowledgementNotAllowedError.html" class="internal-link">_pulsar.CumulativeAcknowledgementNotAllowedError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.DeadLetterPolicy"></a><code><a href="_pulsar.DeadLetterPolicy.html" class="internal-link">_pulsar.DeadLetterPolicy</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.DeadLetterPolicyBuilder"></a><code><a href="_pulsar.DeadLetterPolicyBuilder.html" class="internal-link">_pulsar.DeadLetterPolicyBuilder</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ErrorGettingAuthenticationData"></a><code><a href="_pulsar.ErrorGettingAuthenticationData.html" class="internal-link">_pulsar.ErrorGettingAuthenticationData</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.IncompatibleSchema"></a><code><a href="_pulsar.IncompatibleSchema.html" class="internal-link">_pulsar.IncompatibleSchema</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.InitialPosition"></a><code><a href="_pulsar.InitialPosition.html" class="internal-link">_pulsar.InitialPosition</a></code> - Supported initial position</li><li class="private"><a name="_pulsar.Interrupted"></a><code><a href="_pulsar.Interrupted.html" class="internal-link">_pulsar.Interrupted</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.InvalidConfiguration"></a><code><a href="_pulsar.InvalidConfiguration.html" class="internal-link">_pulsar.InvalidConfiguration</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.InvalidMessage"></a><code><a href="_pulsar.InvalidMessage.html" class="internal-link">_pulsar.InvalidMessage</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.InvalidTopicName"></a><code><a href="_pulsar.InvalidTopicName.html" class="internal-link">_pulsar.InvalidTopicName</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.InvalidTxnStatusError"></a><code><a href="_pulsar.InvalidTxnStatusError.html" class="internal-link">_pulsar.InvalidTxnStatusError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.InvalidUrl"></a><code><a href="_pulsar.InvalidUrl.html" class="internal-link">_pulsar.InvalidUrl</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.KeySharedMode"></a><code><a href="_pulsar.KeySharedMode.html" class="internal-link">_pulsar.KeySharedMode</a></code> - Members:</li><li class="private"><a name="_pulsar.KeySharedPolicy"></a><code><a href="_pulsar.KeySharedPolicy.html" class="internal-link">_pulsar.KeySharedPolicy</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.LoggerLevel"></a><code><a href="_pulsar.LoggerLevel.html" class="internal-link">_pulsar.LoggerLevel</a></code> - Members:</li><li class="private"><a name="_pulsar.LookupError"></a><code><a href="_pulsar.LookupError.html" class="internal-link">_pulsar.LookupError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.MemoryBufferIsFull"></a><code><a href="_pulsar.MemoryBufferIsFull.html" class="internal-link">_pulsar.MemoryBufferIsFull</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.Message"></a><code><a href="_pulsar.Message.html" class="internal-link">_pulsar.Message</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.MessageBatch"></a><code><a href="_pulsar.MessageBatch.html" class="internal-link">_pulsar.MessageBatch</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.MessageBuilder"></a><code><a href="_pulsar.MessageBuilder.html" class="internal-link">_pulsar.MessageBuilder</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.MessageId"></a><code><a href="_pulsar.MessageId.html" class="internal-link">_pulsar.MessageId</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.MessageTooBig"></a><code><a href="_pulsar.MessageTooBig.html" class="internal-link">_pulsar.MessageTooBig</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.NotAllowedError"></a><code><a href="_pulsar.NotAllowedError.html" class="internal-link">_pulsar.NotAllowedError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.NotConnected"></a><code><a href="_pulsar.NotConnected.html" class="internal-link">_pulsar.NotConnected</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.OperationNotSupported"></a><code><a href="_pulsar.OperationNotSupported.html" class="internal-link">_pulsar.OperationNotSupported</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.PartitionsRoutingMode"></a><code><a href="_pulsar.PartitionsRoutingMode.html" class="internal-link">_pulsar.PartitionsRoutingMode</a></code> - Members:</li><li class="private"><a name="_pulsar.Producer"></a><code><a href="_pulsar.Producer.html" class="internal-link">_pulsar.Producer</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ProducerAccessMode"></a><code><a href="_pulsar.ProducerAccessMode.html" class="internal-link">_pulsar.ProducerAccessMode</a></code> - Producer Access Mode</li><li class="private"><a name="_pulsar.ProducerBlockedQuotaExceededError"></a><code><a href="_pulsar.ProducerBlockedQuotaExceededError.html" class="internal-link">_pulsar.ProducerBlockedQuotaExceededError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ProducerBlockedQuotaExceededException"></a><code><a href="_pulsar.ProducerBlockedQuotaExceededException.html" class="internal-link">_pulsar.ProducerBlockedQuotaExceededException</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ProducerBusy"></a><code><a href="_pulsar.ProducerBusy.html" class="internal-link">_pulsar.ProducerBusy</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ProducerConfiguration"></a><code><a href="_pulsar.ProducerConfiguration.html" class="internal-link">_pulsar.ProducerConfiguration</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ProducerFenced"></a><code><a href="_pulsar.ProducerFenced.html" class="internal-link">_pulsar.ProducerFenced</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ProducerNotInitialized"></a><code><a href="_pulsar.ProducerNotInitialized.html" class="internal-link">_pulsar.ProducerNotInitialized</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ProducerQueueIsFull"></a><code><a href="_pulsar.ProducerQueueIsFull.html" class="internal-link">_pulsar.ProducerQueueIsFull</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.PulsarException"></a><code><a href="_pulsar.PulsarException.html" class="internal-link">_pulsar.PulsarException</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.Reader"></a><code><a href="_pulsar.Reader.html" class="internal-link">_pulsar.Reader</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ReaderConfiguration"></a><code><a href="_pulsar.ReaderConfiguration.html" class="internal-link">_pulsar.ReaderConfiguration</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.ReadError"></a><code><a href="_pulsar.ReadError.html" class="internal-link">_pulsar.ReadError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.RegexSubscriptionMode"></a><code><a href="_pulsar.RegexSubscriptionMode.html" class="internal-link">_pulsar.RegexSubscriptionMode</a></code> - Regex subscription mode</li><li class="private"><a name="_pulsar.Result"></a><code><a href="_pulsar.Result.html" class="internal-link">_pulsar.Result</a></code> - Collection of return codes</li><li class="private"><a name="_pulsar.SchemaInfo"></a><code><a href="_pulsar.SchemaInfo.html" class="internal-link">_pulsar.SchemaInfo</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.SchemaType"></a><code><a href="_pulsar.SchemaType.html" class="internal-link">_pulsar.SchemaType</a></code> - Supported schema types</li><li class="private"><a name="_pulsar.ServiceUnitNotReady"></a><code><a href="_pulsar.ServiceUnitNotReady.html" class="internal-link">_pulsar.ServiceUnitNotReady</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.SubscriptionNotFound"></a><code><a href="_pulsar.SubscriptionNotFound.html" class="internal-link">_pulsar.SubscriptionNotFound</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.Timeout"></a><code><a href="_pulsar.Timeout.html" class="internal-link">_pulsar.Timeout</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.TooManyLookupRequestException"></a><code><a href="_pulsar.TooManyLookupRequestException.html" class="internal-link">_pulsar.TooManyLookupRequestException</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.TopicNotFound"></a><code><a href="_pulsar.TopicNotFound.html" class="internal-link">_pulsar.TopicNotFound</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.TopicTerminated"></a><code><a href="_pulsar.TopicTerminated.html" class="internal-link">_pulsar.TopicTerminated</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.TransactionConflict"></a><code><a href="_pulsar.TransactionConflict.html" class="internal-link">_pulsar.TransactionConflict</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.TransactionCoordinatorNotFoundError"></a><code><a href="_pulsar.TransactionCoordinatorNotFoundError.html" class="internal-link">_pulsar.TransactionCoordinatorNotFoundError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.TransactionNotFound"></a><code><a href="_pulsar.TransactionNotFound.html" class="internal-link">_pulsar.TransactionNotFound</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.UnknownError"></a><code><a href="_pulsar.UnknownError.html" class="internal-link">_pulsar.UnknownError</a></code> - <span class="undocumented">Undocumented</span></li><li class="private"><a name="_pulsar.UnsupportedVersionError"></a><code><a href="_pulsar.UnsupportedVersionError.html" class="internal-link">_pulsar.UnsupportedVersionError</a></code> - <span class="undocumented">Undocumented</span></li><li><code>object</code><ul><li><a name="pulsar.functions.context.Context"></a><code><a href="pulsar.functions.context.Context.html" class="internal-link">pulsar.functions.context.Context</a></code> - Interface defining information available at process time</li><li><a name="pulsar.functions.function.Function"></a><code><a href="pulsar.functions.function.Function.html" class="internal-link">pulsar.functions.function.Function</a></code> - Interface for Pulsar Function</li><li><a name="pulsar.functions.serde.SerDe"></a><code><a href="pulsar.functions.serde.SerDe.html" class="internal-link">pulsar.functions.serde.SerDe</a></code> - Interface for Serialization/Deserialization<ul><li><a name="pulsar.functions.serde.IdentitySerDe"></a><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</li><li><a name="pulsar.functions.serde.PickleSerDe"></a><code><a href="pulsar.functions.serde.PickleSerDe.html" class="internal-link">pulsar.functions.serde.PickleSerDe</a></code> - Pickle based serializer</li></ul></li><li><a name="pulsar.schema.definition.Field"></a><code><a href="pulsar.schema.definition.Field.html" class="internal-link">pulsar.schema.definition.Field</a></code> - <span class="undocumented">Undocumented</span><ul><li><a name="pulsar.schema.definition.Array"></a><code><a href="pulsar.schema.definition.Array.html" class="internal-link">pulsar.schema.definition.Array</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.definition.Boolean"></a><code><a href="pulsar.schema.definition.Boolean.html" class="internal-link">pulsar.schema.definition.Boolean</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.definition.Bytes"></a><code><a href="pulsar.schema.definition.Bytes.html" class="internal-link">pulsar.schema.definition.Bytes</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.definition.CustomEnum"></a><code><a href="pulsar.schema.definition.CustomEnum.html" class="internal-link">pulsar.schema.definition.CustomEnum</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.definition.Double"></a><code><a href="pulsar.schema.definition.Double.html" class="internal-link">pulsar.schema.definition.Double</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.definition.Float"></a><code><a href="pulsar.schema.definition.Float.html" class="internal-link">pulsar.schema.definition.Float</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.definition.Integer"></a><code><a href="pulsar.schema.definition.Integer.html" class="internal-link">pulsar.schema.definition.Integer</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.definition.Long"></a><code><a href="pulsar.schema.definition.Long.html" class="internal-link">pulsar.schema.definition.Long</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.definition.Map"></a><code><a href="pulsar.schema.definition.Map.html" class="internal-link">pulsar.schema.definition.Map</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.definition.Null"></a><code><a href="pulsar.schema.definition.Null.html" class="internal-link">pulsar.schema.definition.Null</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.definition.String"></a><code><a href="pulsar.schema.definition.String.html" class="internal-link">pulsar.schema.definition.String</a></code> - <span class="undocumented">Undocumented</span></li></ul></li><li><a name="pulsar.schema.schema.Schema"></a><code><a href="pulsar.schema.schema.Schema.html" class="internal-link">pulsar.schema.schema.Schema</a></code> - <span class="undocumented">Undocumented</span><ul><li><a name="pulsar.schema.schema.BytesSchema"></a><code><a href="pulsar.schema.schema.BytesSchema.html" class="internal-link">pulsar.schema.schema.BytesSchema</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.schema.JsonSchema"></a><code><a href="pulsar.schema.schema.JsonSchema.html" class="internal-link">pulsar.schema.schema.JsonSchema</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.schema.StringSchema"></a><code><a href="pulsar.schema.schema.StringSchema.html" class="internal-link">pulsar.schema.schema.StringSchema</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.schema.schema_avro.AvroSchema"></a><code><a href="pulsar.schema.schema_avro.AvroSchema.html" class="internal-link">pulsar.schema.schema_avro.AvroSchema</a></code> - <span class="undocumented">Undocumented</span></li></ul></li></ul></li><li><a name="pulsar.Authentication"></a><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.<ul><li><a name="pulsar.AuthenticationAthenz"></a><code><a href="pulsar.AuthenticationAthenz.html" class="internal-link">pulsar.AuthenticationAthenz</a></code> - Athenz Authentication implementation</li><li><a name="pulsar.AuthenticationBasic"></a><code><a href="pulsar.AuthenticationBasic.html" class="internal-link">pulsar.AuthenticationBasic</a></code> - Basic Authentication implementation</li><li><a name="pulsar.AuthenticationOauth2"></a><code><a href="pulsar.AuthenticationOauth2.html" class="internal-link">pulsar.AuthenticationOauth2</a></code> - Oauth2 Authentication implementation</li><li><a name="pulsar.AuthenticationTLS"></a><code><a href="pulsar.AuthenticationTLS.html" class="internal-link">pulsar.AuthenticationTLS</a></code> - TLS Authentication implementation</li><li><a name="pulsar.AuthenticationToken"></a><code><a href="pulsar.AuthenticationToken.html" class="internal-link">pulsar.AuthenticationToken</a></code> - Token based authentication implementation</li></ul></li><li><a name="pulsar.Client"></a><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.</li><li><a name="pulsar.ConsoleLogger"></a><code><a href="pulsar.ConsoleLogger.html" class="internal-link">pulsar.ConsoleLogger</a></code> - Logger that writes on standard output</li><li><a name="pulsar.Consumer"></a><code><a href="pulsar.Consumer.html" class="internal-link">pulsar.Consumer</a></code> - Pulsar consumer.</li><li><a name="pulsar.ConsumerBatchReceivePolicy"></a><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.</li><li><a name="pulsar.ConsumerDeadLetterPolicy"></a><code><a href="pulsar.ConsumerDeadLetterPolicy.html" class="internal-link">pulsar.ConsumerDeadLetterPolicy</a></code> - Configuration for the "dead letter queue" feature in consumer.</li><li><a name="pulsar.ConsumerKeySharedPolicy"></a><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.</li><li><a name="pulsar.CryptoKeyReader"></a><code><a href="pulsar.CryptoKeyReader.html" class="internal-link">pulsar.CryptoKeyReader</a></code> - Default crypto key reader implementation</li><li><a name="pulsar.FileLogger"></a><code><a href="pulsar.FileLogger.html" class="internal-link">pulsar.FileLogger</a></code> - Logger that writes into a file</li><li><a name="pulsar.Message"></a><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.</li><li><a name="pulsar.MessageBatch"></a><code><a href="pulsar.MessageBatch.html" class="internal-link">pulsar.MessageBatch</a></code> - <span class="undocumented">Undocumented</span></li><li><a name="pulsar.MessageId"></a><code><a href="pulsar.MessageId.html" class="internal-link">pulsar.MessageId</a></code> - Represents a message id.</li><li><a name="pulsar.Producer"></a><code><a href="pulsar.Producer.html" class="internal-link">pulsar.Producer</a></code> - The Pulsar message producer, used to publish messages on a topic.</li><li><a name="pulsar.Reader"></a><code><a href="pulsar.Reader.html" class="internal-link">pulsar.Reader</a></code> - Pulsar topic reader.</li><li><a name="pulsar.schema.definition.Record"></a><code><a href="pulsar.schema.definition.Record.html" class="internal-link">pulsar.schema.definition.Record</a></code> - <span class="undocumented">Undocumented</span></li><li><code>type</code><ul><li><a name="pulsar.schema.definition.RecordMeta"></a><code><a href="pulsar.schema.definition.RecordMeta.html" class="internal-link">pulsar.schema.definition.RecordMeta</a></code> - <span class="undocumented">Undocumented</span></li></ul></li></ul> |
| |
| </div> |
| |
| <footer class="navbar navbar-default"> |
| <hr /> |
| |
| |
| <div class="container"> |
| <a href="index.html">API Documentation</a> for _pulsar/pulsar, |
| generated by <a href="https://github.com/twisted/pydoctor/">pydoctor</a> |
| 23.4.1 at 2023-08-30 15:10:14. |
| </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> |
