_pulsar/pulsar API Documentation Modules Classes Names
Clear Help

Class Hierarchy

  • _pulsar.AbstractCryptoKeyReader - Undocumented
  • _pulsar.AlreadyClosed - Undocumented
  • _pulsar.Authentication - Undocumented
  • _pulsar.AuthenticationAthenz - Undocumented
  • _pulsar.AuthenticationBasic - Undocumented
  • _pulsar.AuthenticationError - Undocumented
  • _pulsar.AuthenticationOauth2 - Undocumented
  • _pulsar.AuthenticationTLS - Undocumented
  • _pulsar.AuthenticationToken - Undocumented
  • _pulsar.AuthorizationError - Undocumented
  • _pulsar.BatchingType - Supported batching types
  • _pulsar.BatchReceivePolicy - Undocumented
  • _pulsar.BrokerMetadataError - Undocumented
  • _pulsar.BrokerPersistenceError - Undocumented
  • _pulsar.ChecksumError - Undocumented
  • _pulsar.Client - Undocumented
  • _pulsar.ClientConfiguration - Undocumented
  • _pulsar.CompressionType - Members:
  • _pulsar.ConnectError - Undocumented
  • _pulsar.Consumer - Undocumented
  • _pulsar.ConsumerAssignError - Undocumented
  • _pulsar.ConsumerBusy - Undocumented
  • _pulsar.ConsumerConfiguration - Undocumented
  • _pulsar.ConsumerNotFound - Undocumented
  • _pulsar.ConsumerNotInitialized - Undocumented
  • _pulsar.ConsumerType - Members:
  • _pulsar.CryptoError - Undocumented
  • _pulsar.CryptoKeyReader - Undocumented
  • _pulsar.CumulativeAcknowledgementNotAllowedError - Undocumented
  • _pulsar.DeadLetterPolicy - Undocumented
  • _pulsar.DeadLetterPolicyBuilder - Undocumented
  • _pulsar.ErrorGettingAuthenticationData - Undocumented
  • _pulsar.IncompatibleSchema - Undocumented
  • _pulsar.InitialPosition - Supported initial position
  • _pulsar.Interrupted - Undocumented
  • _pulsar.InvalidConfiguration - Undocumented
  • _pulsar.InvalidMessage - Undocumented
  • _pulsar.InvalidTopicName - Undocumented
  • _pulsar.InvalidTxnStatusError - Undocumented
  • _pulsar.InvalidUrl - Undocumented
  • _pulsar.KeySharedMode - Members:
  • _pulsar.KeySharedPolicy - Undocumented
  • _pulsar.LoggerLevel - Members:
  • _pulsar.LookupError - Undocumented
  • _pulsar.MemoryBufferIsFull - Undocumented
  • _pulsar.Message - Undocumented
  • _pulsar.MessageBatch - Undocumented
  • _pulsar.MessageBuilder - Undocumented
  • _pulsar.MessageId - Undocumented
  • _pulsar.MessageTooBig - Undocumented
  • _pulsar.NotAllowedError - Undocumented
  • _pulsar.NotConnected - Undocumented
  • _pulsar.OperationNotSupported - Undocumented
  • _pulsar.PartitionsRoutingMode - Members:
  • _pulsar.Producer - Undocumented
  • _pulsar.ProducerAccessMode - Producer Access Mode
  • _pulsar.ProducerBlockedQuotaExceededError - Undocumented
  • _pulsar.ProducerBlockedQuotaExceededException - Undocumented
  • _pulsar.ProducerBusy - Undocumented
  • _pulsar.ProducerConfiguration - Undocumented
  • _pulsar.ProducerFenced - Undocumented
  • _pulsar.ProducerNotInitialized - Undocumented
  • _pulsar.ProducerQueueIsFull - Undocumented
  • _pulsar.PulsarException - Undocumented
  • _pulsar.Reader - Undocumented
  • _pulsar.ReaderConfiguration - Undocumented
  • _pulsar.ReadError - Undocumented
  • _pulsar.RegexSubscriptionMode - Regex subscription mode
  • _pulsar.Result - Collection of return codes
  • _pulsar.SchemaInfo - Undocumented
  • _pulsar.SchemaType - Supported schema types
  • _pulsar.ServiceUnitNotReady - Undocumented
  • _pulsar.SubscriptionNotFound - Undocumented
  • _pulsar.Timeout - Undocumented
  • _pulsar.TooManyLookupRequestException - Undocumented
  • _pulsar.TopicNotFound - Undocumented
  • _pulsar.TopicTerminated - Undocumented
  • _pulsar.TransactionConflict - Undocumented
  • _pulsar.TransactionCoordinatorNotFoundError - Undocumented
  • _pulsar.TransactionNotFound - Undocumented
  • _pulsar.UnknownError - Undocumented
  • _pulsar.UnsupportedVersionError - Undocumented
  • object
    • pulsar.functions.context.Context - Interface defining information available at process time
    • pulsar.functions.function.Function - Interface for Pulsar Function
    • pulsar.functions.serde.SerDe - Interface for Serialization/Deserialization
      • pulsar.functions.serde.IdentitySerDe - Simple Serde that just conversion to string and back
      • pulsar.functions.serde.PickleSerDe - Pickle based serializer
    • pulsar.schema.definition.Field - Undocumented
      • pulsar.schema.definition.Array - Undocumented
      • pulsar.schema.definition.Boolean - Undocumented
      • pulsar.schema.definition.Bytes - Undocumented
      • pulsar.schema.definition.CustomEnum - Undocumented
      • pulsar.schema.definition.Double - Undocumented
      • pulsar.schema.definition.Float - Undocumented
      • pulsar.schema.definition.Integer - Undocumented
      • pulsar.schema.definition.Long - Undocumented
      • pulsar.schema.definition.Map - Undocumented
      • pulsar.schema.definition.Null - Undocumented
      • pulsar.schema.definition.String - Undocumented
    • pulsar.schema.schema.Schema - Undocumented
      • pulsar.schema.schema.BytesSchema - Undocumented
      • pulsar.schema.schema.JsonSchema - Undocumented
      • pulsar.schema.schema.StringSchema - Undocumented
      • pulsar.schema.schema_avro.AvroSchema - Undocumented
  • pulsar.Authentication - Authentication provider object. Used to load authentication from an external shared library.
    • pulsar.AuthenticationAthenz - Athenz Authentication implementation
    • pulsar.AuthenticationBasic - Basic Authentication implementation
    • pulsar.AuthenticationOauth2 - Oauth2 Authentication implementation
    • pulsar.AuthenticationTLS - TLS Authentication implementation
    • pulsar.AuthenticationToken - Token based authentication implementation
  • pulsar.Client - The Pulsar client. A single client instance can be used to create producers and consumers on multiple topics.
  • pulsar.ConsoleLogger - Logger that writes on standard output
  • pulsar.Consumer - Pulsar consumer.
  • pulsar.ConsumerBatchReceivePolicy - 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.
  • pulsar.ConsumerDeadLetterPolicy - Configuration for the "dead letter queue" feature in consumer.
  • pulsar.ConsumerKeySharedPolicy - Consumer key shared policy is used to configure the consumer behaviour when the ConsumerType is KeyShared.
  • pulsar.CryptoKeyReader - Default crypto key reader implementation
  • pulsar.FileLogger - Logger that writes into a file
  • pulsar.Message - Message objects are returned by a consumer, either by calling receive or through a listener.
  • pulsar.MessageBatch - Undocumented
  • pulsar.MessageId - Represents a message id.
  • pulsar.Producer - The Pulsar message producer, used to publish messages on a topic.
  • pulsar.Reader - Pulsar topic reader.
  • pulsar.schema.definition.Record - Undocumented
  • type
    • pulsar.schema.definition.RecordMeta - Undocumented

API Documentation for _pulsar/pulsar, generated by pydoctor 23.4.1 at 2023-08-30 15:10:14.