From 80ae7958a17a492098f18f31fa21804f37b6cbaa Mon Sep 17 00:00:00 2001 From: zhangzengfei <zhangzengfei@smartai.com> Date: 星期三, 08 五月 2024 14:52:55 +0800 Subject: [PATCH] 更新dataprocess.pb --- dataprocess.pb.go | 3770 +---------------------------------------------------------- 1 files changed, 111 insertions(+), 3,659 deletions(-) diff --git a/dataprocess.pb.go b/dataprocess.pb.go index f1edca1..598b16f 100644 --- a/dataprocess.pb.go +++ b/dataprocess.pb.go @@ -1,14 +1,11 @@ -// Code generated by protoc-gen-gogo. DO NOT EDIT. +// Code generated by protoc-gen-go. DO NOT EDIT. // source: dataprocess.proto package protomsg -import ( - fmt "fmt" - proto "github.com/golang/protobuf/proto" - io "io" - math "math" -) +import proto "github.com/golang/protobuf/proto" +import fmt "fmt" +import math "math" // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal @@ -40,28 +37,19 @@ func (m *TaskBasicInfo) String() string { return proto.CompactTextString(m) } func (*TaskBasicInfo) ProtoMessage() {} func (*TaskBasicInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_02f614a9207041cc, []int{0} + return fileDescriptor_dataprocess_8cd5458c99d96cd7, []int{0} } func (m *TaskBasicInfo) XXX_Unmarshal(b []byte) error { - return m.Unmarshal(b) + return xxx_messageInfo_TaskBasicInfo.Unmarshal(m, b) } func (m *TaskBasicInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - if deterministic { - return xxx_messageInfo_TaskBasicInfo.Marshal(b, m, deterministic) - } else { - b = b[:cap(b)] - n, err := m.MarshalTo(b) - if err != nil { - return nil, err - } - return b[:n], nil - } + return xxx_messageInfo_TaskBasicInfo.Marshal(b, m, deterministic) } -func (m *TaskBasicInfo) XXX_Merge(src proto.Message) { - xxx_messageInfo_TaskBasicInfo.Merge(m, src) +func (dst *TaskBasicInfo) XXX_Merge(src proto.Message) { + xxx_messageInfo_TaskBasicInfo.Merge(dst, src) } func (m *TaskBasicInfo) XXX_Size() int { - return m.Size() + return xxx_messageInfo_TaskBasicInfo.Size(m) } func (m *TaskBasicInfo) XXX_DiscardUnknown() { xxx_messageInfo_TaskBasicInfo.DiscardUnknown(m) @@ -146,28 +134,19 @@ func (m *RuleParams) String() string { return proto.CompactTextString(m) } func (*RuleParams) ProtoMessage() {} func (*RuleParams) Descriptor() ([]byte, []int) { - return fileDescriptor_02f614a9207041cc, []int{1} + return fileDescriptor_dataprocess_8cd5458c99d96cd7, []int{1} } func (m *RuleParams) XXX_Unmarshal(b []byte) error { - return m.Unmarshal(b) + return xxx_messageInfo_RuleParams.Unmarshal(m, b) } func (m *RuleParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - if deterministic { - return xxx_messageInfo_RuleParams.Marshal(b, m, deterministic) - } else { - b = b[:cap(b)] - n, err := m.MarshalTo(b) - if err != nil { - return nil, err - } - return b[:n], nil - } + return xxx_messageInfo_RuleParams.Marshal(b, m, deterministic) } -func (m *RuleParams) XXX_Merge(src proto.Message) { - xxx_messageInfo_RuleParams.Merge(m, src) +func (dst *RuleParams) XXX_Merge(src proto.Message) { + xxx_messageInfo_RuleParams.Merge(dst, src) } func (m *RuleParams) XXX_Size() int { - return m.Size() + return xxx_messageInfo_RuleParams.Size(m) } func (m *RuleParams) XXX_DiscardUnknown() { xxx_messageInfo_RuleParams.DiscardUnknown(m) @@ -222,28 +201,19 @@ func (m *SoRule) String() string { return proto.CompactTextString(m) } func (*SoRule) ProtoMessage() {} func (*SoRule) Descriptor() ([]byte, []int) { - return fileDescriptor_02f614a9207041cc, []int{2} + return fileDescriptor_dataprocess_8cd5458c99d96cd7, []int{2} } func (m *SoRule) XXX_Unmarshal(b []byte) error { - return m.Unmarshal(b) + return xxx_messageInfo_SoRule.Unmarshal(m, b) } func (m *SoRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - if deterministic { - return xxx_messageInfo_SoRule.Marshal(b, m, deterministic) - } else { - b = b[:cap(b)] - n, err := m.MarshalTo(b) - if err != nil { - return nil, err - } - return b[:n], nil - } + return xxx_messageInfo_SoRule.Marshal(b, m, deterministic) } -func (m *SoRule) XXX_Merge(src proto.Message) { - xxx_messageInfo_SoRule.Merge(m, src) +func (dst *SoRule) XXX_Merge(src proto.Message) { + xxx_messageInfo_SoRule.Merge(dst, src) } func (m *SoRule) XXX_Size() int { - return m.Size() + return xxx_messageInfo_SoRule.Size(m) } func (m *SoRule) XXX_DiscardUnknown() { xxx_messageInfo_SoRule.DiscardUnknown(m) @@ -330,28 +300,19 @@ func (m *SoTarget) String() string { return proto.CompactTextString(m) } func (*SoTarget) ProtoMessage() {} func (*SoTarget) Descriptor() ([]byte, []int) { - return fileDescriptor_02f614a9207041cc, []int{3} + return fileDescriptor_dataprocess_8cd5458c99d96cd7, []int{3} } func (m *SoTarget) XXX_Unmarshal(b []byte) error { - return m.Unmarshal(b) + return xxx_messageInfo_SoTarget.Unmarshal(m, b) } func (m *SoTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - if deterministic { - return xxx_messageInfo_SoTarget.Marshal(b, m, deterministic) - } else { - b = b[:cap(b)] - n, err := m.MarshalTo(b) - if err != nil { - return nil, err - } - return b[:n], nil - } + return xxx_messageInfo_SoTarget.Marshal(b, m, deterministic) } -func (m *SoTarget) XXX_Merge(src proto.Message) { - xxx_messageInfo_SoTarget.Merge(m, src) +func (dst *SoTarget) XXX_Merge(src proto.Message) { + xxx_messageInfo_SoTarget.Merge(dst, src) } func (m *SoTarget) XXX_Size() int { - return m.Size() + return xxx_messageInfo_SoTarget.Size(m) } func (m *SoTarget) XXX_DiscardUnknown() { xxx_messageInfo_SoTarget.DiscardUnknown(m) @@ -419,28 +380,19 @@ func (m *SoResult) String() string { return proto.CompactTextString(m) } func (*SoResult) ProtoMessage() {} func (*SoResult) Descriptor() ([]byte, []int) { - return fileDescriptor_02f614a9207041cc, []int{4} + return fileDescriptor_dataprocess_8cd5458c99d96cd7, []int{4} } func (m *SoResult) XXX_Unmarshal(b []byte) error { - return m.Unmarshal(b) + return xxx_messageInfo_SoResult.Unmarshal(m, b) } func (m *SoResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - if deterministic { - return xxx_messageInfo_SoResult.Marshal(b, m, deterministic) - } else { - b = b[:cap(b)] - n, err := m.MarshalTo(b) - if err != nil { - return nil, err - } - return b[:n], nil - } + return xxx_messageInfo_SoResult.Marshal(b, m, deterministic) } -func (m *SoResult) XXX_Merge(src proto.Message) { - xxx_messageInfo_SoResult.Merge(m, src) +func (dst *SoResult) XXX_Merge(src proto.Message) { + xxx_messageInfo_SoResult.Merge(dst, src) } func (m *SoResult) XXX_Size() int { - return m.Size() + return xxx_messageInfo_SoResult.Size(m) } func (m *SoResult) XXX_DiscardUnknown() { xxx_messageInfo_SoResult.DiscardUnknown(m) @@ -517,28 +469,19 @@ func (m *EventCache) String() string { return proto.CompactTextString(m) } func (*EventCache) ProtoMessage() {} func (*EventCache) Descriptor() ([]byte, []int) { - return fileDescriptor_02f614a9207041cc, []int{5} + return fileDescriptor_dataprocess_8cd5458c99d96cd7, []int{5} } func (m *EventCache) XXX_Unmarshal(b []byte) error { - return m.Unmarshal(b) + return xxx_messageInfo_EventCache.Unmarshal(m, b) } func (m *EventCache) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - if deterministic { - return xxx_messageInfo_EventCache.Marshal(b, m, deterministic) - } else { - b = b[:cap(b)] - n, err := m.MarshalTo(b) - if err != nil { - return nil, err - } - return b[:n], nil - } + return xxx_messageInfo_EventCache.Marshal(b, m, deterministic) } -func (m *EventCache) XXX_Merge(src proto.Message) { - xxx_messageInfo_EventCache.Merge(m, src) +func (dst *EventCache) XXX_Merge(src proto.Message) { + xxx_messageInfo_EventCache.Merge(dst, src) } func (m *EventCache) XXX_Size() int { - return m.Size() + return xxx_messageInfo_EventCache.Size(m) } func (m *EventCache) XXX_DiscardUnknown() { xxx_messageInfo_EventCache.DiscardUnknown(m) @@ -580,28 +523,19 @@ func (m *TargetCache) String() string { return proto.CompactTextString(m) } func (*TargetCache) ProtoMessage() {} func (*TargetCache) Descriptor() ([]byte, []int) { - return fileDescriptor_02f614a9207041cc, []int{6} + return fileDescriptor_dataprocess_8cd5458c99d96cd7, []int{6} } func (m *TargetCache) XXX_Unmarshal(b []byte) error { - return m.Unmarshal(b) + return xxx_messageInfo_TargetCache.Unmarshal(m, b) } func (m *TargetCache) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - if deterministic { - return xxx_messageInfo_TargetCache.Marshal(b, m, deterministic) - } else { - b = b[:cap(b)] - n, err := m.MarshalTo(b) - if err != nil { - return nil, err - } - return b[:n], nil - } + return xxx_messageInfo_TargetCache.Marshal(b, m, deterministic) } -func (m *TargetCache) XXX_Merge(src proto.Message) { - xxx_messageInfo_TargetCache.Merge(m, src) +func (dst *TargetCache) XXX_Merge(src proto.Message) { + xxx_messageInfo_TargetCache.Merge(dst, src) } func (m *TargetCache) XXX_Size() int { - return m.Size() + return xxx_messageInfo_TargetCache.Size(m) } func (m *TargetCache) XXX_DiscardUnknown() { xxx_messageInfo_TargetCache.DiscardUnknown(m) @@ -643,28 +577,19 @@ func (m *FilterResult) String() string { return proto.CompactTextString(m) } func (*FilterResult) ProtoMessage() {} func (*FilterResult) Descriptor() ([]byte, []int) { - return fileDescriptor_02f614a9207041cc, []int{7} + return fileDescriptor_dataprocess_8cd5458c99d96cd7, []int{7} } func (m *FilterResult) XXX_Unmarshal(b []byte) error { - return m.Unmarshal(b) + return xxx_messageInfo_FilterResult.Unmarshal(m, b) } func (m *FilterResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - if deterministic { - return xxx_messageInfo_FilterResult.Marshal(b, m, deterministic) - } else { - b = b[:cap(b)] - n, err := m.MarshalTo(b) - if err != nil { - return nil, err - } - return b[:n], nil - } + return xxx_messageInfo_FilterResult.Marshal(b, m, deterministic) } -func (m *FilterResult) XXX_Merge(src proto.Message) { - xxx_messageInfo_FilterResult.Merge(m, src) +func (dst *FilterResult) XXX_Merge(src proto.Message) { + xxx_messageInfo_FilterResult.Merge(dst, src) } func (m *FilterResult) XXX_Size() int { - return m.Size() + return xxx_messageInfo_FilterResult.Size(m) } func (m *FilterResult) XXX_DiscardUnknown() { xxx_messageInfo_FilterResult.DiscardUnknown(m) @@ -710,3538 +635,65 @@ proto.RegisterMapType((map[string]*TargetCache)(nil), "protomsg.FilterResult.TargetsEntry") } -func init() { proto.RegisterFile("dataprocess.proto", fileDescriptor_02f614a9207041cc) } +func init() { proto.RegisterFile("dataprocess.proto", fileDescriptor_dataprocess_8cd5458c99d96cd7) } -var fileDescriptor_02f614a9207041cc = []byte{ - // 926 bytes of a gzipped FileDescriptorProto +var fileDescriptor_dataprocess_8cd5458c99d96cd7 = []byte{ + // 902 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x55, 0x41, 0x6f, 0x23, 0x35, - 0x14, 0x66, 0x26, 0x4d, 0x9a, 0x79, 0x29, 0xdb, 0x62, 0x0a, 0x8c, 0x22, 0x88, 0xc2, 0x40, 0xa5, - 0xb0, 0xac, 0x8a, 0xe8, 0x5e, 0x56, 0x8b, 0xf6, 0xd0, 0xa6, 0xed, 0x32, 0x1c, 0x76, 0x8b, 0x53, - 0xc1, 0xd9, 0x9b, 0x31, 0x69, 0x94, 0x99, 0x4c, 0x64, 0x4f, 0x8a, 0xf2, 0x03, 0xb8, 0x70, 0xe2, - 0xc8, 0x5f, 0xe1, 0x1f, 0x20, 0x71, 0xe1, 0x27, 0xa0, 0xf0, 0x0b, 0x38, 0x73, 0x41, 0x7e, 0xf6, - 0xc4, 0x9e, 0xec, 0x44, 0x9c, 0xf6, 0x14, 0xbf, 0x37, 0xdf, 0xfb, 0xfc, 0xfc, 0xbd, 0xcf, 0x0e, - 0xbc, 0x93, 0xb0, 0x82, 0x2d, 0x44, 0x3e, 0xe6, 0x52, 0x9e, 0x2e, 0x44, 0x5e, 0xe4, 0xa4, 0x8d, - 0x3f, 0x99, 0x9c, 0x74, 0x03, 0x99, 0xcc, 0x74, 0xb2, 0x0b, 0x62, 0x99, 0x72, 0xb3, 0x7e, 0x50, - 0x02, 0x74, 0x1c, 0xfd, 0xe4, 0xc3, 0xdb, 0xb7, 0x4c, 0xce, 0x2e, 0x98, 0x9c, 0x8e, 0xe3, 0xf9, - 0x0f, 0x39, 0x39, 0x86, 0xe6, 0x90, 0x65, 0x71, 0x12, 0x7a, 0x7d, 0x6f, 0x10, 0x50, 0x1d, 0x90, - 0x10, 0xf6, 0x87, 0x2c, 0x7b, 0xc1, 0x32, 0x1e, 0xfa, 0x98, 0x2f, 0x43, 0xf2, 0x3e, 0xb4, 0x14, - 0x41, 0x7c, 0x19, 0x36, 0xf0, 0x83, 0x89, 0x48, 0x17, 0xda, 0x6a, 0x85, 0x25, 0x7b, 0xf8, 0x65, - 0x13, 0x93, 0x1e, 0xc0, 0xd7, 0x6c, 0x9e, 0xa4, 0xfc, 0x76, 0x9a, 0xf1, 0xb0, 0x89, 0x5f, 0x9d, - 0x8c, 0xda, 0x2d, 0xce, 0xd8, 0x84, 0xc7, 0x49, 0xd8, 0xea, 0x7b, 0x83, 0x06, 0x2d, 0x43, 0xf2, - 0x21, 0x04, 0xb8, 0xc4, 0xc2, 0x7d, 0x2c, 0xb4, 0x09, 0xd2, 0x87, 0x4e, 0x2c, 0xaf, 0xe6, 0x09, - 0xe5, 0xe3, 0x5c, 0x24, 0x61, 0xbb, 0xef, 0x0d, 0xda, 0xd4, 0x4d, 0xa9, 0x6e, 0xaf, 0xa7, 0xa9, - 0x22, 0x0e, 0x74, 0xb7, 0x3a, 0x8a, 0x7e, 0xf1, 0x00, 0xe8, 0x32, 0xe5, 0x37, 0x4c, 0xb0, 0x4c, - 0x2a, 0xa2, 0x51, 0x32, 0x3b, 0x17, 0x93, 0xf3, 0x74, 0xca, 0xa4, 0x91, 0xc2, 0x4d, 0xa9, 0xe3, - 0xbd, 0x5c, 0x70, 0xc1, 0x8a, 0x5c, 0x18, 0x45, 0x36, 0x31, 0x89, 0xe0, 0xa0, 0x5c, 0xdf, 0xae, - 0x16, 0xdc, 0x08, 0x53, 0xc9, 0xd9, 0x1d, 0xbe, 0x63, 0xe9, 0xb2, 0x54, 0xc8, 0x4d, 0x45, 0x3f, - 0xfb, 0xd0, 0x1a, 0xe5, 0xaa, 0x29, 0xf2, 0x00, 0xfc, 0xcd, 0x40, 0xfc, 0x38, 0x51, 0x9b, 0x0f, - 0x59, 0xc6, 0x05, 0x8b, 0x93, 0x72, 0xf3, 0x32, 0x56, 0x0a, 0xdd, 0xe4, 0xe9, 0x6a, 0x92, 0xcf, - 0xe3, 0xc4, 0xec, 0x6c, 0x13, 0x6a, 0xba, 0xa3, 0x64, 0x16, 0x27, 0x66, 0x43, 0x1d, 0x10, 0x02, - 0x7b, 0xa3, 0x5c, 0x14, 0x38, 0x89, 0x26, 0xc5, 0xb5, 0x6a, 0x50, 0xed, 0xfd, 0xfd, 0xb4, 0xb8, - 0xbb, 0x11, 0x1c, 0xe7, 0x10, 0x50, 0x37, 0xa5, 0x8e, 0x19, 0xcb, 0x11, 0xbb, 0xe7, 0xe7, 0xf3, - 0xd5, 0x5d, 0xfe, 0x23, 0x8e, 0xa3, 0x4d, 0x2b, 0x39, 0x35, 0xc9, 0xe7, 0x22, 0x5f, 0x2e, 0x62, - 0x3d, 0x8d, 0x80, 0x96, 0x21, 0x79, 0x04, 0x2d, 0x2d, 0x76, 0x18, 0xf4, 0x1b, 0x83, 0xce, 0xd9, - 0xf1, 0xe9, 0xc6, 0x9a, 0x76, 0x10, 0xd4, 0x60, 0xa2, 0x7f, 0x3c, 0x68, 0x8f, 0xf2, 0x5b, 0x26, - 0x26, 0xbc, 0x20, 0xa7, 0x10, 0x8c, 0xc4, 0x58, 0x07, 0xa8, 0x4a, 0xe7, 0xec, 0xc8, 0x56, 0xeb, - 0x3c, 0xb5, 0x10, 0x35, 0xf4, 0x73, 0xc1, 0xad, 0x58, 0x26, 0x52, 0x32, 0xaa, 0x15, 0x5a, 0x54, - 0x2b, 0xb5, 0x89, 0xc9, 0x00, 0x0e, 0x2f, 0x78, 0x9a, 0xcf, 0x27, 0x52, 0x93, 0xc4, 0x97, 0x46, - 0xb2, 0xed, 0x34, 0x79, 0x06, 0x30, 0xcc, 0xb3, 0xc5, 0xe5, 0x2b, 0x75, 0x7d, 0xc2, 0x26, 0x1e, - 0xe6, 0xa3, 0xea, 0x61, 0x2e, 0x98, 0xe4, 0x0a, 0xc3, 0x04, 0x57, 0x20, 0xea, 0x14, 0xec, 0xf6, - 0x7a, 0xf4, 0x87, 0xaf, 0xce, 0x4c, 0xb9, 0x5c, 0xa6, 0x05, 0xc2, 0xe4, 0xd5, 0x3d, 0x9f, 0xeb, - 0x13, 0xb7, 0x69, 0x19, 0x6e, 0x9b, 0xde, 0x7f, 0xdd, 0xf4, 0x8f, 0x60, 0x5f, 0x77, 0x2b, 0xc3, - 0x06, 0xb6, 0x47, 0x6c, 0x7b, 0xa5, 0xa8, 0xb4, 0x84, 0x90, 0x2f, 0x00, 0xae, 0xa7, 0x42, 0x16, - 0xd8, 0x06, 0x1e, 0xba, 0x73, 0x76, 0x68, 0x0b, 0x30, 0x4d, 0x1d, 0x88, 0x2a, 0x18, 0xb2, 0xf1, - 0x1d, 0xd7, 0x05, 0xcd, 0x1d, 0x05, 0x16, 0x42, 0x06, 0xd0, 0x92, 0x68, 0x6c, 0x3c, 0x71, 0x65, - 0x78, 0xda, 0xf0, 0xd4, 0x7c, 0x27, 0x5f, 0x42, 0x30, 0x51, 0x7e, 0x41, 0xf0, 0x3e, 0x82, 0xdf, - 0xb5, 0xe0, 0xe7, 0xe5, 0x27, 0x6a, 0x51, 0x6a, 0xd8, 0xa3, 0x1c, 0xaf, 0x9d, 0x36, 0x9c, 0x89, - 0xa2, 0xdf, 0x1a, 0x00, 0x28, 0x18, 0x36, 0x42, 0xbe, 0xb2, 0x9a, 0x78, 0xa8, 0xc9, 0xc7, 0x96, - 0xd7, 0xc2, 0x8c, 0x99, 0xe4, 0xd5, 0xbc, 0x10, 0x2b, 0x2b, 0xd1, 0xa5, 0x7e, 0x2c, 0x70, 0x7f, - 0x19, 0xfa, 0x58, 0xff, 0x69, 0x6d, 0xbd, 0x85, 0x69, 0x0a, 0xa7, 0x8e, 0x3c, 0x81, 0x16, 0xea, - 0x51, 0x4e, 0xa5, 0x5f, 0xcb, 0xa0, 0x21, 0xba, 0xda, 0xe0, 0xbb, 0x2f, 0xe0, 0xc0, 0x6d, 0x8c, - 0x1c, 0x41, 0x63, 0xc6, 0x57, 0x68, 0x8c, 0x3d, 0xaa, 0x96, 0x64, 0x00, 0xcd, 0x7b, 0x7c, 0x58, - 0x7c, 0x14, 0xad, 0x6e, 0xe0, 0x1a, 0xf0, 0xd4, 0x7f, 0xe2, 0x75, 0x29, 0x1c, 0x6e, 0x35, 0xea, - 0x52, 0x06, 0x9a, 0xf2, 0xb3, 0x2a, 0x65, 0xed, 0x1c, 0x1c, 0xce, 0x6f, 0xa0, 0xe3, 0xb4, 0xee, - 0xf2, 0x35, 0x34, 0xdf, 0x49, 0x95, 0xef, 0x35, 0xc7, 0x58, 0xae, 0xe8, 0x5f, 0x0f, 0x3a, 0xba, - 0x6b, 0x3d, 0xbc, 0x87, 0xea, 0x3f, 0xc7, 0xdc, 0xfe, 0x5d, 0x7e, 0x36, 0x08, 0x72, 0x55, 0x33, - 0xab, 0x93, 0xed, 0xd7, 0xe2, 0xff, 0x87, 0x75, 0x02, 0x4d, 0xed, 0xef, 0xc6, 0x8e, 0x6e, 0xf1, - 0xe7, 0x4d, 0x28, 0x19, 0xad, 0x7d, 0x38, 0xb8, 0x9e, 0xa6, 0x05, 0x17, 0xe6, 0x2d, 0x78, 0x0c, - 0x6d, 0xf5, 0xa2, 0xe0, 0x7b, 0xa3, 0x9f, 0xbf, 0x0f, 0xdc, 0x03, 0x39, 0xff, 0xe6, 0x74, 0x03, - 0x24, 0x4f, 0xa1, 0x85, 0xae, 0x2a, 0x35, 0x88, 0x6c, 0x89, 0x4b, 0xae, 0xad, 0x57, 0xfa, 0x4d, - 0x07, 0xe4, 0xd9, 0xf6, 0x03, 0xf2, 0xc9, 0x8e, 0xe2, 0xda, 0xeb, 0xd2, 0x7d, 0x09, 0x1d, 0x87, - 0xb5, 0x46, 0x90, 0x87, 0x55, 0x41, 0x8e, 0xeb, 0x2e, 0x82, 0xeb, 0xad, 0x6f, 0x77, 0xfb, 0xdf, - 0x30, 0x7e, 0x5e, 0x65, 0x7c, 0xaf, 0x76, 0xe0, 0x0e, 0xe5, 0xc5, 0xd1, 0xef, 0xeb, 0x9e, 0xf7, - 0xe7, 0xba, 0xe7, 0xfd, 0xb5, 0xee, 0x79, 0xbf, 0xfe, 0xdd, 0x7b, 0xeb, 0x55, 0x0b, 0x4b, 0x1e, - 0xff, 0x17, 0x00, 0x00, 0xff, 0xff, 0xdf, 0x62, 0x1f, 0x43, 0x67, 0x09, 0x00, 0x00, + 0x14, 0xd6, 0x4c, 0x9a, 0x34, 0xf3, 0x52, 0xb6, 0x8b, 0x29, 0x30, 0x8a, 0x00, 0x85, 0x81, 0x4a, + 0x61, 0x59, 0x15, 0xd1, 0xbd, 0xac, 0x16, 0xed, 0xa1, 0x4d, 0xdb, 0x65, 0x38, 0xec, 0x16, 0x27, + 0x82, 0xb3, 0x37, 0x63, 0xd2, 0x28, 0x33, 0x71, 0x64, 0x4f, 0x8a, 0xf2, 0x03, 0xb8, 0x70, 0xe2, + 0xef, 0xf0, 0x1b, 0xf8, 0x17, 0xfc, 0x03, 0xce, 0x5c, 0x90, 0x9f, 0x3d, 0xb1, 0x27, 0x9d, 0x88, + 0xd3, 0x9e, 0xe2, 0xf7, 0xe6, 0x7b, 0x9f, 0x9f, 0xbf, 0xf7, 0xd9, 0x81, 0xf7, 0x33, 0x56, 0xb2, + 0x95, 0x14, 0x53, 0xae, 0xd4, 0xd9, 0x4a, 0x8a, 0x52, 0x90, 0x2e, 0xfe, 0x14, 0x6a, 0xd6, 0x8f, + 0x54, 0xb6, 0x30, 0xc9, 0x3e, 0xc8, 0x75, 0xce, 0xed, 0xfa, 0x51, 0x05, 0x30, 0x71, 0xf2, 0x5b, + 0x08, 0xef, 0x4d, 0x98, 0x5a, 0x5c, 0x32, 0x35, 0x9f, 0xa6, 0xcb, 0x5f, 0x04, 0x39, 0x81, 0xf6, + 0x88, 0x15, 0x69, 0x16, 0x07, 0x83, 0x60, 0x18, 0x51, 0x13, 0x90, 0x18, 0x0e, 0x47, 0xac, 0x78, + 0xcd, 0x0a, 0x1e, 0x87, 0x98, 0xaf, 0x42, 0xf2, 0x11, 0x74, 0x34, 0x41, 0x7a, 0x15, 0xb7, 0xf0, + 0x83, 0x8d, 0x48, 0x1f, 0xba, 0x7a, 0x85, 0x25, 0x07, 0xf8, 0x65, 0x1b, 0x93, 0xcf, 0x00, 0xbe, + 0x67, 0xcb, 0x2c, 0xe7, 0x93, 0x79, 0xc1, 0xe3, 0x36, 0x7e, 0xf5, 0x32, 0x7a, 0xb7, 0xb4, 0x60, + 0x33, 0x9e, 0x66, 0x71, 0x67, 0x10, 0x0c, 0x5b, 0xb4, 0x0a, 0xc9, 0x27, 0x10, 0xe1, 0x12, 0x0b, + 0x0f, 0xb1, 0xd0, 0x25, 0xc8, 0x00, 0x7a, 0xa9, 0xba, 0x5e, 0x66, 0x94, 0x4f, 0x85, 0xcc, 0xe2, + 0xee, 0x20, 0x18, 0x76, 0xa9, 0x9f, 0xd2, 0xdd, 0xde, 0xcc, 0x73, 0x4d, 0x1c, 0x99, 0x6e, 0x4d, + 0x94, 0xfc, 0x11, 0x00, 0xd0, 0x75, 0xce, 0x6f, 0x99, 0x64, 0x85, 0xd2, 0x44, 0xe3, 0x6c, 0x71, + 0x21, 0x67, 0x17, 0xf9, 0x9c, 0x29, 0x2b, 0x85, 0x9f, 0xd2, 0xc7, 0x7b, 0xb3, 0xe2, 0x92, 0x95, + 0x42, 0x5a, 0x45, 0xb6, 0x31, 0x49, 0xe0, 0xa8, 0x5a, 0x4f, 0x36, 0x2b, 0x6e, 0x85, 0xa9, 0xe5, + 0xdc, 0x0e, 0x3f, 0xb1, 0x7c, 0x5d, 0x29, 0xe4, 0xa7, 0x92, 0xdf, 0x43, 0xe8, 0x8c, 0x85, 0x6e, + 0x8a, 0x3c, 0x82, 0x70, 0x3b, 0x90, 0x30, 0xcd, 0xf4, 0xe6, 0x23, 0x56, 0x70, 0xc9, 0xd2, 0xac, + 0xda, 0xbc, 0x8a, 0xb5, 0x42, 0xb7, 0x22, 0xdf, 0xcc, 0xc4, 0x32, 0xcd, 0xec, 0xce, 0x2e, 0xa1, + 0xa7, 0x3b, 0xce, 0x16, 0x69, 0x66, 0x37, 0x34, 0x01, 0x21, 0x70, 0x30, 0x16, 0xb2, 0xc4, 0x49, + 0xb4, 0x29, 0xae, 0x75, 0x83, 0x7a, 0xef, 0x9f, 0xe7, 0xe5, 0xdd, 0xad, 0xe4, 0x38, 0x87, 0x88, + 0xfa, 0x29, 0x7d, 0xcc, 0x54, 0x8d, 0xd9, 0x3d, 0xbf, 0x58, 0x6e, 0xee, 0xc4, 0xaf, 0x38, 0x8e, + 0x2e, 0xad, 0xe5, 0xf4, 0x24, 0x5f, 0x49, 0xb1, 0x5e, 0xa5, 0x66, 0x1a, 0x11, 0xad, 0x42, 0xf2, + 0x14, 0x3a, 0x46, 0xec, 0x38, 0x1a, 0xb4, 0x86, 0xbd, 0xf3, 0x93, 0xb3, 0xad, 0x35, 0xdd, 0x20, + 0xa8, 0xc5, 0x24, 0xff, 0x04, 0xd0, 0x1d, 0x8b, 0x09, 0x93, 0x33, 0x5e, 0x92, 0x33, 0x88, 0xc6, + 0x72, 0x6a, 0x02, 0x54, 0xa5, 0x77, 0xfe, 0xd8, 0x55, 0x9b, 0x3c, 0x75, 0x10, 0x3d, 0xf4, 0x0b, + 0xc9, 0x9d, 0x58, 0x36, 0xd2, 0x32, 0xea, 0x15, 0x5a, 0xd4, 0x28, 0xb5, 0x8d, 0xc9, 0x10, 0x8e, + 0x2f, 0x79, 0x2e, 0x96, 0x33, 0x65, 0x48, 0xd2, 0x2b, 0x2b, 0xd9, 0x6e, 0x9a, 0xbc, 0x04, 0x18, + 0x89, 0x62, 0x75, 0xf5, 0x56, 0x5f, 0x9f, 0xb8, 0x8d, 0x87, 0xf9, 0xb4, 0x7e, 0x98, 0x4b, 0xa6, + 0xb8, 0xc6, 0x30, 0xc9, 0x35, 0x88, 0x7a, 0x05, 0xfb, 0xbd, 0x9e, 0xfc, 0x15, 0xea, 0x33, 0x53, + 0xae, 0xd6, 0x79, 0x89, 0x30, 0x75, 0x7d, 0xcf, 0x97, 0xe6, 0xc4, 0x5d, 0x5a, 0x85, 0xbb, 0xa6, + 0x0f, 0x1f, 0x9a, 0xfe, 0x29, 0x1c, 0x9a, 0x6e, 0x55, 0xdc, 0xc2, 0xf6, 0x88, 0x6b, 0xaf, 0x12, + 0x95, 0x56, 0x10, 0xf2, 0x0d, 0xc0, 0xcd, 0x5c, 0xaa, 0x12, 0xdb, 0xc0, 0x43, 0xf7, 0xce, 0x8f, + 0x5d, 0x01, 0xa6, 0xa9, 0x07, 0xd1, 0x05, 0x23, 0x36, 0xbd, 0xe3, 0xa6, 0xa0, 0xbd, 0xa7, 0xc0, + 0x41, 0xc8, 0x10, 0x3a, 0x0a, 0x8d, 0x8d, 0x27, 0xae, 0x0d, 0xcf, 0x18, 0x9e, 0xda, 0xef, 0xe4, + 0x5b, 0x88, 0x66, 0xda, 0x2f, 0x08, 0x3e, 0x44, 0xf0, 0x07, 0x0e, 0xfc, 0xaa, 0xfa, 0x44, 0x1d, + 0x4a, 0x0f, 0x7b, 0x2c, 0xf0, 0xda, 0x19, 0xc3, 0xd9, 0x28, 0xf9, 0xb3, 0x05, 0x80, 0x82, 0x61, + 0x23, 0xe4, 0x3b, 0xa7, 0x49, 0x80, 0x9a, 0x7c, 0xee, 0x78, 0x1d, 0xcc, 0x9a, 0x49, 0x5d, 0x2f, + 0x4b, 0xb9, 0x71, 0x12, 0x5d, 0x99, 0xc7, 0x02, 0xf7, 0x57, 0x71, 0x88, 0xf5, 0x5f, 0x36, 0xd6, + 0x3b, 0x98, 0xa1, 0xf0, 0xea, 0xc8, 0x73, 0xe8, 0xa0, 0x1e, 0xd5, 0x54, 0x06, 0x8d, 0x0c, 0x06, + 0x62, 0xaa, 0x2d, 0xbe, 0xff, 0x1a, 0x8e, 0xfc, 0xc6, 0xc8, 0x63, 0x68, 0x2d, 0xf8, 0x06, 0x8d, + 0x71, 0x40, 0xf5, 0x92, 0x0c, 0xa1, 0x7d, 0x8f, 0x0f, 0x4b, 0x88, 0xa2, 0x35, 0x0d, 0xdc, 0x00, + 0x5e, 0x84, 0xcf, 0x83, 0x3e, 0x85, 0xe3, 0x9d, 0x46, 0x7d, 0xca, 0xc8, 0x50, 0x7e, 0x55, 0xa7, + 0x6c, 0x9c, 0x83, 0xc7, 0xf9, 0x03, 0xf4, 0xbc, 0xd6, 0x7d, 0xbe, 0x96, 0xe1, 0x3b, 0xad, 0xf3, + 0x3d, 0x70, 0x8c, 0xe3, 0x4a, 0xfe, 0x0d, 0xa0, 0x67, 0xba, 0x36, 0xc3, 0x7b, 0xa2, 0xff, 0x73, + 0xec, 0xed, 0xdf, 0xe7, 0x67, 0x8b, 0x20, 0xd7, 0x0d, 0xb3, 0x3a, 0xdd, 0x7d, 0x2d, 0xfe, 0x7f, + 0x58, 0xa7, 0xd0, 0x36, 0xfe, 0x6e, 0xed, 0xe9, 0x16, 0x7f, 0xde, 0x85, 0x92, 0xc9, 0xdf, 0x21, + 0x1c, 0xdd, 0xcc, 0xf3, 0x92, 0x4b, 0xfb, 0x16, 0x3c, 0x83, 0xae, 0x7e, 0x51, 0xf0, 0xbd, 0x31, + 0xcf, 0xdf, 0xc7, 0xfe, 0x81, 0xbc, 0x7f, 0x73, 0xba, 0x05, 0x92, 0x17, 0xd0, 0x41, 0x57, 0x55, + 0x1a, 0x24, 0xae, 0xc4, 0x27, 0x37, 0xd6, 0xab, 0xfc, 0x66, 0x02, 0xf2, 0x72, 0xf7, 0x01, 0xf9, + 0x62, 0x4f, 0x71, 0xe3, 0x75, 0xe9, 0xbf, 0x81, 0x9e, 0xc7, 0xda, 0x20, 0xc8, 0x93, 0xba, 0x20, + 0x27, 0x4d, 0x17, 0xc1, 0xf7, 0xd6, 0x8f, 0xfb, 0xfd, 0x6f, 0x19, 0xbf, 0xae, 0x33, 0x7e, 0xd8, + 0x38, 0x70, 0x8f, 0xf2, 0x6d, 0x07, 0x01, 0xcf, 0xfe, 0x0b, 0x00, 0x00, 0xff, 0xff, 0x49, 0xf3, + 0x62, 0x92, 0x55, 0x09, 0x00, 0x00, } - -func (m *TaskBasicInfo) Marshal() (dAtA []byte, err error) { - size := m.Size() - dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) - if err != nil { - return nil, err - } - return dAtA[:n], nil -} - -func (m *TaskBasicInfo) MarshalTo(dAtA []byte) (int, error) { - var i int - _ = i - var l int - _ = l - if len(m.CamId) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.CamId))) - i += copy(dAtA[i:], m.CamId) - } - if len(m.CamName) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.CamName))) - i += copy(dAtA[i:], m.CamName) - } - if len(m.TaskID) > 0 { - dAtA[i] = 0x1a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.TaskID))) - i += copy(dAtA[i:], m.TaskID) - } - if len(m.TaskName) > 0 { - dAtA[i] = 0x22 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.TaskName))) - i += copy(dAtA[i:], m.TaskName) - } - if len(m.HandleTime) > 0 { - dAtA[i] = 0x2a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.HandleTime))) - i += copy(dAtA[i:], m.HandleTime) - } - if m.ImageId != 0 { - dAtA[i] = 0x30 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(m.ImageId)) - } - if len(m.ImageTime) > 0 { - dAtA[i] = 0x3a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.ImageTime))) - i += copy(dAtA[i:], m.ImageTime) - } - if m.IsEndRecord { - dAtA[i] = 0x40 - i++ - if m.IsEndRecord { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ - } - if len(m.FileId) > 0 { - dAtA[i] = 0x4a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.FileId))) - i += copy(dAtA[i:], m.FileId) - } - if m.XXX_unrecognized != nil { - i += copy(dAtA[i:], m.XXX_unrecognized) - } - return i, nil -} - -func (m *RuleParams) Marshal() (dAtA []byte, err error) { - size := m.Size() - dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) - if err != nil { - return nil, err - } - return dAtA[:n], nil -} - -func (m *RuleParams) MarshalTo(dAtA []byte) (int, error) { - var i int - _ = i - var l int - _ = l - if len(m.SdkArgAlias) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.SdkArgAlias))) - i += copy(dAtA[i:], m.SdkArgAlias) - } - if len(m.Operator) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.Operator))) - i += copy(dAtA[i:], m.Operator) - } - if len(m.OperatorType) > 0 { - dAtA[i] = 0x1a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.OperatorType))) - i += copy(dAtA[i:], m.OperatorType) - } - if len(m.SdkArgValue) > 0 { - dAtA[i] = 0x22 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.SdkArgValue))) - i += copy(dAtA[i:], m.SdkArgValue) - } - if m.XXX_unrecognized != nil { - i += copy(dAtA[i:], m.XXX_unrecognized) - } - return i, nil -} - -func (m *SoRule) Marshal() (dAtA []byte, err error) { - size := m.Size() - dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) - if err != nil { - return nil, err - } - return dAtA[:n], nil -} - -func (m *SoRule) MarshalTo(dAtA []byte) (int, error) { - var i int - _ = i - var l int - _ = l - if len(m.Id) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.Id))) - i += copy(dAtA[i:], m.Id) - } - if len(m.CameraId) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.CameraId))) - i += copy(dAtA[i:], m.CameraId) - } - if len(m.PolygonId) > 0 { - dAtA[i] = 0x1a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.PolygonId))) - i += copy(dAtA[i:], m.PolygonId) - } - if len(m.SdkId) > 0 { - dAtA[i] = 0x22 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.SdkId))) - i += copy(dAtA[i:], m.SdkId) - } - if m.Sort != 0 { - dAtA[i] = 0x28 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(m.Sort)) - } - if len(m.RuleWithPre) > 0 { - dAtA[i] = 0x32 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.RuleWithPre))) - i += copy(dAtA[i:], m.RuleWithPre) - } - if m.IsSaveAnyhow { - dAtA[i] = 0x38 - i++ - if m.IsSaveAnyhow { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ - } - if len(m.GroupId) > 0 { - dAtA[i] = 0x42 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.GroupId))) - i += copy(dAtA[i:], m.GroupId) - } - if len(m.Params) > 0 { - for _, msg := range m.Params { - dAtA[i] = 0x4a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err - } - i += n - } - } - if m.XXX_unrecognized != nil { - i += copy(dAtA[i:], m.XXX_unrecognized) - } - return i, nil -} - -func (m *SoTarget) Marshal() (dAtA []byte, err error) { - size := m.Size() - dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) - if err != nil { - return nil, err - } - return dAtA[:n], nil -} - -func (m *SoTarget) MarshalTo(dAtA []byte) (int, error) { - var i int - _ = i - var l int - _ = l - if m.SrcTarget != nil { - dAtA[i] = 0xa - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(m.SrcTarget.Size())) - n1, err1 := m.SrcTarget.MarshalTo(dAtA[i:]) - if err1 != nil { - return 0, err1 - } - i += n1 - } - if len(m.AreaId) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.AreaId))) - i += copy(dAtA[i:], m.AreaId) - } - if len(m.AreaName) > 0 { - dAtA[i] = 0x1a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.AreaName))) - i += copy(dAtA[i:], m.AreaName) - } - if len(m.BelongsTargetID) > 0 { - dAtA[i] = 0x22 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.BelongsTargetID))) - i += copy(dAtA[i:], m.BelongsTargetID) - } - if len(m.CompDbInfo) > 0 { - for _, msg := range m.CompDbInfo { - dAtA[i] = 0x2a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err - } - i += n - } - } - if m.ImageId != 0 { - dAtA[i] = 0x30 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(m.ImageId)) - } - if m.XXX_unrecognized != nil { - i += copy(dAtA[i:], m.XXX_unrecognized) - } - return i, nil -} - -func (m *SoResult) Marshal() (dAtA []byte, err error) { - size := m.Size() - dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) - if err != nil { - return nil, err - } - return dAtA[:n], nil -} - -func (m *SoResult) MarshalTo(dAtA []byte) (int, error) { - var i int - _ = i - var l int - _ = l - if m.IsEvent { - dAtA[i] = 0x8 - i++ - if m.IsEvent { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ - } - if m.IsEndRecord { - dAtA[i] = 0x10 - i++ - if m.IsEndRecord { - dAtA[i] = 1 - } else { - dAtA[i] = 0 - } - i++ - } - if len(m.Targets) > 0 { - for _, msg := range m.Targets { - dAtA[i] = 0x1a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err - } - i += n - } - } - if m.FirstImage != nil { - dAtA[i] = 0x22 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(m.FirstImage.Size())) - n2, err2 := m.FirstImage.MarshalTo(dAtA[i:]) - if err2 != nil { - return 0, err2 - } - i += n2 - } - if m.CacheImage != nil { - dAtA[i] = 0x2a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(m.CacheImage.Size())) - n3, err3 := m.CacheImage.MarshalTo(dAtA[i:]) - if err3 != nil { - return 0, err3 - } - i += n3 - } - if m.SoRule != nil { - dAtA[i] = 0x32 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(m.SoRule.Size())) - n4, err4 := m.SoRule.MarshalTo(dAtA[i:]) - if err4 != nil { - return 0, err4 - } - i += n4 - } - if m.GroupRule != nil { - dAtA[i] = 0x3a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(m.GroupRule.Size())) - n5, err5 := m.GroupRule.MarshalTo(dAtA[i:]) - if err5 != nil { - return 0, err5 - } - i += n5 - } - if len(m.SoType) > 0 { - dAtA[i] = 0x42 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(m.SoType))) - i += copy(dAtA[i:], m.SoType) - } - if m.XXX_unrecognized != nil { - i += copy(dAtA[i:], m.XXX_unrecognized) - } - return i, nil -} - -func (m *EventCache) Marshal() (dAtA []byte, err error) { - size := m.Size() - dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) - if err != nil { - return nil, err - } - return dAtA[:n], nil -} - -func (m *EventCache) MarshalTo(dAtA []byte) (int, error) { - var i int - _ = i - var l int - _ = l - if len(m.Targets) > 0 { - for k, _ := range m.Targets { - dAtA[i] = 0xa - i++ - v := m.Targets[k] - msgSize := 0 - if v != nil { - msgSize = v.Size() - msgSize += 1 + sovDataprocess(uint64(msgSize)) - } - mapSize := 1 + sovDataprocess(uint64(k)) + msgSize - i = encodeVarintDataprocess(dAtA, i, uint64(mapSize)) - dAtA[i] = 0x8 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(k)) - if v != nil { - dAtA[i] = 0x12 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(v.Size())) - n6, err6 := v.MarshalTo(dAtA[i:]) - if err6 != nil { - return 0, err6 - } - i += n6 - } - } - } - if len(m.RuleGroups) > 0 { - for k, _ := range m.RuleGroups { - dAtA[i] = 0x12 - i++ - v := m.RuleGroups[k] - msgSize := 0 - if v != nil { - msgSize = v.Size() - msgSize += 1 + sovDataprocess(uint64(msgSize)) - } - mapSize := 1 + len(k) + sovDataprocess(uint64(len(k))) + msgSize - i = encodeVarintDataprocess(dAtA, i, uint64(mapSize)) - dAtA[i] = 0xa - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(k))) - i += copy(dAtA[i:], k) - if v != nil { - dAtA[i] = 0x12 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(v.Size())) - n7, err7 := v.MarshalTo(dAtA[i:]) - if err7 != nil { - return 0, err7 - } - i += n7 - } - } - } - if len(m.Images) > 0 { - for k, _ := range m.Images { - dAtA[i] = 0x1a - i++ - v := m.Images[k] - msgSize := 0 - if v != nil { - msgSize = v.Size() - msgSize += 1 + sovDataprocess(uint64(msgSize)) - } - mapSize := 1 + sovDataprocess(uint64(k)) + msgSize - i = encodeVarintDataprocess(dAtA, i, uint64(mapSize)) - dAtA[i] = 0x8 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(k)) - if v != nil { - dAtA[i] = 0x12 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(v.Size())) - n8, err8 := v.MarshalTo(dAtA[i:]) - if err8 != nil { - return 0, err8 - } - i += n8 - } - } - } - if m.XXX_unrecognized != nil { - i += copy(dAtA[i:], m.XXX_unrecognized) - } - return i, nil -} - -func (m *TargetCache) Marshal() (dAtA []byte, err error) { - size := m.Size() - dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) - if err != nil { - return nil, err - } - return dAtA[:n], nil -} - -func (m *TargetCache) MarshalTo(dAtA []byte) (int, error) { - var i int - _ = i - var l int - _ = l - if len(m.Target) > 0 { - for _, msg := range m.Target { - dAtA[i] = 0xa - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err - } - i += n - } - } - if len(m.RuleGroups) > 0 { - for k, _ := range m.RuleGroups { - dAtA[i] = 0x12 - i++ - v := m.RuleGroups[k] - msgSize := 0 - if v != nil { - msgSize = v.Size() - msgSize += 1 + sovDataprocess(uint64(msgSize)) - } - mapSize := 1 + len(k) + sovDataprocess(uint64(len(k))) + msgSize - i = encodeVarintDataprocess(dAtA, i, uint64(mapSize)) - dAtA[i] = 0xa - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(k))) - i += copy(dAtA[i:], k) - if v != nil { - dAtA[i] = 0x12 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(v.Size())) - n9, err9 := v.MarshalTo(dAtA[i:]) - if err9 != nil { - return 0, err9 - } - i += n9 - } - } - } - if m.Image != nil { - dAtA[i] = 0x1a - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(m.Image.Size())) - n10, err10 := m.Image.MarshalTo(dAtA[i:]) - if err10 != nil { - return 0, err10 - } - i += n10 - } - if m.XXX_unrecognized != nil { - i += copy(dAtA[i:], m.XXX_unrecognized) - } - return i, nil -} - -func (m *FilterResult) Marshal() (dAtA []byte, err error) { - size := m.Size() - dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) - if err != nil { - return nil, err - } - return dAtA[:n], nil -} - -func (m *FilterResult) MarshalTo(dAtA []byte) (int, error) { - var i int - _ = i - var l int - _ = l - if m.BaseInfo != nil { - dAtA[i] = 0xa - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(m.BaseInfo.Size())) - n11, err11 := m.BaseInfo.MarshalTo(dAtA[i:]) - if err11 != nil { - return 0, err11 - } - i += n11 - } - if len(m.Events) > 0 { - for k, _ := range m.Events { - dAtA[i] = 0x12 - i++ - v := m.Events[k] - msgSize := 0 - if v != nil { - msgSize = v.Size() - msgSize += 1 + sovDataprocess(uint64(msgSize)) - } - mapSize := 1 + len(k) + sovDataprocess(uint64(len(k))) + msgSize - i = encodeVarintDataprocess(dAtA, i, uint64(mapSize)) - dAtA[i] = 0xa - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(k))) - i += copy(dAtA[i:], k) - if v != nil { - dAtA[i] = 0x12 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(v.Size())) - n12, err12 := v.MarshalTo(dAtA[i:]) - if err12 != nil { - return 0, err12 - } - i += n12 - } - } - } - if len(m.Targets) > 0 { - for k, _ := range m.Targets { - dAtA[i] = 0x1a - i++ - v := m.Targets[k] - msgSize := 0 - if v != nil { - msgSize = v.Size() - msgSize += 1 + sovDataprocess(uint64(msgSize)) - } - mapSize := 1 + len(k) + sovDataprocess(uint64(len(k))) + msgSize - i = encodeVarintDataprocess(dAtA, i, uint64(mapSize)) - dAtA[i] = 0xa - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(len(k))) - i += copy(dAtA[i:], k) - if v != nil { - dAtA[i] = 0x12 - i++ - i = encodeVarintDataprocess(dAtA, i, uint64(v.Size())) - n13, err13 := v.MarshalTo(dAtA[i:]) - if err13 != nil { - return 0, err13 - } - i += n13 - } - } - } - if m.XXX_unrecognized != nil { - i += copy(dAtA[i:], m.XXX_unrecognized) - } - return i, nil -} - -func encodeVarintDataprocess(dAtA []byte, offset int, v uint64) int { - for v >= 1<<7 { - dAtA[offset] = uint8(v&0x7f | 0x80) - v >>= 7 - offset++ - } - dAtA[offset] = uint8(v) - return offset + 1 -} -func (m *TaskBasicInfo) Size() (n int) { - if m == nil { - return 0 - } - var l int - _ = l - l = len(m.CamId) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.CamName) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.TaskID) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.TaskName) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.HandleTime) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.ImageId != 0 { - n += 1 + sovDataprocess(uint64(m.ImageId)) - } - l = len(m.ImageTime) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.IsEndRecord { - n += 2 - } - l = len(m.FileId) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.XXX_unrecognized != nil { - n += len(m.XXX_unrecognized) - } - return n -} - -func (m *RuleParams) Size() (n int) { - if m == nil { - return 0 - } - var l int - _ = l - l = len(m.SdkArgAlias) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.Operator) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.OperatorType) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.SdkArgValue) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.XXX_unrecognized != nil { - n += len(m.XXX_unrecognized) - } - return n -} - -func (m *SoRule) Size() (n int) { - if m == nil { - return 0 - } - var l int - _ = l - l = len(m.Id) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.CameraId) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.PolygonId) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.SdkId) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.Sort != 0 { - n += 1 + sovDataprocess(uint64(m.Sort)) - } - l = len(m.RuleWithPre) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.IsSaveAnyhow { - n += 2 - } - l = len(m.GroupId) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - if len(m.Params) > 0 { - for _, e := range m.Params { - l = e.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - } - if m.XXX_unrecognized != nil { - n += len(m.XXX_unrecognized) - } - return n -} - -func (m *SoTarget) Size() (n int) { - if m == nil { - return 0 - } - var l int - _ = l - if m.SrcTarget != nil { - l = m.SrcTarget.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.AreaId) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.AreaName) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.BelongsTargetID) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - if len(m.CompDbInfo) > 0 { - for _, e := range m.CompDbInfo { - l = e.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - } - if m.ImageId != 0 { - n += 1 + sovDataprocess(uint64(m.ImageId)) - } - if m.XXX_unrecognized != nil { - n += len(m.XXX_unrecognized) - } - return n -} - -func (m *SoResult) Size() (n int) { - if m == nil { - return 0 - } - var l int - _ = l - if m.IsEvent { - n += 2 - } - if m.IsEndRecord { - n += 2 - } - if len(m.Targets) > 0 { - for _, e := range m.Targets { - l = e.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - } - if m.FirstImage != nil { - l = m.FirstImage.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.CacheImage != nil { - l = m.CacheImage.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.SoRule != nil { - l = m.SoRule.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.GroupRule != nil { - l = m.GroupRule.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - l = len(m.SoType) - if l > 0 { - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.XXX_unrecognized != nil { - n += len(m.XXX_unrecognized) - } - return n -} - -func (m *EventCache) Size() (n int) { - if m == nil { - return 0 - } - var l int - _ = l - if len(m.Targets) > 0 { - for k, v := range m.Targets { - _ = k - _ = v - l = 0 - if v != nil { - l = v.Size() - l += 1 + sovDataprocess(uint64(l)) - } - mapEntrySize := 1 + sovDataprocess(uint64(k)) + l - n += mapEntrySize + 1 + sovDataprocess(uint64(mapEntrySize)) - } - } - if len(m.RuleGroups) > 0 { - for k, v := range m.RuleGroups { - _ = k - _ = v - l = 0 - if v != nil { - l = v.Size() - l += 1 + sovDataprocess(uint64(l)) - } - mapEntrySize := 1 + len(k) + sovDataprocess(uint64(len(k))) + l - n += mapEntrySize + 1 + sovDataprocess(uint64(mapEntrySize)) - } - } - if len(m.Images) > 0 { - for k, v := range m.Images { - _ = k - _ = v - l = 0 - if v != nil { - l = v.Size() - l += 1 + sovDataprocess(uint64(l)) - } - mapEntrySize := 1 + sovDataprocess(uint64(k)) + l - n += mapEntrySize + 1 + sovDataprocess(uint64(mapEntrySize)) - } - } - if m.XXX_unrecognized != nil { - n += len(m.XXX_unrecognized) - } - return n -} - -func (m *TargetCache) Size() (n int) { - if m == nil { - return 0 - } - var l int - _ = l - if len(m.Target) > 0 { - for _, e := range m.Target { - l = e.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - } - if len(m.RuleGroups) > 0 { - for k, v := range m.RuleGroups { - _ = k - _ = v - l = 0 - if v != nil { - l = v.Size() - l += 1 + sovDataprocess(uint64(l)) - } - mapEntrySize := 1 + len(k) + sovDataprocess(uint64(len(k))) + l - n += mapEntrySize + 1 + sovDataprocess(uint64(mapEntrySize)) - } - } - if m.Image != nil { - l = m.Image.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - if m.XXX_unrecognized != nil { - n += len(m.XXX_unrecognized) - } - return n -} - -func (m *FilterResult) Size() (n int) { - if m == nil { - return 0 - } - var l int - _ = l - if m.BaseInfo != nil { - l = m.BaseInfo.Size() - n += 1 + l + sovDataprocess(uint64(l)) - } - if len(m.Events) > 0 { - for k, v := range m.Events { - _ = k - _ = v - l = 0 - if v != nil { - l = v.Size() - l += 1 + sovDataprocess(uint64(l)) - } - mapEntrySize := 1 + len(k) + sovDataprocess(uint64(len(k))) + l - n += mapEntrySize + 1 + sovDataprocess(uint64(mapEntrySize)) - } - } - if len(m.Targets) > 0 { - for k, v := range m.Targets { - _ = k - _ = v - l = 0 - if v != nil { - l = v.Size() - l += 1 + sovDataprocess(uint64(l)) - } - mapEntrySize := 1 + len(k) + sovDataprocess(uint64(len(k))) + l - n += mapEntrySize + 1 + sovDataprocess(uint64(mapEntrySize)) - } - } - if m.XXX_unrecognized != nil { - n += len(m.XXX_unrecognized) - } - return n -} - -func sovDataprocess(x uint64) (n int) { - for { - n++ - x >>= 7 - if x == 0 { - break - } - } - return n -} -func sozDataprocess(x uint64) (n int) { - return sovDataprocess(uint64((x << 1) ^ uint64((int64(x) >> 63)))) -} -func (m *TaskBasicInfo) 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 ErrIntOverflowDataprocess - } - 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: TaskBasicInfo: wiretype end group for non-group") - } - if fieldNum <= 0 { - return fmt.Errorf("proto: TaskBasicInfo: illegal tag %d (wire type %d)", fieldNum, wire) - } - switch fieldNum { - case 1: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field CamId", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.CamId = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 2: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field CamName", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.CamName = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 3: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field TaskID", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.TaskID = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 4: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field TaskName", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.TaskName = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 5: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field HandleTime", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.HandleTime = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 6: - if wireType != 0 { - return fmt.Errorf("proto: wrong wireType = %d for field ImageId", wireType) - } - m.ImageId = 0 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - m.ImageId |= int64(b&0x7F) << shift - if b < 0x80 { - break - } - } - case 7: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field ImageTime", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.ImageTime = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 8: - if wireType != 0 { - return fmt.Errorf("proto: wrong wireType = %d for field IsEndRecord", wireType) - } - var v int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - v |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - m.IsEndRecord = bool(v != 0) - case 9: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field FileId", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.FileId = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - default: - iNdEx = preIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) < 0 { - return ErrInvalidLengthDataprocess - } - 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 -} -func (m *RuleParams) 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 ErrIntOverflowDataprocess - } - 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: RuleParams: wiretype end group for non-group") - } - if fieldNum <= 0 { - return fmt.Errorf("proto: RuleParams: illegal tag %d (wire type %d)", fieldNum, wire) - } - switch fieldNum { - case 1: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field SdkArgAlias", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.SdkArgAlias = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 2: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field Operator", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.Operator = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 3: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field OperatorType", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.OperatorType = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 4: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field SdkArgValue", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.SdkArgValue = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - default: - iNdEx = preIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) < 0 { - return ErrInvalidLengthDataprocess - } - 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 -} -func (m *SoRule) 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 ErrIntOverflowDataprocess - } - 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: SoRule: wiretype end group for non-group") - } - if fieldNum <= 0 { - return fmt.Errorf("proto: SoRule: illegal tag %d (wire type %d)", fieldNum, wire) - } - switch fieldNum { - case 1: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field Id", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.Id = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 2: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field CameraId", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.CameraId = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 3: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field PolygonId", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.PolygonId = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 4: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field SdkId", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.SdkId = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 5: - if wireType != 0 { - return fmt.Errorf("proto: wrong wireType = %d for field Sort", wireType) - } - m.Sort = 0 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - m.Sort |= int32(b&0x7F) << shift - if b < 0x80 { - break - } - } - case 6: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field RuleWithPre", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.RuleWithPre = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 7: - if wireType != 0 { - return fmt.Errorf("proto: wrong wireType = %d for field IsSaveAnyhow", wireType) - } - var v int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - v |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - m.IsSaveAnyhow = bool(v != 0) - case 8: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field GroupId", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.GroupId = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 9: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field Params", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.Params = append(m.Params, &RuleParams{}) - if err := m.Params[len(m.Params)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - default: - iNdEx = preIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) < 0 { - return ErrInvalidLengthDataprocess - } - 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 -} -func (m *SoTarget) 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 ErrIntOverflowDataprocess - } - 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: SoTarget: wiretype end group for non-group") - } - if fieldNum <= 0 { - return fmt.Errorf("proto: SoTarget: illegal tag %d (wire type %d)", fieldNum, wire) - } - switch fieldNum { - case 1: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field SrcTarget", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.SrcTarget == nil { - m.SrcTarget = &Target{} - } - if err := m.SrcTarget.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - case 2: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field AreaId", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.AreaId = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 3: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field AreaName", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.AreaName = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 4: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field BelongsTargetID", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.BelongsTargetID = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - case 5: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field CompDbInfo", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.CompDbInfo = append(m.CompDbInfo, &RuleBaseCompareInfo{}) - if err := m.CompDbInfo[len(m.CompDbInfo)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - case 6: - if wireType != 0 { - return fmt.Errorf("proto: wrong wireType = %d for field ImageId", wireType) - } - m.ImageId = 0 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - m.ImageId |= int64(b&0x7F) << shift - if b < 0x80 { - break - } - } - default: - iNdEx = preIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) < 0 { - return ErrInvalidLengthDataprocess - } - 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 -} -func (m *SoResult) 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 ErrIntOverflowDataprocess - } - 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: SoResult: wiretype end group for non-group") - } - if fieldNum <= 0 { - return fmt.Errorf("proto: SoResult: illegal tag %d (wire type %d)", fieldNum, wire) - } - switch fieldNum { - case 1: - if wireType != 0 { - return fmt.Errorf("proto: wrong wireType = %d for field IsEvent", wireType) - } - var v int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - v |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - m.IsEvent = bool(v != 0) - case 2: - if wireType != 0 { - return fmt.Errorf("proto: wrong wireType = %d for field IsEndRecord", wireType) - } - var v int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - v |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - m.IsEndRecord = bool(v != 0) - case 3: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field Targets", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.Targets = append(m.Targets, &SoTarget{}) - if err := m.Targets[len(m.Targets)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - case 4: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field FirstImage", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.FirstImage == nil { - m.FirstImage = &Image{} - } - if err := m.FirstImage.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - case 5: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field CacheImage", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.CacheImage == nil { - m.CacheImage = &Image{} - } - if err := m.CacheImage.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - case 6: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field SoRule", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.SoRule == nil { - m.SoRule = &SoRule{} - } - if err := m.SoRule.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - case 7: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field GroupRule", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.GroupRule == nil { - m.GroupRule = &GroupRule{} - } - if err := m.GroupRule.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - case 8: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field SoType", wireType) - } - var stringLen uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLen |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLen := int(stringLen) - if intStringLen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + intStringLen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.SoType = string(dAtA[iNdEx:postIndex]) - iNdEx = postIndex - default: - iNdEx = preIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) < 0 { - return ErrInvalidLengthDataprocess - } - 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 -} -func (m *EventCache) 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 ErrIntOverflowDataprocess - } - 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: EventCache: wiretype end group for non-group") - } - if fieldNum <= 0 { - return fmt.Errorf("proto: EventCache: illegal tag %d (wire type %d)", fieldNum, wire) - } - switch fieldNum { - case 1: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field Targets", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.Targets == nil { - m.Targets = make(map[uint64]*SoTarget) - } - var mapkey uint64 - var mapvalue *SoTarget - for iNdEx < postIndex { - entryPreIndex := iNdEx - var wire uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - wire |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - fieldNum := int32(wire >> 3) - if fieldNum == 1 { - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - mapkey |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - } else if fieldNum == 2 { - var mapmsglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - mapmsglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if mapmsglen < 0 { - return ErrInvalidLengthDataprocess - } - postmsgIndex := iNdEx + mapmsglen - if postmsgIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postmsgIndex > l { - return io.ErrUnexpectedEOF - } - mapvalue = &SoTarget{} - if err := mapvalue.Unmarshal(dAtA[iNdEx:postmsgIndex]); err != nil { - return err - } - iNdEx = postmsgIndex - } else { - iNdEx = entryPreIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) > postIndex { - return io.ErrUnexpectedEOF - } - iNdEx += skippy - } - } - m.Targets[mapkey] = mapvalue - iNdEx = postIndex - case 2: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field RuleGroups", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.RuleGroups == nil { - m.RuleGroups = make(map[string]*GroupRule) - } - var mapkey string - var mapvalue *GroupRule - for iNdEx < postIndex { - entryPreIndex := iNdEx - var wire uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - wire |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - fieldNum := int32(wire >> 3) - if fieldNum == 1 { - var stringLenmapkey uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLenmapkey |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLenmapkey := int(stringLenmapkey) - if intStringLenmapkey < 0 { - return ErrInvalidLengthDataprocess - } - postStringIndexmapkey := iNdEx + intStringLenmapkey - if postStringIndexmapkey < 0 { - return ErrInvalidLengthDataprocess - } - if postStringIndexmapkey > l { - return io.ErrUnexpectedEOF - } - mapkey = string(dAtA[iNdEx:postStringIndexmapkey]) - iNdEx = postStringIndexmapkey - } else if fieldNum == 2 { - var mapmsglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - mapmsglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if mapmsglen < 0 { - return ErrInvalidLengthDataprocess - } - postmsgIndex := iNdEx + mapmsglen - if postmsgIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postmsgIndex > l { - return io.ErrUnexpectedEOF - } - mapvalue = &GroupRule{} - if err := mapvalue.Unmarshal(dAtA[iNdEx:postmsgIndex]); err != nil { - return err - } - iNdEx = postmsgIndex - } else { - iNdEx = entryPreIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) > postIndex { - return io.ErrUnexpectedEOF - } - iNdEx += skippy - } - } - m.RuleGroups[mapkey] = mapvalue - iNdEx = postIndex - case 3: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field Images", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.Images == nil { - m.Images = make(map[int64]*Image) - } - var mapkey int64 - var mapvalue *Image - for iNdEx < postIndex { - entryPreIndex := iNdEx - var wire uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - wire |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - fieldNum := int32(wire >> 3) - if fieldNum == 1 { - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - mapkey |= int64(b&0x7F) << shift - if b < 0x80 { - break - } - } - } else if fieldNum == 2 { - var mapmsglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - mapmsglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if mapmsglen < 0 { - return ErrInvalidLengthDataprocess - } - postmsgIndex := iNdEx + mapmsglen - if postmsgIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postmsgIndex > l { - return io.ErrUnexpectedEOF - } - mapvalue = &Image{} - if err := mapvalue.Unmarshal(dAtA[iNdEx:postmsgIndex]); err != nil { - return err - } - iNdEx = postmsgIndex - } else { - iNdEx = entryPreIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) > postIndex { - return io.ErrUnexpectedEOF - } - iNdEx += skippy - } - } - m.Images[mapkey] = mapvalue - iNdEx = postIndex - default: - iNdEx = preIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) < 0 { - return ErrInvalidLengthDataprocess - } - 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 -} -func (m *TargetCache) 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 ErrIntOverflowDataprocess - } - 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: TargetCache: wiretype end group for non-group") - } - if fieldNum <= 0 { - return fmt.Errorf("proto: TargetCache: illegal tag %d (wire type %d)", fieldNum, wire) - } - switch fieldNum { - case 1: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field Target", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - m.Target = append(m.Target, &SoTarget{}) - if err := m.Target[len(m.Target)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - case 2: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field RuleGroups", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.RuleGroups == nil { - m.RuleGroups = make(map[string]*GroupRule) - } - var mapkey string - var mapvalue *GroupRule - for iNdEx < postIndex { - entryPreIndex := iNdEx - var wire uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - wire |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - fieldNum := int32(wire >> 3) - if fieldNum == 1 { - var stringLenmapkey uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLenmapkey |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLenmapkey := int(stringLenmapkey) - if intStringLenmapkey < 0 { - return ErrInvalidLengthDataprocess - } - postStringIndexmapkey := iNdEx + intStringLenmapkey - if postStringIndexmapkey < 0 { - return ErrInvalidLengthDataprocess - } - if postStringIndexmapkey > l { - return io.ErrUnexpectedEOF - } - mapkey = string(dAtA[iNdEx:postStringIndexmapkey]) - iNdEx = postStringIndexmapkey - } else if fieldNum == 2 { - var mapmsglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - mapmsglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if mapmsglen < 0 { - return ErrInvalidLengthDataprocess - } - postmsgIndex := iNdEx + mapmsglen - if postmsgIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postmsgIndex > l { - return io.ErrUnexpectedEOF - } - mapvalue = &GroupRule{} - if err := mapvalue.Unmarshal(dAtA[iNdEx:postmsgIndex]); err != nil { - return err - } - iNdEx = postmsgIndex - } else { - iNdEx = entryPreIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) > postIndex { - return io.ErrUnexpectedEOF - } - iNdEx += skippy - } - } - m.RuleGroups[mapkey] = mapvalue - iNdEx = postIndex - case 3: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field Image", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.Image == nil { - m.Image = &Image{} - } - if err := m.Image.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - default: - iNdEx = preIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) < 0 { - return ErrInvalidLengthDataprocess - } - 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 -} -func (m *FilterResult) 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 ErrIntOverflowDataprocess - } - 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: FilterResult: wiretype end group for non-group") - } - if fieldNum <= 0 { - return fmt.Errorf("proto: FilterResult: illegal tag %d (wire type %d)", fieldNum, wire) - } - switch fieldNum { - case 1: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field BaseInfo", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.BaseInfo == nil { - m.BaseInfo = &TaskBasicInfo{} - } - if err := m.BaseInfo.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - case 2: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field Events", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.Events == nil { - m.Events = make(map[string]*EventCache) - } - var mapkey string - var mapvalue *EventCache - for iNdEx < postIndex { - entryPreIndex := iNdEx - var wire uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - wire |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - fieldNum := int32(wire >> 3) - if fieldNum == 1 { - var stringLenmapkey uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLenmapkey |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLenmapkey := int(stringLenmapkey) - if intStringLenmapkey < 0 { - return ErrInvalidLengthDataprocess - } - postStringIndexmapkey := iNdEx + intStringLenmapkey - if postStringIndexmapkey < 0 { - return ErrInvalidLengthDataprocess - } - if postStringIndexmapkey > l { - return io.ErrUnexpectedEOF - } - mapkey = string(dAtA[iNdEx:postStringIndexmapkey]) - iNdEx = postStringIndexmapkey - } else if fieldNum == 2 { - var mapmsglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - mapmsglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if mapmsglen < 0 { - return ErrInvalidLengthDataprocess - } - postmsgIndex := iNdEx + mapmsglen - if postmsgIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postmsgIndex > l { - return io.ErrUnexpectedEOF - } - mapvalue = &EventCache{} - if err := mapvalue.Unmarshal(dAtA[iNdEx:postmsgIndex]); err != nil { - return err - } - iNdEx = postmsgIndex - } else { - iNdEx = entryPreIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) > postIndex { - return io.ErrUnexpectedEOF - } - iNdEx += skippy - } - } - m.Events[mapkey] = mapvalue - iNdEx = postIndex - case 3: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field Targets", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthDataprocess - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.Targets == nil { - m.Targets = make(map[string]*TargetCache) - } - var mapkey string - var mapvalue *TargetCache - for iNdEx < postIndex { - entryPreIndex := iNdEx - var wire uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - wire |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - fieldNum := int32(wire >> 3) - if fieldNum == 1 { - var stringLenmapkey uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - stringLenmapkey |= uint64(b&0x7F) << shift - if b < 0x80 { - break - } - } - intStringLenmapkey := int(stringLenmapkey) - if intStringLenmapkey < 0 { - return ErrInvalidLengthDataprocess - } - postStringIndexmapkey := iNdEx + intStringLenmapkey - if postStringIndexmapkey < 0 { - return ErrInvalidLengthDataprocess - } - if postStringIndexmapkey > l { - return io.ErrUnexpectedEOF - } - mapkey = string(dAtA[iNdEx:postStringIndexmapkey]) - iNdEx = postStringIndexmapkey - } else if fieldNum == 2 { - var mapmsglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowDataprocess - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - mapmsglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if mapmsglen < 0 { - return ErrInvalidLengthDataprocess - } - postmsgIndex := iNdEx + mapmsglen - if postmsgIndex < 0 { - return ErrInvalidLengthDataprocess - } - if postmsgIndex > l { - return io.ErrUnexpectedEOF - } - mapvalue = &TargetCache{} - if err := mapvalue.Unmarshal(dAtA[iNdEx:postmsgIndex]); err != nil { - return err - } - iNdEx = postmsgIndex - } else { - iNdEx = entryPreIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) > postIndex { - return io.ErrUnexpectedEOF - } - iNdEx += skippy - } - } - m.Targets[mapkey] = mapvalue - iNdEx = postIndex - default: - iNdEx = preIndex - skippy, err := skipDataprocess(dAtA[iNdEx:]) - if err != nil { - return err - } - if skippy < 0 { - return ErrInvalidLengthDataprocess - } - if (iNdEx + skippy) < 0 { - return ErrInvalidLengthDataprocess - } - 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 -} -func skipDataprocess(dAtA []byte) (n int, err error) { - l := len(dAtA) - iNdEx := 0 - for iNdEx < l { - var wire uint64 - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return 0, ErrIntOverflowDataprocess - } - if iNdEx >= l { - return 0, io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - wire |= (uint64(b) & 0x7F) << shift - if b < 0x80 { - break - } - } - wireType := int(wire & 0x7) - switch wireType { - case 0: - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return 0, ErrIntOverflowDataprocess - } - if iNdEx >= l { - return 0, io.ErrUnexpectedEOF - } - iNdEx++ - if dAtA[iNdEx-1] < 0x80 { - break - } - } - return iNdEx, nil - case 1: - iNdEx += 8 - return iNdEx, nil - case 2: - var length int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return 0, ErrIntOverflowDataprocess - } - if iNdEx >= l { - return 0, io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - length |= (int(b) & 0x7F) << shift - if b < 0x80 { - break - } - } - if length < 0 { - return 0, ErrInvalidLengthDataprocess - } - iNdEx += length - if iNdEx < 0 { - return 0, ErrInvalidLengthDataprocess - } - return iNdEx, nil - case 3: - for { - var innerWire uint64 - var start int = iNdEx - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return 0, ErrIntOverflowDataprocess - } - if iNdEx >= l { - return 0, io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - innerWire |= (uint64(b) & 0x7F) << shift - if b < 0x80 { - break - } - } - innerWireType := int(innerWire & 0x7) - if innerWireType == 4 { - break - } - next, err := skipDataprocess(dAtA[start:]) - if err != nil { - return 0, err - } - iNdEx = start + next - if iNdEx < 0 { - return 0, ErrInvalidLengthDataprocess - } - } - return iNdEx, nil - case 4: - return iNdEx, nil - case 5: - iNdEx += 4 - return iNdEx, nil - default: - return 0, fmt.Errorf("proto: illegal wireType %d", wireType) - } - } - panic("unreachable") -} - -var ( - ErrInvalidLengthDataprocess = fmt.Errorf("proto: negative length found during unmarshaling") - ErrIntOverflowDataprocess = fmt.Errorf("proto: integer overflow") -) -- Gitblit v1.8.0