pulsar API Documentation Modules Classes Names
Clear Help

Class Hierarchy

  • 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.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, generated by pydoctor 22.9.1 at 2023-03-14 14:09:17.