From 201ba0c95333cb07be9f955a936cd06a929e2e8f Mon Sep 17 00:00:00 2001 From: 554325746@qq.com <554325746@qq.com> Date: 星期四, 06 二月 2020 20:37:20 +0800 Subject: [PATCH] change golang/protobuf to gogo/protobuf --- sysset.pb.go | 695 ++++++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 586 insertions(+), 109 deletions(-) diff --git a/sysset.pb.go b/sysset.pb.go index bad117a..f762669 100644 --- a/sysset.pb.go +++ b/sysset.pb.go @@ -1,12 +1,14 @@ -// Code generated by protoc-gen-go. DO NOT EDIT. +// Code generated by protoc-gen-gogo. DO NOT EDIT. // source: sysset.proto package protomsg import ( fmt "fmt" - proto "github.com/golang/protobuf/proto" + proto "github.com/gogo/protobuf/proto" + io "io" math "math" + math_bits "math/bits" ) // Reference imports to suppress errors if they are not otherwise used. @@ -18,30 +20,27 @@ // 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.ProtoPackageIsVersion3 // please upgrade the proto package +const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package type LocalConfig struct { - ServerId string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` - ServerName string `protobuf:"bytes,2,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"` - ServerType int32 `protobuf:"varint,3,opt,name=server_type,json=serverType,proto3" json:"server_type,omitempty"` - ServerIp string `protobuf:"bytes,4,opt,name=server_ip,json=serverIp,proto3" json:"server_ip,omitempty"` - AlarmIp string `protobuf:"bytes,5,opt,name=alarm_ip,json=alarmIp,proto3" json:"alarm_ip,omitempty"` - AlarmPort int32 `protobuf:"varint,6,opt,name=alarm_port,json=alarmPort,proto3" json:"alarm_port,omitempty"` - WebPicIp string `protobuf:"bytes,7,opt,name=web_pic_ip,json=webPicIp,proto3" json:"web_pic_ip,omitempty"` - WebPicPort int32 `protobuf:"varint,8,opt,name=web_pic_port,json=webPicPort,proto3" json:"web_pic_port,omitempty"` - EsPicIp string `protobuf:"bytes,9,opt,name=es_pic_ip,json=esPicIp,proto3" json:"es_pic_ip,omitempty"` - EsPicPort int32 `protobuf:"varint,10,opt,name=es_pic_port,json=esPicPort,proto3" json:"es_pic_port,omitempty"` - CutMaxDuration int32 `protobuf:"varint,11,opt,name=cut_max_duration,json=cutMaxDuration,proto3" json:"cut_max_duration,omitempty"` - CutMinDuration int32 `protobuf:"varint,12,opt,name=cut_min_duration,json=cutMinDuration,proto3" json:"cut_min_duration,omitempty"` - Reserved string `protobuf:"bytes,13,opt,name=reserved,proto3" json:"reserved,omitempty"` - GateWay string `protobuf:"bytes,14,opt,name=gate_way,json=gateWay,proto3" json:"gate_way,omitempty"` - NetMask string `protobuf:"bytes,15,opt,name=net_mask,json=netMask,proto3" json:"net_mask,omitempty"` - RealMax int32 `protobuf:"varint,16,opt,name=real_max,json=realMax,proto3" json:"real_max,omitempty"` - AlarmThresholdType int32 `protobuf:"varint,17,opt,name=alarm_threshold_type,json=alarmThresholdType,proto3" json:"alarm_threshold_type,omitempty"` - AlarmThreshold int32 `protobuf:"varint,18,opt,name=alarm_threshold,json=alarmThreshold,proto3" json:"alarm_threshold,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + ServerId string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` + ServerName string `protobuf:"bytes,2,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"` + ServerType int32 `protobuf:"varint,3,opt,name=server_type,json=serverType,proto3" json:"server_type,omitempty"` + ServerIp string `protobuf:"bytes,4,opt,name=server_ip,json=serverIp,proto3" json:"server_ip,omitempty"` + AlarmIp string `protobuf:"bytes,5,opt,name=alarm_ip,json=alarmIp,proto3" json:"alarm_ip,omitempty"` + AlarmPort int32 `protobuf:"varint,6,opt,name=alarm_port,json=alarmPort,proto3" json:"alarm_port,omitempty"` + WebPicIp string `protobuf:"bytes,7,opt,name=web_pic_ip,json=webPicIp,proto3" json:"web_pic_ip,omitempty"` + WebPicPort int32 `protobuf:"varint,8,opt,name=web_pic_port,json=webPicPort,proto3" json:"web_pic_port,omitempty"` + EsPicIp string `protobuf:"bytes,9,opt,name=es_pic_ip,json=esPicIp,proto3" json:"es_pic_ip,omitempty"` + EsPicPort int32 `protobuf:"varint,10,opt,name=es_pic_port,json=esPicPort,proto3" json:"es_pic_port,omitempty"` + CutMaxDuration int32 `protobuf:"varint,11,opt,name=cut_max_duration,json=cutMaxDuration,proto3" json:"cut_max_duration,omitempty"` + CutMinDuration int32 `protobuf:"varint,12,opt,name=cut_min_duration,json=cutMinDuration,proto3" json:"cut_min_duration,omitempty"` + Reserved string `protobuf:"bytes,13,opt,name=reserved,proto3" json:"reserved,omitempty"` + GateWay string `protobuf:"bytes,14,opt,name=gate_way,json=gateWay,proto3" json:"gate_way,omitempty"` + NetMask string `protobuf:"bytes,15,opt,name=net_mask,json=netMask,proto3" json:"net_mask,omitempty"` + RealMax int32 `protobuf:"varint,16,opt,name=real_max,json=realMax,proto3" json:"real_max,omitempty"` + AlarmThresholdType int32 `protobuf:"varint,17,opt,name=alarm_threshold_type,json=alarmThresholdType,proto3" json:"alarm_threshold_type,omitempty"` + AlarmThreshold int32 `protobuf:"varint,18,opt,name=alarm_threshold,json=alarmThreshold,proto3" json:"alarm_threshold,omitempty"` } func (m *LocalConfig) Reset() { *m = LocalConfig{} } @@ -50,18 +49,26 @@ func (*LocalConfig) Descriptor() ([]byte, []int) { return fileDescriptor_5be590c6b2a0d755, []int{0} } - func (m *LocalConfig) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_LocalConfig.Unmarshal(m, b) + return m.Unmarshal(b) } func (m *LocalConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_LocalConfig.Marshal(b, m, deterministic) + if deterministic { + return xxx_messageInfo_LocalConfig.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 *LocalConfig) XXX_Merge(src proto.Message) { xxx_messageInfo_LocalConfig.Merge(m, src) } func (m *LocalConfig) XXX_Size() int { - return xxx_messageInfo_LocalConfig.Size(m) + return m.Size() } func (m *LocalConfig) XXX_DiscardUnknown() { xxx_messageInfo_LocalConfig.DiscardUnknown(m) @@ -196,13 +203,11 @@ } type PollConfig struct { - ServerId string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` - PollPeriod int32 `protobuf:"varint,2,opt,name=poll_period,json=pollPeriod,proto3" json:"poll_period,omitempty"` - Delay int32 `protobuf:"varint,3,opt,name=delay,proto3" json:"delay,omitempty"` - Enable bool `protobuf:"varint,4,opt,name=enable,proto3" json:"enable,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + ServerId string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` + PollPeriod int32 `protobuf:"varint,2,opt,name=poll_period,json=pollPeriod,proto3" json:"poll_period,omitempty"` + Delay int32 `protobuf:"varint,3,opt,name=delay,proto3" json:"delay,omitempty"` + Enable bool `protobuf:"varint,4,opt,name=enable,proto3" json:"enable,omitempty"` + PollChannelCount int32 `protobuf:"varint,5,opt,name=pollChannelCount,proto3" json:"pollChannelCount,omitempty"` } func (m *PollConfig) Reset() { *m = PollConfig{} } @@ -211,18 +216,26 @@ func (*PollConfig) Descriptor() ([]byte, []int) { return fileDescriptor_5be590c6b2a0d755, []int{1} } - func (m *PollConfig) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_PollConfig.Unmarshal(m, b) + return m.Unmarshal(b) } func (m *PollConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_PollConfig.Marshal(b, m, deterministic) + if deterministic { + return xxx_messageInfo_PollConfig.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 *PollConfig) XXX_Merge(src proto.Message) { xxx_messageInfo_PollConfig.Merge(m, src) } func (m *PollConfig) XXX_Size() int { - return xxx_messageInfo_PollConfig.Size(m) + return m.Size() } func (m *PollConfig) XXX_DiscardUnknown() { xxx_messageInfo_PollConfig.DiscardUnknown(m) @@ -258,15 +271,19 @@ return false } +func (m *PollConfig) GetPollChannelCount() int32 { + if m != nil { + return m.PollChannelCount + } + return 0 +} + type Cluster struct { - ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` - ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` - Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"` - VirtualIp string `protobuf:"bytes,4,opt,name=virtual_ip,json=virtualIp,proto3" json:"virtual_ip,omitempty"` - Nodes []*ClusterNode `protobuf:"bytes,5,rep,name=nodes,proto3" json:"nodes,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` + ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` + Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"` + VirtualIp string `protobuf:"bytes,4,opt,name=virtual_ip,json=virtualIp,proto3" json:"virtual_ip,omitempty"` + Nodes []*ClusterNode `protobuf:"bytes,5,rep,name=nodes,proto3" json:"nodes,omitempty"` } func (m *Cluster) Reset() { *m = Cluster{} } @@ -275,18 +292,26 @@ func (*Cluster) Descriptor() ([]byte, []int) { return fileDescriptor_5be590c6b2a0d755, []int{2} } - func (m *Cluster) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_Cluster.Unmarshal(m, b) + return m.Unmarshal(b) } func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_Cluster.Marshal(b, m, deterministic) + if deterministic { + return xxx_messageInfo_Cluster.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 *Cluster) XXX_Merge(src proto.Message) { xxx_messageInfo_Cluster.Merge(m, src) } func (m *Cluster) XXX_Size() int { - return xxx_messageInfo_Cluster.Size(m) + return m.Size() } func (m *Cluster) XXX_DiscardUnknown() { xxx_messageInfo_Cluster.DiscardUnknown(m) @@ -330,16 +355,13 @@ } type ClusterNode struct { - Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` - ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` - ServerId string `protobuf:"bytes,3,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` - ServerName string `protobuf:"bytes,4,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"` - NodeId string `protobuf:"bytes,5,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` - NodeIp string `protobuf:"bytes,6,opt,name=node_ip,json=nodeIp,proto3" json:"node_ip,omitempty"` - CreateTime string `protobuf:"bytes,7,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` - XXX_NoUnkeyedLiteral struct{} `json:"-"` - XXX_unrecognized []byte `json:"-"` - XXX_sizecache int32 `json:"-"` + Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` + ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` + ServerId string `protobuf:"bytes,3,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` + ServerName string `protobuf:"bytes,4,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"` + NodeId string `protobuf:"bytes,5,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` + NodeIp string `protobuf:"bytes,6,opt,name=node_ip,json=nodeIp,proto3" json:"node_ip,omitempty"` + CreateTime string `protobuf:"bytes,7,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` } func (m *ClusterNode) Reset() { *m = ClusterNode{} } @@ -348,18 +370,26 @@ func (*ClusterNode) Descriptor() ([]byte, []int) { return fileDescriptor_5be590c6b2a0d755, []int{3} } - func (m *ClusterNode) XXX_Unmarshal(b []byte) error { - return xxx_messageInfo_ClusterNode.Unmarshal(m, b) + return m.Unmarshal(b) } func (m *ClusterNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { - return xxx_messageInfo_ClusterNode.Marshal(b, m, deterministic) + if deterministic { + return xxx_messageInfo_ClusterNode.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 *ClusterNode) XXX_Merge(src proto.Message) { xxx_messageInfo_ClusterNode.Merge(m, src) } func (m *ClusterNode) XXX_Size() int { - return xxx_messageInfo_ClusterNode.Size(m) + return m.Size() } func (m *ClusterNode) XXX_DiscardUnknown() { xxx_messageInfo_ClusterNode.DiscardUnknown(m) @@ -416,53 +446,262 @@ return "" } +type ResourceConfig struct { + IpType int32 `protobuf:"varint,1,opt,name=ipType,proto3" json:"ipType,omitempty"` + ServiceIp string `protobuf:"bytes,2,opt,name=serviceIp,proto3" json:"serviceIp,omitempty"` + Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"` + FilePort int32 `protobuf:"varint,4,opt,name=filePort,proto3" json:"filePort,omitempty"` +} + +func (m *ResourceConfig) Reset() { *m = ResourceConfig{} } +func (m *ResourceConfig) String() string { return proto.CompactTextString(m) } +func (*ResourceConfig) ProtoMessage() {} +func (*ResourceConfig) Descriptor() ([]byte, []int) { + return fileDescriptor_5be590c6b2a0d755, []int{4} +} +func (m *ResourceConfig) XXX_Unmarshal(b []byte) error { + return m.Unmarshal(b) +} +func (m *ResourceConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + if deterministic { + return xxx_messageInfo_ResourceConfig.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 *ResourceConfig) XXX_Merge(src proto.Message) { + xxx_messageInfo_ResourceConfig.Merge(m, src) +} +func (m *ResourceConfig) XXX_Size() int { + return m.Size() +} +func (m *ResourceConfig) XXX_DiscardUnknown() { + xxx_messageInfo_ResourceConfig.DiscardUnknown(m) +} + +var xxx_messageInfo_ResourceConfig proto.InternalMessageInfo + +func (m *ResourceConfig) GetIpType() int32 { + if m != nil { + return m.IpType + } + return 0 +} + +func (m *ResourceConfig) GetServiceIp() string { + if m != nil { + return m.ServiceIp + } + return "" +} + +func (m *ResourceConfig) GetDomain() string { + if m != nil { + return m.Domain + } + return "" +} + +func (m *ResourceConfig) GetFilePort() int32 { + if m != nil { + return m.FilePort + } + return 0 +} + func init() { proto.RegisterType((*LocalConfig)(nil), "protomsg.LocalConfig") proto.RegisterType((*PollConfig)(nil), "protomsg.PollConfig") proto.RegisterType((*Cluster)(nil), "protomsg.Cluster") proto.RegisterType((*ClusterNode)(nil), "protomsg.ClusterNode") + proto.RegisterType((*ResourceConfig)(nil), "protomsg.ResourceConfig") } func init() { proto.RegisterFile("sysset.proto", fileDescriptor_5be590c6b2a0d755) } var fileDescriptor_5be590c6b2a0d755 = []byte{ - // 565 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x53, 0xdb, 0x6e, 0x13, 0x31, - 0x10, 0x55, 0xd2, 0x26, 0xd9, 0x9d, 0x0d, 0x6d, 0xb1, 0x0a, 0x98, 0x72, 0x0b, 0x79, 0x21, 0x12, - 0x52, 0x85, 0xe0, 0x13, 0xca, 0x4b, 0x24, 0x5a, 0x45, 0x51, 0x25, 0x1e, 0x23, 0x67, 0x3d, 0xb4, - 0x56, 0x77, 0xd7, 0x96, 0xed, 0x34, 0xd9, 0xef, 0xe2, 0x3b, 0xf8, 0x02, 0x7e, 0x06, 0x79, 0xbc, - 0x9b, 0xa4, 0x45, 0x42, 0x3c, 0x25, 0x73, 0xce, 0x99, 0x9b, 0xf7, 0x0c, 0x0c, 0x5d, 0xed, 0x1c, - 0xfa, 0x73, 0x63, 0xb5, 0xd7, 0x2c, 0xa1, 0x9f, 0xd2, 0xdd, 0x8c, 0x7f, 0x1f, 0x42, 0xf6, 0x4d, - 0xe7, 0xa2, 0xb8, 0xd0, 0xd5, 0x0f, 0x75, 0xc3, 0x5e, 0x41, 0xea, 0xd0, 0xde, 0xa3, 0x5d, 0x28, - 0xc9, 0x3b, 0xa3, 0xce, 0x24, 0x9d, 0x27, 0x11, 0x98, 0x4a, 0xf6, 0x0e, 0xb2, 0x86, 0xac, 0x44, - 0x89, 0xbc, 0x4b, 0x34, 0x44, 0xe8, 0x4a, 0x94, 0xb8, 0x27, 0xf0, 0xb5, 0x41, 0x7e, 0x30, 0xea, - 0x4c, 0x7a, 0xad, 0xe0, 0xba, 0x36, 0xb8, 0x5f, 0xde, 0xf0, 0xc3, 0x07, 0xe5, 0x0d, 0x7b, 0x09, - 0x89, 0x28, 0x84, 0x2d, 0x03, 0xd7, 0x23, 0x6e, 0x40, 0xf1, 0xd4, 0xb0, 0x37, 0x00, 0x91, 0x32, - 0xda, 0x7a, 0xde, 0xa7, 0xba, 0x29, 0x21, 0x33, 0x6d, 0x3d, 0x7b, 0x0d, 0xb0, 0xc6, 0xe5, 0xc2, - 0xa8, 0x3c, 0xe4, 0x0e, 0x62, 0xdd, 0x35, 0x2e, 0x67, 0x2a, 0x9f, 0x1a, 0x36, 0x82, 0x61, 0xcb, - 0x52, 0x7a, 0x12, 0xc7, 0x8a, 0x3c, 0xe5, 0x9f, 0x41, 0x8a, 0xae, 0x4d, 0x4f, 0x63, 0x6b, 0x74, - 0x31, 0xfb, 0x2d, 0x64, 0x0d, 0x47, 0xc9, 0x10, 0x7b, 0x13, 0x4b, 0xb9, 0x13, 0x38, 0xc9, 0x57, - 0x7e, 0x51, 0x8a, 0xcd, 0x42, 0xae, 0xac, 0xf0, 0x4a, 0x57, 0x3c, 0x23, 0xd1, 0x51, 0xbe, 0xf2, - 0x97, 0x62, 0xf3, 0xb5, 0x41, 0xb7, 0x4a, 0x55, 0xed, 0x94, 0xc3, 0x9d, 0x52, 0x55, 0x5b, 0xe5, - 0x19, 0x24, 0x16, 0xe9, 0x5d, 0x24, 0x7f, 0x12, 0xb7, 0x69, 0xe3, 0xf0, 0x4a, 0x37, 0xc2, 0xe3, - 0x62, 0x2d, 0x6a, 0x7e, 0x14, 0x47, 0x0d, 0xf1, 0x77, 0x51, 0x07, 0xaa, 0xc2, 0x30, 0x8a, 0xbb, - 0xe3, 0xc7, 0x91, 0xaa, 0xd0, 0x5f, 0x0a, 0x77, 0x17, 0x28, 0x8b, 0xa2, 0x08, 0x63, 0xf2, 0x13, - 0xea, 0x39, 0x08, 0xf1, 0xa5, 0xd8, 0xb0, 0x4f, 0x70, 0x1a, 0xdf, 0xd6, 0xdf, 0x5a, 0x74, 0xb7, - 0xba, 0x90, 0xf1, 0xeb, 0x3d, 0x25, 0x19, 0x23, 0xee, 0xba, 0xa5, 0xe8, 0x2b, 0x7e, 0x80, 0xe3, - 0x47, 0x19, 0x9c, 0xc5, 0x3d, 0x1e, 0x8a, 0xc7, 0x1b, 0x80, 0x99, 0x2e, 0xfe, 0xd7, 0x5b, 0x46, - 0x17, 0xc5, 0xc2, 0xa0, 0x55, 0x5a, 0x92, 0xb7, 0x7a, 0x73, 0x08, 0xd0, 0x8c, 0x10, 0x76, 0x0a, - 0x3d, 0x89, 0x85, 0xa8, 0x1b, 0x57, 0xc5, 0x80, 0x3d, 0x87, 0x3e, 0x56, 0x62, 0x59, 0x20, 0xb9, - 0x29, 0x99, 0x37, 0xd1, 0xf8, 0x67, 0x07, 0x06, 0x17, 0xc5, 0xca, 0x79, 0xb4, 0xc1, 0x3c, 0x79, - 0xfc, 0xbb, 0x6b, 0x9c, 0x36, 0xc8, 0x54, 0xb2, 0xf7, 0x30, 0x6c, 0xe9, 0x3d, 0x5b, 0x67, 0x0d, - 0x46, 0xbe, 0x3e, 0x83, 0xc4, 0x08, 0xe7, 0xd6, 0xda, 0x4a, 0x6a, 0x9f, 0xce, 0xb7, 0x71, 0xa8, - 0x7e, 0xaf, 0xac, 0x5f, 0x89, 0x62, 0xe7, 0xe9, 0xb4, 0x41, 0xa6, 0x86, 0x7d, 0x84, 0x5e, 0xa5, - 0x25, 0x3a, 0xde, 0x1b, 0x1d, 0x4c, 0xb2, 0xcf, 0xcf, 0xce, 0xdb, 0xd3, 0x3b, 0x6f, 0xc6, 0xbb, - 0xd2, 0x12, 0xe7, 0x51, 0x33, 0xfe, 0xd5, 0x81, 0x6c, 0x0f, 0x66, 0x47, 0xd0, 0xdd, 0x4e, 0xdc, - 0x55, 0xf2, 0xd1, 0x26, 0xdd, 0xc7, 0x9b, 0x3c, 0x78, 0xe0, 0x83, 0x7f, 0x1f, 0xef, 0xe1, 0x5f, - 0xc7, 0xfb, 0x02, 0x06, 0x61, 0x8a, 0x90, 0x1b, 0xaf, 0xaf, 0x1f, 0xc2, 0xa9, 0xdc, 0x11, 0x86, - 0x2e, 0xaf, 0x25, 0x4c, 0x28, 0x99, 0x5b, 0x0c, 0x66, 0xf4, 0xaa, 0xc4, 0xe6, 0xee, 0x20, 0x42, - 0xd7, 0xaa, 0xc4, 0x65, 0x9f, 0x96, 0xfd, 0xf2, 0x27, 0x00, 0x00, 0xff, 0xff, 0x1c, 0xcb, 0xf3, - 0x28, 0x7e, 0x04, 0x00, 0x00, + // 680 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x53, 0x4d, 0x6e, 0x13, 0x4d, + 0x10, 0xcd, 0x38, 0x19, 0xdb, 0x53, 0xf6, 0xe7, 0xe4, 0x6b, 0x85, 0x30, 0x84, 0x60, 0x8c, 0x37, + 0x58, 0x20, 0x45, 0x08, 0x6e, 0x80, 0xd9, 0x58, 0x22, 0x91, 0x35, 0x8a, 0xc4, 0xd2, 0x6a, 0xcf, + 0x54, 0x92, 0x56, 0x66, 0xa6, 0x5b, 0xdd, 0xed, 0x38, 0xe6, 0x14, 0x1c, 0x82, 0x1b, 0x70, 0x09, + 0x36, 0x48, 0x59, 0x22, 0xb1, 0x41, 0xc9, 0x45, 0x50, 0xff, 0x8c, 0xed, 0x24, 0x12, 0x62, 0x65, + 0xbf, 0xf7, 0xea, 0xd5, 0x54, 0x75, 0x55, 0x41, 0x5b, 0x2d, 0x94, 0x42, 0x7d, 0x28, 0x24, 0xd7, + 0x9c, 0x34, 0xed, 0x4f, 0xa1, 0xce, 0xfa, 0xbf, 0xb6, 0xa0, 0xf5, 0x91, 0xa7, 0x34, 0x1f, 0xf2, + 0xf2, 0x94, 0x9d, 0x91, 0xa7, 0x10, 0x29, 0x94, 0x97, 0x28, 0x27, 0x2c, 0x8b, 0x83, 0x5e, 0x30, + 0x88, 0x92, 0xa6, 0x23, 0x46, 0x19, 0x79, 0x0e, 0x2d, 0x2f, 0x96, 0xb4, 0xc0, 0xb8, 0x66, 0x65, + 0x70, 0xd4, 0x31, 0x2d, 0x70, 0x2d, 0x40, 0x2f, 0x04, 0xc6, 0x9b, 0xbd, 0x60, 0x10, 0x56, 0x01, + 0x27, 0x0b, 0x81, 0xeb, 0xe9, 0x45, 0xbc, 0x75, 0x27, 0xbd, 0x20, 0x4f, 0xa0, 0x49, 0x73, 0x2a, + 0x0b, 0xa3, 0x85, 0x56, 0x6b, 0x58, 0x3c, 0x12, 0xe4, 0x19, 0x80, 0x93, 0x04, 0x97, 0x3a, 0xae, + 0xdb, 0xbc, 0x91, 0x65, 0xc6, 0x5c, 0x6a, 0x72, 0x00, 0x30, 0xc7, 0xe9, 0x44, 0xb0, 0xd4, 0x78, + 0x1b, 0x2e, 0xef, 0x1c, 0xa7, 0x63, 0x96, 0x8e, 0x04, 0xe9, 0x41, 0xbb, 0x52, 0xad, 0xbd, 0xe9, + 0xca, 0x72, 0xba, 0xf5, 0xef, 0x43, 0x84, 0xaa, 0xb2, 0x47, 0xee, 0xd3, 0xa8, 0x9c, 0xbb, 0x0b, + 0x2d, 0xaf, 0x59, 0x33, 0xb8, 0x6f, 0x5b, 0xd5, 0x7a, 0x07, 0xb0, 0x93, 0xce, 0xf4, 0xa4, 0xa0, + 0x57, 0x93, 0x6c, 0x26, 0xa9, 0x66, 0xbc, 0x8c, 0x5b, 0x36, 0xa8, 0x93, 0xce, 0xf4, 0x11, 0xbd, + 0xfa, 0xe0, 0xd9, 0x65, 0x24, 0x2b, 0x57, 0x91, 0xed, 0x55, 0x24, 0x2b, 0x97, 0x91, 0xfb, 0xd0, + 0x94, 0x68, 0xdf, 0x25, 0x8b, 0xff, 0x73, 0xdd, 0x54, 0xd8, 0xbc, 0xd2, 0x19, 0xd5, 0x38, 0x99, + 0xd3, 0x45, 0xdc, 0x71, 0xa5, 0x1a, 0xfc, 0x89, 0x2e, 0x8c, 0x54, 0xa2, 0x29, 0x45, 0x5d, 0xc4, + 0xdb, 0x4e, 0x2a, 0x51, 0x1f, 0x51, 0x75, 0x61, 0x24, 0x89, 0x34, 0x37, 0x65, 0xc6, 0x3b, 0xf6, + 0x9b, 0x0d, 0x83, 0x8f, 0xe8, 0x15, 0x79, 0x03, 0xbb, 0xee, 0x6d, 0xf5, 0xb9, 0x44, 0x75, 0xce, + 0xf3, 0xcc, 0x4d, 0xef, 0x7f, 0x1b, 0x46, 0xac, 0x76, 0x52, 0x49, 0x76, 0x8a, 0x2f, 0x61, 0xfb, + 0x9e, 0x23, 0x26, 0xae, 0x8f, 0xbb, 0xc1, 0xfd, 0xaf, 0x01, 0xc0, 0x98, 0xe7, 0xff, 0xba, 0x5c, + 0x82, 0xe7, 0xf9, 0x44, 0xa0, 0x64, 0x3c, 0xb3, 0xcb, 0x15, 0x26, 0x60, 0xa8, 0xb1, 0x65, 0xc8, + 0x2e, 0x84, 0x19, 0xe6, 0x74, 0xe1, 0xd7, 0xca, 0x01, 0xb2, 0x07, 0x75, 0x2c, 0xe9, 0x34, 0x47, + 0xbb, 0x4e, 0xcd, 0xc4, 0x23, 0xf2, 0x0a, 0x76, 0x8c, 0x77, 0x78, 0x4e, 0xcb, 0x12, 0xf3, 0x21, + 0x9f, 0x95, 0xda, 0x2e, 0x55, 0x98, 0x3c, 0xe0, 0xfb, 0xdf, 0x02, 0x68, 0x0c, 0xf3, 0x99, 0xd2, + 0x28, 0xcd, 0xa6, 0xa5, 0xee, 0xef, 0xaa, 0xc8, 0xc8, 0x33, 0xa3, 0x8c, 0xbc, 0x80, 0x76, 0x25, + 0xaf, 0xdd, 0x40, 0xcb, 0x73, 0xf6, 0x08, 0xf6, 0xa1, 0x29, 0xa8, 0x52, 0x73, 0x2e, 0x33, 0x5b, + 0x6a, 0x94, 0x2c, 0xb1, 0xc9, 0x7e, 0xc9, 0xa4, 0x9e, 0xd1, 0x7c, 0x75, 0x00, 0x91, 0x67, 0x46, + 0x82, 0xbc, 0x86, 0xb0, 0xe4, 0x19, 0xaa, 0x38, 0xec, 0x6d, 0x0e, 0x5a, 0x6f, 0x1f, 0x1d, 0x56, + 0x77, 0x7a, 0xe8, 0xcb, 0x3b, 0xe6, 0x19, 0x26, 0x2e, 0xa6, 0xff, 0x23, 0x80, 0xd6, 0x1a, 0x4d, + 0x3a, 0x50, 0x5b, 0x56, 0x5c, 0x63, 0xd9, 0xbd, 0x4e, 0x6a, 0xf7, 0x3b, 0xb9, 0x33, 0x8c, 0xcd, + 0xbf, 0x5f, 0xfa, 0xd6, 0x83, 0x4b, 0x7f, 0x0c, 0x0d, 0x53, 0x85, 0xf1, 0xba, 0x53, 0xad, 0x1b, + 0x38, 0xca, 0x56, 0x82, 0xb0, 0x67, 0x5a, 0x09, 0xc2, 0xa4, 0x4c, 0x25, 0x9a, 0xcd, 0xd5, 0xac, + 0x40, 0x7f, 0xa4, 0xe0, 0xa8, 0x13, 0x56, 0x60, 0xff, 0x33, 0x74, 0x12, 0x54, 0x7c, 0x26, 0x53, + 0xf4, 0xfb, 0xb2, 0x07, 0x75, 0x26, 0xcc, 0xc6, 0xd9, 0xae, 0xc2, 0xc4, 0x23, 0x72, 0xe0, 0x4a, + 0x67, 0x29, 0x8e, 0x44, 0xd5, 0xd8, 0x92, 0x30, 0xae, 0x8c, 0x17, 0x94, 0x95, 0xbe, 0x2b, 0x8f, + 0xcc, 0x5c, 0x4e, 0x59, 0x8e, 0xe6, 0x68, 0x6d, 0x43, 0x61, 0xb2, 0xc4, 0xef, 0xe3, 0xef, 0x37, + 0xdd, 0xe0, 0xfa, 0xa6, 0x1b, 0xfc, 0xbe, 0xe9, 0x06, 0x5f, 0x6e, 0xbb, 0x1b, 0xd7, 0xb7, 0xdd, + 0x8d, 0x9f, 0xb7, 0xdd, 0x8d, 0x69, 0xdd, 0x8e, 0xe0, 0xdd, 0x9f, 0x00, 0x00, 0x00, 0xff, 0xff, + 0x79, 0xee, 0xda, 0x54, 0x41, 0x05, 0x00, 0x00, +} + +func (m *LocalConfig) 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 *LocalConfig) MarshalTo(dAtA []byte) (int, error) { + var i int + _ = i + var l int + _ = l + if len(m.ServerId) > 0 { + dAtA[i] = 0xa + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.ServerId))) + i += copy(dAtA[i:], m.ServerId) + } + if len(m.ServerName) > 0 { + dAtA[i] = 0x12 + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.ServerName))) + i += copy(dAtA[i:], m.ServerName) + } + if m.ServerType != 0 { + dAtA[i] = 0x18 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.ServerType)) + } + if len(m.ServerIp) > 0 { + dAtA[i] = 0x22 + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.ServerIp))) + i += copy(dAtA[i:], m.ServerIp) + } + if len(m.AlarmIp) > 0 { + dAtA[i] = 0x2a + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.AlarmIp))) + i += copy(dAtA[i:], m.AlarmIp) + } + if m.AlarmPort != 0 { + dAtA[i] = 0x30 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.AlarmPort)) + } + if len(m.WebPicIp) > 0 { + dAtA[i] = 0x3a + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.WebPicIp))) + i += copy(dAtA[i:], m.WebPicIp) + } + if m.WebPicPort != 0 { + dAtA[i] = 0x40 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.WebPicPort)) + } + if len(m.EsPicIp) > 0 { + dAtA[i] = 0x4a + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.EsPicIp))) + i += copy(dAtA[i:], m.EsPicIp) + } + if m.EsPicPort != 0 { + dAtA[i] = 0x50 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.EsPicPort)) + } + if m.CutMaxDuration != 0 { + dAtA[i] = 0x58 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.CutMaxDuration)) + } + if m.CutMinDuration != 0 { + dAtA[i] = 0x60 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.CutMinDuration)) + } + if len(m.Reserved) > 0 { + dAtA[i] = 0x6a + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.Reserved))) + i += copy(dAtA[i:], m.Reserved) + } + if len(m.GateWay) > 0 { + dAtA[i] = 0x72 + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.GateWay))) + i += copy(dAtA[i:], m.GateWay) + } + if len(m.NetMask) > 0 { + dAtA[i] = 0x7a + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.NetMask))) + i += copy(dAtA[i:], m.NetMask) + } + if m.RealMax != 0 { + dAtA[i] = 0x80 + i++ + dAtA[i] = 0x1 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.RealMax)) + } + if m.AlarmThresholdType != 0 { + dAtA[i] = 0x88 + i++ + dAtA[i] = 0x1 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.AlarmThresholdType)) + } + if m.AlarmThreshold != 0 { + dAtA[i] = 0x90 + i++ + dAtA[i] = 0x1 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.AlarmThreshold)) + } + return i, nil +} + +func (m *PollConfig) 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 *PollConfig) MarshalTo(dAtA []byte) (int, error) { @@ -495,6 +734,11 @@ dAtA[i] = 0 } i++ + } + if m.PollChannelCount != 0 { + dAtA[i] = 0x28 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.PollChannelCount)) } return i, nil } @@ -613,6 +857,46 @@ return i, nil } +func (m *ResourceConfig) 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 *ResourceConfig) MarshalTo(dAtA []byte) (int, error) { + var i int + _ = i + var l int + _ = l + if m.IpType != 0 { + dAtA[i] = 0x8 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.IpType)) + } + if len(m.ServiceIp) > 0 { + dAtA[i] = 0x12 + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.ServiceIp))) + i += copy(dAtA[i:], m.ServiceIp) + } + if len(m.Domain) > 0 { + dAtA[i] = 0x1a + i++ + i = encodeVarintSysset(dAtA, i, uint64(len(m.Domain))) + i += copy(dAtA[i:], m.Domain) + } + if m.FilePort != 0 { + dAtA[i] = 0x20 + i++ + i = encodeVarintSysset(dAtA, i, uint64(m.FilePort)) + } + return i, nil +} + func encodeVarintSysset(dAtA []byte, offset int, v uint64) int { for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) @@ -713,6 +997,9 @@ if m.Enable { n += 2 } + if m.PollChannelCount != 0 { + n += 1 + sovSysset(uint64(m.PollChannelCount)) + } return n } @@ -784,15 +1071,31 @@ return n } -func sovSysset(x uint64) (n int) { - for { - n++ - x >>= 7 - if x == 0 { - break - } +func (m *ResourceConfig) Size() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.IpType != 0 { + n += 1 + sovSysset(uint64(m.IpType)) + } + l = len(m.ServiceIp) + if l > 0 { + n += 1 + l + sovSysset(uint64(l)) + } + l = len(m.Domain) + if l > 0 { + n += 1 + l + sovSysset(uint64(l)) + } + if m.FilePort != 0 { + n += 1 + sovSysset(uint64(m.FilePort)) } return n +} + +func sovSysset(x uint64) (n int) { + return (math_bits.Len64(x|1) + 6) / 7 } func sozSysset(x uint64) (n int) { return sovSysset(uint64((x << 1) ^ uint64((int64(x) >> 63)))) @@ -1428,6 +1731,25 @@ } } m.Enable = bool(v != 0) + case 5: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field PollChannelCount", wireType) + } + m.PollChannelCount = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowSysset + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.PollChannelCount |= int32(b&0x7F) << shift + if b < 0x80 { + break + } + } default: iNdEx = preIndex skippy, err := skipSysset(dAtA[iNdEx:]) @@ -1944,6 +2266,161 @@ } return nil } +func (m *ResourceConfig) 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 ErrIntOverflowSysset + } + 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: ResourceConfig: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: ResourceConfig: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field IpType", wireType) + } + m.IpType = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowSysset + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.IpType |= int32(b&0x7F) << shift + if b < 0x80 { + break + } + } + case 2: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field ServiceIp", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowSysset + } + 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 ErrInvalidLengthSysset + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthSysset + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.ServiceIp = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + case 3: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Domain", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowSysset + } + 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 ErrInvalidLengthSysset + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthSysset + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.Domain = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + case 4: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field FilePort", wireType) + } + m.FilePort = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowSysset + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.FilePort |= int32(b&0x7F) << shift + if b < 0x80 { + break + } + } + default: + iNdEx = preIndex + skippy, err := skipSysset(dAtA[iNdEx:]) + if err != nil { + return err + } + if skippy < 0 { + return ErrInvalidLengthSysset + } + if (iNdEx + skippy) < 0 { + return ErrInvalidLengthSysset + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} func skipSysset(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 -- Gitblit v1.8.0