codec

Jul 29, 2025

Changes in this version

type Codec

+ func (c *Codec) MarshalStruct(source any) ([]byte, error)

+ type StructEncoder struct

+ func NewStructEncoder(md protoreflect.MessageDescriptor) *StructEncoder

+ func (se *StructEncoder) EncodeStruct(source any) ([]byte, error)

Jul 22, 2025

Changes in this version

+ var DefaultDecoderOptions = DecoderOptions

+ func ClearPools()

+ type Codec struct

+ func New(md protoreflect.MessageDescriptor, opts Options) (*Codec, error)

+ func (c *Codec) Descriptor() protoreflect.MessageDescriptor

+ func (c *Codec) Marshal(msg protobuf.Message) ([]byte, error)

+ func (c *Codec) MarshalToJSON(msg protobuf.Message) ([]byte, error)

+ func (c *Codec) NewMessage() protobuf.Message

+ func (c *Codec) ReleaseMessage(msg protobuf.Message)

+ func (c *Codec) Unmarshal(data []byte) (protobuf.Message, error)

+ func (c *Codec) UnmarshalFromJSON(data []byte) (protobuf.Message, error)

+ type Decoder struct

+ func NewDecoder(md protoreflect.MessageDescriptor, opts DecoderOptions) (*Decoder, error)

+ func (d *Decoder) Decode(data []byte) (*hyperpb.Message, error)

+ func (d *Decoder) DecodeInto(data []byte, msg protobuf.Message) error

+ func (d *Decoder) DecodeJSON(data []byte) (*hyperpb.Message, error)

+ func (d *Decoder) Descriptor() protoreflect.MessageDescriptor

+ func (d *Decoder) GetMessage() *hyperpb.Message

+ func (d *Decoder) PutMessage(msg *hyperpb.Message)

+ type DecoderOptions struct

+ AllowUnknownFields bool

+ EnablePGO bool

+ EnablePooling bool

+ InitialPoolSize int

+ type Encoder struct

+ func NewEncoder(md protoreflect.MessageDescriptor, opts EncoderOptions) (*Encoder, error)

+ func (e *Encoder) Descriptor() protoreflect.MessageDescriptor

+ func (e *Encoder) Encode(msg protobuf.Message) ([]byte, error)

+ func (e *Encoder) EncodeJSON(msg protobuf.Message) ([]byte, error)

+ func (e *Encoder) GetMessage() *hyperpb.Message

+ func (e *Encoder) PutMessage(msg *hyperpb.Message)

+ type EncoderOptions struct

+ EnablePooling bool

+ InitialPoolSize int

+ type GlobalPools struct

+ type MessagePool struct

+ func GetPool(md protoreflect.MessageDescriptor) (*MessagePool, error)

+ func NewMessagePool(md protoreflect.MessageDescriptor) (*MessagePool, error)

+ func (p *MessagePool) Get() *hyperpb.Message

+ func (p *MessagePool) Put(msg *hyperpb.Message)

+ func (p *MessagePool) Stats() PoolStats

+ type Options struct

+ AllowUnknownFields bool

+ EnablePooling bool

+ PoolSize int

+ func DefaultOptions() Options

+ type PoolStats struct

+ Gets atomic.Int64

+ InUse atomic.Int64

+ MaxSize atomic.Int64

+ News atomic.Int64

+ Puts atomic.Int64