README
¶
protoenc
Protobuf encoder for serializing messages in a format compatible with the Confluent wire format.
Usage
// First you construct encoder which would register schema for the message (you can pass empty message)
enc, err := protoenc.NewEncoder(context.Background(), client, subject, (*test.Test)(nil))
...
// Then to serialize message you call Marshal method
bytes, err := enc.Marshal(&test.Test{Id: "1234"})
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrWrongMessage is returned when Marshal/MarshalAppend receive // a message different from one in the constructor. ErrWrongMessage = errors.New("unexpected message type") )
Functions ¶
This section is empty.
Types ¶
type Encoder ¶
type Encoder struct {
// contains filtered or unexported fields
}
func NewEncoder ¶
func (*Encoder) Marshal ¶
Marshal returns the confluent wire-format encoding of msg. See https://docs.confluent.io/cloud/current/sr/fundamentals/serdes-develop/index.html#wire-format for details.
func (*Encoder) MarshalAppend ¶
MarshalAppend appends the confluent wire-format encoding of msg with stored recordID and index to b, returning the result. See https://docs.confluent.io/cloud/current/sr/fundamentals/serdes-develop/index.html#wire-format for details.
type SchemaRegistryClient ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.