From ad6c105f7a2b6f97322cf84364579bee079f25e2 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 01 八月 2019 20:25:04 +0800
Subject: [PATCH] change table_id to arr
---
protomsg.proto | 2
protomsg.pb.go | 64 +++++++++++++++++++-------------
2 files changed, 39 insertions(+), 27 deletions(-)
diff --git a/protomsg.pb.go b/protomsg.pb.go
index f5c9b5d..9b614ea 100644
--- a/protomsg.pb.go
+++ b/protomsg.pb.go
@@ -2635,7 +2635,7 @@
type EsPersonCacheChange struct {
Type EsCacheChanged `protobuf:"varint,1,opt,name=type,proto3,enum=protomsg.EsCacheChanged" json:"type,omitempty"`
- TableId string `protobuf:"bytes,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
+ TableId []string `protobuf:"bytes,2,rep,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
PersonId string `protobuf:"bytes,3,opt,name=person_id,json=personId,proto3" json:"person_id,omitempty"`
Feature string `protobuf:"bytes,4,opt,name=feature,proto3" json:"feature,omitempty"`
Action DbAction `protobuf:"varint,5,opt,name=action,proto3,enum=protomsg.DbAction" json:"action,omitempty"`
@@ -2681,11 +2681,11 @@
return EsCacheChanged_T_DbTable
}
-func (m *EsPersonCacheChange) GetTableId() string {
+func (m *EsPersonCacheChange) GetTableId() []string {
if m != nil {
return m.TableId
}
- return ""
+ return nil
}
func (m *EsPersonCacheChange) GetPersonId() string {
@@ -2750,7 +2750,7 @@
func init() { proto.RegisterFile("protomsg.proto", fileDescriptor_32de24555f916688) }
var fileDescriptor_32de24555f916688 = []byte{
- // 2367 bytes of a gzipped FileDescriptorProto
+ // 2369 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x58, 0x4b, 0x6f, 0x1c, 0xc7,
0xf1, 0xe7, 0xec, 0x7b, 0x6a, 0x1f, 0x5a, 0xb5, 0xf4, 0xb7, 0xc7, 0xf2, 0x5f, 0x34, 0x35, 0x91,
0x61, 0x42, 0xb0, 0x95, 0x80, 0xd2, 0x29, 0x87, 0x00, 0x34, 0x49, 0x05, 0x0b, 0x38, 0x02, 0x33,
@@ -2885,20 +2885,21 @@
0x19, 0x0c, 0xad, 0xe1, 0xcb, 0x79, 0xce, 0xa9, 0xe7, 0xb9, 0x77, 0x8c, 0x45, 0xfe, 0x9f, 0x1d,
0xb8, 0x77, 0xa4, 0x8f, 0x85, 0xd2, 0x69, 0x72, 0xc0, 0x57, 0xe7, 0xb6, 0x63, 0xb2, 0xcf, 0x6d,
0x65, 0x35, 0x6d, 0xb5, 0x91, 0x48, 0x47, 0xba, 0x21, 0x16, 0xd9, 0xe6, 0xf1, 0x91, 0xad, 0xb1,
- 0xe1, 0x46, 0x4a, 0x9b, 0x87, 0x42, 0x46, 0xbb, 0x37, 0x1e, 0x0a, 0x06, 0x58, 0x50, 0x25, 0x38,
- 0xb3, 0xf5, 0xd4, 0x66, 0x89, 0x25, 0x1b, 0x9d, 0xb9, 0xff, 0x43, 0x9d, 0xf9, 0xc9, 0x5f, 0x1c,
- 0x98, 0x34, 0xbb, 0x3d, 0x9b, 0xc0, 0xe8, 0x34, 0x34, 0x7d, 0x79, 0xbe, 0xc5, 0xe6, 0x30, 0x29,
- 0x29, 0x1c, 0x20, 0xe7, 0x0e, 0xbb, 0x0f, 0xf3, 0x26, 0x82, 0x6d, 0x62, 0xde, 0x61, 0x00, 0x83,
- 0xd3, 0x90, 0x24, 0xba, 0x6c, 0x0a, 0xae, 0x59, 0x9f, 0x44, 0x17, 0xf3, 0x1e, 0xbb, 0x0b, 0xd3,
- 0x8a, 0xc4, 0x90, 0x9c, 0xf7, 0x99, 0x0b, 0xfd, 0xd3, 0x10, 0xb9, 0x03, 0x76, 0x0f, 0xee, 0x94,
- 0xdb, 0xd9, 0x31, 0x60, 0x3e, 0x64, 0x33, 0x80, 0xd3, 0xf0, 0xd4, 0x3e, 0xfb, 0xe7, 0x23, 0xa3,
- 0x93, 0x29, 0x92, 0x73, 0xd7, 0xe8, 0x74, 0x9c, 0x4a, 0x79, 0x90, 0x26, 0x67, 0xf1, 0x7a, 0x0e,
- 0x4f, 0x9e, 0xc2, 0xa8, 0xbc, 0x18, 0x6a, 0xb2, 0x48, 0xb4, 0x50, 0xf9, 0x7c, 0x0b, 0xd7, 0xaf,
- 0x68, 0xa8, 0x9e, 0x3b, 0xb8, 0x3e, 0x14, 0x52, 0xe4, 0x62, 0xde, 0x79, 0xf2, 0x1c, 0x66, 0x6d,
- 0x57, 0x18, 0x9d, 0x0f, 0x97, 0x64, 0x89, 0xf9, 0x96, 0xd1, 0xca, 0x92, 0xc6, 0xbf, 0x73, 0xe7,
- 0x4b, 0xef, 0xaf, 0x6f, 0xb6, 0x9d, 0x6f, 0xdf, 0x6c, 0x3b, 0xff, 0x78, 0xb3, 0xed, 0xfc, 0xfe,
- 0xed, 0xf6, 0xd6, 0xb7, 0x6f, 0xb7, 0xb7, 0xfe, 0xfe, 0x76, 0x7b, 0x6b, 0x39, 0x20, 0xfb, 0x3e,
- 0xfb, 0x5f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xe4, 0x9d, 0xd5, 0xfd, 0xfd, 0x16, 0x00, 0x00,
+ 0xa6, 0xc9, 0x75, 0xab, 0x94, 0x36, 0x0f, 0x85, 0x8c, 0x76, 0x6f, 0x3c, 0x14, 0x0c, 0xb0, 0xa0,
+ 0x4a, 0x70, 0x66, 0xeb, 0xa9, 0xcd, 0x12, 0x4b, 0x36, 0x3a, 0x73, 0xff, 0x87, 0x3a, 0xf3, 0x93,
+ 0xbf, 0x38, 0x30, 0x69, 0x76, 0x7b, 0x36, 0x81, 0xd1, 0x69, 0x68, 0xfa, 0xf2, 0x7c, 0x8b, 0xcd,
+ 0x61, 0x52, 0x52, 0x38, 0x40, 0xce, 0x1d, 0x76, 0x1f, 0xe6, 0x4d, 0x04, 0xdb, 0xc4, 0xbc, 0xc3,
+ 0x00, 0x06, 0xa7, 0x21, 0x49, 0x74, 0xd9, 0x14, 0x5c, 0xb3, 0x3e, 0x89, 0x2e, 0xe6, 0x3d, 0x76,
+ 0x17, 0xa6, 0x15, 0x89, 0x21, 0x39, 0xef, 0x33, 0x17, 0xfa, 0xa7, 0x21, 0x72, 0x07, 0xec, 0x1e,
+ 0xdc, 0x29, 0xb7, 0xb3, 0x63, 0xc0, 0x7c, 0xc8, 0x66, 0x00, 0xa7, 0xe1, 0xa9, 0x7d, 0xf6, 0xcf,
+ 0x47, 0x46, 0x27, 0x53, 0x24, 0xe7, 0xae, 0xd1, 0xe9, 0x38, 0x95, 0xf2, 0x20, 0x4d, 0xce, 0xe2,
+ 0xf5, 0x1c, 0x9e, 0x3c, 0x85, 0x51, 0x79, 0x31, 0xd4, 0x64, 0x91, 0x68, 0xa1, 0xf2, 0xf9, 0x16,
+ 0xae, 0x5f, 0xd1, 0x50, 0x3d, 0x77, 0x70, 0x7d, 0x28, 0xa4, 0xc8, 0xc5, 0xbc, 0xf3, 0xe4, 0x39,
+ 0xcc, 0xda, 0xae, 0x30, 0x3a, 0x1f, 0x2e, 0xc9, 0x12, 0xf3, 0x2d, 0xa3, 0x95, 0x25, 0x8d, 0x7f,
+ 0xe7, 0xce, 0x97, 0xde, 0x5f, 0xdf, 0x6c, 0x3b, 0xdf, 0xbe, 0xd9, 0x76, 0xfe, 0xf1, 0x66, 0xdb,
+ 0xf9, 0xfd, 0xdb, 0xed, 0xad, 0x6f, 0xdf, 0x6e, 0x6f, 0xfd, 0xfd, 0xed, 0xf6, 0xd6, 0x72, 0x40,
+ 0xf6, 0x7d, 0xf6, 0xbf, 0x00, 0x00, 0x00, 0xff, 0xff, 0xcb, 0xb5, 0x60, 0x5d, 0xfd, 0x16, 0x00,
+ 0x00,
}
func (m *Area) Marshal() (dAtA []byte, err error) {
@@ -4750,10 +4751,19 @@
i = encodeVarintProtomsg(dAtA, i, uint64(m.Type))
}
if len(m.TableId) > 0 {
- dAtA[i] = 0x12
- i++
- i = encodeVarintProtomsg(dAtA, i, uint64(len(m.TableId)))
- i += copy(dAtA[i:], m.TableId)
+ for _, s := range m.TableId {
+ dAtA[i] = 0x12
+ i++
+ l = len(s)
+ for l >= 1<<7 {
+ dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
+ l >>= 7
+ i++
+ }
+ dAtA[i] = uint8(l)
+ i++
+ i += copy(dAtA[i:], s)
+ }
}
if len(m.PersonId) > 0 {
dAtA[i] = 0x1a
@@ -5764,9 +5774,11 @@
if m.Type != 0 {
n += 1 + sovProtomsg(uint64(m.Type))
}
- l = len(m.TableId)
- if l > 0 {
- n += 1 + l + sovProtomsg(uint64(l))
+ if len(m.TableId) > 0 {
+ for _, s := range m.TableId {
+ l = len(s)
+ n += 1 + l + sovProtomsg(uint64(l))
+ }
}
l = len(m.PersonId)
if l > 0 {
@@ -12500,7 +12512,7 @@
if postIndex > l {
return io.ErrUnexpectedEOF
}
- m.TableId = string(dAtA[iNdEx:postIndex])
+ m.TableId = append(m.TableId, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 3:
if wireType != 2 {
diff --git a/protomsg.proto b/protomsg.proto
index 1993742..20b03e6 100644
--- a/protomsg.proto
+++ b/protomsg.proto
@@ -313,7 +313,7 @@
message EsPersonCacheChange {
EsCacheChanged type = 1;
- string table_id = 2;//搴曞簱id
+ repeated string table_id = 2;//搴曞簱id
string person_id = 3;//浜哄憳id
string feature = 4;//鐗瑰緛鍊糱ase64
DbAction action = 5;
--
Gitblit v1.8.0