Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
What's new
10
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Open sidebar
p2p
go-p2p-pubsub
Commits
f125ed69
Unverified
Commit
f125ed69
authored
Aug 25, 2020
by
Steven Allen
Committed by
GitHub
Aug 25, 2020
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
regenerate protobufs (#381)
parent
efd56962
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
387 additions
and
327 deletions
+387
-327
pb/rpc.pb.go
pb/rpc.pb.go
+387
-327
No files found.
pb/rpc.pb.go
View file @
f125ed69
...
@@ -8,6 +8,7 @@ import (
...
@@ -8,6 +8,7 @@ import (
proto "github.com/gogo/protobuf/proto"
proto "github.com/gogo/protobuf/proto"
io "io"
io "io"
math "math"
math "math"
math_bits "math/bits"
)
)
// Reference imports to suppress errors if they are not otherwise used.
// Reference imports to suppress errors if they are not otherwise used.
...
@@ -19,7 +20,7 @@ var _ = math.Inf
...
@@ -19,7 +20,7 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against.
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
// proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion
2
// please upgrade the proto package
const _ = proto.GoGoProtoPackageIsVersion
3
// please upgrade the proto package
type TopicDescriptor_AuthOpts_AuthMode int32
type TopicDescriptor_AuthOpts_AuthMode int32
...
@@ -130,7 +131,7 @@ func (m *RPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
...
@@ -130,7 +131,7 @@ func (m *RPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RPC.Marshal(b, m, deterministic)
return xxx_messageInfo_RPC.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -192,7 +193,7 @@ func (m *RPC_SubOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
...
@@ -192,7 +193,7 @@ func (m *RPC_SubOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
return xxx_messageInfo_RPC_SubOpts.Marshal(b, m, deterministic)
return xxx_messageInfo_RPC_SubOpts.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -251,7 +252,7 @@ func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
...
@@ -251,7 +252,7 @@ func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Message.Marshal(b, m, deterministic)
return xxx_messageInfo_Message.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -336,7 +337,7 @@ func (m *ControlMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, erro
...
@@ -336,7 +337,7 @@ func (m *ControlMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, erro
return xxx_messageInfo_ControlMessage.Marshal(b, m, deterministic)
return xxx_messageInfo_ControlMessage.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -384,7 +385,8 @@ func (m *ControlMessage) GetPrune() []*ControlPrune {
...
@@ -384,7 +385,8 @@ func (m *ControlMessage) GetPrune() []*ControlPrune {
}
}
type ControlIHave struct {
type ControlIHave struct {
TopicID *string `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"`
TopicID *string `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"`
// implementors from other languages should use bytes here - go protobuf emits invalid utf8 strings
MessageIDs []string `protobuf:"bytes,2,rep,name=messageIDs" json:"messageIDs,omitempty"`
MessageIDs []string `protobuf:"bytes,2,rep,name=messageIDs" json:"messageIDs,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_unrecognized []byte `json:"-"`
...
@@ -405,7 +407,7 @@ func (m *ControlIHave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
...
@@ -405,7 +407,7 @@ func (m *ControlIHave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
return xxx_messageInfo_ControlIHave.Marshal(b, m, deterministic)
return xxx_messageInfo_ControlIHave.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -439,6 +441,7 @@ func (m *ControlIHave) GetMessageIDs() []string {
...
@@ -439,6 +441,7 @@ func (m *ControlIHave) GetMessageIDs() []string {
}
}
type ControlIWant struct {
type ControlIWant struct {
// implementors from other languages should use bytes here - go protobuf emits invalid utf8 strings
MessageIDs []string `protobuf:"bytes,1,rep,name=messageIDs" json:"messageIDs,omitempty"`
MessageIDs []string `protobuf:"bytes,1,rep,name=messageIDs" json:"messageIDs,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_unrecognized []byte `json:"-"`
...
@@ -459,7 +462,7 @@ func (m *ControlIWant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
...
@@ -459,7 +462,7 @@ func (m *ControlIWant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
return xxx_messageInfo_ControlIWant.Marshal(b, m, deterministic)
return xxx_messageInfo_ControlIWant.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -506,7 +509,7 @@ func (m *ControlGraft) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
...
@@ -506,7 +509,7 @@ func (m *ControlGraft) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
return xxx_messageInfo_ControlGraft.Marshal(b, m, deterministic)
return xxx_messageInfo_ControlGraft.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -555,7 +558,7 @@ func (m *ControlPrune) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
...
@@ -555,7 +558,7 @@ func (m *ControlPrune) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
return xxx_messageInfo_ControlPrune.Marshal(b, m, deterministic)
return xxx_messageInfo_ControlPrune.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -617,7 +620,7 @@ func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
...
@@ -617,7 +620,7 @@ func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PeerInfo.Marshal(b, m, deterministic)
return xxx_messageInfo_PeerInfo.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -673,7 +676,7 @@ func (m *TopicDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, err
...
@@ -673,7 +676,7 @@ func (m *TopicDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, err
return xxx_messageInfo_TopicDescriptor.Marshal(b, m, deterministic)
return xxx_messageInfo_TopicDescriptor.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -735,7 +738,7 @@ func (m *TopicDescriptor_AuthOpts) XXX_Marshal(b []byte, deterministic bool) ([]
...
@@ -735,7 +738,7 @@ func (m *TopicDescriptor_AuthOpts) XXX_Marshal(b []byte, deterministic bool) ([]
return xxx_messageInfo_TopicDescriptor_AuthOpts.Marshal(b, m, deterministic)
return xxx_messageInfo_TopicDescriptor_AuthOpts.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -790,7 +793,7 @@ func (m *TopicDescriptor_EncOpts) XXX_Marshal(b []byte, deterministic bool) ([]b
...
@@ -790,7 +793,7 @@ func (m *TopicDescriptor_EncOpts) XXX_Marshal(b []byte, deterministic bool) ([]b
return xxx_messageInfo_TopicDescriptor_EncOpts.Marshal(b, m, deterministic)
return xxx_messageInfo_TopicDescriptor_EncOpts.Marshal(b, m, deterministic)
} else {
} else {
b = b[:cap(b)]
b = b[:cap(b)]
n, err := m.MarshalTo(b)
n, err := m.MarshalTo
SizedBuffer
(b)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -891,7 +894,7 @@ var fileDescriptor_77a6da22d6a3feb1 = []byte{
...
@@ -891,7 +894,7 @@ var fileDescriptor_77a6da22d6a3feb1 = []byte{
func (m *RPC) Marshal() (dAtA []byte, err error) {
func (m *RPC) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -899,54 +902,66 @@ func (m *RPC) Marshal() (dAtA []byte, err error) {
...
@@ -899,54 +902,66 @@ func (m *RPC) Marshal() (dAtA []byte, err error) {
}
}
func (m *RPC) MarshalTo(dAtA []byte) (int, error) {
func (m *RPC) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *RPC) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if len(m.Subscriptions) > 0 {
if m.XXX_unrecognized != nil {
for _, msg := range m.Subscriptions {
i -= len(m.XXX_unrecognized)
dAtA[i] = 0xa
copy(dAtA[i:], m.XXX_unrecognized)
i++
}
i = encodeVarintRpc(dAtA, i, uint64(msg.Size()))
if m.Control != nil {
n, err := msg.MarshalTo(dAtA[i:])
{
size, err := m.Control.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
if err != nil {
return 0, err
return 0, err
}
}
i += n
i -= size
i = encodeVarintRpc(dAtA, i, uint64(size))
}
}
i--
dAtA[i] = 0x1a
}
}
if len(m.Publish) > 0 {
if len(m.Publish) > 0 {
for _, msg := range m.Publish {
for iNdEx := len(m.Publish) - 1; iNdEx >= 0; iNdEx-- {
dAtA[i] = 0x12
{
i++
size, err := m.Publish[iNdEx].MarshalToSizedBuffer(dAtA[:i])
i = encodeVarintRpc(dAtA, i, uint64(msg.Size()))
if err != nil {
n, err := msg.MarshalTo(dAtA[i:])
return 0, err
if err != nil {
}
return 0, err
i -= size
i = encodeVarintRpc(dAtA, i, uint64(size))
}
}
i += n
i--
dAtA[i] = 0x12
}
}
}
}
if m.Control != nil {
if len(m.Subscriptions) > 0 {
dAtA[i] = 0x1a
for iNdEx := len(m.Subscriptions) - 1; iNdEx >= 0; iNdEx-- {
i++
{
i = encodeVarintRpc(dAtA, i, uint64(m.Control.Size()))
size, err := m.Subscriptions[iNdEx].MarshalToSizedBuffer(dAtA[:i])
n1, err1 := m.Control.MarshalTo(dAtA[i:])
if err != nil {
if err1 != nil {
return 0, err
return 0, err1
}
i -= size
i = encodeVarintRpc(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
}
i += n1
}
}
if m.XXX_unrecognized != nil {
return len(dAtA) - i, nil
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
}
func (m *RPC_SubOpts) Marshal() (dAtA []byte, err error) {
func (m *RPC_SubOpts) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -954,36 +969,43 @@ func (m *RPC_SubOpts) Marshal() (dAtA []byte, err error) {
...
@@ -954,36 +969,43 @@ func (m *RPC_SubOpts) Marshal() (dAtA []byte, err error) {
}
}
func (m *RPC_SubOpts) MarshalTo(dAtA []byte) (int, error) {
func (m *RPC_SubOpts) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *RPC_SubOpts) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if m.XXX_unrecognized != nil {
i -= len(m.XXX_unrecognized)
copy(dAtA[i:], m.XXX_unrecognized)
}
if m.Topicid != nil {
i -= len(*m.Topicid)
copy(dAtA[i:], *m.Topicid)
i = encodeVarintRpc(dAtA, i, uint64(len(*m.Topicid)))
i--
dAtA[i] = 0x12
}
if m.Subscribe != nil {
if m.Subscribe != nil {
dAtA[i] = 0x8
i--
i++
if *m.Subscribe {
if *m.Subscribe {
dAtA[i] = 1
dAtA[i] = 1
} else {
} else {
dAtA[i] = 0
dAtA[i] = 0
}
}
i++
i--
}
dAtA[i] = 0x8
if m.Topicid != nil {
dAtA[i] = 0x12
i++
i = encodeVarintRpc(dAtA, i, uint64(len(*m.Topicid)))
i += copy(dAtA[i:], *m.Topicid)
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
}
return i, nil
return
len(dAtA) -
i, nil
}
}
func (m *Message) Marshal() (dAtA []byte, err error) {
func (m *Message) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -991,65 +1013,70 @@ func (m *Message) Marshal() (dAtA []byte, err error) {
...
@@ -991,65 +1013,70 @@ func (m *Message) Marshal() (dAtA []byte, err error) {
}
}
func (m *Message) MarshalTo(dAtA []byte) (int, error) {
func (m *Message) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if m.From != nil {
if m.XXX_unrecognized != nil {
dAtA[i] = 0xa
i -= len(m.XXX_unrecognized)
i++
copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintRpc(dAtA, i, uint64(len(m.From)))
i += copy(dAtA[i:], m.From)
}
}
if m.Data != nil {
if m.Key != nil {
dAtA[i] = 0x12
i -= len(m.Key)
i++
copy(dAtA[i:], m.Key)
i = encodeVarintRpc(dAtA, i, uint64(len(m.Data)))
i = encodeVarintRpc(dAtA, i, uint64(len(m.Key)))
i += copy(dAtA[i:], m.Data)
i--
dAtA[i] = 0x32
}
}
if m.Seqno != nil {
if m.Signature != nil {
dAtA[i] = 0x1a
i -= len(m.Signature)
i++
copy(dAtA[i:], m.Signature)
i = encodeVarintRpc(dAtA, i, uint64(len(m.Seqno)))
i = encodeVarintRpc(dAtA, i, uint64(len(m.Signature)))
i += copy(dAtA[i:], m.Seqno)
i--
dAtA[i] = 0x2a
}
}
if len(m.TopicIDs) > 0 {
if len(m.TopicIDs) > 0 {
for _, s := range m.TopicIDs {
for iNdEx := len(m.TopicIDs) - 1; iNdEx >= 0; iNdEx-- {
i -= len(m.TopicIDs[iNdEx])
copy(dAtA[i:], m.TopicIDs[iNdEx])
i = encodeVarintRpc(dAtA, i, uint64(len(m.TopicIDs[iNdEx])))
i--
dAtA[i] = 0x22
dAtA[i] = 0x22
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 m.Signature != nil {
if m.Seqno != nil {
dAtA[i] = 0x2a
i -= len(m.Seqno)
i++
copy(dAtA[i:], m.Seqno)
i = encodeVarintRpc(dAtA, i, uint64(len(m.Signature)))
i = encodeVarintRpc(dAtA, i, uint64(len(m.Seqno)))
i += copy(dAtA[i:], m.Signature)
i--
dAtA[i] = 0x1a
}
}
if m.Key != nil {
if m.Data != nil {
dAtA[i] = 0x32
i -= len(m.Data)
i++
copy(dAtA[i:], m.Data)
i = encodeVarintRpc(dAtA, i, uint64(len(m.Key)))
i = encodeVarintRpc(dAtA, i, uint64(len(m.Data)))
i += copy(dAtA[i:], m.Key)
i--
dAtA[i] = 0x12
}
}
if m.XXX_unrecognized != nil {
if m.From != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
i -= len(m.From)
copy(dAtA[i:], m.From)
i = encodeVarintRpc(dAtA, i, uint64(len(m.From)))
i--
dAtA[i] = 0xa
}
}
return i, nil
return
len(dAtA) -
i, nil
}
}
func (m *ControlMessage) Marshal() (dAtA []byte, err error) {
func (m *ControlMessage) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -1057,68 +1084,82 @@ func (m *ControlMessage) Marshal() (dAtA []byte, err error) {
...
@@ -1057,68 +1084,82 @@ func (m *ControlMessage) Marshal() (dAtA []byte, err error) {
}
}
func (m *ControlMessage) MarshalTo(dAtA []byte) (int, error) {
func (m *ControlMessage) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *ControlMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if len(m.Ihave) > 0 {
if m.XXX_unrecognized != nil {
for _, msg := range m.Ihave {
i -= len(m.XXX_unrecognized)
dAtA[i] = 0xa
copy(dAtA[i:], m.XXX_unrecognized)
i++
i = encodeVarintRpc(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
}
if len(m.Iwant) > 0 {
if len(m.Prune) > 0 {
for _, msg := range m.Iwant {
for iNdEx := len(m.Prune) - 1; iNdEx >= 0; iNdEx-- {
dAtA[i] = 0x12
{
i++
size, err := m.Prune[iNdEx].MarshalToSizedBuffer(dAtA[:i])
i = encodeVarintRpc(dAtA, i, uint64(msg.Size()))
if err != nil {
n, err := msg.MarshalTo(dAtA[i:])
return 0, err
if err != nil {
}
return 0, err
i -= size
i = encodeVarintRpc(dAtA, i, uint64(size))
}
}
i += n
i--
dAtA[i] = 0x22
}
}
}
}
if len(m.Graft) > 0 {
if len(m.Graft) > 0 {
for _, msg := range m.Graft {
for iNdEx := len(m.Graft) - 1; iNdEx >= 0; iNdEx-- {
dAtA[i] = 0x1a
{
i++
size, err := m.Graft[iNdEx].MarshalToSizedBuffer(dAtA[:i])
i = encodeVarintRpc(dAtA, i, uint64(msg.Size()))
if err != nil {
n, err := msg.MarshalTo(dAtA[i:])
return 0, err
if err != nil {
}
return 0, err
i -= size
i = encodeVarintRpc(dAtA, i, uint64(size))
}
}
i += n
i--
dAtA[i] = 0x1a
}
}
}
}
if len(m.Prune) > 0 {
if len(m.Iwant) > 0 {
for _, msg := range m.Prune {
for iNdEx := len(m.Iwant) - 1; iNdEx >= 0; iNdEx-- {
dAtA[i] = 0x22
{
i++
size, err := m.Iwant[iNdEx].MarshalToSizedBuffer(dAtA[:i])
i = encodeVarintRpc(dAtA, i, uint64(msg.Size()))
if err != nil {
n, err := msg.MarshalTo(dAtA[i:])
return 0, err
if err != nil {
}
return 0, err
i -= size
i = encodeVarintRpc(dAtA, i, uint64(size))
}
}
i += n
i--
dAtA[i] = 0x12
}
}
}
}
if m.XXX_unrecognized != nil {
if len(m.Ihave) > 0 {
i += copy(dAtA[i:], m.XXX_unrecognized)
for iNdEx := len(m.Ihave) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Ihave[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintRpc(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
}
}
return i, nil
return
len(dAtA) -
i, nil
}
}
func (m *ControlIHave) Marshal() (dAtA []byte, err error) {
func (m *ControlIHave) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -1126,41 +1167,42 @@ func (m *ControlIHave) Marshal() (dAtA []byte, err error) {
...
@@ -1126,41 +1167,42 @@ func (m *ControlIHave) Marshal() (dAtA []byte, err error) {
}
}
func (m *ControlIHave) MarshalTo(dAtA []byte) (int, error) {
func (m *ControlIHave) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *ControlIHave) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if m.TopicID != nil {
if m.XXX_unrecognized != nil {
dAtA[i] = 0xa
i -= len(m.XXX_unrecognized)
i++
copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintRpc(dAtA, i, uint64(len(*m.TopicID)))
i += copy(dAtA[i:], *m.TopicID)
}
}
if len(m.MessageIDs) > 0 {
if len(m.MessageIDs) > 0 {
for _, s := range m.MessageIDs {
for iNdEx := len(m.MessageIDs) - 1; iNdEx >= 0; iNdEx-- {
i -= len(m.MessageIDs[iNdEx])
copy(dAtA[i:], m.MessageIDs[iNdEx])
i = encodeVarintRpc(dAtA, i, uint64(len(m.MessageIDs[iNdEx])))
i--
dAtA[i] = 0x12
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 m.XXX_unrecognized != nil {
if m.TopicID != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
i -= len(*m.TopicID)
copy(dAtA[i:], *m.TopicID)
i = encodeVarintRpc(dAtA, i, uint64(len(*m.TopicID)))
i--
dAtA[i] = 0xa
}
}
return i, nil
return
len(dAtA) -
i, nil
}
}
func (m *ControlIWant) Marshal() (dAtA []byte, err error) {
func (m *ControlIWant) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -1168,35 +1210,35 @@ func (m *ControlIWant) Marshal() (dAtA []byte, err error) {
...
@@ -1168,35 +1210,35 @@ func (m *ControlIWant) Marshal() (dAtA []byte, err error) {
}
}
func (m *ControlIWant) MarshalTo(dAtA []byte) (int, error) {
func (m *ControlIWant) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *ControlIWant) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if m.XXX_unrecognized != nil {
i -= len(m.XXX_unrecognized)
copy(dAtA[i:], m.XXX_unrecognized)
}
if len(m.MessageIDs) > 0 {
if len(m.MessageIDs) > 0 {
for _, s := range m.MessageIDs {
for iNdEx := len(m.MessageIDs) - 1; iNdEx >= 0; iNdEx-- {
i -= len(m.MessageIDs[iNdEx])
copy(dAtA[i:], m.MessageIDs[iNdEx])
i = encodeVarintRpc(dAtA, i, uint64(len(m.MessageIDs[iNdEx])))
i--
dAtA[i] = 0xa
dAtA[i] = 0xa
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 m.XXX_unrecognized != nil {
return len(dAtA) - i, nil
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
}
func (m *ControlGraft) Marshal() (dAtA []byte, err error) {
func (m *ControlGraft) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -1204,26 +1246,33 @@ func (m *ControlGraft) Marshal() (dAtA []byte, err error) {
...
@@ -1204,26 +1246,33 @@ func (m *ControlGraft) Marshal() (dAtA []byte, err error) {
}
}
func (m *ControlGraft) MarshalTo(dAtA []byte) (int, error) {
func (m *ControlGraft) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *ControlGraft) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if m.XXX_unrecognized != nil {
i -= len(m.XXX_unrecognized)
copy(dAtA[i:], m.XXX_unrecognized)
}
if m.TopicID != nil {
if m.TopicID != nil {
dAtA[i] = 0xa
i -= len(*m.TopicID)
i++
copy(dAtA[i:], *m.TopicID)
i = encodeVarintRpc(dAtA, i, uint64(len(*m.TopicID)))
i = encodeVarintRpc(dAtA, i, uint64(len(*m.TopicID)))
i += copy(dAtA[i:], *m.TopicID)
i--
}
dAtA[i] = 0xa
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
}
return i, nil
return
len(dAtA) -
i, nil
}
}
func (m *ControlPrune) Marshal() (dAtA []byte, err error) {
func (m *ControlPrune) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -1231,43 +1280,52 @@ func (m *ControlPrune) Marshal() (dAtA []byte, err error) {
...
@@ -1231,43 +1280,52 @@ func (m *ControlPrune) Marshal() (dAtA []byte, err error) {
}
}
func (m *ControlPrune) MarshalTo(dAtA []byte) (int, error) {
func (m *ControlPrune) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *ControlPrune) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if m.TopicID != nil {
if m.XXX_unrecognized != nil {
dAtA[i] = 0xa
i -= len(m.XXX_unrecognized)
i++
copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintRpc(dAtA, i, uint64(len(*m.TopicID)))
}
i += copy(dAtA[i:], *m.TopicID)
if m.Backoff != nil {
i = encodeVarintRpc(dAtA, i, uint64(*m.Backoff))
i--
dAtA[i] = 0x18
}
}
if len(m.Peers) > 0 {
if len(m.Peers) > 0 {
for _, msg := range m.Peers {
for iNdEx := len(m.Peers) - 1; iNdEx >= 0; iNdEx-- {
dAtA[i] = 0x12
{
i++
size, err := m.Peers[iNdEx].MarshalToSizedBuffer(dAtA[:i])
i = encodeVarintRpc(dAtA, i, uint64(msg.Size()))
if err != nil {
n, err := msg.MarshalTo(dAtA[i:])
return 0, err
if err != nil {
}
return 0, err
i -= size
i = encodeVarintRpc(dAtA, i, uint64(size))
}
}
i += n
i--
dAtA[i] = 0x12
}
}
}
}
if m.Backoff != nil {
if m.TopicID != nil {
dAtA[i] = 0x18
i -= len(*m.TopicID)
i++
copy(dAtA[i:], *m.TopicID)
i = encodeVarintRpc(dAtA, i, uint64(*m.Backoff))
i = encodeVarintRpc(dAtA, i, uint64(len(*m.TopicID)))
}
i--
if m.XXX_unrecognized != nil {
dAtA[i] = 0xa
i += copy(dAtA[i:], m.XXX_unrecognized)
}
}
return i, nil
return
len(dAtA) -
i, nil
}
}
func (m *PeerInfo) Marshal() (dAtA []byte, err error) {
func (m *PeerInfo) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -1275,32 +1333,40 @@ func (m *PeerInfo) Marshal() (dAtA []byte, err error) {
...
@@ -1275,32 +1333,40 @@ func (m *PeerInfo) Marshal() (dAtA []byte, err error) {
}
}
func (m *PeerInfo) MarshalTo(dAtA []byte) (int, error) {
func (m *PeerInfo) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *PeerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if m.PeerID != nil {
if m.XXX_unrecognized != nil {
dAtA[i] = 0xa
i -= len(m.XXX_unrecognized)
i++
copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerID)))
i += copy(dAtA[i:], m.PeerID)
}
}
if m.SignedPeerRecord != nil {
if m.SignedPeerRecord != nil {
dAtA[i] = 0x12
i -= len(m.SignedPeerRecord)
i++
copy(dAtA[i:], m.SignedPeerRecord)
i = encodeVarintRpc(dAtA, i, uint64(len(m.SignedPeerRecord)))
i = encodeVarintRpc(dAtA, i, uint64(len(m.SignedPeerRecord)))
i += copy(dAtA[i:], m.SignedPeerRecord)
i--
dAtA[i] = 0x12
}
}
if m.XXX_unrecognized != nil {
if m.PeerID != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
i -= len(m.PeerID)
copy(dAtA[i:], m.PeerID)
i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerID)))
i--
dAtA[i] = 0xa
}
}
return i, nil
return
len(dAtA) -
i, nil
}
}
func (m *TopicDescriptor) Marshal() (dAtA []byte, err error) {
func (m *TopicDescriptor) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -1308,46 +1374,57 @@ func (m *TopicDescriptor) Marshal() (dAtA []byte, err error) {
...
@@ -1308,46 +1374,57 @@ func (m *TopicDescriptor) Marshal() (dAtA []byte, err error) {
}
}
func (m *TopicDescriptor) MarshalTo(dAtA []byte) (int, error) {
func (m *TopicDescriptor) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *TopicDescriptor) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if m.Name != nil {
if m.XXX_unrecognized != nil {
dAtA[i] = 0xa
i -= len(m.XXX_unrecognized)
i++
copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintRpc(dAtA, i, uint64(len(*m.Name)))
i += copy(dAtA[i:], *m.Name)
}
if m.Auth != nil {
dAtA[i] = 0x12
i++
i = encodeVarintRpc(dAtA, i, uint64(m.Auth.Size()))
n2, err2 := m.Auth.MarshalTo(dAtA[i:])
if err2 != nil {
return 0, err2
}
i += n2
}
}
if m.Enc != nil {
if m.Enc != nil {
{
size, err := m.Enc.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintRpc(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x1a
dAtA[i] = 0x1a
i++
}
i = encodeVarintRpc(dAtA, i, uint64(m.Enc.Size()))
if m.Auth != nil {
n3, err3 := m.Enc.MarshalTo(dAtA[i:])
{
if err3 != nil {
size, err := m.Auth.MarshalToSizedBuffer(dAtA[:i])
return 0, err3
if err != nil {
return 0, err
}
i -= size
i = encodeVarintRpc(dAtA, i, uint64(size))
}
}
i += n3
i--
dAtA[i] = 0x12
}
}
if m.XXX_unrecognized != nil {
if m.Name != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
i -= len(*m.Name)
copy(dAtA[i:], *m.Name)
i = encodeVarintRpc(dAtA, i, uint64(len(*m.Name)))
i--
dAtA[i] = 0xa
}
}
return i, nil
return
len(dAtA) -
i, nil
}
}
func (m *TopicDescriptor_AuthOpts) Marshal() (dAtA []byte, err error) {
func (m *TopicDescriptor_AuthOpts) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -1355,33 +1432,40 @@ func (m *TopicDescriptor_AuthOpts) Marshal() (dAtA []byte, err error) {
...
@@ -1355,33 +1432,40 @@ func (m *TopicDescriptor_AuthOpts) Marshal() (dAtA []byte, err error) {
}
}
func (m *TopicDescriptor_AuthOpts) MarshalTo(dAtA []byte) (int, error) {
func (m *TopicDescriptor_AuthOpts) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *TopicDescriptor_AuthOpts) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if m.Mode != nil {
if m.XXX_unrecognized != nil {
dAtA[i] = 0x8
i -= len(m.XXX_unrecognized)
i++
copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintRpc(dAtA, i, uint64(*m.Mode))
}
}
if len(m.Keys) > 0 {
if len(m.Keys) > 0 {
for _, b := range m.Keys {
for iNdEx := len(m.Keys) - 1; iNdEx >= 0; iNdEx-- {
i -= len(m.Keys[iNdEx])
copy(dAtA[i:], m.Keys[iNdEx])
i = encodeVarintRpc(dAtA, i, uint64(len(m.Keys[iNdEx])))
i--
dAtA[i] = 0x12
dAtA[i] = 0x12
i++
i = encodeVarintRpc(dAtA, i, uint64(len(b)))
i += copy(dAtA[i:], b)
}
}
}
}
if m.XXX_unrecognized != nil {
if m.Mode != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintRpc(dAtA, i, uint64(*m.Mode))
i--
dAtA[i] = 0x8
}
}
return i, nil
return
len(dAtA) -
i, nil
}
}
func (m *TopicDescriptor_EncOpts) Marshal() (dAtA []byte, err error) {
func (m *TopicDescriptor_EncOpts) Marshal() (dAtA []byte, err error) {
size := m.Size()
size := m.Size()
dAtA = make([]byte, size)
dAtA = make([]byte, size)
n, err := m.MarshalTo
(dAtA
)
n, err := m.MarshalTo
SizedBuffer(dAtA[:size]
)
if err != nil {
if err != nil {
return nil, err
return nil, err
}
}
...
@@ -1389,37 +1473,46 @@ func (m *TopicDescriptor_EncOpts) Marshal() (dAtA []byte, err error) {
...
@@ -1389,37 +1473,46 @@ func (m *TopicDescriptor_EncOpts) Marshal() (dAtA []byte, err error) {
}
}
func (m *TopicDescriptor_EncOpts) MarshalTo(dAtA []byte) (int, error) {
func (m *TopicDescriptor_EncOpts) MarshalTo(dAtA []byte) (int, error) {
var i int
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *TopicDescriptor_EncOpts) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
_ = i
var l int
var l int
_ = l
_ = l
if m.Mode != nil {
if m.XXX_unrecognized != nil {
dAtA[i] = 0x8
i -= len(m.XXX_unrecognized)
i++
copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintRpc(dAtA, i, uint64(*m.Mode))
}
}
if len(m.KeyHashes) > 0 {
if len(m.KeyHashes) > 0 {
for _, b := range m.KeyHashes {
for iNdEx := len(m.KeyHashes) - 1; iNdEx >= 0; iNdEx-- {
i -= len(m.KeyHashes[iNdEx])
copy(dAtA[i:], m.KeyHashes[iNdEx])
i = encodeVarintRpc(dAtA, i, uint64(len(m.KeyHashes[iNdEx])))
i--
dAtA[i] = 0x12
dAtA[i] = 0x12
i++
i = encodeVarintRpc(dAtA, i, uint64(len(b)))
i += copy(dAtA[i:], b)
}
}
}
}
if m.XXX_unrecognized != nil {
if m.Mode != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
i = encodeVarintRpc(dAtA, i, uint64(*m.Mode))
i--
dAtA[i] = 0x8
}
}
return i, nil
return
len(dAtA) -
i, nil
}
}
func encodeVarintRpc(dAtA []byte, offset int, v uint64) int {
func encodeVarintRpc(dAtA []byte, offset int, v uint64) int {
offset -= sovRpc(v)
base := offset
for v >= 1<<7 {
for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80)
dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7
v >>= 7
offset++
offset++
}
}
dAtA[offset] = uint8(v)
dAtA[offset] = uint8(v)
return
offset + 1
return
base
}
}
func (m *RPC) Size() (n int) {
func (m *RPC) Size() (n int) {
if m == nil {
if m == nil {
...
@@ -1710,14 +1803,7 @@ func (m *TopicDescriptor_EncOpts) Size() (n int) {
...
@@ -1710,14 +1803,7 @@ func (m *TopicDescriptor_EncOpts) Size() (n int) {
}
}
func sovRpc(x uint64) (n int) {
func sovRpc(x uint64) (n int) {
for {
return (math_bits.Len64(x|1) + 6) / 7
n++
x >>= 7
if x == 0 {
break
}
}
return n
}
}
func sozRpc(x uint64) (n int) {
func sozRpc(x uint64) (n int) {
return sovRpc(uint64((x << 1) ^ uint64((int64(x) >> 63))))
return sovRpc(uint64((x << 1) ^ uint64((int64(x) >> 63))))
...
@@ -3363,6 +3449,7 @@ func (m *TopicDescriptor_EncOpts) Unmarshal(dAtA []byte) error {
...
@@ -3363,6 +3449,7 @@ func (m *TopicDescriptor_EncOpts) Unmarshal(dAtA []byte) error {
func skipRpc(dAtA []byte) (n int, err error) {
func skipRpc(dAtA []byte) (n int, err error) {
l := len(dAtA)
l := len(dAtA)
iNdEx := 0
iNdEx := 0
depth := 0
for iNdEx < l {
for iNdEx < l {
var wire uint64
var wire uint64
for shift := uint(0); ; shift += 7 {
for shift := uint(0); ; shift += 7 {
...
@@ -3394,10 +3481,8 @@ func skipRpc(dAtA []byte) (n int, err error) {
...
@@ -3394,10 +3481,8 @@ func skipRpc(dAtA []byte) (n int, err error) {
break
break
}
}
}
}
return iNdEx, nil
case 1:
case 1:
iNdEx += 8
iNdEx += 8
return iNdEx, nil
case 2:
case 2:
var length int
var length int
for shift := uint(0); ; shift += 7 {
for shift := uint(0); ; shift += 7 {
...
@@ -3418,55 +3503,30 @@ func skipRpc(dAtA []byte) (n int, err error) {
...
@@ -3418,55 +3503,30 @@ func skipRpc(dAtA []byte) (n int, err error) {
return 0, ErrInvalidLengthRpc
return 0, ErrInvalidLengthRpc
}
}
iNdEx += length
iNdEx += length
if iNdEx < 0 {
return 0, ErrInvalidLengthRpc
}
return iNdEx, nil
case 3:
case 3:
for {
depth++
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowRpc
}
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 := skipRpc(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
if iNdEx < 0 {
return 0, ErrInvalidLengthRpc
}
}
return iNdEx, nil
case 4:
case 4:
return iNdEx, nil
if depth == 0 {
return 0, ErrUnexpectedEndOfGroupRpc
}
depth--
case 5:
case 5:
iNdEx += 4
iNdEx += 4
return iNdEx, nil
default:
default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
}
}
if iNdEx < 0 {
return 0, ErrInvalidLengthRpc
}
if depth == 0 {
return iNdEx, nil
}
}
}
panic("unreachable")
return 0, io.ErrUnexpectedEOF
}
}
var (
var (
ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow")
ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group")
)
)
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment