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
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.