// Code generated by protoc-gen-gogo. DO NOT EDIT. // source: protomsg.proto package protomsg import ( encoding_binary "encoding/binary" fmt "fmt" proto "github.com/gogo/protobuf/proto" io "io" math "math" ) // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal var _ = fmt.Errorf var _ = math.Inf // This is a compile-time assertion to ensure that this generated file // is compatible with the proto package it is being compiled against. // A compilation error at this line likely means your copy of the // proto package needs to be updated. const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package //TableChanged enum type TableChanged int32 const ( TableChanged_T_Camera TableChanged = 0 TableChanged_T_CameraTask TableChanged = 1 TableChanged_T_CameraTaskArgs TableChanged = 2 TableChanged_T_Task TableChanged = 3 TableChanged_T_TaskSdk TableChanged = 4 TableChanged_T_TaskSdkRule TableChanged = 5 TableChanged_T_Sdk TableChanged = 6 TableChanged_T_CameraPolygon TableChanged = 7 TableChanged_T_TimeRule TableChanged = 8 TableChanged_T_Server TableChanged = 9 TableChanged_T_PollConfig TableChanged = 10 ) var TableChanged_name = map[int32]string{ 0: "T_Camera", 1: "T_CameraTask", 2: "T_CameraTaskArgs", 3: "T_Task", 4: "T_TaskSdk", 5: "T_TaskSdkRule", 6: "T_Sdk", 7: "T_CameraPolygon", 8: "T_TimeRule", 9: "T_Server", 10: "T_PollConfig", } var TableChanged_value = map[string]int32{ "T_Camera": 0, "T_CameraTask": 1, "T_CameraTaskArgs": 2, "T_Task": 3, "T_TaskSdk": 4, "T_TaskSdkRule": 5, "T_Sdk": 6, "T_CameraPolygon": 7, "T_TimeRule": 8, "T_Server": 9, "T_PollConfig": 10, } func (x TableChanged) String() string { return proto.EnumName(TableChanged_name, int32(x)) } func (TableChanged) EnumDescriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{0} } type DbAction int32 const ( DbAction_Insert DbAction = 0 DbAction_Update DbAction = 1 DbAction_Delete DbAction = 2 ) var DbAction_name = map[int32]string{ 0: "Insert", 1: "Update", 2: "Delete", } var DbAction_value = map[string]int32{ "Insert": 0, "Update": 1, "Delete": 2, } func (x DbAction) String() string { return proto.EnumName(DbAction_name, int32(x)) } func (DbAction) EnumDescriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{1} } //Area结构体 type Area struct { Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Parentid int32 `protobuf:"varint,2,opt,name=parentid,proto3" json:"parentid,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` } func (m *Area) Reset() { *m = Area{} } func (m *Area) String() string { return proto.CompactTextString(m) } func (*Area) ProtoMessage() {} func (*Area) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{0} } func (m *Area) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Area) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Area.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Area) XXX_Merge(src proto.Message) { xxx_messageInfo_Area.Merge(m, src) } func (m *Area) XXX_Size() int { return m.Size() } func (m *Area) XXX_DiscardUnknown() { xxx_messageInfo_Area.DiscardUnknown(m) } var xxx_messageInfo_Area proto.InternalMessageInfo func (m *Area) GetId() int32 { if m != nil { return m.Id } return 0 } func (m *Area) GetParentid() int32 { if m != nil { return m.Parentid } return 0 } func (m *Area) GetName() string { if m != nil { return m.Name } return "" } //Camera结构体 type Camera struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Alias string `protobuf:"bytes,3,opt,name=alias,proto3" json:"alias,omitempty"` SnapshotUrl string `protobuf:"bytes,4,opt,name=snapshot_url,json=snapshotUrl,proto3" json:"snapshot_url,omitempty"` Type int32 `protobuf:"varint,5,opt,name=type,proto3" json:"type,omitempty"` Addr string `protobuf:"bytes,6,opt,name=addr,proto3" json:"addr,omitempty"` Areaid int32 `protobuf:"varint,7,opt,name=areaid,proto3" json:"areaid,omitempty"` Longitude float32 `protobuf:"fixed32,8,opt,name=longitude,proto3" json:"longitude,omitempty"` Latitude float32 `protobuf:"fixed32,9,opt,name=latitude,proto3" json:"latitude,omitempty"` Rtsp string `protobuf:"bytes,10,opt,name=rtsp,proto3" json:"rtsp,omitempty"` Ip string `protobuf:"bytes,11,opt,name=ip,proto3" json:"ip,omitempty"` Port int32 `protobuf:"varint,12,opt,name=port,proto3" json:"port,omitempty"` Username string `protobuf:"bytes,13,opt,name=username,proto3" json:"username,omitempty"` Password string `protobuf:"bytes,14,opt,name=password,proto3" json:"password,omitempty"` Brand string `protobuf:"bytes,15,opt,name=brand,proto3" json:"brand,omitempty"` Reserved string `protobuf:"bytes,16,opt,name=reserved,proto3" json:"reserved,omitempty"` IsRunning bool `protobuf:"varint,17,opt,name=is_running,json=isRunning,proto3" json:"is_running,omitempty"` RunEnable bool `protobuf:"varint,18,opt,name=run_enable,json=runEnable,proto3" json:"run_enable,omitempty"` RunType int32 `protobuf:"varint,19,opt,name=run_type,json=runType,proto3" json:"run_type,omitempty"` RunServerId string `protobuf:"bytes,20,opt,name=run_server_id,json=runServerId,proto3" json:"run_server_id,omitempty"` } func (m *Camera) Reset() { *m = Camera{} } func (m *Camera) String() string { return proto.CompactTextString(m) } func (*Camera) ProtoMessage() {} func (*Camera) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{1} } func (m *Camera) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Camera) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Camera.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Camera) XXX_Merge(src proto.Message) { xxx_messageInfo_Camera.Merge(m, src) } func (m *Camera) XXX_Size() int { return m.Size() } func (m *Camera) XXX_DiscardUnknown() { xxx_messageInfo_Camera.DiscardUnknown(m) } var xxx_messageInfo_Camera proto.InternalMessageInfo func (m *Camera) GetId() string { if m != nil { return m.Id } return "" } func (m *Camera) GetName() string { if m != nil { return m.Name } return "" } func (m *Camera) GetAlias() string { if m != nil { return m.Alias } return "" } func (m *Camera) GetSnapshotUrl() string { if m != nil { return m.SnapshotUrl } return "" } func (m *Camera) GetType() int32 { if m != nil { return m.Type } return 0 } func (m *Camera) GetAddr() string { if m != nil { return m.Addr } return "" } func (m *Camera) GetAreaid() int32 { if m != nil { return m.Areaid } return 0 } func (m *Camera) GetLongitude() float32 { if m != nil { return m.Longitude } return 0 } func (m *Camera) GetLatitude() float32 { if m != nil { return m.Latitude } return 0 } func (m *Camera) GetRtsp() string { if m != nil { return m.Rtsp } return "" } func (m *Camera) GetIp() string { if m != nil { return m.Ip } return "" } func (m *Camera) GetPort() int32 { if m != nil { return m.Port } return 0 } func (m *Camera) GetUsername() string { if m != nil { return m.Username } return "" } func (m *Camera) GetPassword() string { if m != nil { return m.Password } return "" } func (m *Camera) GetBrand() string { if m != nil { return m.Brand } return "" } func (m *Camera) GetReserved() string { if m != nil { return m.Reserved } return "" } func (m *Camera) GetIsRunning() bool { if m != nil { return m.IsRunning } return false } func (m *Camera) GetRunEnable() bool { if m != nil { return m.RunEnable } return false } func (m *Camera) GetRunType() int32 { if m != nil { return m.RunType } return 0 } func (m *Camera) GetRunServerId() string { if m != nil { return m.RunServerId } return "" } //摄像机的任务信息 type CameraAndTaskInfo struct { Camera *Camera `protobuf:"bytes,1,opt,name=camera,proto3" json:"camera,omitempty"` Tasks []*Task `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"` } func (m *CameraAndTaskInfo) Reset() { *m = CameraAndTaskInfo{} } func (m *CameraAndTaskInfo) String() string { return proto.CompactTextString(m) } func (*CameraAndTaskInfo) ProtoMessage() {} func (*CameraAndTaskInfo) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{2} } func (m *CameraAndTaskInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *CameraAndTaskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_CameraAndTaskInfo.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *CameraAndTaskInfo) XXX_Merge(src proto.Message) { xxx_messageInfo_CameraAndTaskInfo.Merge(m, src) } func (m *CameraAndTaskInfo) XXX_Size() int { return m.Size() } func (m *CameraAndTaskInfo) XXX_DiscardUnknown() { xxx_messageInfo_CameraAndTaskInfo.DiscardUnknown(m) } var xxx_messageInfo_CameraAndTaskInfo proto.InternalMessageInfo func (m *CameraAndTaskInfo) GetCamera() *Camera { if m != nil { return m.Camera } return nil } func (m *CameraAndTaskInfo) GetTasks() []*Task { if m != nil { return m.Tasks } return nil } //Task结构体 type Task struct { Taskid string `protobuf:"bytes,1,opt,name=taskid,proto3" json:"taskid,omitempty"` Taskname string `protobuf:"bytes,2,opt,name=taskname,proto3" json:"taskname,omitempty"` CreateAt string `protobuf:"bytes,3,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"` CreateBy string `protobuf:"bytes,4,opt,name=create_by,json=createBy,proto3" json:"create_by,omitempty"` UpdateAt string `protobuf:"bytes,5,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"` Enable bool `protobuf:"varint,6,opt,name=enable,proto3" json:"enable,omitempty"` IsAlarm bool `protobuf:"varint,7,opt,name=is_alarm,json=isAlarm,proto3" json:"is_alarm,omitempty"` DelFlag bool `protobuf:"varint,8,opt,name=del_flag,json=delFlag,proto3" json:"del_flag,omitempty"` } func (m *Task) Reset() { *m = Task{} } func (m *Task) String() string { return proto.CompactTextString(m) } func (*Task) ProtoMessage() {} func (*Task) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{3} } func (m *Task) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Task.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Task) XXX_Merge(src proto.Message) { xxx_messageInfo_Task.Merge(m, src) } func (m *Task) XXX_Size() int { return m.Size() } func (m *Task) XXX_DiscardUnknown() { xxx_messageInfo_Task.DiscardUnknown(m) } var xxx_messageInfo_Task proto.InternalMessageInfo func (m *Task) GetTaskid() string { if m != nil { return m.Taskid } return "" } func (m *Task) GetTaskname() string { if m != nil { return m.Taskname } return "" } func (m *Task) GetCreateAt() string { if m != nil { return m.CreateAt } return "" } func (m *Task) GetCreateBy() string { if m != nil { return m.CreateBy } return "" } func (m *Task) GetUpdateAt() string { if m != nil { return m.UpdateAt } return "" } func (m *Task) GetEnable() bool { if m != nil { return m.Enable } return false } func (m *Task) GetIsAlarm() bool { if m != nil { return m.IsAlarm } return false } func (m *Task) GetDelFlag() bool { if m != nil { return m.DelFlag } return false } type TaskSdkInfo struct { Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` Sdks []*Sdk `protobuf:"bytes,2,rep,name=sdks,proto3" json:"sdks,omitempty"` } func (m *TaskSdkInfo) Reset() { *m = TaskSdkInfo{} } func (m *TaskSdkInfo) String() string { return proto.CompactTextString(m) } func (*TaskSdkInfo) ProtoMessage() {} func (*TaskSdkInfo) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{4} } func (m *TaskSdkInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *TaskSdkInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_TaskSdkInfo.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *TaskSdkInfo) XXX_Merge(src proto.Message) { xxx_messageInfo_TaskSdkInfo.Merge(m, src) } func (m *TaskSdkInfo) XXX_Size() int { return m.Size() } func (m *TaskSdkInfo) XXX_DiscardUnknown() { xxx_messageInfo_TaskSdkInfo.DiscardUnknown(m) } var xxx_messageInfo_TaskSdkInfo proto.InternalMessageInfo func (m *TaskSdkInfo) GetTask() *Task { if m != nil { return m.Task } return nil } func (m *TaskSdkInfo) GetSdks() []*Sdk { if m != nil { return m.Sdks } return nil } type SdkRun struct { IpcId string `protobuf:"bytes,1,opt,name=ipc_id,json=ipcId,proto3" json:"ipc_id,omitempty"` SdkType string `protobuf:"bytes,2,opt,name=sdk_type,json=sdkType,proto3" json:"sdk_type,omitempty"` } func (m *SdkRun) Reset() { *m = SdkRun{} } func (m *SdkRun) String() string { return proto.CompactTextString(m) } func (*SdkRun) ProtoMessage() {} func (*SdkRun) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{5} } func (m *SdkRun) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *SdkRun) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_SdkRun.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *SdkRun) XXX_Merge(src proto.Message) { xxx_messageInfo_SdkRun.Merge(m, src) } func (m *SdkRun) XXX_Size() int { return m.Size() } func (m *SdkRun) XXX_DiscardUnknown() { xxx_messageInfo_SdkRun.DiscardUnknown(m) } var xxx_messageInfo_SdkRun proto.InternalMessageInfo func (m *SdkRun) GetIpcId() string { if m != nil { return m.IpcId } return "" } func (m *SdkRun) GetSdkType() string { if m != nil { return m.SdkType } return "" } type TaskSdkRun struct { Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` Sdks []*SdkRun `protobuf:"bytes,2,rep,name=sdks,proto3" json:"sdks,omitempty"` } func (m *TaskSdkRun) Reset() { *m = TaskSdkRun{} } func (m *TaskSdkRun) String() string { return proto.CompactTextString(m) } func (*TaskSdkRun) ProtoMessage() {} func (*TaskSdkRun) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{6} } func (m *TaskSdkRun) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *TaskSdkRun) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_TaskSdkRun.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *TaskSdkRun) XXX_Merge(src proto.Message) { xxx_messageInfo_TaskSdkRun.Merge(m, src) } func (m *TaskSdkRun) XXX_Size() int { return m.Size() } func (m *TaskSdkRun) XXX_DiscardUnknown() { xxx_messageInfo_TaskSdkRun.DiscardUnknown(m) } var xxx_messageInfo_TaskSdkRun proto.InternalMessageInfo func (m *TaskSdkRun) GetTask() *Task { if m != nil { return m.Task } return nil } func (m *TaskSdkRun) GetSdks() []*SdkRun { if m != nil { return m.Sdks } return nil } //摄像机任务 type CameraTask struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` CameraId string `protobuf:"bytes,2,opt,name=camera_id,json=cameraId,proto3" json:"camera_id,omitempty"` TaskId string `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` TimeRule []*DayCtl `protobuf:"bytes,4,rep,name=time_rule,json=timeRule,proto3" json:"time_rule,omitempty"` ReactRule string `protobuf:"bytes,5,opt,name=react_rule,json=reactRule,proto3" json:"react_rule,omitempty"` ReactDevice string `protobuf:"bytes,6,opt,name=react_device,json=reactDevice,proto3" json:"react_device,omitempty"` DelFlag bool `protobuf:"varint,7,opt,name=del_flag,json=delFlag,proto3" json:"del_flag,omitempty"` UpdateFlag bool `protobuf:"varint,8,opt,name=update_flag,json=updateFlag,proto3" json:"update_flag,omitempty"` Enable bool `protobuf:"varint,9,opt,name=enable,proto3" json:"enable,omitempty"` Sort int32 `protobuf:"varint,10,opt,name=sort,proto3" json:"sort,omitempty"` IsFull bool `protobuf:"varint,11,opt,name=is_full,json=isFull,proto3" json:"is_full,omitempty"` LinkTaskId string `protobuf:"bytes,12,opt,name=link_task_id,json=linkTaskId,proto3" json:"link_task_id,omitempty"` } func (m *CameraTask) Reset() { *m = CameraTask{} } func (m *CameraTask) String() string { return proto.CompactTextString(m) } func (*CameraTask) ProtoMessage() {} func (*CameraTask) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{7} } func (m *CameraTask) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *CameraTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_CameraTask.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *CameraTask) XXX_Merge(src proto.Message) { xxx_messageInfo_CameraTask.Merge(m, src) } func (m *CameraTask) XXX_Size() int { return m.Size() } func (m *CameraTask) XXX_DiscardUnknown() { xxx_messageInfo_CameraTask.DiscardUnknown(m) } var xxx_messageInfo_CameraTask proto.InternalMessageInfo func (m *CameraTask) GetId() string { if m != nil { return m.Id } return "" } func (m *CameraTask) GetCameraId() string { if m != nil { return m.CameraId } return "" } func (m *CameraTask) GetTaskId() string { if m != nil { return m.TaskId } return "" } func (m *CameraTask) GetTimeRule() []*DayCtl { if m != nil { return m.TimeRule } return nil } func (m *CameraTask) GetReactRule() string { if m != nil { return m.ReactRule } return "" } func (m *CameraTask) GetReactDevice() string { if m != nil { return m.ReactDevice } return "" } func (m *CameraTask) GetDelFlag() bool { if m != nil { return m.DelFlag } return false } func (m *CameraTask) GetUpdateFlag() bool { if m != nil { return m.UpdateFlag } return false } func (m *CameraTask) GetEnable() bool { if m != nil { return m.Enable } return false } func (m *CameraTask) GetSort() int32 { if m != nil { return m.Sort } return 0 } func (m *CameraTask) GetIsFull() bool { if m != nil { return m.IsFull } return false } func (m *CameraTask) GetLinkTaskId() string { if m != nil { return m.LinkTaskId } return "" } //摄像机布防的时间规则,可以设置多个,用id关联到具体的规则配置中 type CameraTimerule struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` TimeRule string `protobuf:"bytes,3,opt,name=time_rule,json=timeRule,proto3" json:"time_rule,omitempty"` } func (m *CameraTimerule) Reset() { *m = CameraTimerule{} } func (m *CameraTimerule) String() string { return proto.CompactTextString(m) } func (*CameraTimerule) ProtoMessage() {} func (*CameraTimerule) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{8} } func (m *CameraTimerule) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *CameraTimerule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_CameraTimerule.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *CameraTimerule) XXX_Merge(src proto.Message) { xxx_messageInfo_CameraTimerule.Merge(m, src) } func (m *CameraTimerule) XXX_Size() int { return m.Size() } func (m *CameraTimerule) XXX_DiscardUnknown() { xxx_messageInfo_CameraTimerule.DiscardUnknown(m) } var xxx_messageInfo_CameraTimerule proto.InternalMessageInfo func (m *CameraTimerule) GetId() string { if m != nil { return m.Id } return "" } func (m *CameraTimerule) GetName() string { if m != nil { return m.Name } return "" } func (m *CameraTimerule) GetTimeRule() string { if m != nil { return m.TimeRule } return "" } //DayCtl struct 每天的时间控制规则 type DayCtl struct { Day int32 `protobuf:"varint,1,opt,name=day,proto3" json:"day,omitempty"` TimeRange []*TimeRange `protobuf:"bytes,2,rep,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` } func (m *DayCtl) Reset() { *m = DayCtl{} } func (m *DayCtl) String() string { return proto.CompactTextString(m) } func (*DayCtl) ProtoMessage() {} func (*DayCtl) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{9} } func (m *DayCtl) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *DayCtl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_DayCtl.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *DayCtl) XXX_Merge(src proto.Message) { xxx_messageInfo_DayCtl.Merge(m, src) } func (m *DayCtl) XXX_Size() int { return m.Size() } func (m *DayCtl) XXX_DiscardUnknown() { xxx_messageInfo_DayCtl.DiscardUnknown(m) } var xxx_messageInfo_DayCtl proto.InternalMessageInfo func (m *DayCtl) GetDay() int32 { if m != nil { return m.Day } return 0 } func (m *DayCtl) GetTimeRange() []*TimeRange { if m != nil { return m.TimeRange } return nil } //时间起始范围 type TimeRange struct { Start string `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"` End string `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"` } func (m *TimeRange) Reset() { *m = TimeRange{} } func (m *TimeRange) String() string { return proto.CompactTextString(m) } func (*TimeRange) ProtoMessage() {} func (*TimeRange) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{10} } func (m *TimeRange) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *TimeRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_TimeRange.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *TimeRange) XXX_Merge(src proto.Message) { xxx_messageInfo_TimeRange.Merge(m, src) } func (m *TimeRange) XXX_Size() int { return m.Size() } func (m *TimeRange) XXX_DiscardUnknown() { xxx_messageInfo_TimeRange.DiscardUnknown(m) } var xxx_messageInfo_TimeRange proto.InternalMessageInfo func (m *TimeRange) GetStart() string { if m != nil { return m.Start } return "" } func (m *TimeRange) GetEnd() string { if m != nil { return m.End } return "" } //Polygon struct type Polygon struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Points []*Point `protobuf:"bytes,3,rep,name=points,proto3" json:"points,omitempty"` } func (m *Polygon) Reset() { *m = Polygon{} } func (m *Polygon) String() string { return proto.CompactTextString(m) } func (*Polygon) ProtoMessage() {} func (*Polygon) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{11} } func (m *Polygon) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Polygon) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Polygon.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Polygon) XXX_Merge(src proto.Message) { xxx_messageInfo_Polygon.Merge(m, src) } func (m *Polygon) XXX_Size() int { return m.Size() } func (m *Polygon) XXX_DiscardUnknown() { xxx_messageInfo_Polygon.DiscardUnknown(m) } var xxx_messageInfo_Polygon proto.InternalMessageInfo func (m *Polygon) GetId() string { if m != nil { return m.Id } return "" } func (m *Polygon) GetName() string { if m != nil { return m.Name } return "" } func (m *Polygon) GetPoints() []*Point { if m != nil { return m.Points } return nil } type CameraTaskArgs struct { CameraId string `protobuf:"bytes,1,opt,name=camera_id,json=cameraId,proto3" json:"camera_id,omitempty"` TaskArgs []*TaskGroupArgs `protobuf:"bytes,2,rep,name=task_args,json=taskArgs,proto3" json:"task_args,omitempty"` } func (m *CameraTaskArgs) Reset() { *m = CameraTaskArgs{} } func (m *CameraTaskArgs) String() string { return proto.CompactTextString(m) } func (*CameraTaskArgs) ProtoMessage() {} func (*CameraTaskArgs) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{12} } func (m *CameraTaskArgs) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *CameraTaskArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_CameraTaskArgs.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *CameraTaskArgs) XXX_Merge(src proto.Message) { xxx_messageInfo_CameraTaskArgs.Merge(m, src) } func (m *CameraTaskArgs) XXX_Size() int { return m.Size() } func (m *CameraTaskArgs) XXX_DiscardUnknown() { xxx_messageInfo_CameraTaskArgs.DiscardUnknown(m) } var xxx_messageInfo_CameraTaskArgs proto.InternalMessageInfo func (m *CameraTaskArgs) GetCameraId() string { if m != nil { return m.CameraId } return "" } func (m *CameraTaskArgs) GetTaskArgs() []*TaskGroupArgs { if m != nil { return m.TaskArgs } return nil } type TaskGroupArgs struct { TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` GroupRules []*GroupRule `protobuf:"bytes,2,rep,name=group_rules,json=groupRules,proto3" json:"group_rules,omitempty"` Enable bool `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"` } func (m *TaskGroupArgs) Reset() { *m = TaskGroupArgs{} } func (m *TaskGroupArgs) String() string { return proto.CompactTextString(m) } func (*TaskGroupArgs) ProtoMessage() {} func (*TaskGroupArgs) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{13} } func (m *TaskGroupArgs) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *TaskGroupArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_TaskGroupArgs.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *TaskGroupArgs) XXX_Merge(src proto.Message) { xxx_messageInfo_TaskGroupArgs.Merge(m, src) } func (m *TaskGroupArgs) XXX_Size() int { return m.Size() } func (m *TaskGroupArgs) XXX_DiscardUnknown() { xxx_messageInfo_TaskGroupArgs.DiscardUnknown(m) } var xxx_messageInfo_TaskGroupArgs proto.InternalMessageInfo func (m *TaskGroupArgs) GetTaskId() string { if m != nil { return m.TaskId } return "" } func (m *TaskGroupArgs) GetGroupRules() []*GroupRule { if m != nil { return m.GroupRules } return nil } func (m *TaskGroupArgs) GetEnable() bool { if m != nil { return m.Enable } return false } type GroupRule struct { GroupId string `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"` GroupText string `protobuf:"bytes,2,opt,name=group_text,json=groupText,proto3" json:"group_text,omitempty"` AlarmLevel int32 `protobuf:"varint,3,opt,name=alarm_level,json=alarmLevel,proto3" json:"alarm_level,omitempty"` Rules []*Rule `protobuf:"bytes,4,rep,name=rules,proto3" json:"rules,omitempty"` SetType string `protobuf:"bytes,5,opt,name=set_type,json=setType,proto3" json:"set_type,omitempty"` DefenceState bool `protobuf:"varint,6,opt,name=defence_state,json=defenceState,proto3" json:"defence_state,omitempty"` } func (m *GroupRule) Reset() { *m = GroupRule{} } func (m *GroupRule) String() string { return proto.CompactTextString(m) } func (*GroupRule) ProtoMessage() {} func (*GroupRule) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{14} } func (m *GroupRule) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *GroupRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_GroupRule.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *GroupRule) XXX_Merge(src proto.Message) { xxx_messageInfo_GroupRule.Merge(m, src) } func (m *GroupRule) XXX_Size() int { return m.Size() } func (m *GroupRule) XXX_DiscardUnknown() { xxx_messageInfo_GroupRule.DiscardUnknown(m) } var xxx_messageInfo_GroupRule proto.InternalMessageInfo func (m *GroupRule) GetGroupId() string { if m != nil { return m.GroupId } return "" } func (m *GroupRule) GetGroupText() string { if m != nil { return m.GroupText } return "" } func (m *GroupRule) GetAlarmLevel() int32 { if m != nil { return m.AlarmLevel } return 0 } func (m *GroupRule) GetRules() []*Rule { if m != nil { return m.Rules } return nil } func (m *GroupRule) GetSetType() string { if m != nil { return m.SetType } return "" } func (m *GroupRule) GetDefenceState() bool { if m != nil { return m.DefenceState } return false } type Rule struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` CameraTaskId string `protobuf:"bytes,2,opt,name=camera_task_id,json=cameraTaskId,proto3" json:"camera_task_id,omitempty"` CameraId string `protobuf:"bytes,3,opt,name=camera_id,json=cameraId,proto3" json:"camera_id,omitempty"` PolygonId string `protobuf:"bytes,4,opt,name=polygon_id,json=polygonId,proto3" json:"polygon_id,omitempty"` SdkId string `protobuf:"bytes,5,opt,name=sdk_id,json=sdkId,proto3" json:"sdk_id,omitempty"` SdkArgAlias string `protobuf:"bytes,6,opt,name=sdk_arg_alias,json=sdkArgAlias,proto3" json:"sdk_arg_alias,omitempty"` Operator string `protobuf:"bytes,7,opt,name=operator,proto3" json:"operator,omitempty"` OperatorType string `protobuf:"bytes,8,opt,name=operator_type,json=operatorType,proto3" json:"operator_type,omitempty"` SdkArgValue string `protobuf:"bytes,9,opt,name=sdk_arg_value,json=sdkArgValue,proto3" json:"sdk_arg_value,omitempty"` Sort int32 `protobuf:"varint,10,opt,name=sort,proto3" json:"sort,omitempty"` RuleWithPre string `protobuf:"bytes,11,opt,name=rule_with_pre,json=ruleWithPre,proto3" json:"rule_with_pre,omitempty"` GroupId string `protobuf:"bytes,12,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"` } func (m *Rule) Reset() { *m = Rule{} } func (m *Rule) String() string { return proto.CompactTextString(m) } func (*Rule) ProtoMessage() {} func (*Rule) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{15} } func (m *Rule) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Rule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Rule.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Rule) XXX_Merge(src proto.Message) { xxx_messageInfo_Rule.Merge(m, src) } func (m *Rule) XXX_Size() int { return m.Size() } func (m *Rule) XXX_DiscardUnknown() { xxx_messageInfo_Rule.DiscardUnknown(m) } var xxx_messageInfo_Rule proto.InternalMessageInfo func (m *Rule) GetId() string { if m != nil { return m.Id } return "" } func (m *Rule) GetCameraTaskId() string { if m != nil { return m.CameraTaskId } return "" } func (m *Rule) GetCameraId() string { if m != nil { return m.CameraId } return "" } func (m *Rule) GetPolygonId() string { if m != nil { return m.PolygonId } return "" } func (m *Rule) GetSdkId() string { if m != nil { return m.SdkId } return "" } func (m *Rule) GetSdkArgAlias() string { if m != nil { return m.SdkArgAlias } return "" } func (m *Rule) GetOperator() string { if m != nil { return m.Operator } return "" } func (m *Rule) GetOperatorType() string { if m != nil { return m.OperatorType } return "" } func (m *Rule) GetSdkArgValue() string { if m != nil { return m.SdkArgValue } return "" } func (m *Rule) GetSort() int32 { if m != nil { return m.Sort } return 0 } func (m *Rule) GetRuleWithPre() string { if m != nil { return m.RuleWithPre } return "" } func (m *Rule) GetGroupId() string { if m != nil { return m.GroupId } return "" } //Sdk struct type Sdk struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` IpcId string `protobuf:"bytes,2,opt,name=ipc_id,json=ipcId,proto3" json:"ipc_id,omitempty"` SdkType string `protobuf:"bytes,3,opt,name=sdk_type,json=sdkType,proto3" json:"sdk_type,omitempty"` SdkName string `protobuf:"bytes,4,opt,name=sdk_name,json=sdkName,proto3" json:"sdk_name,omitempty"` Args []*SdkArg `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"` Icon string `protobuf:"bytes,6,opt,name=icon,proto3" json:"icon,omitempty"` Url string `protobuf:"bytes,7,opt,name=url,proto3" json:"url,omitempty"` CreateTime string `protobuf:"bytes,8,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` UpdateTime string `protobuf:"bytes,9,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` CreateBy string `protobuf:"bytes,10,opt,name=create_by,json=createBy,proto3" json:"create_by,omitempty"` Enable bool `protobuf:"varint,11,opt,name=enable,proto3" json:"enable,omitempty"` DelFlag int32 `protobuf:"varint,12,opt,name=del_flag,json=delFlag,proto3" json:"del_flag,omitempty"` } func (m *Sdk) Reset() { *m = Sdk{} } func (m *Sdk) String() string { return proto.CompactTextString(m) } func (*Sdk) ProtoMessage() {} func (*Sdk) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{16} } func (m *Sdk) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Sdk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Sdk.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Sdk) XXX_Merge(src proto.Message) { xxx_messageInfo_Sdk.Merge(m, src) } func (m *Sdk) XXX_Size() int { return m.Size() } func (m *Sdk) XXX_DiscardUnknown() { xxx_messageInfo_Sdk.DiscardUnknown(m) } var xxx_messageInfo_Sdk proto.InternalMessageInfo func (m *Sdk) GetId() string { if m != nil { return m.Id } return "" } func (m *Sdk) GetIpcId() string { if m != nil { return m.IpcId } return "" } func (m *Sdk) GetSdkType() string { if m != nil { return m.SdkType } return "" } func (m *Sdk) GetSdkName() string { if m != nil { return m.SdkName } return "" } func (m *Sdk) GetArgs() []*SdkArg { if m != nil { return m.Args } return nil } func (m *Sdk) GetIcon() string { if m != nil { return m.Icon } return "" } func (m *Sdk) GetUrl() string { if m != nil { return m.Url } return "" } func (m *Sdk) GetCreateTime() string { if m != nil { return m.CreateTime } return "" } func (m *Sdk) GetUpdateTime() string { if m != nil { return m.UpdateTime } return "" } func (m *Sdk) GetCreateBy() string { if m != nil { return m.CreateBy } return "" } func (m *Sdk) GetEnable() bool { if m != nil { return m.Enable } return false } func (m *Sdk) GetDelFlag() int32 { if m != nil { return m.DelFlag } return 0 } //SdkArg struct type SdkArg struct { Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` Must bool `protobuf:"varint,4,opt,name=must,proto3" json:"must,omitempty"` Unit string `protobuf:"bytes,5,opt,name=unit,proto3" json:"unit,omitempty"` Range string `protobuf:"bytes,6,opt,name=range,proto3" json:"range,omitempty"` Sort int32 `protobuf:"varint,7,opt,name=sort,proto3" json:"sort,omitempty"` } func (m *SdkArg) Reset() { *m = SdkArg{} } func (m *SdkArg) String() string { return proto.CompactTextString(m) } func (*SdkArg) ProtoMessage() {} func (*SdkArg) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{17} } func (m *SdkArg) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *SdkArg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_SdkArg.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *SdkArg) XXX_Merge(src proto.Message) { xxx_messageInfo_SdkArg.Merge(m, src) } func (m *SdkArg) XXX_Size() int { return m.Size() } func (m *SdkArg) XXX_DiscardUnknown() { xxx_messageInfo_SdkArg.DiscardUnknown(m) } var xxx_messageInfo_SdkArg proto.InternalMessageInfo func (m *SdkArg) GetAlias() string { if m != nil { return m.Alias } return "" } func (m *SdkArg) GetName() string { if m != nil { return m.Name } return "" } func (m *SdkArg) GetType() string { if m != nil { return m.Type } return "" } func (m *SdkArg) GetMust() bool { if m != nil { return m.Must } return false } func (m *SdkArg) GetUnit() string { if m != nil { return m.Unit } return "" } func (m *SdkArg) GetRange() string { if m != nil { return m.Range } return "" } func (m *SdkArg) GetSort() int32 { if m != nil { return m.Sort } return 0 } //publish db change message type DbChangeMessage struct { Table TableChanged `protobuf:"varint,1,opt,name=table,proto3,enum=protomsg.TableChanged" json:"table,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Action DbAction `protobuf:"varint,3,opt,name=action,proto3,enum=protomsg.DbAction" json:"action,omitempty"` Info string `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"` } func (m *DbChangeMessage) Reset() { *m = DbChangeMessage{} } func (m *DbChangeMessage) String() string { return proto.CompactTextString(m) } func (*DbChangeMessage) ProtoMessage() {} func (*DbChangeMessage) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{18} } func (m *DbChangeMessage) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *DbChangeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_DbChangeMessage.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *DbChangeMessage) XXX_Merge(src proto.Message) { xxx_messageInfo_DbChangeMessage.Merge(m, src) } func (m *DbChangeMessage) XXX_Size() int { return m.Size() } func (m *DbChangeMessage) XXX_DiscardUnknown() { xxx_messageInfo_DbChangeMessage.DiscardUnknown(m) } var xxx_messageInfo_DbChangeMessage proto.InternalMessageInfo func (m *DbChangeMessage) GetTable() TableChanged { if m != nil { return m.Table } return TableChanged_T_Camera } func (m *DbChangeMessage) GetId() string { if m != nil { return m.Id } return "" } func (m *DbChangeMessage) GetAction() DbAction { if m != nil { return m.Action } return DbAction_Insert } func (m *DbChangeMessage) GetInfo() string { if m != nil { return m.Info } return "" } type CameraPolygon struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` CameraId string `protobuf:"bytes,2,opt,name=camera_id,json=cameraId,proto3" json:"camera_id,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Polygon string `protobuf:"bytes,4,opt,name=polygon,proto3" json:"polygon,omitempty"` TriggerLine string `protobuf:"bytes,5,opt,name=trigger_line,json=triggerLine,proto3" json:"trigger_line,omitempty"` DirectionLine string `protobuf:"bytes,6,opt,name=direction_line,json=directionLine,proto3" json:"direction_line,omitempty"` Type string `protobuf:"bytes,7,opt,name=type,proto3" json:"type,omitempty"` DefenceState int32 `protobuf:"varint,8,opt,name=defence_state,json=defenceState,proto3" json:"defence_state,omitempty"` } func (m *CameraPolygon) Reset() { *m = CameraPolygon{} } func (m *CameraPolygon) String() string { return proto.CompactTextString(m) } func (*CameraPolygon) ProtoMessage() {} func (*CameraPolygon) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{19} } func (m *CameraPolygon) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *CameraPolygon) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_CameraPolygon.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *CameraPolygon) XXX_Merge(src proto.Message) { xxx_messageInfo_CameraPolygon.Merge(m, src) } func (m *CameraPolygon) XXX_Size() int { return m.Size() } func (m *CameraPolygon) XXX_DiscardUnknown() { xxx_messageInfo_CameraPolygon.DiscardUnknown(m) } var xxx_messageInfo_CameraPolygon proto.InternalMessageInfo func (m *CameraPolygon) GetId() string { if m != nil { return m.Id } return "" } func (m *CameraPolygon) GetCameraId() string { if m != nil { return m.CameraId } return "" } func (m *CameraPolygon) GetName() string { if m != nil { return m.Name } return "" } func (m *CameraPolygon) GetPolygon() string { if m != nil { return m.Polygon } return "" } func (m *CameraPolygon) GetTriggerLine() string { if m != nil { return m.TriggerLine } return "" } func (m *CameraPolygon) GetDirectionLine() string { if m != nil { return m.DirectionLine } return "" } func (m *CameraPolygon) GetType() string { if m != nil { return m.Type } return "" } func (m *CameraPolygon) GetDefenceState() int32 { if m != nil { return m.DefenceState } return 0 } type VideotapeInfo struct { EsDataId string `protobuf:"bytes,1,opt,name=esDataId,proto3" json:"esDataId,omitempty"` CameraId string `protobuf:"bytes,2,opt,name=cameraId,proto3" json:"cameraId,omitempty"` TaskId string `protobuf:"bytes,3,opt,name=taskId,proto3" json:"taskId,omitempty"` ImgId int64 `protobuf:"varint,4,opt,name=imgId,proto3" json:"imgId,omitempty"` SdkIds []string `protobuf:"bytes,5,rep,name=sdkIds,proto3" json:"sdkIds,omitempty"` } func (m *VideotapeInfo) Reset() { *m = VideotapeInfo{} } func (m *VideotapeInfo) String() string { return proto.CompactTextString(m) } func (*VideotapeInfo) ProtoMessage() {} func (*VideotapeInfo) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{20} } func (m *VideotapeInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *VideotapeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_VideotapeInfo.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *VideotapeInfo) XXX_Merge(src proto.Message) { xxx_messageInfo_VideotapeInfo.Merge(m, src) } func (m *VideotapeInfo) XXX_Size() int { return m.Size() } func (m *VideotapeInfo) XXX_DiscardUnknown() { xxx_messageInfo_VideotapeInfo.DiscardUnknown(m) } var xxx_messageInfo_VideotapeInfo proto.InternalMessageInfo func (m *VideotapeInfo) GetEsDataId() string { if m != nil { return m.EsDataId } return "" } func (m *VideotapeInfo) GetCameraId() string { if m != nil { return m.CameraId } return "" } func (m *VideotapeInfo) GetTaskId() string { if m != nil { return m.TaskId } return "" } func (m *VideotapeInfo) GetImgId() int64 { if m != nil { return m.ImgId } return 0 } func (m *VideotapeInfo) GetSdkIds() []string { if m != nil { return m.SdkIds } return nil } type CompareArgs struct { TableIds []string `protobuf:"bytes,1,rep,name=tableIds,proto3" json:"tableIds,omitempty"` FaceFeature []byte `protobuf:"bytes,2,opt,name=faceFeature,proto3" json:"faceFeature,omitempty"` CompareThreshold float32 `protobuf:"fixed32,3,opt,name=compareThreshold,proto3" json:"compareThreshold,omitempty"` } func (m *CompareArgs) Reset() { *m = CompareArgs{} } func (m *CompareArgs) String() string { return proto.CompactTextString(m) } func (*CompareArgs) ProtoMessage() {} func (*CompareArgs) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{21} } func (m *CompareArgs) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *CompareArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_CompareArgs.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *CompareArgs) XXX_Merge(src proto.Message) { xxx_messageInfo_CompareArgs.Merge(m, src) } func (m *CompareArgs) XXX_Size() int { return m.Size() } func (m *CompareArgs) XXX_DiscardUnknown() { xxx_messageInfo_CompareArgs.DiscardUnknown(m) } var xxx_messageInfo_CompareArgs proto.InternalMessageInfo func (m *CompareArgs) GetTableIds() []string { if m != nil { return m.TableIds } return nil } func (m *CompareArgs) GetFaceFeature() []byte { if m != nil { return m.FaceFeature } return nil } func (m *CompareArgs) GetCompareThreshold() float32 { if m != nil { return m.CompareThreshold } return 0 } type EventPush struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` TimeStart string `protobuf:"bytes,3,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"` TimeEnd string `protobuf:"bytes,4,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"` IsSatisfyAll bool `protobuf:"varint,5,opt,name=is_satisfy_all,json=isSatisfyAll,proto3" json:"is_satisfy_all,omitempty"` RuleText string `protobuf:"bytes,6,opt,name=rule_text,json=ruleText,proto3" json:"rule_text,omitempty"` Enable bool `protobuf:"varint,7,opt,name=enable,proto3" json:"enable,omitempty"` LinkType string `protobuf:"bytes,8,opt,name=link_type,json=linkType,proto3" json:"link_type,omitempty"` LinkDevice string `protobuf:"bytes,9,opt,name=link_device,json=linkDevice,proto3" json:"link_device,omitempty"` IpPorts []*PushIpPort `protobuf:"bytes,10,rep,name=ip_ports,json=ipPorts,proto3" json:"ip_ports,omitempty"` Urls []*PushUrl `protobuf:"bytes,11,rep,name=urls,proto3" json:"urls,omitempty"` Rules []*EventPushRule `protobuf:"bytes,12,rep,name=rules,proto3" json:"rules,omitempty"` } func (m *EventPush) Reset() { *m = EventPush{} } func (m *EventPush) String() string { return proto.CompactTextString(m) } func (*EventPush) ProtoMessage() {} func (*EventPush) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{22} } func (m *EventPush) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *EventPush) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_EventPush.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *EventPush) XXX_Merge(src proto.Message) { xxx_messageInfo_EventPush.Merge(m, src) } func (m *EventPush) XXX_Size() int { return m.Size() } func (m *EventPush) XXX_DiscardUnknown() { xxx_messageInfo_EventPush.DiscardUnknown(m) } var xxx_messageInfo_EventPush proto.InternalMessageInfo func (m *EventPush) GetId() string { if m != nil { return m.Id } return "" } func (m *EventPush) GetName() string { if m != nil { return m.Name } return "" } func (m *EventPush) GetTimeStart() string { if m != nil { return m.TimeStart } return "" } func (m *EventPush) GetTimeEnd() string { if m != nil { return m.TimeEnd } return "" } func (m *EventPush) GetIsSatisfyAll() bool { if m != nil { return m.IsSatisfyAll } return false } func (m *EventPush) GetRuleText() string { if m != nil { return m.RuleText } return "" } func (m *EventPush) GetEnable() bool { if m != nil { return m.Enable } return false } func (m *EventPush) GetLinkType() string { if m != nil { return m.LinkType } return "" } func (m *EventPush) GetLinkDevice() string { if m != nil { return m.LinkDevice } return "" } func (m *EventPush) GetIpPorts() []*PushIpPort { if m != nil { return m.IpPorts } return nil } func (m *EventPush) GetUrls() []*PushUrl { if m != nil { return m.Urls } return nil } func (m *EventPush) GetRules() []*EventPushRule { if m != nil { return m.Rules } return nil } type EventPushRule struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` TopicType string `protobuf:"bytes,2,opt,name=topic_type,json=topicType,proto3" json:"topic_type,omitempty"` TopicArg string `protobuf:"bytes,3,opt,name=topic_arg,json=topicArg,proto3" json:"topic_arg,omitempty"` Operator string `protobuf:"bytes,4,opt,name=operator,proto3" json:"operator,omitempty"` OperatorType string `protobuf:"bytes,5,opt,name=operator_type,json=operatorType,proto3" json:"operator_type,omitempty"` RuleValue string `protobuf:"bytes,6,opt,name=rule_value,json=ruleValue,proto3" json:"rule_value,omitempty"` EventPushId string `protobuf:"bytes,7,opt,name=event_push_id,json=eventPushId,proto3" json:"event_push_id,omitempty"` } func (m *EventPushRule) Reset() { *m = EventPushRule{} } func (m *EventPushRule) String() string { return proto.CompactTextString(m) } func (*EventPushRule) ProtoMessage() {} func (*EventPushRule) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{23} } func (m *EventPushRule) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *EventPushRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_EventPushRule.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *EventPushRule) XXX_Merge(src proto.Message) { xxx_messageInfo_EventPushRule.Merge(m, src) } func (m *EventPushRule) XXX_Size() int { return m.Size() } func (m *EventPushRule) XXX_DiscardUnknown() { xxx_messageInfo_EventPushRule.DiscardUnknown(m) } var xxx_messageInfo_EventPushRule proto.InternalMessageInfo func (m *EventPushRule) GetId() string { if m != nil { return m.Id } return "" } func (m *EventPushRule) GetTopicType() string { if m != nil { return m.TopicType } return "" } func (m *EventPushRule) GetTopicArg() string { if m != nil { return m.TopicArg } return "" } func (m *EventPushRule) GetOperator() string { if m != nil { return m.Operator } return "" } func (m *EventPushRule) GetOperatorType() string { if m != nil { return m.OperatorType } return "" } func (m *EventPushRule) GetRuleValue() string { if m != nil { return m.RuleValue } return "" } func (m *EventPushRule) GetEventPushId() string { if m != nil { return m.EventPushId } return "" } type PushIpPort struct { ServerIp string `protobuf:"bytes,1,opt,name=server_ip,json=serverIp,proto3" json:"server_ip,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` Enable bool `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"` } func (m *PushIpPort) Reset() { *m = PushIpPort{} } func (m *PushIpPort) String() string { return proto.CompactTextString(m) } func (*PushIpPort) ProtoMessage() {} func (*PushIpPort) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{24} } func (m *PushIpPort) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PushIpPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_PushIpPort.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *PushIpPort) XXX_Merge(src proto.Message) { xxx_messageInfo_PushIpPort.Merge(m, src) } func (m *PushIpPort) XXX_Size() int { return m.Size() } func (m *PushIpPort) XXX_DiscardUnknown() { xxx_messageInfo_PushIpPort.DiscardUnknown(m) } var xxx_messageInfo_PushIpPort proto.InternalMessageInfo func (m *PushIpPort) GetServerIp() string { if m != nil { return m.ServerIp } return "" } func (m *PushIpPort) GetPort() int32 { if m != nil { return m.Port } return 0 } func (m *PushIpPort) GetEnable() bool { if m != nil { return m.Enable } return false } type PushUrl struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` Enable bool `protobuf:"varint,2,opt,name=enable,proto3" json:"enable,omitempty"` } func (m *PushUrl) Reset() { *m = PushUrl{} } func (m *PushUrl) String() string { return proto.CompactTextString(m) } func (*PushUrl) ProtoMessage() {} func (*PushUrl) Descriptor() ([]byte, []int) { return fileDescriptor_32de24555f916688, []int{25} } func (m *PushUrl) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PushUrl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_PushUrl.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalTo(b) if err != nil { return nil, err } return b[:n], nil } } func (m *PushUrl) XXX_Merge(src proto.Message) { xxx_messageInfo_PushUrl.Merge(m, src) } func (m *PushUrl) XXX_Size() int { return m.Size() } func (m *PushUrl) XXX_DiscardUnknown() { xxx_messageInfo_PushUrl.DiscardUnknown(m) } var xxx_messageInfo_PushUrl proto.InternalMessageInfo func (m *PushUrl) GetUrl() string { if m != nil { return m.Url } return "" } func (m *PushUrl) GetEnable() bool { if m != nil { return m.Enable } return false } func init() { proto.RegisterEnum("protomsg.TableChanged", TableChanged_name, TableChanged_value) proto.RegisterEnum("protomsg.DbAction", DbAction_name, DbAction_value) proto.RegisterType((*Area)(nil), "protomsg.Area") proto.RegisterType((*Camera)(nil), "protomsg.Camera") proto.RegisterType((*CameraAndTaskInfo)(nil), "protomsg.CameraAndTaskInfo") proto.RegisterType((*Task)(nil), "protomsg.Task") proto.RegisterType((*TaskSdkInfo)(nil), "protomsg.TaskSdkInfo") proto.RegisterType((*SdkRun)(nil), "protomsg.SdkRun") proto.RegisterType((*TaskSdkRun)(nil), "protomsg.TaskSdkRun") proto.RegisterType((*CameraTask)(nil), "protomsg.CameraTask") proto.RegisterType((*CameraTimerule)(nil), "protomsg.CameraTimerule") proto.RegisterType((*DayCtl)(nil), "protomsg.DayCtl") proto.RegisterType((*TimeRange)(nil), "protomsg.TimeRange") proto.RegisterType((*Polygon)(nil), "protomsg.Polygon") proto.RegisterType((*CameraTaskArgs)(nil), "protomsg.CameraTaskArgs") proto.RegisterType((*TaskGroupArgs)(nil), "protomsg.TaskGroupArgs") proto.RegisterType((*GroupRule)(nil), "protomsg.GroupRule") proto.RegisterType((*Rule)(nil), "protomsg.Rule") proto.RegisterType((*Sdk)(nil), "protomsg.Sdk") proto.RegisterType((*SdkArg)(nil), "protomsg.SdkArg") proto.RegisterType((*DbChangeMessage)(nil), "protomsg.DbChangeMessage") proto.RegisterType((*CameraPolygon)(nil), "protomsg.CameraPolygon") proto.RegisterType((*VideotapeInfo)(nil), "protomsg.VideotapeInfo") proto.RegisterType((*CompareArgs)(nil), "protomsg.CompareArgs") proto.RegisterType((*EventPush)(nil), "protomsg.EventPush") proto.RegisterType((*EventPushRule)(nil), "protomsg.EventPushRule") proto.RegisterType((*PushIpPort)(nil), "protomsg.PushIpPort") proto.RegisterType((*PushUrl)(nil), "protomsg.PushUrl") } func init() { proto.RegisterFile("protomsg.proto", fileDescriptor_32de24555f916688) } var fileDescriptor_32de24555f916688 = []byte{ // 2023 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x58, 0xcd, 0x6e, 0xdc, 0xc8, 0x11, 0x36, 0xe7, 0x97, 0xac, 0x99, 0x91, 0xc7, 0xbd, 0xce, 0x2e, 0xd7, 0x8e, 0xb5, 0x32, 0xe3, 0x45, 0x04, 0x23, 0xeb, 0x00, 0xf6, 0x9e, 0x72, 0x9b, 0xf5, 0x4f, 0x30, 0xc0, 0x66, 0xa1, 0x50, 0x63, 0xe7, 0x48, 0xb4, 0x86, 0x2d, 0x8a, 0x50, 0x8b, 0x24, 0xba, 0x9b, 0xf2, 0xea, 0x11, 0x72, 0x08, 0x92, 0x63, 0x1e, 0x27, 0xc8, 0x29, 0x87, 0x1c, 0xf6, 0x98, 0x5b, 0x02, 0x1b, 0xc8, 0x25, 0xc8, 0x2b, 0x04, 0x41, 0x55, 0x37, 0x39, 0x9c, 0x91, 0x9c, 0xf8, 0x34, 0xf5, 0xc7, 0xee, 0xea, 0xaa, 0xea, 0xaf, 0xaa, 0x07, 0xf6, 0x2a, 0x55, 0x9a, 0xf2, 0x42, 0x67, 0x4f, 0x88, 0x60, 0x7e, 0xc3, 0xdf, 0x83, 0x13, 0xae, 0x85, 0x95, 0x46, 0xaf, 0x60, 0xb0, 0x50, 0x82, 0xb3, 0x3d, 0xe8, 0xe5, 0x69, 0xe8, 0x1d, 0x78, 0x87, 0xc3, 0xb8, 0x97, 0xa7, 0xec, 0x1e, 0xf8, 0x15, 0x57, 0xa2, 0x30, 0x79, 0x1a, 0xf6, 0x48, 0xda, 0xf2, 0x8c, 0xc1, 0xa0, 0xe0, 0x17, 0x22, 0xec, 0x1f, 0x78, 0x87, 0x41, 0x4c, 0x74, 0xf4, 0x9f, 0x3e, 0x8c, 0x9e, 0xf3, 0x0b, 0xa1, 0xba, 0x4b, 0x05, 0xb4, 0x54, 0x63, 0xde, 0xdb, 0x98, 0xb3, 0xbb, 0x30, 0xe4, 0x32, 0xe7, 0xda, 0xad, 0x61, 0x19, 0xf6, 0x10, 0xa6, 0xba, 0xe0, 0x95, 0x3e, 0x2b, 0x4d, 0x52, 0x2b, 0x19, 0x0e, 0x48, 0x39, 0x69, 0x64, 0xaf, 0x95, 0xc4, 0xc5, 0xcc, 0x55, 0x25, 0xc2, 0x21, 0xf9, 0x44, 0x34, 0xca, 0x78, 0x9a, 0xaa, 0x70, 0x64, 0x37, 0x40, 0x9a, 0x7d, 0x0a, 0x23, 0xae, 0x04, 0xcf, 0xd3, 0x70, 0x4c, 0x96, 0x8e, 0x63, 0x3f, 0x86, 0x40, 0x96, 0x45, 0x96, 0x9b, 0x3a, 0x15, 0xa1, 0x7f, 0xe0, 0x1d, 0xf6, 0xe2, 0x8d, 0x00, 0x4f, 0x2d, 0xb9, 0xb1, 0xca, 0x80, 0x94, 0x2d, 0x8f, 0xbb, 0x28, 0xa3, 0xab, 0x10, 0xec, 0x2e, 0x48, 0xd3, 0x51, 0xab, 0x70, 0xe2, 0x8e, 0x5a, 0xa1, 0x4d, 0x55, 0x2a, 0x13, 0x4e, 0xad, 0x77, 0x48, 0xe3, 0x9a, 0xb5, 0x16, 0x8a, 0x42, 0x30, 0x23, 0xcb, 0x96, 0xb7, 0x51, 0xd6, 0xfa, 0x6d, 0xa9, 0xd2, 0x70, 0xcf, 0xea, 0x1a, 0x1e, 0x43, 0x74, 0xa2, 0x78, 0x91, 0x86, 0xb7, 0x6d, 0x88, 0x88, 0xc1, 0x2f, 0x94, 0xd0, 0x42, 0x5d, 0x8a, 0x34, 0x9c, 0xdb, 0x2f, 0x1a, 0x9e, 0x3d, 0x00, 0xc8, 0x75, 0xa2, 0xea, 0xa2, 0xc8, 0x8b, 0x2c, 0xbc, 0x73, 0xe0, 0x1d, 0xfa, 0x71, 0x90, 0xeb, 0xd8, 0x0a, 0x50, 0xad, 0xea, 0x22, 0x11, 0x05, 0x3f, 0x91, 0x22, 0x64, 0x56, 0xad, 0xea, 0xe2, 0x25, 0x09, 0xd8, 0xe7, 0xe0, 0xa3, 0x9a, 0xa2, 0xfb, 0x09, 0xf9, 0x3f, 0x56, 0x75, 0xb1, 0xc2, 0x00, 0x47, 0x30, 0x43, 0x15, 0x6d, 0xa3, 0x92, 0x3c, 0x0d, 0xef, 0xda, 0xc4, 0xa8, 0xba, 0x38, 0x26, 0xd9, 0x32, 0x8d, 0xd6, 0x70, 0xc7, 0xe6, 0x7f, 0x51, 0xa4, 0x2b, 0xae, 0xcf, 0x97, 0xc5, 0x69, 0xc9, 0x0e, 0x61, 0xb4, 0x26, 0x21, 0x95, 0xc3, 0xe4, 0xe9, 0xfc, 0x49, 0x5b, 0x94, 0xd6, 0x38, 0x76, 0x7a, 0xf6, 0x08, 0x86, 0x86, 0xeb, 0x73, 0x1d, 0xf6, 0x0e, 0xfa, 0x87, 0x93, 0xa7, 0x7b, 0x1b, 0x43, 0x5c, 0x2c, 0xb6, 0xca, 0xe8, 0xef, 0x1e, 0x0c, 0x90, 0xc7, 0xf4, 0xa2, 0xa4, 0xad, 0x33, 0xc7, 0x61, 0x78, 0x90, 0xea, 0xd4, 0x5b, 0xcb, 0xb3, 0xfb, 0x10, 0xac, 0x95, 0xe0, 0x46, 0x24, 0xdc, 0xb8, 0xba, 0xf3, 0xad, 0x60, 0x61, 0x3a, 0xca, 0x93, 0x2b, 0x57, 0x77, 0x4e, 0xf9, 0xcd, 0x15, 0x2a, 0xeb, 0x2a, 0x75, 0x5f, 0x0e, 0x5d, 0x0e, 0x49, 0xb0, 0x30, 0xe8, 0x8a, 0x0b, 0xe9, 0x88, 0x42, 0xea, 0x38, 0x8c, 0x67, 0xae, 0x13, 0x2e, 0xb9, 0xba, 0xa0, 0x1a, 0xf4, 0xe3, 0x71, 0xae, 0x17, 0xc8, 0xa2, 0x2a, 0x15, 0x32, 0x39, 0x95, 0x3c, 0xa3, 0x1a, 0xf4, 0xe3, 0x71, 0x2a, 0xe4, 0x2b, 0xc9, 0xb3, 0x68, 0x05, 0x13, 0x3c, 0xe0, 0x71, 0x6a, 0x03, 0x18, 0xc1, 0x00, 0xfd, 0x77, 0xe1, 0xdb, 0x8d, 0x0a, 0xe9, 0xd8, 0x43, 0x18, 0xe8, 0xb4, 0x8d, 0xdc, 0x6c, 0x63, 0x73, 0x9c, 0x9e, 0xc7, 0xa4, 0x8a, 0x7e, 0x01, 0x23, 0x64, 0xea, 0x82, 0xfd, 0x08, 0x46, 0x79, 0xb5, 0x4e, 0xda, 0xc0, 0x0d, 0xf3, 0x6a, 0xbd, 0x4c, 0xd1, 0x23, 0x9d, 0x9e, 0xdb, 0xe4, 0xdb, 0xb8, 0x8d, 0x75, 0x7a, 0x8e, 0xc9, 0x8f, 0xde, 0x00, 0x38, 0x8f, 0xf0, 0xfb, 0x8f, 0x71, 0xe8, 0xd1, 0x96, 0x43, 0xf3, 0x6d, 0x87, 0xea, 0xc2, 0xf9, 0xf4, 0xcf, 0x1e, 0x80, 0x2d, 0x02, 0xca, 0xe8, 0x2e, 0x6a, 0x60, 0x42, 0x48, 0x9b, 0x38, 0x04, 0xc2, 0x84, 0x90, 0x60, 0x99, 0xb2, 0xcf, 0x60, 0x8c, 0x3b, 0xa1, 0xaa, 0xbf, 0xc9, 0xff, 0x32, 0x65, 0x5f, 0x41, 0x60, 0xf2, 0x0b, 0x91, 0xa8, 0x5a, 0x8a, 0x70, 0xb0, 0xbb, 0xff, 0x0b, 0x7e, 0xf5, 0xdc, 0xc8, 0xd8, 0x47, 0x93, 0xb8, 0x96, 0x82, 0xae, 0x84, 0xe0, 0x6b, 0x63, 0xed, 0x6d, 0x66, 0x03, 0x92, 0x90, 0xfa, 0x21, 0x4c, 0xad, 0x3a, 0x15, 0x97, 0xf9, 0x5a, 0x38, 0x80, 0x99, 0x90, 0xec, 0x05, 0x89, 0xb6, 0x52, 0x39, 0xde, 0x4a, 0x25, 0xfb, 0x02, 0x26, 0xae, 0x6a, 0x3a, 0x89, 0x06, 0x2b, 0x22, 0x83, 0x4d, 0xe5, 0x04, 0x5b, 0x95, 0xc3, 0x60, 0xa0, 0x11, 0x45, 0xc0, 0xa2, 0x08, 0xd2, 0x78, 0xe2, 0x5c, 0x27, 0xa7, 0xb5, 0x94, 0x04, 0x37, 0x7e, 0x3c, 0xca, 0xf5, 0xab, 0x5a, 0x4a, 0x76, 0x00, 0x53, 0x99, 0x17, 0xe7, 0x49, 0x13, 0x8f, 0x29, 0xf9, 0x08, 0x28, 0xa3, 0x6b, 0x98, 0x46, 0xbf, 0x86, 0x3d, 0x17, 0xe7, 0xfc, 0x42, 0xe0, 0x41, 0x3f, 0x0a, 0xa1, 0xef, 0x77, 0x23, 0xe9, 0x6e, 0x4b, 0x13, 0xb7, 0xe8, 0x3b, 0x18, 0xd9, 0x58, 0xb2, 0x39, 0xf4, 0x53, 0x7e, 0xe5, 0x1a, 0x07, 0x92, 0xec, 0x29, 0x80, 0xfd, 0x90, 0x17, 0x99, 0x70, 0x35, 0xf0, 0x49, 0xa7, 0x4e, 0x70, 0x0d, 0x54, 0xc5, 0xb4, 0x3e, 0x91, 0xd1, 0x33, 0x08, 0x5a, 0x39, 0x02, 0x9f, 0x36, 0x5c, 0x99, 0xa6, 0x42, 0x89, 0xc1, 0x8d, 0x44, 0xd1, 0x54, 0x02, 0x92, 0xd1, 0x1b, 0x18, 0x1f, 0x95, 0xf2, 0x2a, 0x2b, 0x8b, 0x8f, 0x3a, 0xd0, 0x4f, 0x61, 0x54, 0x95, 0x79, 0x61, 0xb0, 0xe7, 0xa0, 0x4f, 0xb7, 0x37, 0x3e, 0x1d, 0xa1, 0x3c, 0x76, 0xea, 0x68, 0xdd, 0xc6, 0x8b, 0xeb, 0xf3, 0x85, 0xca, 0xf4, 0x76, 0x2d, 0x7a, 0x3b, 0xb5, 0xf8, 0x35, 0x04, 0x14, 0x7b, 0xae, 0xb2, 0xa6, 0xe4, 0x3f, 0xdb, 0xbe, 0x16, 0xbf, 0x54, 0x65, 0x5d, 0xe1, 0x42, 0x16, 0x8c, 0x90, 0x8a, 0x2e, 0x61, 0xb6, 0xa5, 0xea, 0x96, 0xb4, 0xb7, 0x55, 0xd2, 0x5f, 0xc3, 0x24, 0x43, 0x2b, 0xca, 0x84, 0xbe, 0x1e, 0x50, 0x5a, 0x02, 0xb3, 0x12, 0x43, 0xd6, 0x90, 0xba, 0x53, 0x5b, 0xfd, 0x6e, 0x6d, 0x45, 0x7f, 0xf5, 0x20, 0x68, 0xbf, 0xc0, 0xea, 0xb5, 0x6b, 0xb7, 0xbb, 0x8e, 0x89, 0x5f, 0x52, 0x33, 0xb1, 0x2a, 0x23, 0xbe, 0x37, 0x2e, 0x90, 0x01, 0x49, 0x56, 0xe2, 0x7b, 0x83, 0xc5, 0x4d, 0xd0, 0x96, 0x48, 0x71, 0x29, 0x24, 0x6d, 0x32, 0x8c, 0x81, 0x44, 0xdf, 0xa2, 0x04, 0x01, 0xdd, 0x3a, 0x3c, 0xd8, 0x05, 0x74, 0xf2, 0xd5, 0x2a, 0x09, 0x77, 0x84, 0x49, 0xda, 0x96, 0x8e, 0xb8, 0x23, 0x0c, 0x35, 0x9d, 0x9f, 0xc0, 0x2c, 0x15, 0xa7, 0xa2, 0x58, 0x8b, 0x44, 0x1b, 0x6e, 0x1a, 0x78, 0x9d, 0x3a, 0xe1, 0x31, 0xca, 0xa2, 0x7f, 0xf5, 0x60, 0x10, 0xdf, 0x54, 0xd2, 0x8f, 0x60, 0xcf, 0xa5, 0xac, 0x89, 0xaa, 0x3d, 0xc2, 0x74, 0xdd, 0xa6, 0x76, 0xb9, 0x03, 0x32, 0xfd, 0x9d, 0xc4, 0x3e, 0x00, 0xa8, 0x6c, 0x7d, 0xa1, 0xd6, 0xf6, 0x84, 0xc0, 0x49, 0x96, 0x29, 0x22, 0x29, 0x42, 0x66, 0x9e, 0x3a, 0xc7, 0x87, 0x3a, 0xc5, 0x25, 0x23, 0x98, 0xa1, 0x98, 0xab, 0x2c, 0xb1, 0x13, 0x8e, 0x03, 0x0d, 0x9d, 0x62, 0xe2, 0x17, 0x34, 0xe7, 0xdc, 0x03, 0xbf, 0xac, 0x84, 0xe2, 0xa6, 0x54, 0x04, 0x1a, 0x41, 0xdc, 0xf2, 0x78, 0xec, 0x86, 0xb6, 0x61, 0xf1, 0xad, 0xdf, 0x8d, 0xb0, 0x69, 0xc8, 0xcd, 0x26, 0x97, 0x5c, 0xd6, 0x16, 0x40, 0xda, 0x4d, 0xde, 0xa0, 0xe8, 0x46, 0x14, 0xa1, 0x46, 0x2e, 0x45, 0xf2, 0x36, 0x37, 0x67, 0x49, 0xa5, 0x84, 0x1b, 0x5d, 0x26, 0x28, 0xfc, 0x4d, 0x6e, 0xce, 0x8e, 0xd4, 0x76, 0x4d, 0x4c, 0xb7, 0x6a, 0x22, 0xfa, 0x53, 0x0f, 0xfa, 0xc7, 0xe9, 0x75, 0xac, 0xde, 0x34, 0x95, 0xde, 0x87, 0x9a, 0x4a, 0x7f, 0xab, 0xa9, 0x34, 0x2a, 0xba, 0xa4, 0x83, 0x56, 0xf5, 0x1d, 0xde, 0xd3, 0x47, 0x30, 0xa0, 0xab, 0x34, 0xbc, 0xa1, 0x7b, 0x2c, 0x54, 0x16, 0x93, 0x16, 0x4f, 0x97, 0xaf, 0xcb, 0xa2, 0x99, 0xf9, 0x90, 0x46, 0x88, 0xc0, 0xa9, 0xd1, 0x46, 0x14, 0x49, 0xac, 0x52, 0xd7, 0xd5, 0x11, 0x6b, 0x5c, 0x28, 0xc1, 0x8a, 0x10, 0x70, 0x3a, 0x18, 0x4d, 0x06, 0x36, 0x8c, 0x0e, 0xa3, 0xc9, 0x60, 0x6b, 0x2e, 0x80, 0x9d, 0xb9, 0x60, 0x73, 0xc9, 0x26, 0xbb, 0xad, 0xbf, 0x6d, 0x0a, 0x76, 0x14, 0x6c, 0xfb, 0xfb, 0x1f, 0x3d, 0x6a, 0xc5, 0x0b, 0x95, 0x6d, 0x66, 0x60, 0xaf, 0x3b, 0x03, 0xdf, 0x04, 0x5d, 0xcd, 0xd0, 0xeb, 0x06, 0xee, 0x66, 0xe8, 0xbd, 0xa8, 0xb5, 0xa1, 0xe8, 0xf9, 0x31, 0xd1, 0x28, 0xab, 0x8b, 0xbc, 0x19, 0x51, 0x88, 0xc6, 0x5d, 0x2c, 0x12, 0xdb, 0x48, 0x59, 0xa6, 0x2d, 0x8e, 0xf1, 0xa6, 0x38, 0xa2, 0xdf, 0x7b, 0x70, 0xfb, 0xc5, 0xc9, 0xf3, 0x33, 0x34, 0xf8, 0x95, 0xd0, 0x9a, 0x67, 0x82, 0xfd, 0x0c, 0xc7, 0x32, 0x3c, 0x20, 0xfa, 0xb8, 0xf7, 0xf4, 0xd3, 0x2e, 0xb0, 0x9d, 0x48, 0x61, 0x8d, 0xd3, 0xd8, 0x1a, 0xb9, 0xba, 0xe8, 0xb5, 0x75, 0xf1, 0x18, 0x46, 0x7c, 0x6d, 0xf2, 0xb2, 0x20, 0xcf, 0xf7, 0x9e, 0xb2, 0x4e, 0x2b, 0x3e, 0x59, 0x90, 0x26, 0x76, 0x16, 0x94, 0xd0, 0xe2, 0xb4, 0x74, 0xd5, 0x40, 0x74, 0xf4, 0x6f, 0x0f, 0x66, 0x16, 0x8a, 0x3f, 0x04, 0xf4, 0xff, 0x73, 0x4a, 0xb8, 0xe1, 0x9d, 0xc2, 0x42, 0x18, 0xbb, 0x2b, 0xdc, 0xd4, 0x9d, 0x63, 0xb1, 0xd9, 0x1b, 0x95, 0x67, 0x99, 0x50, 0x89, 0xcc, 0x8b, 0x06, 0x8e, 0x26, 0x4e, 0xf6, 0x6d, 0x5e, 0x08, 0xf6, 0x25, 0xec, 0xa5, 0xb9, 0x12, 0xe4, 0xb0, 0x35, 0xb2, 0x41, 0x9d, 0xb5, 0x52, 0x32, 0x6b, 0xd2, 0x35, 0xee, 0xa4, 0xeb, 0x1a, 0x9a, 0xf9, 0x14, 0xf9, 0x6d, 0x34, 0xfb, 0x9d, 0x07, 0xb3, 0x37, 0x79, 0x2a, 0x4a, 0xc3, 0x2b, 0x41, 0xf3, 0xdf, 0x3d, 0xf0, 0x85, 0x7e, 0xc1, 0x0d, 0x5f, 0xb6, 0x8d, 0xa7, 0xe1, 0x51, 0xd7, 0x1c, 0xf5, 0xda, 0xd1, 0xdd, 0x7c, 0xbc, 0xdc, 0x9d, 0x8f, 0xee, 0xc2, 0x30, 0xbf, 0xc8, 0x96, 0x16, 0xce, 0xfa, 0xb1, 0x65, 0xd0, 0x9a, 0xc0, 0xcb, 0x5e, 0xba, 0x20, 0x76, 0x5c, 0xf4, 0x16, 0x26, 0xcf, 0xcb, 0x0b, 0x7c, 0xf7, 0x51, 0x8b, 0xa2, 0xe1, 0xfa, 0x44, 0x0a, 0x34, 0xf4, 0xc8, 0xb0, 0xe5, 0xd9, 0x01, 0x4c, 0x4e, 0xf9, 0x5a, 0xbc, 0x12, 0xdc, 0xd4, 0xca, 0x56, 0xef, 0x34, 0xee, 0x8a, 0xd8, 0x63, 0x98, 0xaf, 0xed, 0x62, 0xab, 0x33, 0x25, 0xf4, 0x59, 0x29, 0xad, 0x73, 0xbd, 0xf8, 0x9a, 0x3c, 0xfa, 0x6d, 0x1f, 0x82, 0x97, 0x97, 0xa2, 0x30, 0x47, 0xb5, 0x3e, 0xfb, 0xa8, 0xee, 0xfe, 0xc0, 0x4d, 0x1d, 0x76, 0x72, 0xb0, 0x87, 0xa6, 0x01, 0xe3, 0x98, 0xa6, 0x87, 0xcf, 0x81, 0x86, 0x97, 0x04, 0x47, 0x08, 0x97, 0x77, 0xe4, 0x5f, 0x16, 0xd4, 0x29, 0x72, 0x9d, 0x68, 0x6e, 0x72, 0x7d, 0x7a, 0x95, 0x70, 0x29, 0x29, 0xf3, 0x7e, 0x3c, 0xcd, 0xf5, 0xb1, 0x15, 0x2e, 0xa4, 0xc4, 0x42, 0x23, 0xe4, 0xa4, 0x6e, 0x38, 0x72, 0x0f, 0xaf, 0x5a, 0x0a, 0x6a, 0x86, 0x1b, 0x1c, 0x18, 0x6f, 0xe1, 0xc0, 0x7d, 0x08, 0xec, 0x6c, 0xb6, 0xc1, 0x71, 0x9f, 0x06, 0x33, 0xac, 0x88, 0x2f, 0x60, 0x42, 0x4a, 0x37, 0x5b, 0x06, 0x9b, 0xb9, 0xcd, 0x8d, 0x96, 0x3f, 0x07, 0x3f, 0xaf, 0x12, 0x7c, 0x43, 0xea, 0x10, 0x08, 0x0c, 0xef, 0x76, 0x46, 0x96, 0x5a, 0x9f, 0x2d, 0xab, 0xa3, 0x52, 0x99, 0x78, 0x9c, 0xd3, 0xaf, 0x66, 0x5f, 0xc2, 0xa0, 0x56, 0x52, 0x87, 0x13, 0x32, 0xbe, 0xb3, 0x6d, 0xfc, 0x5a, 0xc9, 0x98, 0xd4, 0xec, 0xab, 0xa6, 0x33, 0x4f, 0x77, 0x87, 0x95, 0x36, 0xe4, 0x9d, 0x16, 0x8d, 0x6f, 0xae, 0xd9, 0x96, 0xe2, 0x5a, 0x3e, 0x30, 0xf6, 0x65, 0x95, 0xaf, 0xbb, 0xcf, 0x87, 0x80, 0x24, 0x74, 0x50, 0x9c, 0x24, 0x49, 0xcd, 0x55, 0xd6, 0x4e, 0x92, 0x28, 0x40, 0x10, 0xec, 0xb6, 0xc2, 0xc1, 0xff, 0x6b, 0x85, 0xc3, 0x1b, 0x5a, 0x21, 0xbd, 0x6a, 0xa5, 0x70, 0x7d, 0x70, 0xe4, 0x46, 0xf8, 0x5a, 0x0a, 0xdb, 0x05, 0x23, 0x98, 0x09, 0x74, 0x3e, 0xa9, 0x6a, 0x7d, 0x96, 0xb8, 0xbf, 0x03, 0x82, 0x78, 0x22, 0x9a, 0x13, 0x2d, 0xd3, 0xe8, 0x35, 0xc0, 0x26, 0x9c, 0xe8, 0x6e, 0xf3, 0xd0, 0xad, 0x9a, 0x3b, 0x67, 0x05, 0xcb, 0xcd, 0x03, 0xbf, 0xd7, 0x79, 0xe0, 0x7f, 0x68, 0xd4, 0x7a, 0x06, 0x63, 0x17, 0xf8, 0xa6, 0x33, 0x79, 0x9b, 0xce, 0xb4, 0xf9, 0xa8, 0xd7, 0xfd, 0xe8, 0xf1, 0x9f, 0x3d, 0x98, 0x76, 0xa1, 0x95, 0x4d, 0xc1, 0x5f, 0x25, 0x16, 0x04, 0xe7, 0xb7, 0xd8, 0x1c, 0xa6, 0x0d, 0x87, 0x23, 0xcc, 0xdc, 0x63, 0x77, 0x61, 0xde, 0x95, 0xe0, 0x45, 0x9d, 0xf7, 0x18, 0xc0, 0x68, 0x95, 0x90, 0x45, 0x9f, 0xcd, 0x20, 0xb0, 0xf4, 0x71, 0x7a, 0x3e, 0x1f, 0xb0, 0x3b, 0x30, 0x6b, 0x59, 0x4c, 0xe7, 0x7c, 0xc8, 0x02, 0x18, 0xae, 0x12, 0xd4, 0x8e, 0xd8, 0x27, 0x70, 0xbb, 0x59, 0xce, 0x61, 0xee, 0x7c, 0xcc, 0xf6, 0x00, 0x56, 0xc9, 0xca, 0x0d, 0xff, 0x73, 0xdf, 0xfa, 0x64, 0x5f, 0xfe, 0xf3, 0xc0, 0xfa, 0x74, 0x54, 0x4a, 0xf9, 0xbc, 0x2c, 0x4e, 0xf3, 0x6c, 0x0e, 0x8f, 0x9f, 0x80, 0xdf, 0xe0, 0x3b, 0x7a, 0xb2, 0x2c, 0xb4, 0x50, 0x66, 0x7e, 0x0b, 0xe9, 0xd7, 0xd4, 0x5a, 0xe7, 0x1e, 0xd2, 0x2f, 0x84, 0x14, 0x46, 0xcc, 0x7b, 0xdf, 0x84, 0x7f, 0x79, 0xb7, 0xef, 0xfd, 0xf0, 0x6e, 0xdf, 0xfb, 0xc7, 0xbb, 0x7d, 0xef, 0x0f, 0xef, 0xf7, 0x6f, 0xfd, 0xf0, 0x7e, 0xff, 0xd6, 0xdf, 0xde, 0xef, 0xdf, 0x3a, 0x19, 0x51, 0x6d, 0x3e, 0xfb, 0x6f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xa9, 0x34, 0x40, 0x4e, 0xcd, 0x12, 0x00, 0x00, } func (m *Area) 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 *Area) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Id != 0 { dAtA[i] = 0x8 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Id)) } if m.Parentid != 0 { dAtA[i] = 0x10 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Parentid)) } if len(m.Name) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } return i, nil } func (m *Camera) 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 *Camera) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Id) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Id))) i += copy(dAtA[i:], m.Id) } if len(m.Name) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if len(m.Alias) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Alias))) i += copy(dAtA[i:], m.Alias) } if len(m.SnapshotUrl) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.SnapshotUrl))) i += copy(dAtA[i:], m.SnapshotUrl) } if m.Type != 0 { dAtA[i] = 0x28 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Type)) } if len(m.Addr) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Addr))) i += copy(dAtA[i:], m.Addr) } if m.Areaid != 0 { dAtA[i] = 0x38 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Areaid)) } if m.Longitude != 0 { dAtA[i] = 0x45 i++ encoding_binary.LittleEndian.PutUint32(dAtA[i:], uint32(math.Float32bits(float32(m.Longitude)))) i += 4 } if m.Latitude != 0 { dAtA[i] = 0x4d i++ encoding_binary.LittleEndian.PutUint32(dAtA[i:], uint32(math.Float32bits(float32(m.Latitude)))) i += 4 } if len(m.Rtsp) > 0 { dAtA[i] = 0x52 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Rtsp))) i += copy(dAtA[i:], m.Rtsp) } if len(m.Ip) > 0 { dAtA[i] = 0x5a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Ip))) i += copy(dAtA[i:], m.Ip) } if m.Port != 0 { dAtA[i] = 0x60 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Port)) } if len(m.Username) > 0 { dAtA[i] = 0x6a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Username))) i += copy(dAtA[i:], m.Username) } if len(m.Password) > 0 { dAtA[i] = 0x72 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Password))) i += copy(dAtA[i:], m.Password) } if len(m.Brand) > 0 { dAtA[i] = 0x7a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Brand))) i += copy(dAtA[i:], m.Brand) } if len(m.Reserved) > 0 { dAtA[i] = 0x82 i++ dAtA[i] = 0x1 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Reserved))) i += copy(dAtA[i:], m.Reserved) } if m.IsRunning { dAtA[i] = 0x88 i++ dAtA[i] = 0x1 i++ if m.IsRunning { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.RunEnable { dAtA[i] = 0x90 i++ dAtA[i] = 0x1 i++ if m.RunEnable { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.RunType != 0 { dAtA[i] = 0x98 i++ dAtA[i] = 0x1 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.RunType)) } if len(m.RunServerId) > 0 { dAtA[i] = 0xa2 i++ dAtA[i] = 0x1 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.RunServerId))) i += copy(dAtA[i:], m.RunServerId) } return i, nil } func (m *CameraAndTaskInfo) 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 *CameraAndTaskInfo) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Camera != nil { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Camera.Size())) n1, err1 := m.Camera.MarshalTo(dAtA[i:]) if err1 != nil { return 0, err1 } i += n1 } if len(m.Tasks) > 0 { for _, msg := range m.Tasks { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *Task) 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 *Task) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Taskid) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Taskid))) i += copy(dAtA[i:], m.Taskid) } if len(m.Taskname) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Taskname))) i += copy(dAtA[i:], m.Taskname) } if len(m.CreateAt) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.CreateAt))) i += copy(dAtA[i:], m.CreateAt) } if len(m.CreateBy) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.CreateBy))) i += copy(dAtA[i:], m.CreateBy) } if len(m.UpdateAt) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.UpdateAt))) i += copy(dAtA[i:], m.UpdateAt) } if m.Enable { dAtA[i] = 0x30 i++ if m.Enable { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.IsAlarm { dAtA[i] = 0x38 i++ if m.IsAlarm { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.DelFlag { dAtA[i] = 0x40 i++ if m.DelFlag { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } return i, nil } func (m *TaskSdkInfo) 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 *TaskSdkInfo) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Task != nil { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Task.Size())) n2, err2 := m.Task.MarshalTo(dAtA[i:]) if err2 != nil { return 0, err2 } i += n2 } if len(m.Sdks) > 0 { for _, msg := range m.Sdks { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *SdkRun) 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 *SdkRun) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.IpcId) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.IpcId))) i += copy(dAtA[i:], m.IpcId) } if len(m.SdkType) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.SdkType))) i += copy(dAtA[i:], m.SdkType) } return i, nil } func (m *TaskSdkRun) 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 *TaskSdkRun) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Task != nil { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Task.Size())) n3, err3 := m.Task.MarshalTo(dAtA[i:]) if err3 != nil { return 0, err3 } i += n3 } if len(m.Sdks) > 0 { for _, msg := range m.Sdks { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *CameraTask) 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 *CameraTask) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Id) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Id))) i += copy(dAtA[i:], m.Id) } if len(m.CameraId) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.CameraId))) i += copy(dAtA[i:], m.CameraId) } if len(m.TaskId) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.TaskId))) i += copy(dAtA[i:], m.TaskId) } if len(m.TimeRule) > 0 { for _, msg := range m.TimeRule { dAtA[i] = 0x22 i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if len(m.ReactRule) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.ReactRule))) i += copy(dAtA[i:], m.ReactRule) } if len(m.ReactDevice) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.ReactDevice))) i += copy(dAtA[i:], m.ReactDevice) } if m.DelFlag { dAtA[i] = 0x38 i++ if m.DelFlag { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.UpdateFlag { dAtA[i] = 0x40 i++ if m.UpdateFlag { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.Enable { dAtA[i] = 0x48 i++ if m.Enable { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.Sort != 0 { dAtA[i] = 0x50 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Sort)) } if m.IsFull { dAtA[i] = 0x58 i++ if m.IsFull { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.LinkTaskId) > 0 { dAtA[i] = 0x62 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.LinkTaskId))) i += copy(dAtA[i:], m.LinkTaskId) } return i, nil } func (m *CameraTimerule) 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 *CameraTimerule) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Id) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Id))) i += copy(dAtA[i:], m.Id) } if len(m.Name) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if len(m.TimeRule) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.TimeRule))) i += copy(dAtA[i:], m.TimeRule) } return i, nil } func (m *DayCtl) 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 *DayCtl) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Day != 0 { dAtA[i] = 0x8 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Day)) } if len(m.TimeRange) > 0 { for _, msg := range m.TimeRange { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *TimeRange) 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 *TimeRange) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Start) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Start))) i += copy(dAtA[i:], m.Start) } if len(m.End) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.End))) i += copy(dAtA[i:], m.End) } return i, nil } func (m *Polygon) 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 *Polygon) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Id) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Id))) i += copy(dAtA[i:], m.Id) } if len(m.Name) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if len(m.Points) > 0 { for _, msg := range m.Points { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *CameraTaskArgs) 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 *CameraTaskArgs) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.CameraId) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.CameraId))) i += copy(dAtA[i:], m.CameraId) } if len(m.TaskArgs) > 0 { for _, msg := range m.TaskArgs { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *TaskGroupArgs) 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 *TaskGroupArgs) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.TaskId) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.TaskId))) i += copy(dAtA[i:], m.TaskId) } if len(m.GroupRules) > 0 { for _, msg := range m.GroupRules { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if m.Enable { dAtA[i] = 0x18 i++ if m.Enable { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } return i, nil } func (m *GroupRule) 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 *GroupRule) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.GroupId) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.GroupId))) i += copy(dAtA[i:], m.GroupId) } if len(m.GroupText) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.GroupText))) i += copy(dAtA[i:], m.GroupText) } if m.AlarmLevel != 0 { dAtA[i] = 0x18 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.AlarmLevel)) } if len(m.Rules) > 0 { for _, msg := range m.Rules { dAtA[i] = 0x22 i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if len(m.SetType) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.SetType))) i += copy(dAtA[i:], m.SetType) } if m.DefenceState { dAtA[i] = 0x30 i++ if m.DefenceState { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } return i, nil } func (m *Rule) 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 *Rule) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Id) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Id))) i += copy(dAtA[i:], m.Id) } if len(m.CameraTaskId) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.CameraTaskId))) i += copy(dAtA[i:], m.CameraTaskId) } if len(m.CameraId) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.CameraId))) i += copy(dAtA[i:], m.CameraId) } if len(m.PolygonId) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.PolygonId))) i += copy(dAtA[i:], m.PolygonId) } if len(m.SdkId) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.SdkId))) i += copy(dAtA[i:], m.SdkId) } if len(m.SdkArgAlias) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.SdkArgAlias))) i += copy(dAtA[i:], m.SdkArgAlias) } if len(m.Operator) > 0 { dAtA[i] = 0x3a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Operator))) i += copy(dAtA[i:], m.Operator) } if len(m.OperatorType) > 0 { dAtA[i] = 0x42 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.OperatorType))) i += copy(dAtA[i:], m.OperatorType) } if len(m.SdkArgValue) > 0 { dAtA[i] = 0x4a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.SdkArgValue))) i += copy(dAtA[i:], m.SdkArgValue) } if m.Sort != 0 { dAtA[i] = 0x50 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Sort)) } if len(m.RuleWithPre) > 0 { dAtA[i] = 0x5a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.RuleWithPre))) i += copy(dAtA[i:], m.RuleWithPre) } if len(m.GroupId) > 0 { dAtA[i] = 0x62 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.GroupId))) i += copy(dAtA[i:], m.GroupId) } return i, nil } func (m *Sdk) 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 *Sdk) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Id) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Id))) i += copy(dAtA[i:], m.Id) } if len(m.IpcId) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.IpcId))) i += copy(dAtA[i:], m.IpcId) } if len(m.SdkType) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.SdkType))) i += copy(dAtA[i:], m.SdkType) } if len(m.SdkName) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.SdkName))) i += copy(dAtA[i:], m.SdkName) } if len(m.Args) > 0 { for _, msg := range m.Args { dAtA[i] = 0x2a i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if len(m.Icon) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Icon))) i += copy(dAtA[i:], m.Icon) } if len(m.Url) > 0 { dAtA[i] = 0x3a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Url))) i += copy(dAtA[i:], m.Url) } if len(m.CreateTime) > 0 { dAtA[i] = 0x42 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.CreateTime))) i += copy(dAtA[i:], m.CreateTime) } if len(m.UpdateTime) > 0 { dAtA[i] = 0x4a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.UpdateTime))) i += copy(dAtA[i:], m.UpdateTime) } if len(m.CreateBy) > 0 { dAtA[i] = 0x52 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.CreateBy))) i += copy(dAtA[i:], m.CreateBy) } if m.Enable { dAtA[i] = 0x58 i++ if m.Enable { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.DelFlag != 0 { dAtA[i] = 0x60 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.DelFlag)) } return i, nil } func (m *SdkArg) 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 *SdkArg) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Alias) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Alias))) i += copy(dAtA[i:], m.Alias) } if len(m.Name) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if len(m.Type) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Type))) i += copy(dAtA[i:], m.Type) } if m.Must { dAtA[i] = 0x20 i++ if m.Must { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Unit) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Unit))) i += copy(dAtA[i:], m.Unit) } if len(m.Range) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Range))) i += copy(dAtA[i:], m.Range) } if m.Sort != 0 { dAtA[i] = 0x38 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Sort)) } return i, nil } func (m *DbChangeMessage) 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 *DbChangeMessage) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Table != 0 { dAtA[i] = 0x8 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Table)) } if len(m.Id) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Id))) i += copy(dAtA[i:], m.Id) } if m.Action != 0 { dAtA[i] = 0x18 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Action)) } if len(m.Info) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Info))) i += copy(dAtA[i:], m.Info) } return i, nil } func (m *CameraPolygon) 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 *CameraPolygon) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Id) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Id))) i += copy(dAtA[i:], m.Id) } if len(m.CameraId) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.CameraId))) i += copy(dAtA[i:], m.CameraId) } if len(m.Name) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if len(m.Polygon) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Polygon))) i += copy(dAtA[i:], m.Polygon) } if len(m.TriggerLine) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.TriggerLine))) i += copy(dAtA[i:], m.TriggerLine) } if len(m.DirectionLine) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.DirectionLine))) i += copy(dAtA[i:], m.DirectionLine) } if len(m.Type) > 0 { dAtA[i] = 0x3a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Type))) i += copy(dAtA[i:], m.Type) } if m.DefenceState != 0 { dAtA[i] = 0x40 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.DefenceState)) } return i, nil } func (m *VideotapeInfo) 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 *VideotapeInfo) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.EsDataId) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.EsDataId))) i += copy(dAtA[i:], m.EsDataId) } if len(m.CameraId) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.CameraId))) i += copy(dAtA[i:], m.CameraId) } if len(m.TaskId) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.TaskId))) i += copy(dAtA[i:], m.TaskId) } if m.ImgId != 0 { dAtA[i] = 0x20 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.ImgId)) } if len(m.SdkIds) > 0 { for _, s := range m.SdkIds { dAtA[i] = 0x2a i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *CompareArgs) 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 *CompareArgs) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.TableIds) > 0 { for _, s := range m.TableIds { dAtA[i] = 0xa i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } if len(m.FaceFeature) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.FaceFeature))) i += copy(dAtA[i:], m.FaceFeature) } if m.CompareThreshold != 0 { dAtA[i] = 0x1d i++ encoding_binary.LittleEndian.PutUint32(dAtA[i:], uint32(math.Float32bits(float32(m.CompareThreshold)))) i += 4 } return i, nil } func (m *EventPush) 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 *EventPush) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Id) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Id))) i += copy(dAtA[i:], m.Id) } if len(m.Name) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if len(m.TimeStart) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.TimeStart))) i += copy(dAtA[i:], m.TimeStart) } if len(m.TimeEnd) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.TimeEnd))) i += copy(dAtA[i:], m.TimeEnd) } if m.IsSatisfyAll { dAtA[i] = 0x28 i++ if m.IsSatisfyAll { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.RuleText) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.RuleText))) i += copy(dAtA[i:], m.RuleText) } if m.Enable { dAtA[i] = 0x38 i++ if m.Enable { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.LinkType) > 0 { dAtA[i] = 0x42 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.LinkType))) i += copy(dAtA[i:], m.LinkType) } if len(m.LinkDevice) > 0 { dAtA[i] = 0x4a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.LinkDevice))) i += copy(dAtA[i:], m.LinkDevice) } if len(m.IpPorts) > 0 { for _, msg := range m.IpPorts { dAtA[i] = 0x52 i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if len(m.Urls) > 0 { for _, msg := range m.Urls { dAtA[i] = 0x5a i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } if len(m.Rules) > 0 { for _, msg := range m.Rules { dAtA[i] = 0x62 i++ i = encodeVarintProtomsg(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *EventPushRule) 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 *EventPushRule) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Id) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Id))) i += copy(dAtA[i:], m.Id) } if len(m.TopicType) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.TopicType))) i += copy(dAtA[i:], m.TopicType) } if len(m.TopicArg) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.TopicArg))) i += copy(dAtA[i:], m.TopicArg) } if len(m.Operator) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Operator))) i += copy(dAtA[i:], m.Operator) } if len(m.OperatorType) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.OperatorType))) i += copy(dAtA[i:], m.OperatorType) } if len(m.RuleValue) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.RuleValue))) i += copy(dAtA[i:], m.RuleValue) } if len(m.EventPushId) > 0 { dAtA[i] = 0x3a i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.EventPushId))) i += copy(dAtA[i:], m.EventPushId) } return i, nil } func (m *PushIpPort) 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 *PushIpPort) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.ServerIp) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.ServerIp))) i += copy(dAtA[i:], m.ServerIp) } if m.Port != 0 { dAtA[i] = 0x10 i++ i = encodeVarintProtomsg(dAtA, i, uint64(m.Port)) } if m.Enable { dAtA[i] = 0x18 i++ if m.Enable { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } return i, nil } func (m *PushUrl) 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 *PushUrl) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Url) > 0 { dAtA[i] = 0xa i++ i = encodeVarintProtomsg(dAtA, i, uint64(len(m.Url))) i += copy(dAtA[i:], m.Url) } if m.Enable { dAtA[i] = 0x10 i++ if m.Enable { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } return i, nil } func encodeVarintProtomsg(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 *Area) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Id != 0 { n += 1 + sovProtomsg(uint64(m.Id)) } if m.Parentid != 0 { n += 1 + sovProtomsg(uint64(m.Parentid)) } l = len(m.Name) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } return n } func (m *Camera) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Id) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Name) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Alias) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.SnapshotUrl) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Type != 0 { n += 1 + sovProtomsg(uint64(m.Type)) } l = len(m.Addr) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Areaid != 0 { n += 1 + sovProtomsg(uint64(m.Areaid)) } if m.Longitude != 0 { n += 5 } if m.Latitude != 0 { n += 5 } l = len(m.Rtsp) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Ip) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Port != 0 { n += 1 + sovProtomsg(uint64(m.Port)) } l = len(m.Username) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Password) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Brand) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Reserved) if l > 0 { n += 2 + l + sovProtomsg(uint64(l)) } if m.IsRunning { n += 3 } if m.RunEnable { n += 3 } if m.RunType != 0 { n += 2 + sovProtomsg(uint64(m.RunType)) } l = len(m.RunServerId) if l > 0 { n += 2 + l + sovProtomsg(uint64(l)) } return n } func (m *CameraAndTaskInfo) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Camera != nil { l = m.Camera.Size() n += 1 + l + sovProtomsg(uint64(l)) } if len(m.Tasks) > 0 { for _, e := range m.Tasks { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } return n } func (m *Task) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Taskid) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Taskname) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.CreateAt) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.CreateBy) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.UpdateAt) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Enable { n += 2 } if m.IsAlarm { n += 2 } if m.DelFlag { n += 2 } return n } func (m *TaskSdkInfo) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Task != nil { l = m.Task.Size() n += 1 + l + sovProtomsg(uint64(l)) } if len(m.Sdks) > 0 { for _, e := range m.Sdks { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } return n } func (m *SdkRun) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.IpcId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.SdkType) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } return n } func (m *TaskSdkRun) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Task != nil { l = m.Task.Size() n += 1 + l + sovProtomsg(uint64(l)) } if len(m.Sdks) > 0 { for _, e := range m.Sdks { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } return n } func (m *CameraTask) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Id) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.CameraId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.TaskId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if len(m.TimeRule) > 0 { for _, e := range m.TimeRule { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } l = len(m.ReactRule) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.ReactDevice) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.DelFlag { n += 2 } if m.UpdateFlag { n += 2 } if m.Enable { n += 2 } if m.Sort != 0 { n += 1 + sovProtomsg(uint64(m.Sort)) } if m.IsFull { n += 2 } l = len(m.LinkTaskId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } return n } func (m *CameraTimerule) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Id) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Name) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.TimeRule) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } return n } func (m *DayCtl) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Day != 0 { n += 1 + sovProtomsg(uint64(m.Day)) } if len(m.TimeRange) > 0 { for _, e := range m.TimeRange { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } return n } func (m *TimeRange) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Start) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.End) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } return n } func (m *Polygon) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Id) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Name) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if len(m.Points) > 0 { for _, e := range m.Points { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } return n } func (m *CameraTaskArgs) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.CameraId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if len(m.TaskArgs) > 0 { for _, e := range m.TaskArgs { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } return n } func (m *TaskGroupArgs) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.TaskId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if len(m.GroupRules) > 0 { for _, e := range m.GroupRules { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } if m.Enable { n += 2 } return n } func (m *GroupRule) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.GroupId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.GroupText) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.AlarmLevel != 0 { n += 1 + sovProtomsg(uint64(m.AlarmLevel)) } if len(m.Rules) > 0 { for _, e := range m.Rules { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } l = len(m.SetType) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.DefenceState { n += 2 } return n } func (m *Rule) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Id) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.CameraTaskId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.CameraId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.PolygonId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.SdkId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.SdkArgAlias) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Operator) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.OperatorType) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.SdkArgValue) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Sort != 0 { n += 1 + sovProtomsg(uint64(m.Sort)) } l = len(m.RuleWithPre) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.GroupId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } return n } func (m *Sdk) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Id) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.IpcId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.SdkType) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.SdkName) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if len(m.Args) > 0 { for _, e := range m.Args { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } l = len(m.Icon) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Url) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.CreateTime) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.UpdateTime) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.CreateBy) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Enable { n += 2 } if m.DelFlag != 0 { n += 1 + sovProtomsg(uint64(m.DelFlag)) } return n } func (m *SdkArg) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Alias) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Name) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Type) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Must { n += 2 } l = len(m.Unit) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Range) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Sort != 0 { n += 1 + sovProtomsg(uint64(m.Sort)) } return n } func (m *DbChangeMessage) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Table != 0 { n += 1 + sovProtomsg(uint64(m.Table)) } l = len(m.Id) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Action != 0 { n += 1 + sovProtomsg(uint64(m.Action)) } l = len(m.Info) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } return n } func (m *CameraPolygon) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Id) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.CameraId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Name) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Polygon) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.TriggerLine) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.DirectionLine) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Type) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.DefenceState != 0 { n += 1 + sovProtomsg(uint64(m.DefenceState)) } return n } func (m *VideotapeInfo) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.EsDataId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.CameraId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.TaskId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.ImgId != 0 { n += 1 + sovProtomsg(uint64(m.ImgId)) } if len(m.SdkIds) > 0 { for _, s := range m.SdkIds { l = len(s) n += 1 + l + sovProtomsg(uint64(l)) } } return n } func (m *CompareArgs) Size() (n int) { if m == nil { return 0 } var l int _ = l if len(m.TableIds) > 0 { for _, s := range m.TableIds { l = len(s) n += 1 + l + sovProtomsg(uint64(l)) } } l = len(m.FaceFeature) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.CompareThreshold != 0 { n += 5 } return n } func (m *EventPush) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Id) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Name) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.TimeStart) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.TimeEnd) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.IsSatisfyAll { n += 2 } l = len(m.RuleText) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Enable { n += 2 } l = len(m.LinkType) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.LinkDevice) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if len(m.IpPorts) > 0 { for _, e := range m.IpPorts { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } if len(m.Urls) > 0 { for _, e := range m.Urls { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } if len(m.Rules) > 0 { for _, e := range m.Rules { l = e.Size() n += 1 + l + sovProtomsg(uint64(l)) } } return n } func (m *EventPushRule) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Id) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.TopicType) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.TopicArg) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.Operator) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.OperatorType) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.RuleValue) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } l = len(m.EventPushId) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } return n } func (m *PushIpPort) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.ServerIp) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Port != 0 { n += 1 + sovProtomsg(uint64(m.Port)) } if m.Enable { n += 2 } return n } func (m *PushUrl) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Url) if l > 0 { n += 1 + l + sovProtomsg(uint64(l)) } if m.Enable { n += 2 } return n } func sovProtomsg(x uint64) (n int) { for { n++ x >>= 7 if x == 0 { break } } return n } func sozProtomsg(x uint64) (n int) { return sovProtomsg(uint64((x << 1) ^ uint64((int64(x) >> 63)))) } func (m *Area) 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 ErrIntOverflowProtomsg } 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: Area: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Area: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Id", wireType) } m.Id = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Id |= int32(b&0x7F) << shift if b < 0x80 { break } } case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Parentid", wireType) } m.Parentid = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Parentid |= int32(b&0x7F) << shift if b < 0x80 { break } } case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Camera) 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 ErrIntOverflowProtomsg } 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: Camera: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Camera: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Alias", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Alias = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SnapshotUrl", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.SnapshotUrl = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType) } m.Type = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Type |= int32(b&0x7F) << shift if b < 0x80 { break } } case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Addr", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Addr = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Areaid", wireType) } m.Areaid = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Areaid |= int32(b&0x7F) << shift if b < 0x80 { break } } case 8: if wireType != 5 { return fmt.Errorf("proto: wrong wireType = %d for field Longitude", wireType) } var v uint32 if (iNdEx + 4) > l { return io.ErrUnexpectedEOF } v = uint32(encoding_binary.LittleEndian.Uint32(dAtA[iNdEx:])) iNdEx += 4 m.Longitude = float32(math.Float32frombits(v)) case 9: if wireType != 5 { return fmt.Errorf("proto: wrong wireType = %d for field Latitude", wireType) } var v uint32 if (iNdEx + 4) > l { return io.ErrUnexpectedEOF } v = uint32(encoding_binary.LittleEndian.Uint32(dAtA[iNdEx:])) iNdEx += 4 m.Latitude = float32(math.Float32frombits(v)) case 10: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Rtsp", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Rtsp = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 11: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Ip", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Ip = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 12: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Port", wireType) } m.Port = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Port |= int32(b&0x7F) << shift if b < 0x80 { break } } case 13: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Username", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Username = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 14: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Password", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Password = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 15: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Brand", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Brand = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 16: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Reserved", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Reserved = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 17: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field IsRunning", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.IsRunning = bool(v != 0) case 18: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field RunEnable", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.RunEnable = bool(v != 0) case 19: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field RunType", wireType) } m.RunType = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.RunType |= int32(b&0x7F) << shift if b < 0x80 { break } } case 20: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field RunServerId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.RunServerId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *CameraAndTaskInfo) 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 ErrIntOverflowProtomsg } 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: CameraAndTaskInfo: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: CameraAndTaskInfo: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Camera", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } if m.Camera == nil { m.Camera = &Camera{} } if err := m.Camera.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Tasks", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Tasks = append(m.Tasks, &Task{}) if err := m.Tasks[len(m.Tasks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Task) 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 ErrIntOverflowProtomsg } 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: Task: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Task: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Taskid = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Taskname = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field CreateAt", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.CreateAt = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field CreateBy", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.CreateBy = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field UpdateAt", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.UpdateAt = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Enable", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.Enable = bool(v != 0) case 7: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field IsAlarm", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.IsAlarm = bool(v != 0) case 8: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field DelFlag", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.DelFlag = bool(v != 0) default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *TaskSdkInfo) 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 ErrIntOverflowProtomsg } 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: TaskSdkInfo: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: TaskSdkInfo: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Task", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } if m.Task == nil { m.Task = &Task{} } if err := m.Task.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Sdks", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Sdks = append(m.Sdks, &Sdk{}) if err := m.Sdks[len(m.Sdks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *SdkRun) 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 ErrIntOverflowProtomsg } 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: SdkRun: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: SdkRun: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field IpcId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.IpcId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SdkType", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.SdkType = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *TaskSdkRun) 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 ErrIntOverflowProtomsg } 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: TaskSdkRun: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: TaskSdkRun: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Task", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } if m.Task == nil { m.Task = &Task{} } if err := m.Task.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Sdks", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Sdks = append(m.Sdks, &SdkRun{}) if err := m.Sdks[len(m.Sdks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *CameraTask) 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 ErrIntOverflowProtomsg } 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: CameraTask: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: CameraTask: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 TaskId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 TimeRule", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TimeRule = append(m.TimeRule, &DayCtl{}) if err := m.TimeRule[len(m.TimeRule)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ReactRule", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.ReactRule = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ReactDevice", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.ReactDevice = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field DelFlag", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.DelFlag = bool(v != 0) case 8: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field UpdateFlag", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.UpdateFlag = bool(v != 0) case 9: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Enable", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.Enable = bool(v != 0) case 10: 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 ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Sort |= int32(b&0x7F) << shift if b < 0x80 { break } } case 11: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field IsFull", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.IsFull = bool(v != 0) case 12: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field LinkTaskId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.LinkTaskId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *CameraTimerule) 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 ErrIntOverflowProtomsg } 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: CameraTimerule: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: CameraTimerule: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TimeRule", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TimeRule = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *DayCtl) 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 ErrIntOverflowProtomsg } 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: DayCtl: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: DayCtl: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Day", wireType) } m.Day = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Day |= int32(b&0x7F) << shift if b < 0x80 { break } } case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TimeRange", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TimeRange = append(m.TimeRange, &TimeRange{}) if err := m.TimeRange[len(m.TimeRange)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *TimeRange) 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 ErrIntOverflowProtomsg } 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: TimeRange: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: TimeRange: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Start", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Start = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field End", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.End = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Polygon) 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 ErrIntOverflowProtomsg } 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: Polygon: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Polygon: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Points", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Points = append(m.Points, &Point{}) if err := m.Points[len(m.Points)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *CameraTaskArgs) 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 ErrIntOverflowProtomsg } 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: CameraTaskArgs: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: CameraTaskArgs: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.CameraId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TaskArgs", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TaskArgs = append(m.TaskArgs, &TaskGroupArgs{}) if err := m.TaskArgs[len(m.TaskArgs)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *TaskGroupArgs) 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 ErrIntOverflowProtomsg } 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: TaskGroupArgs: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: TaskGroupArgs: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TaskId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field GroupRules", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.GroupRules = append(m.GroupRules, &GroupRule{}) if err := m.GroupRules[len(m.GroupRules)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 3: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Enable", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.Enable = bool(v != 0) default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *GroupRule) 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 ErrIntOverflowProtomsg } 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: GroupRule: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: GroupRule: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.GroupId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field GroupText", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.GroupText = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field AlarmLevel", wireType) } m.AlarmLevel = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.AlarmLevel |= int32(b&0x7F) << shift if b < 0x80 { break } } case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Rules", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Rules = append(m.Rules, &Rule{}) if err := m.Rules[len(m.Rules)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SetType", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.SetType = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field DefenceState", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.DefenceState = bool(v != 0) default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Rule) 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 ErrIntOverflowProtomsg } 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: Rule: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Rule: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 CameraTaskId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.CameraTaskId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.CameraId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.PolygonId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.SdkId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.SdkArgAlias = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Operator = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 8: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.OperatorType = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 9: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.SdkArgValue = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 10: 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 ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Sort |= int32(b&0x7F) << shift if b < 0x80 { break } } case 11: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.RuleWithPre = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 12: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.GroupId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Sdk) 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 ErrIntOverflowProtomsg } 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: Sdk: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Sdk: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 IpcId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.IpcId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SdkType", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.SdkType = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SdkName", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.SdkName = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Args", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Args = append(m.Args, &SdkArg{}) if err := m.Args[len(m.Args)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Icon", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Icon = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Url", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Url = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 8: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field CreateTime", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.CreateTime = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 9: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field UpdateTime", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.UpdateTime = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 10: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field CreateBy", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.CreateBy = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 11: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Enable", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.Enable = bool(v != 0) case 12: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field DelFlag", wireType) } m.DelFlag = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.DelFlag |= int32(b&0x7F) << shift if b < 0x80 { break } } default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *SdkArg) 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 ErrIntOverflowProtomsg } 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: SdkArg: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: SdkArg: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Alias", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Alias = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Type = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Must", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.Must = bool(v != 0) case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Unit", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Unit = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Range", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Range = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: 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 ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Sort |= int32(b&0x7F) << shift if b < 0x80 { break } } default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *DbChangeMessage) 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 ErrIntOverflowProtomsg } 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: DbChangeMessage: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: DbChangeMessage: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Table", wireType) } m.Table = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Table |= TableChanged(b&0x7F) << shift if b < 0x80 { break } } case 2: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Id = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Action", wireType) } m.Action = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Action |= DbAction(b&0x7F) << shift if b < 0x80 { break } } case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Info", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Info = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *CameraPolygon) 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 ErrIntOverflowProtomsg } 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: CameraPolygon: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: CameraPolygon: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Polygon", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Polygon = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TriggerLine", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TriggerLine = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field DirectionLine", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.DirectionLine = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Type = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 8: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field DefenceState", wireType) } m.DefenceState = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.DefenceState |= int32(b&0x7F) << shift if b < 0x80 { break } } default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *VideotapeInfo) 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 ErrIntOverflowProtomsg } 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: VideotapeInfo: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: VideotapeInfo: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field EsDataId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.EsDataId = 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 TaskId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TaskId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field ImgId", wireType) } m.ImgId = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.ImgId |= int64(b&0x7F) << shift if b < 0x80 { break } } case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SdkIds", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.SdkIds = append(m.SdkIds, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *CompareArgs) 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 ErrIntOverflowProtomsg } 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: CompareArgs: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: CompareArgs: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TableIds", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TableIds = append(m.TableIds, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field FaceFeature", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.FaceFeature = append(m.FaceFeature[:0], dAtA[iNdEx:postIndex]...) if m.FaceFeature == nil { m.FaceFeature = []byte{} } iNdEx = postIndex case 3: if wireType != 5 { return fmt.Errorf("proto: wrong wireType = %d for field CompareThreshold", wireType) } var v uint32 if (iNdEx + 4) > l { return io.ErrUnexpectedEOF } v = uint32(encoding_binary.LittleEndian.Uint32(dAtA[iNdEx:])) iNdEx += 4 m.CompareThreshold = float32(math.Float32frombits(v)) default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *EventPush) 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 ErrIntOverflowProtomsg } 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: EventPush: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: EventPush: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TimeStart", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TimeStart = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TimeEnd", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TimeEnd = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field IsSatisfyAll", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.IsSatisfyAll = bool(v != 0) case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field RuleText", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.RuleText = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Enable", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.Enable = bool(v != 0) case 8: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field LinkType", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.LinkType = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 9: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field LinkDevice", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.LinkDevice = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 10: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field IpPorts", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.IpPorts = append(m.IpPorts, &PushIpPort{}) if err := m.IpPorts[len(m.IpPorts)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 11: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Urls", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Urls = append(m.Urls, &PushUrl{}) if err := m.Urls[len(m.Urls)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 12: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Rules", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthProtomsg } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Rules = append(m.Rules, &EventPushRule{}) if err := m.Rules[len(m.Rules)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *EventPushRule) 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 ErrIntOverflowProtomsg } 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: EventPushRule: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: EventPushRule: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } 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 TopicType", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TopicType = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TopicArg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.TopicArg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Operator = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: 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 ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.OperatorType = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field RuleValue", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.RuleValue = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field EventPushId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.EventPushId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PushIpPort) 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 ErrIntOverflowProtomsg } 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: PushIpPort: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PushIpPort: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ServerIp", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.ServerIp = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Port", wireType) } m.Port = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Port |= int32(b&0x7F) << shift if b < 0x80 { break } } case 3: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Enable", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.Enable = bool(v != 0) default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PushUrl) 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 ErrIntOverflowProtomsg } 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: PushUrl: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PushUrl: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Url", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } 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 ErrInvalidLengthProtomsg } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthProtomsg } if postIndex > l { return io.ErrUnexpectedEOF } m.Url = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Enable", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowProtomsg } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } m.Enable = bool(v != 0) default: iNdEx = preIndex skippy, err := skipProtomsg(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) < 0 { return ErrInvalidLengthProtomsg } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func skipProtomsg(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, ErrIntOverflowProtomsg } 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, ErrIntOverflowProtomsg } 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, ErrIntOverflowProtomsg } 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, ErrInvalidLengthProtomsg } iNdEx += length if iNdEx < 0 { return 0, ErrInvalidLengthProtomsg } return iNdEx, nil case 3: for { var innerWire uint64 var start int = iNdEx for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowProtomsg } 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 := skipProtomsg(dAtA[start:]) if err != nil { return 0, err } iNdEx = start + next if iNdEx < 0 { return 0, ErrInvalidLengthProtomsg } } 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 ( ErrInvalidLengthProtomsg = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowProtomsg = fmt.Errorf("proto: integer overflow") )