in go/proto/api/v1/decision.pb.go [3350:3855]
func (m *Decision) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: Decision: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: Decision: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ScheduleActivityTaskDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &ScheduleActivityTaskDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_ScheduleActivityTaskDecisionAttributes{v}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field StartTimerDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &StartTimerDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_StartTimerDecisionAttributes{v}
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field CompleteWorkflowExecutionDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &CompleteWorkflowExecutionDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_CompleteWorkflowExecutionDecisionAttributes{v}
iNdEx = postIndex
case 4:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field FailWorkflowExecutionDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &FailWorkflowExecutionDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_FailWorkflowExecutionDecisionAttributes{v}
iNdEx = postIndex
case 5:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field RequestCancelActivityTaskDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &RequestCancelActivityTaskDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_RequestCancelActivityTaskDecisionAttributes{v}
iNdEx = postIndex
case 6:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field CancelTimerDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &CancelTimerDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_CancelTimerDecisionAttributes{v}
iNdEx = postIndex
case 7:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field CancelWorkflowExecutionDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &CancelWorkflowExecutionDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_CancelWorkflowExecutionDecisionAttributes{v}
iNdEx = postIndex
case 8:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field RequestCancelExternalWorkflowExecutionDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &RequestCancelExternalWorkflowExecutionDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_RequestCancelExternalWorkflowExecutionDecisionAttributes{v}
iNdEx = postIndex
case 9:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field RecordMarkerDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &RecordMarkerDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_RecordMarkerDecisionAttributes{v}
iNdEx = postIndex
case 10:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ContinueAsNewWorkflowExecutionDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &ContinueAsNewWorkflowExecutionDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_ContinueAsNewWorkflowExecutionDecisionAttributes{v}
iNdEx = postIndex
case 11:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field StartChildWorkflowExecutionDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &StartChildWorkflowExecutionDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_StartChildWorkflowExecutionDecisionAttributes{v}
iNdEx = postIndex
case 12:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field SignalExternalWorkflowExecutionDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &SignalExternalWorkflowExecutionDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_SignalExternalWorkflowExecutionDecisionAttributes{v}
iNdEx = postIndex
case 13:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field UpsertWorkflowSearchAttributesDecisionAttributes", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowDecision
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthDecision
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthDecision
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
v := &UpsertWorkflowSearchAttributesDecisionAttributes{}
if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
m.Attributes = &Decision_UpsertWorkflowSearchAttributesDecisionAttributes{v}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipDecision(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthDecision
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}