protobufencoder

Documentation

Overview

Package protobuf provides a Protocol Buffers encoder for Conduit messages. Protocol Buffers provide strongly-typed schemas with excellent performance, backward/forward compatibility, and cross-language support.

Index

• type Encoder
  • func New() *Encoder
  • func (e *Encoder) Decode(data []byte, v any) error
  • func (e *Encoder) Encode(v any) ([]byte, error)

Types

type Encoder

type Encoder struct{}

Encoder implements conduit.Encoder using Protocol Buffers binary serialization. It provides type-safe encoding with schema validation, making it ideal for production microservices and cross-language communication.

func New

func New() *Encoder

New creates a new Protocol Buffers encoder.

func (*Encoder) Decode

func (e *Encoder) Decode(data []byte, v any) error

Decode deserializes Protocol Buffers bytes into v. The value v must implement proto.Message.

func (*Encoder) Encode

func (e *Encoder) Encode(v any) ([]byte, error)

Encode serializes v to Protocol Buffers bytes. The value v must implement proto.Message.