proto

Documentation

Index

• type Codec
  • 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

Types

type Codec

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

Codec uses protobuf to exchange messages with underlying workers.

func NewCodec

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

NewCodec creates new Proto communication Codec.

func (*Codec) Decode

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

func (*Codec) DecodeWorkerInfo

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

DecodeWorkerInfo ... info []*internal.Message is read-only wi *[]*internal.WorkerInfo should be pre-allocated

func (*Codec) Encode

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