protobuf

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 27, 2022 License: Apache-2.0 Imports: 39 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Deserializer

type Deserializer struct {
	serde.BaseDeserializer
	ProtoRegistry *protoregistry.Types
}

Deserializer represents a Protobuf deserializer

func NewDeserializer

func NewDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*Deserializer, error)

NewDeserializer creates a Protobuf deserializer for Protobuf-generated objects

func (*Deserializer) ConfigureDeserializer

func (s *Deserializer) ConfigureDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *serde.DeserializerConfig) error

ConfigureDeserializer configures the Protobuf deserializer

func (*Deserializer) Deserialize

func (s *Deserializer) Deserialize(topic string, payload []byte) (interface{}, error)

Deserialize implements deserialization of Protobuf data

func (*Deserializer) DeserializeInto

func (s *Deserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error

DeserializeInto implements deserialization of Protobuf data to the given object

type DeserializerConfig

type DeserializerConfig struct {
	serde.DeserializerConfig
}

DeserializerConfig is used to pass multiple configuration options to the deserializers.

func NewDeserializerConfig

func NewDeserializerConfig() *DeserializerConfig

NewDeserializerConfig returns a new configuration instance with sane defaults.

type Serializer

type Serializer struct {
	serde.BaseSerializer
}

Serializer represents a Protobuf serializer

func NewSerializer

func NewSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*Serializer, error)

NewSerializer creates a Protobuf serializer for Protobuf-generated objects

func (*Serializer) Serialize

func (s *Serializer) Serialize(topic string, msg interface{}) ([]byte, error)

Serialize implements serialization of Protobuf data

type SerializerConfig

type SerializerConfig struct {
	serde.SerializerConfig
}

SerializerConfig is used to pass multiple configuration options to the serializers.

func NewSerializerConfig

func NewSerializerConfig() *SerializerConfig

NewSerializerConfig returns a new configuration instance with sane defaults.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL