proto

Nov 23, 2022

Changes in this version

+ type Codec struct

+ func NewCodec(log *zap.Logger, dc converter.DataConverter) *Codec

+ func (c *Codec) Decode(pld *payload.Payload, result *[]*internal.Message) error

+ func (c *Codec) DecodeWorkerInfo(p *payload.Payload, wi *[]*internal.WorkerInfo) error

+ func (c *Codec) Encode(ctx *internal.Context, p *payload.Payload, msg ...*internal.Message) error