add PollConfig

liuxiaolong

2019-06-22 c4afd616a70770977bae6135b25c5d8ef148ba1e

add PollConfig

 sysset.pb.go

@@ -171,6 +171,77 @@
    return ""
}

type PollConfig struct {
    ServerId             string   `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
    RealMax              int32    `protobuf:"varint,2,opt,name=real_max,json=realMax,proto3" json:"real_max,omitempty"`
    PollPeriod           int32    `protobuf:"varint,3,opt,name=poll_period,json=pollPeriod,proto3" json:"poll_period,omitempty"`
    Delay                int32    `protobuf:"varint,4,opt,name=delay,proto3" json:"delay,omitempty"`
    Enable               bool     `protobuf:"varint,5,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 (m *PollConfig) String() string { return proto.CompactTextString(m) }
func (*PollConfig) ProtoMessage()    {}
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)
}
func (m *PollConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    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 xxx_messageInfo_PollConfig.Size(m)
}
func (m *PollConfig) XXX_DiscardUnknown() {
    xxx_messageInfo_PollConfig.DiscardUnknown(m)
}

var xxx_messageInfo_PollConfig proto.InternalMessageInfo

func (m *PollConfig) GetServerId() string {
    if m != nil {
        return m.ServerId
    }
    return ""
}

func (m *PollConfig) GetRealMax() int32 {
    if m != nil {
        return m.RealMax
    }
    return 0
}

func (m *PollConfig) GetPollPeriod() int32 {
    if m != nil {
        return m.PollPeriod
    }
    return 0
}

func (m *PollConfig) GetDelay() int32 {
    if m != nil {
        return m.Delay
    }
    return 0
}

func (m *PollConfig) GetEnable() bool {
    if m != nil {
        return m.Enable
    }
    return false
}

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"`
@@ -186,7 +257,7 @@
func (m *Cluster) String() string { return proto.CompactTextString(m) }
func (*Cluster) ProtoMessage()    {}
func (*Cluster) Descriptor() ([]byte, []int) {
    return fileDescriptor_5be590c6b2a0d755, []int{1}
    return fileDescriptor_5be590c6b2a0d755, []int{2}
}

func (m *Cluster) XXX_Unmarshal(b []byte) error {
@@ -259,7 +330,7 @@
func (m *ClusterNode) String() string { return proto.CompactTextString(m) }
func (*ClusterNode) ProtoMessage()    {}
func (*ClusterNode) Descriptor() ([]byte, []int) {
    return fileDescriptor_5be590c6b2a0d755, []int{2}
    return fileDescriptor_5be590c6b2a0d755, []int{3}
}

func (m *ClusterNode) XXX_Unmarshal(b []byte) error {
@@ -331,6 +402,7 @@

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")
}
@@ -338,35 +410,39 @@
func init() { proto.RegisterFile("sysset.proto", fileDescriptor_5be590c6b2a0d755) }

var fileDescriptor_5be590c6b2a0d755 = []byte{
    // 469 bytes of a gzipped FileDescriptorProto
    0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x52, 0xdd, 0x6a, 0xdb, 0x30,
    0x14, 0xc6, 0x49, 0x93, 0xd8, 0xc7, 0x59, 0x36, 0x04, 0x63, 0x5a, 0xf6, 0x97, 0xe5, 0x2a, 0x30,
    0xc8, 0xc5, 0xf6, 0x08, 0xdd, 0x8d, 0x61, 0x2d, 0x25, 0x14, 0x76, 0x69, 0x14, 0xeb, 0x2c, 0x88,
    0xc6, 0x96, 0x90, 0xe4, 0xa6, 0x7e, 0xae, 0x3d, 0xc7, 0x1e, 0x63, 0xef, 0x31, 0x24, 0xd9, 0xb1,
    0xdb, 0x41, 0xaf, 0x92, 0xf3, 0xfd, 0x1c, 0x9f, 0xa3, 0xf3, 0xc1, 0xdc, 0x34, 0xc6, 0xa0, 0xdd,
    0x2a, 0x2d, 0xad, 0x24, 0xb1, 0xff, 0x29, 0xcd, 0x61, 0xfd, 0x77, 0x0c, 0xe9, 0x0f, 0x59, 0xb0,
    0xe3, 0xa5, 0xac, 0x7e, 0x89, 0x03, 0x79, 0x07, 0x89, 0x41, 0x7d, 0x8f, 0x3a, 0x17, 0x9c, 0x46,
    0xab, 0x68, 0x93, 0xec, 0xe2, 0x00, 0x64, 0x9c, 0x7c, 0x82, 0xb4, 0x25, 0x2b, 0x56, 0x22, 0x1d,
    0x79, 0x1a, 0x02, 0x74, 0xcd, 0x4a, 0x1c, 0x08, 0x6c, 0xa3, 0x90, 0x8e, 0x57, 0xd1, 0x66, 0xd2,
    0x09, 0x6e, 0x1b, 0x85, 0xc3, 0xf6, 0x8a, 0x5e, 0x3c, 0x6a, 0xaf, 0xc8, 0x5b, 0x88, 0xd9, 0x91,
    0xe9, 0xd2, 0x71, 0x13, 0xcf, 0xcd, 0x7c, 0x9d, 0x29, 0xf2, 0x01, 0x20, 0x50, 0x4a, 0x6a, 0x4b,
    0xa7, 0xbe, 0x6f, 0xe2, 0x91, 0x1b, 0xa9, 0x2d, 0x79, 0x0f, 0x70, 0xc2, 0x7d, 0xae, 0x44, 0xe1,
    0xbc, 0xb3, 0xd0, 0xf7, 0x84, 0xfb, 0x1b, 0x51, 0x64, 0x8a, 0xac, 0x60, 0xde, 0xb1, 0xde, 0x1e,
    0x87, 0xb1, 0x02, 0xef, 0xfd, 0x4b, 0x48, 0xd0, 0x74, 0xf6, 0x24, 0x7c, 0x1a, 0x4d, 0x70, 0x7f,
    0x84, 0xb4, 0xe5, 0xbc, 0x19, 0xc2, 0xb7, 0x3d, 0xeb, 0xbd, 0x1b, 0x78, 0x55, 0xd4, 0x36, 0x2f,
    0xd9, 0x43, 0xce, 0x6b, 0xcd, 0xac, 0x90, 0x15, 0x4d, 0xbd, 0x68, 0x51, 0xd4, 0xf6, 0x8a, 0x3d,
    0x7c, 0x6f, 0xd1, 0xb3, 0x52, 0x54, 0xbd, 0x72, 0xde, 0x2b, 0x45, 0x75, 0x56, 0x2e, 0x21, 0xd6,
    0xe8, 0xdf, 0x85, 0xd3, 0x17, 0x61, 0x9b, 0xae, 0x76, 0xaf, 0x74, 0x60, 0x16, 0xf3, 0x13, 0x6b,
    0xe8, 0x22, 0x8c, 0xea, 0xea, 0x9f, 0xac, 0x71, 0x54, 0x85, 0x6e, 0x14, 0x73, 0x47, 0x5f, 0x06,
    0xaa, 0x42, 0x7b, 0xc5, 0xcc, 0xdd, 0xfa, 0x77, 0x04, 0xb3, 0xcb, 0x63, 0x6d, 0x2c, 0x6a, 0xf7,
    0x98, 0x45, 0xf8, 0xdb, 0x1f, 0x39, 0x69, 0x91, 0x8c, 0x93, 0xcf, 0x30, 0xef, 0xe8, 0xc1, 0x99,
    0xd3, 0x16, 0xf3, 0x77, 0x5e, 0x42, 0xac, 0x98, 0x31, 0x27, 0xa9, 0xb9, 0x3f, 0x72, 0xb2, 0x3b,
    0xd7, 0xae, 0xfb, 0xbd, 0xd0, 0xb6, 0x66, 0xc7, 0xfe, 0xc6, 0x49, 0x8b, 0x64, 0x8a, 0x7c, 0x81,
    0x49, 0x25, 0x39, 0x1a, 0x3a, 0x59, 0x8d, 0x37, 0xe9, 0xd7, 0xd7, 0xdb, 0x2e, 0x8a, 0xdb, 0x76,
    0xbc, 0x6b, 0xc9, 0x71, 0x17, 0x34, 0xeb, 0x3f, 0x11, 0xa4, 0x03, 0x98, 0x2c, 0x60, 0x74, 0x9e,
    0x78, 0x24, 0xf8, 0x93, 0x4d, 0x46, 0x4f, 0x37, 0x79, 0x14, 0xe6, 0xf1, 0xf3, 0x61, 0xbe, 0xf8,
    0x2f, 0xcc, 0x6f, 0x60, 0xe6, 0xa6, 0x70, 0xde, 0x90, 0xc6, 0xa9, 0x2b, 0x33, 0xde, 0x13, 0xca,
    0x27, 0xb1, 0x23, 0x94, 0x6b, 0x59, 0x68, 0x74, 0xc7, 0xb1, 0xa2, 0xc4, 0x36, 0x87, 0x10, 0xa0,
    0x5b, 0x51, 0xe2, 0x7e, 0xea, 0x97, 0xfd, 0xf6, 0x2f, 0x00, 0x00, 0xff, 0xff, 0x31, 0xf2, 0x53,
    0x2d, 0x8e, 0x03, 0x00, 0x00,
    // 536 bytes of a gzipped FileDescriptorProto
    0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x53, 0x5d, 0x8a, 0xdb, 0x30,
    0x10, 0xc6, 0xc9, 0x3a, 0xb1, 0xc7, 0xe9, 0xb6, 0x88, 0xfe, 0x78, 0xd3, 0xbf, 0x34, 0x4f, 0x81,
    0x42, 0x1e, 0xda, 0x23, 0x6c, 0x5f, 0x0c, 0xcd, 0x12, 0xcc, 0x42, 0x1f, 0x8d, 0x62, 0x4d, 0x83,
    0x58, 0xdb, 0x12, 0x92, 0xb2, 0x89, 0xcf, 0xd1, 0xa3, 0xf4, 0x1c, 0x3d, 0x46, 0xef, 0x51, 0x24,
    0xd9, 0x49, 0x76, 0x0b, 0xa5, 0x4f, 0xf6, 0x7c, 0xdf, 0x7c, 0xa3, 0x6f, 0x34, 0x1a, 0x98, 0xe8,
    0x56, 0x6b, 0x34, 0x4b, 0xa9, 0x84, 0x11, 0x24, 0x72, 0x9f, 0x5a, 0x6f, 0xe7, 0xbf, 0x87, 0x90,
    0x7c, 0x15, 0x25, 0xad, 0xae, 0x45, 0xf3, 0x9d, 0x6f, 0xc9, 0x6b, 0x88, 0x35, 0xaa, 0x7b, 0x54,
    0x05, 0x67, 0x69, 0x30, 0x0b, 0x16, 0x71, 0x1e, 0x79, 0x20, 0x63, 0xe4, 0x3d, 0x24, 0x1d, 0xd9,
    0xd0, 0x1a, 0xd3, 0x81, 0xa3, 0xc1, 0x43, 0x37, 0xb4, 0xc6, 0xb3, 0x04, 0xd3, 0x4a, 0x4c, 0x87,
    0xb3, 0x60, 0x11, 0xf6, 0x09, 0xb7, 0xad, 0xc4, 0xf3, 0xf2, 0x32, 0xbd, 0x78, 0x50, 0x5e, 0x92,
    0x2b, 0x88, 0x68, 0x45, 0x55, 0x6d, 0xb9, 0xd0, 0x71, 0x63, 0x17, 0x67, 0x92, 0xbc, 0x05, 0xf0,
    0x94, 0x14, 0xca, 0xa4, 0x23, 0x57, 0x37, 0x76, 0xc8, 0x5a, 0x28, 0x43, 0xde, 0x00, 0xec, 0x71,
    0x53, 0x48, 0x5e, 0x5a, 0xed, 0xd8, 0xd7, 0xdd, 0xe3, 0x66, 0xcd, 0xcb, 0x4c, 0x92, 0x19, 0x4c,
    0x7a, 0xd6, 0xc9, 0x23, 0x6f, 0xcb, 0xf3, 0x4e, 0x3f, 0x85, 0x18, 0x75, 0x2f, 0x8f, 0xfd, 0xd1,
    0xa8, 0xbd, 0xfa, 0x1d, 0x24, 0x1d, 0xe7, 0xc4, 0xe0, 0xcf, 0x76, 0xac, 0xd3, 0x2e, 0xe0, 0x59,
    0xb9, 0x33, 0x45, 0x4d, 0x0f, 0x05, 0xdb, 0x29, 0x6a, 0xb8, 0x68, 0xd2, 0xc4, 0x25, 0x5d, 0x96,
    0x3b, 0xb3, 0xa2, 0x87, 0x2f, 0x1d, 0x7a, 0xcc, 0xe4, 0xcd, 0x29, 0x73, 0x72, 0xca, 0xe4, 0xcd,
    0x31, 0x73, 0x0a, 0x91, 0x42, 0x77, 0x2f, 0x2c, 0x7d, 0xe2, 0xbb, 0xe9, 0x63, 0x7b, 0x4b, 0x5b,
    0x6a, 0xb0, 0xd8, 0xd3, 0x36, 0xbd, 0xf4, 0x56, 0x6d, 0xfc, 0x8d, 0xb6, 0x96, 0x6a, 0xd0, 0x5a,
    0xd1, 0x77, 0xe9, 0x53, 0x4f, 0x35, 0x68, 0x56, 0x54, 0xdf, 0xcd, 0x7f, 0x04, 0x00, 0x6b, 0x51,
    0xfd, 0xd7, 0x98, 0xaf, 0xec, 0xe9, 0xb4, 0xb2, 0x2d, 0xb9, 0x19, 0x87, 0xf9, 0xd8, 0xc6, 0x2b,
    0x7a, 0xb0, 0x03, 0x96, 0xa2, 0xaa, 0x0a, 0x89, 0x8a, 0x0b, 0xd6, 0x0f, 0xd8, 0x42, 0x6b, 0x87,
    0x90, 0xe7, 0x10, 0x32, 0xac, 0x68, 0xeb, 0x86, 0x1b, 0xe6, 0x3e, 0x20, 0x2f, 0x61, 0x84, 0x0d,
    0xdd, 0x54, 0xe8, 0xe6, 0x1a, 0xe5, 0x5d, 0x34, 0xff, 0x19, 0xc0, 0xf8, 0xba, 0xda, 0x69, 0x83,
    0xca, 0x8e, 0xb8, 0xf4, 0xbf, 0x27, 0x4f, 0x71, 0x87, 0x64, 0x8c, 0x7c, 0x80, 0x49, 0x4f, 0x9f,
    0x3d, 0xbe, 0xa4, 0xc3, 0xdc, 0xeb, 0x9b, 0x42, 0x24, 0xa9, 0xd6, 0x7b, 0xa1, 0xbc, 0xb3, 0x38,
    0x3f, 0xc6, 0xb6, 0xfa, 0x3d, 0x57, 0x66, 0x47, 0xab, 0xd3, 0xcb, 0x8b, 0x3b, 0x24, 0x93, 0xe4,
    0x23, 0x84, 0x8d, 0x60, 0xa8, 0xd3, 0x70, 0x36, 0x5c, 0x24, 0x9f, 0x5e, 0x2c, 0xfb, 0x05, 0x59,
    0x76, 0xf6, 0x6e, 0x04, 0xc3, 0xdc, 0xe7, 0xcc, 0x7f, 0x05, 0x90, 0x9c, 0xc1, 0xe4, 0x12, 0x06,
    0x47, 0xc7, 0x03, 0xce, 0x1e, 0x75, 0x32, 0x78, 0xdc, 0xc9, 0x83, 0xbb, 0x1f, 0xfe, 0x7b, 0xc5,
    0x2e, 0xfe, 0x5a, 0xb1, 0x57, 0x30, 0xb6, 0x2e, 0xac, 0xd6, 0xef, 0xc8, 0xc8, 0x86, 0x19, 0x3b,
    0x11, 0xd2, 0xed, 0x47, 0x4f, 0x48, 0x5b, 0xb2, 0x54, 0x68, 0x9f, 0x8c, 0xe1, 0x35, 0x76, 0xdb,
    0x01, 0x1e, 0xba, 0xe5, 0x35, 0x6e, 0x46, 0xae, 0xd9, 0xcf, 0x7f, 0x02, 0x00, 0x00, 0xff, 0xff,
    0x64, 0x0a, 0xad, 0x64, 0x24, 0x04, 0x00, 0x00,
}

 sysset.proto

@@ -21,6 +21,14 @@
    string net_mask = 15;
}

message PollConfig {
    string server_id = 1;//服务器id
    int32 real_max = 2;//实时处理的最大路数
    int32 poll_period = 3;//轮询周期
    int32 delay = 4;//延迟时间
    bool enable = 5;//是否启用
}

message Cluster {
    string cluster_id = 1;
    string cluster_name = 2;