Method doDecodePayload

kayak/callbacks.go:44–50

(ctx context.Context, data []byte)

}

func (r *Runtime) doDecodePayload(ctx context.Context, data []byte) (req interface{}, err error) {
	defer trace.StartRegion(ctx, "decodePayloadCallback").End()
	if req, err = r.sh.DecodePayload(data); err != nil {
		err = errors.Wrap(err, "decode kayak payload failed")
	}
	return
}

func (r *Runtime) doCommit(ctx context.Context, req interface{}, isLeader bool) (result interface{}, err error) {
	defer trace.StartRegion(ctx, "commitCallback").End()