This commit is contained in:
decanus
2019-06-21 00:10:39 +02:00
parent d2ae4d1213
commit 1762929e74
4 changed files with 39 additions and 39 deletions

View File

@@ -84,7 +84,7 @@ func (m *Payload) GetMessages() []*Message {
}
type Ack struct {
Id [][]byte `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
Ids [][]byte `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
@@ -115,9 +115,9 @@ func (m *Ack) XXX_DiscardUnknown() {
var xxx_messageInfo_Ack proto.InternalMessageInfo
func (m *Ack) GetId() [][]byte {
func (m *Ack) GetIds() [][]byte {
if m != nil {
return m.Id
return m.Ids
}
return nil
}
@@ -178,7 +178,7 @@ func (m *Message) GetBody() []byte {
}
type Offer struct {
Id [][]byte `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
Ids [][]byte `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
@@ -209,15 +209,15 @@ func (m *Offer) XXX_DiscardUnknown() {
var xxx_messageInfo_Offer proto.InternalMessageInfo
func (m *Offer) GetId() [][]byte {
func (m *Offer) GetIds() [][]byte {
if m != nil {
return m.Id
return m.Ids
}
return nil
}
type Request struct {
Id [][]byte `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
Ids [][]byte `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
@@ -248,9 +248,9 @@ func (m *Request) XXX_DiscardUnknown() {
var xxx_messageInfo_Request proto.InternalMessageInfo
func (m *Request) GetId() [][]byte {
func (m *Request) GetIds() [][]byte {
if m != nil {
return m.Id
return m.Ids
}
return nil
}
@@ -266,22 +266,22 @@ func init() {
func init() { proto.RegisterFile("protobuf/sync.proto", fileDescriptor_2dca527c092c79d7) }
var fileDescriptor_2dca527c092c79d7 = []byte{
// 258 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x64, 0x90, 0x41, 0x4f, 0xb4, 0x30,
0x10, 0x86, 0x03, 0x65, 0x3f, 0xd8, 0x59, 0x3e, 0x0f, 0x63, 0x8c, 0xdd, 0xe8, 0x01, 0xb9, 0x88,
0x17, 0x4c, 0xf4, 0x17, 0xac, 0x37, 0x0f, 0x46, 0xd3, 0x83, 0x07, 0x2f, 0xa6, 0xd0, 0xb2, 0x21,
0x88, 0x45, 0x0a, 0x26, 0xfc, 0x18, 0xff, 0xab, 0x61, 0xba, 0xeb, 0x26, 0x7a, 0x9b, 0x79, 0x9f,
0x27, 0xe9, 0xbc, 0x85, 0xe3, 0xae, 0x37, 0x83, 0x29, 0xc6, 0xea, 0xda, 0x4e, 0xef, 0x65, 0x4e,
0x1b, 0x06, 0xed, 0xa7, 0xb2, 0xe9, 0x97, 0x07, 0xe1, 0x93, 0x9c, 0xde, 0x8c, 0x54, 0x78, 0x06,
0x4c, 0x96, 0x0d, 0xf7, 0x12, 0x2f, 0x5b, 0xdd, 0x2c, 0xf3, 0x99, 0xe7, 0x9b, 0xb2, 0x11, 0x73,
0x8a, 0x17, 0xb0, 0x30, 0x55, 0xa5, 0x7b, 0xee, 0x13, 0x5e, 0x39, 0xfc, 0x38, 0x47, 0xc2, 0x11,
0xbc, 0x84, 0xb0, 0xd7, 0x1f, 0xa3, 0xb6, 0x03, 0x67, 0x24, 0xfd, 0x77, 0x92, 0x70, 0xa1, 0xd8,
0x53, 0xbc, 0x82, 0xa8, 0xd5, 0xd6, 0xca, 0xad, 0xb6, 0x3c, 0x48, 0xd8, 0xc1, 0x7c, 0x70, 0xa9,
0xf8, 0xc1, 0xe9, 0x09, 0xb0, 0x4d, 0xd9, 0xe0, 0x11, 0xf8, 0xb5, 0xe2, 0x5e, 0xc2, 0xb2, 0x58,
0xf8, 0xb5, 0x4a, 0x9f, 0x21, 0xdc, 0xb9, 0xb8, 0x86, 0x68, 0xdb, 0x9b, 0xb1, 0x7b, 0x25, 0xc1,
0xcb, 0x62, 0x11, 0xd2, 0x7e, 0xaf, 0xf0, 0x1c, 0x96, 0x43, 0xdd, 0x6a, 0x3b, 0xc8, 0xb6, 0xa3,
0xbb, 0x99, 0x38, 0x04, 0x88, 0x10, 0x14, 0x46, 0x4d, 0x74, 0x6b, 0x2c, 0x68, 0x4e, 0x4f, 0x61,
0x41, 0x95, 0xfe, 0x3c, 0xb8, 0x86, 0x70, 0x57, 0xe3, 0x37, 0xba, 0x83, 0x97, 0x68, 0xff, 0xbf,
0xc5, 0x3f, 0x9a, 0x6e, 0xbf, 0x03, 0x00, 0x00, 0xff, 0xff, 0xd9, 0xf0, 0x22, 0x6e, 0x72, 0x01,
0x00, 0x00,
// 257 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0x90, 0xb1, 0x4e, 0xc3, 0x30,
0x10, 0x86, 0x15, 0x9c, 0xe2, 0xf4, 0x1a, 0x24, 0x74, 0x0c, 0xb8, 0x2a, 0x43, 0xc8, 0x42, 0x59,
0x82, 0x04, 0x4f, 0x50, 0x36, 0x06, 0x04, 0xf2, 0xc0, 0xc0, 0x82, 0x9c, 0xd8, 0xa9, 0xa2, 0x10,
0x1c, 0xe2, 0x04, 0x29, 0x0f, 0xc3, 0xbb, 0xa2, 0x9c, 0x5b, 0x3a, 0xc0, 0x76, 0xf7, 0x7d, 0xbf,
0xe4, 0xff, 0x0c, 0x67, 0x6d, 0x67, 0x7b, 0x9b, 0x0f, 0xe5, 0x8d, 0x1b, 0x3f, 0x8a, 0x8c, 0x36,
0x0c, 0x9b, 0x2f, 0xed, 0xd2, 0xef, 0x00, 0xf8, 0xb3, 0x1a, 0xdf, 0xad, 0xd2, 0xb8, 0x02, 0xa6,
0x8a, 0x5a, 0x04, 0x49, 0xb0, 0x5e, 0xdc, 0xce, 0xb3, 0xc9, 0x67, 0x9b, 0xa2, 0x96, 0x13, 0xc5,
0x4b, 0x98, 0xd9, 0xb2, 0x34, 0x9d, 0x38, 0x22, 0xbd, 0xf0, 0xfa, 0x69, 0x42, 0xd2, 0x1b, 0xbc,
0x02, 0xde, 0x99, 0xcf, 0xc1, 0xb8, 0x5e, 0x30, 0x0a, 0x9d, 0xf8, 0x90, 0xf4, 0x50, 0xee, 0x2d,
0x5e, 0x43, 0xd4, 0x18, 0xe7, 0xd4, 0xd6, 0x38, 0x11, 0x26, 0xec, 0x90, 0x7c, 0xf4, 0x54, 0xfe,
0xea, 0xf4, 0x1c, 0xd8, 0xa6, 0xa8, 0xf1, 0x14, 0x58, 0xa5, 0x9d, 0x08, 0x12, 0xb6, 0x8e, 0xe5,
0x34, 0xa6, 0x2f, 0xc0, 0x77, 0x69, 0x5c, 0x42, 0xb4, 0xed, 0xec, 0xd0, 0xbe, 0x55, 0x9a, 0xca,
0xc7, 0x92, 0xd3, 0xfe, 0xa0, 0xf1, 0x02, 0xe6, 0x7d, 0xd5, 0x18, 0xd7, 0xab, 0xa6, 0xa5, 0xe6,
0x4c, 0x1e, 0x00, 0x22, 0x84, 0xb9, 0xd5, 0x23, 0xb5, 0x8d, 0x25, 0xcd, 0xe9, 0x12, 0x66, 0x74,
0xd4, 0x3f, 0x4f, 0xae, 0x80, 0xef, 0x4e, 0xf9, 0x2b, 0xef, 0xe1, 0x35, 0xda, 0xff, 0x72, 0x7e,
0x4c, 0xd3, 0xdd, 0x4f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x7e, 0x8e, 0x53, 0x0c, 0x78, 0x01, 0x00,
0x00,
}

View File

@@ -11,7 +11,7 @@ message Payload {
}
message Ack {
repeated bytes id = 1;
repeated bytes ids = 1; // A list of Message IDs a node is acknowledging
}
message Message {
@@ -21,9 +21,9 @@ message Message {
}
message Offer {
repeated bytes id = 1;
repeated bytes ids = 1; // A list of Message IDs a node is offering
}
message Request {
repeated bytes id = 1;
repeated bytes ids = 1; // A list of Message IDs a node is requesting
}