| | |
| | | // Code generated by protoc-gen-gogo. DO NOT EDIT. |
| | | // Code generated by protoc-gen-go. DO NOT EDIT. |
| | | // source: sysset.proto |
| | | |
| | | package protomsg |
| | | |
| | | import ( |
| | | fmt "fmt" |
| | | proto "github.com/gogo/protobuf/proto" |
| | | io "io" |
| | | proto "github.com/golang/protobuf/proto" |
| | | math "math" |
| | | math_bits "math/bits" |
| | | ) |
| | | |
| | | // Reference imports to suppress errors if they are not otherwise used. |
| | |
| | | // 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 |
| | | const _ = proto.ProtoPackageIsVersion3 // 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"` |
| | | 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:"-"` |
| | | } |
| | | |
| | | func (m *LocalConfig) Reset() { *m = LocalConfig{} } |
| | |
| | | func (*LocalConfig) Descriptor() ([]byte, []int) { |
| | | return fileDescriptor_5be590c6b2a0d755, []int{0} |
| | | } |
| | | |
| | | func (m *LocalConfig) XXX_Unmarshal(b []byte) error { |
| | | return m.Unmarshal(b) |
| | | return xxx_messageInfo_LocalConfig.Unmarshal(m, b) |
| | | } |
| | | func (m *LocalConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { |
| | | 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 |
| | | } |
| | | return xxx_messageInfo_LocalConfig.Marshal(b, m, deterministic) |
| | | } |
| | | func (m *LocalConfig) XXX_Merge(src proto.Message) { |
| | | xxx_messageInfo_LocalConfig.Merge(m, src) |
| | | } |
| | | func (m *LocalConfig) XXX_Size() int { |
| | | return m.Size() |
| | | return xxx_messageInfo_LocalConfig.Size(m) |
| | | } |
| | | func (m *LocalConfig) XXX_DiscardUnknown() { |
| | | xxx_messageInfo_LocalConfig.DiscardUnknown(m) |
| | |
| | | } |
| | | |
| | | 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"` |
| | | 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:"-"` |
| | | } |
| | | |
| | | func (m *PollConfig) Reset() { *m = PollConfig{} } |
| | |
| | | func (*PollConfig) Descriptor() ([]byte, []int) { |
| | | return fileDescriptor_5be590c6b2a0d755, []int{1} |
| | | } |
| | | |
| | | func (m *PollConfig) XXX_Unmarshal(b []byte) error { |
| | | return m.Unmarshal(b) |
| | | return xxx_messageInfo_PollConfig.Unmarshal(m, b) |
| | | } |
| | | func (m *PollConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { |
| | | 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 |
| | | } |
| | | return xxx_messageInfo_PollConfig.Marshal(b, m, deterministic) |
| | | } |
| | | func (m *PollConfig) XXX_Merge(src proto.Message) { |
| | | xxx_messageInfo_PollConfig.Merge(m, src) |
| | | } |
| | | func (m *PollConfig) XXX_Size() int { |
| | | return m.Size() |
| | | return xxx_messageInfo_PollConfig.Size(m) |
| | | } |
| | | func (m *PollConfig) XXX_DiscardUnknown() { |
| | | xxx_messageInfo_PollConfig.DiscardUnknown(m) |
| | |
| | | } |
| | | |
| | | 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"` |
| | | 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:"-"` |
| | | } |
| | | |
| | | func (m *Cluster) Reset() { *m = Cluster{} } |
| | |
| | | func (*Cluster) Descriptor() ([]byte, []int) { |
| | | return fileDescriptor_5be590c6b2a0d755, []int{2} |
| | | } |
| | | |
| | | func (m *Cluster) XXX_Unmarshal(b []byte) error { |
| | | return m.Unmarshal(b) |
| | | return xxx_messageInfo_Cluster.Unmarshal(m, b) |
| | | } |
| | | func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { |
| | | 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 |
| | | } |
| | | return xxx_messageInfo_Cluster.Marshal(b, m, deterministic) |
| | | } |
| | | func (m *Cluster) XXX_Merge(src proto.Message) { |
| | | xxx_messageInfo_Cluster.Merge(m, src) |
| | | } |
| | | func (m *Cluster) XXX_Size() int { |
| | | return m.Size() |
| | | return xxx_messageInfo_Cluster.Size(m) |
| | | } |
| | | func (m *Cluster) XXX_DiscardUnknown() { |
| | | xxx_messageInfo_Cluster.DiscardUnknown(m) |
| | |
| | | } |
| | | |
| | | 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"` |
| | | 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:"-"` |
| | | } |
| | | |
| | | func (m *ClusterNode) Reset() { *m = ClusterNode{} } |
| | |
| | | func (*ClusterNode) Descriptor() ([]byte, []int) { |
| | | return fileDescriptor_5be590c6b2a0d755, []int{3} |
| | | } |
| | | |
| | | func (m *ClusterNode) XXX_Unmarshal(b []byte) error { |
| | | return m.Unmarshal(b) |
| | | return xxx_messageInfo_ClusterNode.Unmarshal(m, b) |
| | | } |
| | | func (m *ClusterNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { |
| | | 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 |
| | | } |
| | | return xxx_messageInfo_ClusterNode.Marshal(b, m, deterministic) |
| | | } |
| | | func (m *ClusterNode) XXX_Merge(src proto.Message) { |
| | | xxx_messageInfo_ClusterNode.Merge(m, src) |
| | | } |
| | | func (m *ClusterNode) XXX_Size() int { |
| | | return m.Size() |
| | | return xxx_messageInfo_ClusterNode.Size(m) |
| | | } |
| | | func (m *ClusterNode) XXX_DiscardUnknown() { |
| | | xxx_messageInfo_ClusterNode.DiscardUnknown(m) |
| | |
| | | func init() { proto.RegisterFile("sysset.proto", fileDescriptor_5be590c6b2a0d755) } |
| | | |
| | | var fileDescriptor_5be590c6b2a0d755 = []byte{ |
| | | // 601 bytes of a gzipped FileDescriptorProto |
| | | 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x53, 0xdd, 0x6e, 0xd3, 0x30, |
| | | 0x14, 0x5e, 0xba, 0xb5, 0x4d, 0x4e, 0xca, 0x36, 0xac, 0x01, 0x66, 0x40, 0x28, 0xbd, 0xa1, 0x12, |
| | | 0xd2, 0x84, 0xe0, 0x0d, 0x18, 0x37, 0x95, 0xd8, 0x54, 0x55, 0x93, 0xb8, 0xac, 0xdc, 0xf8, 0xb0, |
| | | 0x45, 0x4b, 0x62, 0xcb, 0x76, 0xd7, 0xe6, 0x2d, 0x78, 0x17, 0x5e, 0x82, 0x1b, 0xa4, 0x5d, 0x22, |
| | | 0x71, 0x83, 0xb6, 0x17, 0x41, 0xb6, 0x93, 0xb6, 0x1b, 0x12, 0xe2, 0xaa, 0x3d, 0xdf, 0xf7, 0x9d, |
| | | 0x1f, 0x9f, 0x7c, 0x07, 0x7a, 0xba, 0xd2, 0x1a, 0xcd, 0x91, 0x54, 0xc2, 0x08, 0x12, 0xba, 0x9f, |
| | | 0x42, 0x9f, 0x0f, 0x7e, 0xed, 0x40, 0xfc, 0x49, 0xa4, 0x2c, 0x3f, 0x16, 0xe5, 0x97, 0xec, 0x9c, |
| | | 0x3c, 0x83, 0x48, 0xa3, 0xba, 0x42, 0x35, 0xcd, 0x38, 0x0d, 0xfa, 0xc1, 0x30, 0x9a, 0x84, 0x1e, |
| | | 0x18, 0x71, 0xf2, 0x12, 0xe2, 0x9a, 0x2c, 0x59, 0x81, 0xb4, 0xe5, 0x68, 0xf0, 0xd0, 0x29, 0x2b, |
| | | 0x70, 0x43, 0x60, 0x2a, 0x89, 0x74, 0xbb, 0x1f, 0x0c, 0xdb, 0x8d, 0xe0, 0xac, 0x92, 0xb8, 0x59, |
| | | 0x5e, 0xd2, 0x9d, 0x3b, 0xe5, 0x25, 0x79, 0x0a, 0x21, 0xcb, 0x99, 0x2a, 0x2c, 0xd7, 0x76, 0x5c, |
| | | 0xd7, 0xc5, 0x23, 0x49, 0x5e, 0x00, 0x78, 0x4a, 0x0a, 0x65, 0x68, 0xc7, 0xd5, 0x8d, 0x1c, 0x32, |
| | | 0x16, 0xca, 0x90, 0xe7, 0x00, 0x0b, 0x9c, 0x4d, 0x65, 0x96, 0xda, 0xdc, 0xae, 0xaf, 0xbb, 0xc0, |
| | | 0xd9, 0x38, 0x4b, 0x47, 0x92, 0xf4, 0xa1, 0xd7, 0xb0, 0x2e, 0x3d, 0xf4, 0x63, 0x79, 0xde, 0xe5, |
| | | 0x1f, 0x42, 0x84, 0xba, 0x49, 0x8f, 0x7c, 0x6b, 0xd4, 0x3e, 0x3b, 0x81, 0xb8, 0xe6, 0x5c, 0x32, |
| | | 0xf8, 0xde, 0x8e, 0x75, 0xb9, 0x43, 0xd8, 0x4f, 0xe7, 0x66, 0x5a, 0xb0, 0xe5, 0x94, 0xcf, 0x15, |
| | | 0x33, 0x99, 0x28, 0x69, 0xec, 0x44, 0xbb, 0xe9, 0xdc, 0x9c, 0xb0, 0xe5, 0xc7, 0x1a, 0x5d, 0x29, |
| | | 0xb3, 0x72, 0xad, 0xec, 0xad, 0x95, 0x59, 0xb9, 0x52, 0x1e, 0x42, 0xa8, 0xd0, 0xed, 0x85, 0xd3, |
| | | 0x07, 0xfe, 0x35, 0x4d, 0x6c, 0xb7, 0x74, 0xce, 0x0c, 0x4e, 0x17, 0xac, 0xa2, 0xbb, 0x7e, 0x54, |
| | | 0x1b, 0x7f, 0x66, 0x95, 0xa5, 0x4a, 0xb4, 0xa3, 0xe8, 0x4b, 0xba, 0xe7, 0xa9, 0x12, 0xcd, 0x09, |
| | | 0xd3, 0x97, 0x96, 0x52, 0xc8, 0x72, 0x3b, 0x26, 0xdd, 0x77, 0x3d, 0xbb, 0x36, 0x3e, 0x61, 0x4b, |
| | | 0xf2, 0x16, 0x0e, 0xfc, 0x6e, 0xcd, 0x85, 0x42, 0x7d, 0x21, 0x72, 0xee, 0xbf, 0xde, 0x43, 0x27, |
| | | 0x23, 0x8e, 0x3b, 0x6b, 0x28, 0xf7, 0x15, 0x5f, 0xc3, 0xde, 0xbd, 0x0c, 0x4a, 0xfc, 0x3b, 0xee, |
| | | 0x8a, 0x07, 0x4b, 0x80, 0xb1, 0xc8, 0xff, 0xd7, 0x5b, 0x52, 0xe4, 0xf9, 0x54, 0xa2, 0xca, 0x04, |
| | | 0x77, 0xde, 0x6a, 0x4f, 0xc0, 0x42, 0x63, 0x87, 0x90, 0x03, 0x68, 0x73, 0xcc, 0x59, 0x55, 0xbb, |
| | | 0xca, 0x07, 0xe4, 0x31, 0x74, 0xb0, 0x64, 0xb3, 0x1c, 0x9d, 0x9b, 0xc2, 0x49, 0x1d, 0x0d, 0xbe, |
| | | 0x05, 0xd0, 0x3d, 0xce, 0xe7, 0xda, 0xa0, 0xb2, 0xe6, 0x49, 0xfd, 0xdf, 0x75, 0xe3, 0xa8, 0x46, |
| | | 0x46, 0x9c, 0xbc, 0x82, 0x5e, 0x43, 0x6f, 0xd8, 0x3a, 0xae, 0x31, 0xe7, 0xeb, 0x43, 0x08, 0x25, |
| | | 0xd3, 0x7a, 0x21, 0x14, 0x77, 0xed, 0xa3, 0xc9, 0x2a, 0xb6, 0xd5, 0xaf, 0x32, 0x65, 0xe6, 0x2c, |
| | | 0x5f, 0x7b, 0x3a, 0xaa, 0x91, 0x91, 0x24, 0x6f, 0xa0, 0x5d, 0x0a, 0x8e, 0x9a, 0xb6, 0xfb, 0xdb, |
| | | 0xc3, 0xf8, 0xdd, 0xa3, 0xa3, 0xe6, 0xf4, 0x8e, 0xea, 0xf1, 0x4e, 0x05, 0xc7, 0x89, 0xd7, 0x0c, |
| | | 0x7e, 0x04, 0x10, 0x6f, 0xc0, 0x64, 0x17, 0x5a, 0xab, 0x89, 0x5b, 0x19, 0xbf, 0xf7, 0x92, 0xd6, |
| | | 0xfd, 0x97, 0xdc, 0x59, 0xf0, 0xf6, 0xbf, 0x8f, 0x77, 0xe7, 0xaf, 0xe3, 0x7d, 0x02, 0x5d, 0x3b, |
| | | 0x85, 0xcd, 0xf5, 0xd7, 0xd7, 0xb1, 0xe1, 0x88, 0xaf, 0x09, 0xe9, 0x2e, 0xaf, 0x21, 0xa4, 0x2d, |
| | | 0x99, 0x2a, 0xb4, 0x66, 0x34, 0x59, 0x81, 0xf5, 0xdd, 0x81, 0x87, 0xce, 0xb2, 0x02, 0x3f, 0xd0, |
| | | 0xef, 0x37, 0x49, 0x70, 0x7d, 0x93, 0x04, 0xbf, 0x6f, 0x92, 0xe0, 0xeb, 0x6d, 0xb2, 0x75, 0x7d, |
| | | 0x9b, 0x6c, 0xfd, 0xbc, 0x4d, 0xb6, 0x66, 0x1d, 0xb7, 0x86, 0xf7, 0x7f, 0x02, 0x00, 0x00, 0xff, |
| | | 0xff, 0x4c, 0xdc, 0xed, 0xe9, 0x98, 0x04, 0x00, 0x00, |
| | | // 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, |
| | | } |
| | | |
| | | 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) { |
| | | 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 m.PollPeriod != 0 { |
| | | dAtA[i] = 0x10 |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(m.PollPeriod)) |
| | | } |
| | | if m.Delay != 0 { |
| | | dAtA[i] = 0x18 |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(m.Delay)) |
| | | } |
| | | if m.Enable { |
| | | dAtA[i] = 0x20 |
| | | i++ |
| | | if m.Enable { |
| | | dAtA[i] = 1 |
| | | } else { |
| | | dAtA[i] = 0 |
| | | } |
| | | i++ |
| | | } |
| | | return i, nil |
| | | } |
| | | |
| | | func (m *Cluster) 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 *Cluster) MarshalTo(dAtA []byte) (int, error) { |
| | | var i int |
| | | _ = i |
| | | var l int |
| | | _ = l |
| | | if len(m.ClusterId) > 0 { |
| | | dAtA[i] = 0xa |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.ClusterId))) |
| | | i += copy(dAtA[i:], m.ClusterId) |
| | | } |
| | | if len(m.ClusterName) > 0 { |
| | | dAtA[i] = 0x12 |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.ClusterName))) |
| | | i += copy(dAtA[i:], m.ClusterName) |
| | | } |
| | | if len(m.Password) > 0 { |
| | | dAtA[i] = 0x1a |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.Password))) |
| | | i += copy(dAtA[i:], m.Password) |
| | | } |
| | | if len(m.VirtualIp) > 0 { |
| | | dAtA[i] = 0x22 |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.VirtualIp))) |
| | | i += copy(dAtA[i:], m.VirtualIp) |
| | | } |
| | | if len(m.Nodes) > 0 { |
| | | for _, msg := range m.Nodes { |
| | | dAtA[i] = 0x2a |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(msg.Size())) |
| | | n, err := msg.MarshalTo(dAtA[i:]) |
| | | if err != nil { |
| | | return 0, err |
| | | } |
| | | i += n |
| | | } |
| | | } |
| | | return i, nil |
| | | } |
| | | |
| | | func (m *ClusterNode) 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 *ClusterNode) MarshalTo(dAtA []byte) (int, error) { |
| | | var i int |
| | | _ = i |
| | | var l int |
| | | _ = l |
| | | if len(m.Id) > 0 { |
| | | dAtA[i] = 0xa |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.Id))) |
| | | i += copy(dAtA[i:], m.Id) |
| | | } |
| | | if len(m.ClusterId) > 0 { |
| | | dAtA[i] = 0x12 |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.ClusterId))) |
| | | i += copy(dAtA[i:], m.ClusterId) |
| | | } |
| | | if len(m.ServerId) > 0 { |
| | | dAtA[i] = 0x1a |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.ServerId))) |
| | | i += copy(dAtA[i:], m.ServerId) |
| | | } |
| | | if len(m.ServerName) > 0 { |
| | | dAtA[i] = 0x22 |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.ServerName))) |
| | | i += copy(dAtA[i:], m.ServerName) |
| | | } |
| | | if len(m.NodeId) > 0 { |
| | | dAtA[i] = 0x2a |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.NodeId))) |
| | | i += copy(dAtA[i:], m.NodeId) |
| | | } |
| | | if len(m.NodeIp) > 0 { |
| | | dAtA[i] = 0x32 |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.NodeIp))) |
| | | i += copy(dAtA[i:], m.NodeIp) |
| | | } |
| | | if len(m.CreateTime) > 0 { |
| | | dAtA[i] = 0x3a |
| | | i++ |
| | | i = encodeVarintSysset(dAtA, i, uint64(len(m.CreateTime))) |
| | | i += copy(dAtA[i:], m.CreateTime) |
| | | } |
| | | return i, nil |
| | | } |
| | | |
| | | func encodeVarintSysset(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 *LocalConfig) Size() (n int) { |
| | | if m == nil { |
| | | return 0 |
| | | } |
| | | var l int |
| | | _ = l |
| | | l = len(m.ServerId) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.ServerName) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | if m.ServerType != 0 { |
| | | n += 1 + sovSysset(uint64(m.ServerType)) |
| | | } |
| | | l = len(m.ServerIp) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.AlarmIp) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | if m.AlarmPort != 0 { |
| | | n += 1 + sovSysset(uint64(m.AlarmPort)) |
| | | } |
| | | l = len(m.WebPicIp) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | if m.WebPicPort != 0 { |
| | | n += 1 + sovSysset(uint64(m.WebPicPort)) |
| | | } |
| | | l = len(m.EsPicIp) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | if m.EsPicPort != 0 { |
| | | n += 1 + sovSysset(uint64(m.EsPicPort)) |
| | | } |
| | | if m.CutMaxDuration != 0 { |
| | | n += 1 + sovSysset(uint64(m.CutMaxDuration)) |
| | | } |
| | | if m.CutMinDuration != 0 { |
| | | n += 1 + sovSysset(uint64(m.CutMinDuration)) |
| | | } |
| | | l = len(m.Reserved) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.GateWay) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.NetMask) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | if m.RealMax != 0 { |
| | | n += 2 + sovSysset(uint64(m.RealMax)) |
| | | } |
| | | if m.AlarmThresholdType != 0 { |
| | | n += 2 + sovSysset(uint64(m.AlarmThresholdType)) |
| | | } |
| | | if m.AlarmThreshold != 0 { |
| | | n += 2 + sovSysset(uint64(m.AlarmThreshold)) |
| | | } |
| | | return n |
| | | } |
| | | |
| | | func (m *PollConfig) Size() (n int) { |
| | | if m == nil { |
| | | return 0 |
| | | } |
| | | var l int |
| | | _ = l |
| | | l = len(m.ServerId) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | if m.PollPeriod != 0 { |
| | | n += 1 + sovSysset(uint64(m.PollPeriod)) |
| | | } |
| | | if m.Delay != 0 { |
| | | n += 1 + sovSysset(uint64(m.Delay)) |
| | | } |
| | | if m.Enable { |
| | | n += 2 |
| | | } |
| | | return n |
| | | } |
| | | |
| | | func (m *Cluster) Size() (n int) { |
| | | if m == nil { |
| | | return 0 |
| | | } |
| | | var l int |
| | | _ = l |
| | | l = len(m.ClusterId) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.ClusterName) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.Password) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.VirtualIp) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | if len(m.Nodes) > 0 { |
| | | for _, e := range m.Nodes { |
| | | l = e.Size() |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | } |
| | | return n |
| | | } |
| | | |
| | | func (m *ClusterNode) Size() (n int) { |
| | | if m == nil { |
| | | return 0 |
| | | } |
| | | var l int |
| | | _ = l |
| | | l = len(m.Id) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.ClusterId) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.ServerId) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.ServerName) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.NodeId) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.NodeIp) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | l = len(m.CreateTime) |
| | | if l > 0 { |
| | | n += 1 + l + sovSysset(uint64(l)) |
| | | } |
| | | 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)))) |
| | | } |
| | | func (m *LocalConfig) 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: LocalConfig: wiretype end group for non-group") |
| | | } |
| | | if fieldNum <= 0 { |
| | | return fmt.Errorf("proto: LocalConfig: illegal tag %d (wire type %d)", fieldNum, wire) |
| | | } |
| | | switch fieldNum { |
| | | case 1: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field ServerId", 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.ServerId = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 2: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field ServerName", 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.ServerName = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 3: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field ServerType", wireType) |
| | | } |
| | | m.ServerType = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.ServerType |= int32(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | case 4: |
| | | 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 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.ServerIp = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 5: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field AlarmIp", 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.AlarmIp = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 6: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field AlarmPort", wireType) |
| | | } |
| | | m.AlarmPort = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.AlarmPort |= int32(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | case 7: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field WebPicIp", 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.WebPicIp = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 8: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field WebPicPort", wireType) |
| | | } |
| | | m.WebPicPort = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.WebPicPort |= int32(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | case 9: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field EsPicIp", 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.EsPicIp = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 10: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field EsPicPort", wireType) |
| | | } |
| | | m.EsPicPort = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.EsPicPort |= int32(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | case 11: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field CutMaxDuration", wireType) |
| | | } |
| | | m.CutMaxDuration = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.CutMaxDuration |= int32(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | case 12: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field CutMinDuration", wireType) |
| | | } |
| | | m.CutMinDuration = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.CutMinDuration |= int32(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | case 13: |
| | | 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 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.Reserved = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 14: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field GateWay", 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.GateWay = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 15: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field NetMask", 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.NetMask = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 16: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field RealMax", wireType) |
| | | } |
| | | m.RealMax = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.RealMax |= int32(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | case 17: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field AlarmThresholdType", wireType) |
| | | } |
| | | m.AlarmThresholdType = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.AlarmThresholdType |= int32(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | case 18: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field AlarmThreshold", wireType) |
| | | } |
| | | m.AlarmThreshold = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.AlarmThreshold |= 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 (m *PollConfig) 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: PollConfig: wiretype end group for non-group") |
| | | } |
| | | if fieldNum <= 0 { |
| | | return fmt.Errorf("proto: PollConfig: illegal tag %d (wire type %d)", fieldNum, wire) |
| | | } |
| | | switch fieldNum { |
| | | case 1: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field ServerId", 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.ServerId = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 2: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field PollPeriod", wireType) |
| | | } |
| | | m.PollPeriod = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.PollPeriod |= int32(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | case 3: |
| | | if wireType != 0 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field Delay", wireType) |
| | | } |
| | | m.Delay = 0 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | m.Delay |= int32(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | case 4: |
| | | 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 ErrIntOverflowSysset |
| | | } |
| | | 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 := 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 (m *Cluster) 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: Cluster: wiretype end group for non-group") |
| | | } |
| | | if fieldNum <= 0 { |
| | | return fmt.Errorf("proto: Cluster: illegal tag %d (wire type %d)", fieldNum, wire) |
| | | } |
| | | switch fieldNum { |
| | | case 1: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field ClusterId", 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.ClusterId = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 2: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field ClusterName", 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.ClusterName = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 3: |
| | | 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 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.Password = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 4: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field VirtualIp", 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.VirtualIp = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 5: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field Nodes", wireType) |
| | | } |
| | | var msglen int |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return ErrIntOverflowSysset |
| | | } |
| | | if iNdEx >= l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | b := dAtA[iNdEx] |
| | | iNdEx++ |
| | | msglen |= int(b&0x7F) << shift |
| | | if b < 0x80 { |
| | | break |
| | | } |
| | | } |
| | | if msglen < 0 { |
| | | return ErrInvalidLengthSysset |
| | | } |
| | | postIndex := iNdEx + msglen |
| | | if postIndex < 0 { |
| | | return ErrInvalidLengthSysset |
| | | } |
| | | if postIndex > l { |
| | | return io.ErrUnexpectedEOF |
| | | } |
| | | m.Nodes = append(m.Nodes, &ClusterNode{}) |
| | | if err := m.Nodes[len(m.Nodes)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { |
| | | return err |
| | | } |
| | | iNdEx = postIndex |
| | | 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 (m *ClusterNode) 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: ClusterNode: wiretype end group for non-group") |
| | | } |
| | | if fieldNum <= 0 { |
| | | return fmt.Errorf("proto: ClusterNode: 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 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.Id = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 2: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field ClusterId", 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.ClusterId = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 3: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field ServerId", 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.ServerId = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 4: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field ServerName", 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.ServerName = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 5: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field NodeId", 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.NodeId = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 6: |
| | | if wireType != 2 { |
| | | return fmt.Errorf("proto: wrong wireType = %d for field NodeIp", 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.NodeIp = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | case 7: |
| | | 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 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.CreateTime = string(dAtA[iNdEx:postIndex]) |
| | | iNdEx = postIndex |
| | | 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 |
| | | for iNdEx < l { |
| | | var wire uint64 |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return 0, ErrIntOverflowSysset |
| | | } |
| | | 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, ErrIntOverflowSysset |
| | | } |
| | | 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, ErrIntOverflowSysset |
| | | } |
| | | 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, ErrInvalidLengthSysset |
| | | } |
| | | iNdEx += length |
| | | if iNdEx < 0 { |
| | | return 0, ErrInvalidLengthSysset |
| | | } |
| | | return iNdEx, nil |
| | | case 3: |
| | | for { |
| | | var innerWire uint64 |
| | | var start int = iNdEx |
| | | for shift := uint(0); ; shift += 7 { |
| | | if shift >= 64 { |
| | | return 0, ErrIntOverflowSysset |
| | | } |
| | | 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 := skipSysset(dAtA[start:]) |
| | | if err != nil { |
| | | return 0, err |
| | | } |
| | | iNdEx = start + next |
| | | if iNdEx < 0 { |
| | | return 0, ErrInvalidLengthSysset |
| | | } |
| | | } |
| | | 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 ( |
| | | ErrInvalidLengthSysset = fmt.Errorf("proto: negative length found during unmarshaling") |
| | | ErrIntOverflowSysset = fmt.Errorf("proto: integer overflow") |
| | | ) |