Method doEncodePayload

kayak/callbacks.go:36–42

(ctx context.Context, req interface{})

}

func (r *Runtime) doEncodePayload(ctx context.Context, req interface{}) (enc []byte, err error) {
	defer trace.StartRegion(ctx, "encodePayloadCallback").End()
	if enc, err = r.sh.EncodePayload(req); err != nil {
		err = errors.Wrap(err, "encode kayak payload failed")
	}
	return
}

func (r *Runtime) doDecodePayload(ctx context.Context, data []byte) (req interface{}, err error) {
	defer trace.StartRegion(ctx, "decodePayloadCallback").End()