protobuf

Documentation

Index

• type Deserializer
  • func NewDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*Deserializer, error)
  • func (s *Deserializer) ConfigureDeserializer(client schemaregistry.Client, serdeType serde.Type, ...) error
  • func (s *Deserializer) Deserialize(topic string, payload []byte) (interface{}, error)
  • func (s *Deserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error
• type DeserializerConfig
  • func NewDeserializerConfig() *DeserializerConfig
• type Serializer
  • func NewSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*Serializer, error)
  • func (s *Serializer) Serialize(topic string, msg interface{}) ([]byte, error)
• type SerializerConfig
  • func NewSerializerConfig() *SerializerConfig

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.