protobuf

Documentation

Index

• type ProtoSerDe
  • func NewProtoSerDe() *ProtoSerDe
  • func (s *ProtoSerDe) Deserialize(msgData []byte, msg interface{}) (int, error)
  • func (s *ProtoSerDe) Serialize(schemaID int, msg interface{}) ([]byte, error)
• type SchemaRegistrator
  • func NewSchemaRegistrator(srclient srclient.Client) *SchemaRegistrator
  • func (r *SchemaRegistrator) Load(ctx context.Context, schemaID int, name string) ([]*desc.FileDescriptor, error)
  • func (r *SchemaRegistrator) RegisterKey(ctx context.Context, topic string, msg interface{}) (int, error)
  • func (r *SchemaRegistrator) RegisterValue(ctx context.Context, topic string, msg interface{}) (int, error)

Types

type ProtoSerDe

type ProtoSerDe struct{}

ProtoSerDe implements protbuf messages serializer and deserializer

func NewProtoSerDe

func NewProtoSerDe() *ProtoSerDe

func (*ProtoSerDe) Deserialize

func (s *ProtoSerDe) Deserialize(msgData []byte, msg interface{}) (int, error)

func (*ProtoSerDe) Serialize

func (s *ProtoSerDe) Serialize(schemaID int, msg interface{}) ([]byte, error)

type SchemaRegistrator

type SchemaRegistrator struct {
	// contains filtered or unexported fields
}

func NewSchemaRegistrator

func NewSchemaRegistrator(srclient srclient.Client) *SchemaRegistrator

func (*SchemaRegistrator) Load

func (r *SchemaRegistrator) Load(ctx context.Context, schemaID int, name string) ([]*desc.FileDescriptor, error)

func (*SchemaRegistrator) RegisterKey

func (r *SchemaRegistrator) RegisterKey(ctx context.Context, topic string, msg interface{}) (int, error)

func (*SchemaRegistrator) RegisterValue

func (r *SchemaRegistrator) RegisterValue(ctx context.Context, topic string, msg interface{}) (int, error)