pulsar.schema.schema_protobuf

module documentation
(source)

Undocumented

Class ProtobufNativeSchema Schema for protobuf messages using the native protobuf binary encoding.
Variable HAS_PROTOBUF Undocumented
Function _build_schema_definition Build the schema definition dict used by Java's ProtobufNativeSchemaData.
Function _collect_file_descriptors Recursively collect all FileDescriptorProto objects into file_descriptor_set.
HAS_PROTOBUF: bool = (source)

Undocumented

def _build_schema_definition(descriptor): (source)

Build the schema definition dict used by Java's ProtobufNativeSchemaData.

The returned mapping has these keys:

fileDescriptorSet
rootMessageTypeName
rootFileDescriptorName

fileDescriptorSet contains base64-encoded FileDescriptorSet bytes. This mirrors ProtobufNativeSchemaUtils.serialize() in the Java client.

def _collect_file_descriptors(file_descriptor, visited, file_descriptor_set): (source)

Recursively collect all FileDescriptorProto objects into file_descriptor_set.