proto

package

v5.11.0 Latest Latest Go to latest Published: May 15, 2026 License: MIT Imports: 9 Imported by: 0

Details

Package proto implements a protobuf-based codec for encoding and decoding messages exchanged between the Temporal plugin and PHP worker processes.

This section is empty.

This section is empty.

This section is empty.

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

Codec uses protobuf to exchange messages with underlying workers.

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

NewCodec creates new Proto communication Codec.

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

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 (c *Codec) Encode(ctx *internal.Context, p *payload.Payload, msg ...*internal.Message) error