// Code generated by protoc-gen-gogo. DO NOT EDIT. // source: rpc.proto package pubsub_pb import ( fmt "fmt" proto "github.com/gogo/protobuf/proto" io "io" math "math" math_bits "math/bits" ) // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal var _ = fmt.Errorf var _ = math.Inf // This is a compile-time assertion to ensure that this generated file // 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.GoGoProtoPackageIsVersion3 // please upgrade the proto package type TopicDescriptor_AuthOpts_AuthMode int32 const ( TopicDescriptor_AuthOpts_NONE TopicDescriptor_AuthOpts_AuthMode = 0 TopicDescriptor_AuthOpts_KEY TopicDescriptor_AuthOpts_AuthMode = 1 TopicDescriptor_AuthOpts_WOT TopicDescriptor_AuthOpts_AuthMode = 2 ) var TopicDescriptor_AuthOpts_AuthMode_name = map[int32]string{ 0: "NONE", 1: "KEY", 2: "WOT", } var TopicDescriptor_AuthOpts_AuthMode_value = map[string]int32{ "NONE": 0, "KEY": 1, "WOT": 2, } func (x TopicDescriptor_AuthOpts_AuthMode) Enum() *TopicDescriptor_AuthOpts_AuthMode { p := new(TopicDescriptor_AuthOpts_AuthMode) *p = x return p } func (x TopicDescriptor_AuthOpts_AuthMode) String() string { return proto.EnumName(TopicDescriptor_AuthOpts_AuthMode_name, int32(x)) } func (x *TopicDescriptor_AuthOpts_AuthMode) UnmarshalJSON(data []byte) error { value, err := proto.UnmarshalJSONEnum(TopicDescriptor_AuthOpts_AuthMode_value, data, "TopicDescriptor_AuthOpts_AuthMode") if err != nil { return err } *x = TopicDescriptor_AuthOpts_AuthMode(value) return nil } func (TopicDescriptor_AuthOpts_AuthMode) EnumDescriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{8, 0, 0} } type TopicDescriptor_EncOpts_EncMode int32 const ( TopicDescriptor_EncOpts_NONE TopicDescriptor_EncOpts_EncMode = 0 TopicDescriptor_EncOpts_SHAREDKEY TopicDescriptor_EncOpts_EncMode = 1 TopicDescriptor_EncOpts_WOT TopicDescriptor_EncOpts_EncMode = 2 ) var TopicDescriptor_EncOpts_EncMode_name = map[int32]string{ 0: "NONE", 1: "SHAREDKEY", 2: "WOT", } var TopicDescriptor_EncOpts_EncMode_value = map[string]int32{ "NONE": 0, "SHAREDKEY": 1, "WOT": 2, } func (x TopicDescriptor_EncOpts_EncMode) Enum() *TopicDescriptor_EncOpts_EncMode { p := new(TopicDescriptor_EncOpts_EncMode) *p = x return p } func (x TopicDescriptor_EncOpts_EncMode) String() string { return proto.EnumName(TopicDescriptor_EncOpts_EncMode_name, int32(x)) } func (x *TopicDescriptor_EncOpts_EncMode) UnmarshalJSON(data []byte) error { value, err := proto.UnmarshalJSONEnum(TopicDescriptor_EncOpts_EncMode_value, data, "TopicDescriptor_EncOpts_EncMode") if err != nil { return err } *x = TopicDescriptor_EncOpts_EncMode(value) return nil } func (TopicDescriptor_EncOpts_EncMode) EnumDescriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{8, 1, 0} } type RPC struct { Subscriptions []*RPC_SubOpts `protobuf:"bytes,1,rep,name=subscriptions" json:"subscriptions,omitempty"` Publish []*Message `protobuf:"bytes,2,rep,name=publish" json:"publish,omitempty"` Control *ControlMessage `protobuf:"bytes,3,opt,name=control" json:"control,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *RPC) Reset() { *m = RPC{} } func (m *RPC) String() string { return proto.CompactTextString(m) } func (*RPC) ProtoMessage() {} func (*RPC) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{0} } func (m *RPC) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *RPC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_RPC.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *RPC) XXX_Merge(src proto.Message) { xxx_messageInfo_RPC.Merge(m, src) } func (m *RPC) XXX_Size() int { return m.Size() } func (m *RPC) XXX_DiscardUnknown() { xxx_messageInfo_RPC.DiscardUnknown(m) } var xxx_messageInfo_RPC proto.InternalMessageInfo func (m *RPC) GetSubscriptions() []*RPC_SubOpts { if m != nil { return m.Subscriptions } return nil } func (m *RPC) GetPublish() []*Message { if m != nil { return m.Publish } return nil } func (m *RPC) GetControl() *ControlMessage { if m != nil { return m.Control } return nil } type RPC_SubOpts struct { Subscribe *bool `protobuf:"varint,1,opt,name=subscribe" json:"subscribe,omitempty"` Topicid *string `protobuf:"bytes,2,opt,name=topicid" json:"topicid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *RPC_SubOpts) Reset() { *m = RPC_SubOpts{} } func (m *RPC_SubOpts) String() string { return proto.CompactTextString(m) } func (*RPC_SubOpts) ProtoMessage() {} func (*RPC_SubOpts) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{0, 0} } func (m *RPC_SubOpts) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *RPC_SubOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_RPC_SubOpts.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *RPC_SubOpts) XXX_Merge(src proto.Message) { xxx_messageInfo_RPC_SubOpts.Merge(m, src) } func (m *RPC_SubOpts) XXX_Size() int { return m.Size() } func (m *RPC_SubOpts) XXX_DiscardUnknown() { xxx_messageInfo_RPC_SubOpts.DiscardUnknown(m) } var xxx_messageInfo_RPC_SubOpts proto.InternalMessageInfo func (m *RPC_SubOpts) GetSubscribe() bool { if m != nil && m.Subscribe != nil { return *m.Subscribe } return false } func (m *RPC_SubOpts) GetTopicid() string { if m != nil && m.Topicid != nil { return *m.Topicid } return "" } type Message struct { From []byte `protobuf:"bytes,1,opt,name=from" json:"from,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"` Seqno []byte `protobuf:"bytes,3,opt,name=seqno" json:"seqno,omitempty"` TopicIDs []string `protobuf:"bytes,4,rep,name=topicIDs" json:"topicIDs,omitempty"` Signature []byte `protobuf:"bytes,5,opt,name=signature" json:"signature,omitempty"` Key []byte `protobuf:"bytes,6,opt,name=key" json:"key,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *Message) Reset() { *m = Message{} } func (m *Message) String() string { return proto.CompactTextString(m) } func (*Message) ProtoMessage() {} func (*Message) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{1} } func (m *Message) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Message.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Message) XXX_Merge(src proto.Message) { xxx_messageInfo_Message.Merge(m, src) } func (m *Message) XXX_Size() int { return m.Size() } func (m *Message) XXX_DiscardUnknown() { xxx_messageInfo_Message.DiscardUnknown(m) } var xxx_messageInfo_Message proto.InternalMessageInfo func (m *Message) GetFrom() []byte { if m != nil { return m.From } return nil } func (m *Message) GetData() []byte { if m != nil { return m.Data } return nil } func (m *Message) GetSeqno() []byte { if m != nil { return m.Seqno } return nil } func (m *Message) GetTopicIDs() []string { if m != nil { return m.TopicIDs } return nil } func (m *Message) GetSignature() []byte { if m != nil { return m.Signature } return nil } func (m *Message) GetKey() []byte { if m != nil { return m.Key } return nil } type ControlMessage struct { Ihave []*ControlIHave `protobuf:"bytes,1,rep,name=ihave" json:"ihave,omitempty"` Iwant []*ControlIWant `protobuf:"bytes,2,rep,name=iwant" json:"iwant,omitempty"` Graft []*ControlGraft `protobuf:"bytes,3,rep,name=graft" json:"graft,omitempty"` Prune []*ControlPrune `protobuf:"bytes,4,rep,name=prune" json:"prune,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ControlMessage) Reset() { *m = ControlMessage{} } func (m *ControlMessage) String() string { return proto.CompactTextString(m) } func (*ControlMessage) ProtoMessage() {} func (*ControlMessage) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{2} } func (m *ControlMessage) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ControlMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_ControlMessage.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *ControlMessage) XXX_Merge(src proto.Message) { xxx_messageInfo_ControlMessage.Merge(m, src) } func (m *ControlMessage) XXX_Size() int { return m.Size() } func (m *ControlMessage) XXX_DiscardUnknown() { xxx_messageInfo_ControlMessage.DiscardUnknown(m) } var xxx_messageInfo_ControlMessage proto.InternalMessageInfo func (m *ControlMessage) GetIhave() []*ControlIHave { if m != nil { return m.Ihave } return nil } func (m *ControlMessage) GetIwant() []*ControlIWant { if m != nil { return m.Iwant } return nil } func (m *ControlMessage) GetGraft() []*ControlGraft { if m != nil { return m.Graft } return nil } func (m *ControlMessage) GetPrune() []*ControlPrune { if m != nil { return m.Prune } return nil } type ControlIHave struct { 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ControlIHave) Reset() { *m = ControlIHave{} } func (m *ControlIHave) String() string { return proto.CompactTextString(m) } func (*ControlIHave) ProtoMessage() {} func (*ControlIHave) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{3} } func (m *ControlIHave) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ControlIHave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_ControlIHave.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *ControlIHave) XXX_Merge(src proto.Message) { xxx_messageInfo_ControlIHave.Merge(m, src) } func (m *ControlIHave) XXX_Size() int { return m.Size() } func (m *ControlIHave) XXX_DiscardUnknown() { xxx_messageInfo_ControlIHave.DiscardUnknown(m) } var xxx_messageInfo_ControlIHave proto.InternalMessageInfo func (m *ControlIHave) GetTopicID() string { if m != nil && m.TopicID != nil { return *m.TopicID } return "" } func (m *ControlIHave) GetMessageIDs() []string { if m != nil { return m.MessageIDs } return nil } 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ControlIWant) Reset() { *m = ControlIWant{} } func (m *ControlIWant) String() string { return proto.CompactTextString(m) } func (*ControlIWant) ProtoMessage() {} func (*ControlIWant) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{4} } func (m *ControlIWant) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ControlIWant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_ControlIWant.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *ControlIWant) XXX_Merge(src proto.Message) { xxx_messageInfo_ControlIWant.Merge(m, src) } func (m *ControlIWant) XXX_Size() int { return m.Size() } func (m *ControlIWant) XXX_DiscardUnknown() { xxx_messageInfo_ControlIWant.DiscardUnknown(m) } var xxx_messageInfo_ControlIWant proto.InternalMessageInfo func (m *ControlIWant) GetMessageIDs() []string { if m != nil { return m.MessageIDs } return nil } type ControlGraft struct { TopicID *string `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ControlGraft) Reset() { *m = ControlGraft{} } func (m *ControlGraft) String() string { return proto.CompactTextString(m) } func (*ControlGraft) ProtoMessage() {} func (*ControlGraft) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{5} } func (m *ControlGraft) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ControlGraft) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_ControlGraft.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *ControlGraft) XXX_Merge(src proto.Message) { xxx_messageInfo_ControlGraft.Merge(m, src) } func (m *ControlGraft) XXX_Size() int { return m.Size() } func (m *ControlGraft) XXX_DiscardUnknown() { xxx_messageInfo_ControlGraft.DiscardUnknown(m) } var xxx_messageInfo_ControlGraft proto.InternalMessageInfo func (m *ControlGraft) GetTopicID() string { if m != nil && m.TopicID != nil { return *m.TopicID } return "" } type ControlPrune struct { TopicID *string `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"` Peers []*PeerInfo `protobuf:"bytes,2,rep,name=peers" json:"peers,omitempty"` Backoff *uint64 `protobuf:"varint,3,opt,name=backoff" json:"backoff,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ControlPrune) Reset() { *m = ControlPrune{} } func (m *ControlPrune) String() string { return proto.CompactTextString(m) } func (*ControlPrune) ProtoMessage() {} func (*ControlPrune) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{6} } func (m *ControlPrune) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ControlPrune) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_ControlPrune.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *ControlPrune) XXX_Merge(src proto.Message) { xxx_messageInfo_ControlPrune.Merge(m, src) } func (m *ControlPrune) XXX_Size() int { return m.Size() } func (m *ControlPrune) XXX_DiscardUnknown() { xxx_messageInfo_ControlPrune.DiscardUnknown(m) } var xxx_messageInfo_ControlPrune proto.InternalMessageInfo func (m *ControlPrune) GetTopicID() string { if m != nil && m.TopicID != nil { return *m.TopicID } return "" } func (m *ControlPrune) GetPeers() []*PeerInfo { if m != nil { return m.Peers } return nil } func (m *ControlPrune) GetBackoff() uint64 { if m != nil && m.Backoff != nil { return *m.Backoff } return 0 } type PeerInfo struct { PeerID []byte `protobuf:"bytes,1,opt,name=peerID" json:"peerID,omitempty"` SignedPeerRecord []byte `protobuf:"bytes,2,opt,name=signedPeerRecord" json:"signedPeerRecord,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *PeerInfo) Reset() { *m = PeerInfo{} } func (m *PeerInfo) String() string { return proto.CompactTextString(m) } func (*PeerInfo) ProtoMessage() {} func (*PeerInfo) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{7} } func (m *PeerInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_PeerInfo.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *PeerInfo) XXX_Merge(src proto.Message) { xxx_messageInfo_PeerInfo.Merge(m, src) } func (m *PeerInfo) XXX_Size() int { return m.Size() } func (m *PeerInfo) XXX_DiscardUnknown() { xxx_messageInfo_PeerInfo.DiscardUnknown(m) } var xxx_messageInfo_PeerInfo proto.InternalMessageInfo func (m *PeerInfo) GetPeerID() []byte { if m != nil { return m.PeerID } return nil } func (m *PeerInfo) GetSignedPeerRecord() []byte { if m != nil { return m.SignedPeerRecord } return nil } type TopicDescriptor struct { Name *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Auth *TopicDescriptor_AuthOpts `protobuf:"bytes,2,opt,name=auth" json:"auth,omitempty"` Enc *TopicDescriptor_EncOpts `protobuf:"bytes,3,opt,name=enc" json:"enc,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *TopicDescriptor) Reset() { *m = TopicDescriptor{} } func (m *TopicDescriptor) String() string { return proto.CompactTextString(m) } func (*TopicDescriptor) ProtoMessage() {} func (*TopicDescriptor) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{8} } func (m *TopicDescriptor) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *TopicDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_TopicDescriptor.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *TopicDescriptor) XXX_Merge(src proto.Message) { xxx_messageInfo_TopicDescriptor.Merge(m, src) } func (m *TopicDescriptor) XXX_Size() int { return m.Size() } func (m *TopicDescriptor) XXX_DiscardUnknown() { xxx_messageInfo_TopicDescriptor.DiscardUnknown(m) } var xxx_messageInfo_TopicDescriptor proto.InternalMessageInfo func (m *TopicDescriptor) GetName() string { if m != nil && m.Name != nil { return *m.Name } return "" } func (m *TopicDescriptor) GetAuth() *TopicDescriptor_AuthOpts { if m != nil { return m.Auth } return nil } func (m *TopicDescriptor) GetEnc() *TopicDescriptor_EncOpts { if m != nil { return m.Enc } return nil } type TopicDescriptor_AuthOpts struct { Mode *TopicDescriptor_AuthOpts_AuthMode `protobuf:"varint,1,opt,name=mode,enum=pubsub.pb.TopicDescriptor_AuthOpts_AuthMode" json:"mode,omitempty"` Keys [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *TopicDescriptor_AuthOpts) Reset() { *m = TopicDescriptor_AuthOpts{} } func (m *TopicDescriptor_AuthOpts) String() string { return proto.CompactTextString(m) } func (*TopicDescriptor_AuthOpts) ProtoMessage() {} func (*TopicDescriptor_AuthOpts) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{8, 0} } func (m *TopicDescriptor_AuthOpts) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *TopicDescriptor_AuthOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_TopicDescriptor_AuthOpts.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *TopicDescriptor_AuthOpts) XXX_Merge(src proto.Message) { xxx_messageInfo_TopicDescriptor_AuthOpts.Merge(m, src) } func (m *TopicDescriptor_AuthOpts) XXX_Size() int { return m.Size() } func (m *TopicDescriptor_AuthOpts) XXX_DiscardUnknown() { xxx_messageInfo_TopicDescriptor_AuthOpts.DiscardUnknown(m) } var xxx_messageInfo_TopicDescriptor_AuthOpts proto.InternalMessageInfo func (m *TopicDescriptor_AuthOpts) GetMode() TopicDescriptor_AuthOpts_AuthMode { if m != nil && m.Mode != nil { return *m.Mode } return TopicDescriptor_AuthOpts_NONE } func (m *TopicDescriptor_AuthOpts) GetKeys() [][]byte { if m != nil { return m.Keys } return nil } type TopicDescriptor_EncOpts struct { Mode *TopicDescriptor_EncOpts_EncMode `protobuf:"varint,1,opt,name=mode,enum=pubsub.pb.TopicDescriptor_EncOpts_EncMode" json:"mode,omitempty"` KeyHashes [][]byte `protobuf:"bytes,2,rep,name=keyHashes" json:"keyHashes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *TopicDescriptor_EncOpts) Reset() { *m = TopicDescriptor_EncOpts{} } func (m *TopicDescriptor_EncOpts) String() string { return proto.CompactTextString(m) } func (*TopicDescriptor_EncOpts) ProtoMessage() {} func (*TopicDescriptor_EncOpts) Descriptor() ([]byte, []int) { return fileDescriptor_77a6da22d6a3feb1, []int{8, 1} } func (m *TopicDescriptor_EncOpts) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *TopicDescriptor_EncOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_TopicDescriptor_EncOpts.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *TopicDescriptor_EncOpts) XXX_Merge(src proto.Message) { xxx_messageInfo_TopicDescriptor_EncOpts.Merge(m, src) } func (m *TopicDescriptor_EncOpts) XXX_Size() int { return m.Size() } func (m *TopicDescriptor_EncOpts) XXX_DiscardUnknown() { xxx_messageInfo_TopicDescriptor_EncOpts.DiscardUnknown(m) } var xxx_messageInfo_TopicDescriptor_EncOpts proto.InternalMessageInfo func (m *TopicDescriptor_EncOpts) GetMode() TopicDescriptor_EncOpts_EncMode { if m != nil && m.Mode != nil { return *m.Mode } return TopicDescriptor_EncOpts_NONE } func (m *TopicDescriptor_EncOpts) GetKeyHashes() [][]byte { if m != nil { return m.KeyHashes } return nil } func init() { proto.RegisterEnum("pubsub.pb.TopicDescriptor_AuthOpts_AuthMode", TopicDescriptor_AuthOpts_AuthMode_name, TopicDescriptor_AuthOpts_AuthMode_value) proto.RegisterEnum("pubsub.pb.TopicDescriptor_EncOpts_EncMode", TopicDescriptor_EncOpts_EncMode_name, TopicDescriptor_EncOpts_EncMode_value) proto.RegisterType((*RPC)(nil), "pubsub.pb.RPC") proto.RegisterType((*RPC_SubOpts)(nil), "pubsub.pb.RPC.SubOpts") proto.RegisterType((*Message)(nil), "pubsub.pb.Message") proto.RegisterType((*ControlMessage)(nil), "pubsub.pb.ControlMessage") proto.RegisterType((*ControlIHave)(nil), "pubsub.pb.ControlIHave") proto.RegisterType((*ControlIWant)(nil), "pubsub.pb.ControlIWant") proto.RegisterType((*ControlGraft)(nil), "pubsub.pb.ControlGraft") proto.RegisterType((*ControlPrune)(nil), "pubsub.pb.ControlPrune") proto.RegisterType((*PeerInfo)(nil), "pubsub.pb.PeerInfo") proto.RegisterType((*TopicDescriptor)(nil), "pubsub.pb.TopicDescriptor") proto.RegisterType((*TopicDescriptor_AuthOpts)(nil), "pubsub.pb.TopicDescriptor.AuthOpts") proto.RegisterType((*TopicDescriptor_EncOpts)(nil), "pubsub.pb.TopicDescriptor.EncOpts") } func init() { proto.RegisterFile("rpc.proto", fileDescriptor_77a6da22d6a3feb1) } var fileDescriptor_77a6da22d6a3feb1 = []byte{ // 668 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x93, 0xcd, 0x6e, 0xd3, 0x4a, 0x14, 0xc7, 0xef, 0xc4, 0x49, 0x1d, 0x9f, 0xba, 0xbd, 0xd1, 0xdc, 0xab, 0x5e, 0xdf, 0xa8, 0x8a, 0x22, 0x23, 0xa1, 0x50, 0x8a, 0x17, 0x01, 0x89, 0x0d, 0x42, 0x94, 0x26, 0x22, 0x11, 0x6a, 0x1b, 0x4d, 0x2b, 0x55, 0x2c, 0x6d, 0x67, 0xd2, 0x58, 0x69, 0x3c, 0xc6, 0x1f, 0x45, 0x7d, 0x03, 0xf6, 0xf0, 0x2c, 0x3c, 0x03, 0x0b, 0x16, 0x3c, 0x02, 0xea, 0x8e, 0xb7, 0x40, 0x73, 0x3c, 0x4e, 0x9c, 0x7e, 0xc1, 0xca, 0x67, 0x8e, 0x7f, 0xff, 0x73, 0xfe, 0xe7, 0x78, 0x0c, 0x46, 0x1c, 0xf9, 0x4e, 0x14, 0x8b, 0x54, 0x50, 0x23, 0xca, 0xbc, 0x24, 0xf3, 0x9c, 0xc8, 0xb3, 0x7f, 0x12, 0xd0, 0xd8, 0x68, 0x9f, 0xbe, 0x80, 0x8d, 0x24, 0xf3, 0x12, 0x3f, 0x0e, 0xa2, 0x34, 0x10, 0x61, 0x62, 0x91, 0xb6, 0xd6, 0x59, 0xef, 0x6e, 0x39, 0x0b, 0xd4, 0x61, 0xa3, 0x7d, 0xe7, 0x38, 0xf3, 0x8e, 0xa2, 0x34, 0x61, 0xab, 0x30, 0xdd, 0x05, 0x3d, 0xca, 0xbc, 0xf3, 0x20, 0x99, 0x5a, 0x15, 0xd4, 0xd1, 0x92, 0xee, 0x80, 0x27, 0x89, 0x7b, 0xc6, 0x59, 0x81, 0xd0, 0xa7, 0xa0, 0xfb, 0x22, 0x4c, 0x63, 0x71, 0x6e, 0x69, 0x6d, 0xd2, 0x59, 0xef, 0xfe, 0x5f, 0xa2, 0xf7, 0xf3, 0x37, 0x0b, 0x91, 0x22, 0x9b, 0x7b, 0xa0, 0xab, 0xe6, 0x74, 0x1b, 0x0c, 0xd5, 0xde, 0xe3, 0x16, 0x69, 0x93, 0x4e, 0x9d, 0x2d, 0x13, 0xd4, 0x02, 0x3d, 0x15, 0x51, 0xe0, 0x07, 0x63, 0xab, 0xd2, 0x26, 0x1d, 0x83, 0x15, 0x47, 0xfb, 0x13, 0x01, 0x5d, 0xd5, 0xa5, 0x14, 0xaa, 0x93, 0x58, 0xcc, 0x51, 0x6e, 0x32, 0x8c, 0x65, 0x6e, 0xec, 0xa6, 0x2e, 0xca, 0x4c, 0x86, 0x31, 0xfd, 0x17, 0x6a, 0x09, 0x7f, 0x1f, 0x0a, 0x74, 0x6a, 0xb2, 0xfc, 0x40, 0x9b, 0x50, 0xc7, 0xa2, 0xc3, 0x5e, 0x62, 0x55, 0xdb, 0x5a, 0xc7, 0x60, 0x8b, 0x33, 0xba, 0x0b, 0xce, 0x42, 0x37, 0xcd, 0x62, 0x6e, 0xd5, 0x50, 0xb5, 0x4c, 0xd0, 0x06, 0x68, 0x33, 0x7e, 0x69, 0xad, 0x61, 0x5e, 0x86, 0xf6, 0x37, 0x02, 0x9b, 0xab, 0x43, 0xd3, 0x27, 0x50, 0x0b, 0xa6, 0xee, 0x05, 0x57, 0x1f, 0xe1, 0xbf, 0x9b, 0xeb, 0x19, 0x0e, 0xdc, 0x0b, 0xce, 0x72, 0x0a, 0xf1, 0x0f, 0x6e, 0x98, 0xaa, 0xdd, 0xdf, 0x86, 0x9f, 0xba, 0x61, 0xca, 0x72, 0x4a, 0xe2, 0x67, 0xb1, 0x3b, 0x49, 0x2d, 0xed, 0x2e, 0xfc, 0x8d, 0x7c, 0xcd, 0x72, 0x4a, 0xe2, 0x51, 0x9c, 0x85, 0x1c, 0x07, 0xbd, 0x15, 0x1f, 0xc9, 0xd7, 0x2c, 0xa7, 0xec, 0x01, 0x98, 0x65, 0x8f, 0x8b, 0xcf, 0x31, 0xec, 0xe1, 0xae, 0x8b, 0xcf, 0x31, 0xec, 0xd1, 0x16, 0xc0, 0x3c, 0x1f, 0x58, 0xae, 0xb1, 0x82, 0x6b, 0x2c, 0x65, 0x6c, 0x67, 0x59, 0x49, 0xda, 0xbf, 0xc6, 0x93, 0x1b, 0x7c, 0x67, 0xc1, 0xa3, 0xff, 0xbb, 0x3b, 0xdb, 0xf3, 0x05, 0x89, 0xd6, 0xef, 0xf1, 0xf8, 0x08, 0x6a, 0x11, 0xe7, 0x71, 0xa2, 0x56, 0xfb, 0x4f, 0x69, 0xf8, 0x11, 0xe7, 0xf1, 0x30, 0x9c, 0x08, 0x96, 0x13, 0xb2, 0x88, 0xe7, 0xfa, 0x33, 0x31, 0x99, 0xe0, 0x5d, 0xa9, 0xb2, 0xe2, 0x68, 0x1f, 0x42, 0xbd, 0x80, 0xe9, 0x16, 0xac, 0x49, 0x5c, 0x75, 0x32, 0x99, 0x3a, 0xd1, 0x1d, 0x68, 0xc8, 0x4b, 0xc2, 0xc7, 0x92, 0x64, 0xdc, 0x17, 0xf1, 0x58, 0xdd, 0xc3, 0x1b, 0x79, 0xfb, 0x8b, 0x06, 0x7f, 0x9f, 0x48, 0x83, 0x3d, 0x9e, 0xff, 0x83, 0x22, 0x96, 0x77, 0x37, 0x74, 0xe7, 0x5c, 0xf9, 0xc7, 0x98, 0x3e, 0x87, 0xaa, 0x9b, 0xa5, 0x53, 0xac, 0xb3, 0xde, 0x7d, 0x50, 0xf2, 0x7e, 0x4d, 0xed, 0xec, 0x65, 0xe9, 0x14, 0xff, 0x6b, 0x14, 0xd0, 0x67, 0xa0, 0xf1, 0xd0, 0x57, 0x3f, 0xa7, 0x7d, 0x8f, 0xae, 0x1f, 0xfa, 0x28, 0x93, 0x78, 0xf3, 0x23, 0x81, 0x7a, 0x51, 0x88, 0xbe, 0x82, 0xea, 0x5c, 0x8c, 0x73, 0x3f, 0x9b, 0xdd, 0xdd, 0x3f, 0xe8, 0x8d, 0xc1, 0x81, 0x18, 0x73, 0x86, 0x4a, 0x39, 0xd1, 0x8c, 0x5f, 0xe6, 0x9b, 0x37, 0x19, 0xc6, 0xf6, 0xc3, 0xbc, 0x83, 0xa4, 0x68, 0x1d, 0xaa, 0x87, 0x47, 0x87, 0xfd, 0xc6, 0x5f, 0x54, 0x07, 0xed, 0x6d, 0xff, 0x5d, 0x83, 0xc8, 0xe0, 0xf4, 0xe8, 0xa4, 0x51, 0x69, 0x7e, 0x26, 0xa0, 0x2b, 0x6f, 0xf4, 0xe5, 0x8a, 0x93, 0x9d, 0xdf, 0x4f, 0x23, 0x9f, 0x25, 0x1f, 0xdb, 0x60, 0xcc, 0xf8, 0xe5, 0xc0, 0x4d, 0xa6, 0xbc, 0x30, 0xb3, 0x4c, 0xd8, 0x8f, 0xb1, 0xd1, 0x35, 0x43, 0x1b, 0x60, 0x1c, 0x0f, 0xf6, 0x58, 0xbf, 0xb7, 0x6a, 0xeb, 0xb5, 0xf9, 0xf5, 0xaa, 0x45, 0xbe, 0x5f, 0xb5, 0xc8, 0x8f, 0xab, 0x16, 0xf9, 0x15, 0x00, 0x00, 0xff, 0xff, 0xd4, 0xb4, 0x37, 0x28, 0x91, 0x05, 0x00, 0x00, } func (m *RPC) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *RPC) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *RPC) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.XXX_unrecognized != nil { i -= len(m.XXX_unrecognized) copy(dAtA[i:], m.XXX_unrecognized) } if m.Control != nil { { size, err := m.Control.MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintRpc(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x1a } if len(m.Publish) > 0 { for iNdEx := len(m.Publish) - 1; iNdEx >= 0; iNdEx-- { { size, err := m.Publish[iNdEx].MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintRpc(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x12 } } if len(m.Subscriptions) > 0 { for iNdEx := len(m.Subscriptions) - 1; iNdEx >= 0; iNdEx-- { { size, err := m.Subscriptions[iNdEx].MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintRpc(dAtA, i, uint64(size)) } i-- dAtA[i] = 0xa } } return len(dAtA) - i, nil } func (m *RPC_SubOpts) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *RPC_SubOpts) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *RPC_SubOpts) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = 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 { i-- if *m.Subscribe { dAtA[i] = 1 } else { dAtA[i] = 0 } i-- dAtA[i] = 0x8 } return len(dAtA) - i, nil } func (m *Message) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Message) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.XXX_unrecognized != nil { i -= len(m.XXX_unrecognized) copy(dAtA[i:], m.XXX_unrecognized) } if m.Key != nil { i -= len(m.Key) copy(dAtA[i:], m.Key) i = encodeVarintRpc(dAtA, i, uint64(len(m.Key))) i-- dAtA[i] = 0x32 } if m.Signature != nil { i -= len(m.Signature) copy(dAtA[i:], m.Signature) i = encodeVarintRpc(dAtA, i, uint64(len(m.Signature))) i-- dAtA[i] = 0x2a } if len(m.TopicIDs) > 0 { 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 } } if m.Seqno != nil { i -= len(m.Seqno) copy(dAtA[i:], m.Seqno) i = encodeVarintRpc(dAtA, i, uint64(len(m.Seqno))) i-- dAtA[i] = 0x1a } if m.Data != nil { i -= len(m.Data) copy(dAtA[i:], m.Data) i = encodeVarintRpc(dAtA, i, uint64(len(m.Data))) i-- dAtA[i] = 0x12 } if m.From != nil { i -= len(m.From) copy(dAtA[i:], m.From) i = encodeVarintRpc(dAtA, i, uint64(len(m.From))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *ControlMessage) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ControlMessage) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *ControlMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.XXX_unrecognized != nil { i -= len(m.XXX_unrecognized) copy(dAtA[i:], m.XXX_unrecognized) } if len(m.Prune) > 0 { for iNdEx := len(m.Prune) - 1; iNdEx >= 0; iNdEx-- { { size, err := m.Prune[iNdEx].MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintRpc(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x22 } } if len(m.Graft) > 0 { for iNdEx := len(m.Graft) - 1; iNdEx >= 0; iNdEx-- { { size, err := m.Graft[iNdEx].MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintRpc(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x1a } } if len(m.Iwant) > 0 { for iNdEx := len(m.Iwant) - 1; iNdEx >= 0; iNdEx-- { { size, err := m.Iwant[iNdEx].MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintRpc(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x12 } } if len(m.Ihave) > 0 { 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 len(dAtA) - i, nil } func (m *ControlIHave) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ControlIHave) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *ControlIHave) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.XXX_unrecognized != nil { i -= len(m.XXX_unrecognized) copy(dAtA[i:], m.XXX_unrecognized) } if len(m.MessageIDs) > 0 { 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 } } if m.TopicID != nil { i -= len(*m.TopicID) copy(dAtA[i:], *m.TopicID) i = encodeVarintRpc(dAtA, i, uint64(len(*m.TopicID))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *ControlIWant) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ControlIWant) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *ControlIWant) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.XXX_unrecognized != nil { i -= len(m.XXX_unrecognized) copy(dAtA[i:], m.XXX_unrecognized) } if len(m.MessageIDs) > 0 { 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 } } return len(dAtA) - i, nil } func (m *ControlGraft) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ControlGraft) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *ControlGraft) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = 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] = 0xa } return len(dAtA) - i, nil } func (m *ControlPrune) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ControlPrune) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *ControlPrune) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.XXX_unrecognized != nil { i -= len(m.XXX_unrecognized) copy(dAtA[i:], m.XXX_unrecognized) } if m.Backoff != nil { i = encodeVarintRpc(dAtA, i, uint64(*m.Backoff)) i-- dAtA[i] = 0x18 } if len(m.Peers) > 0 { for iNdEx := len(m.Peers) - 1; iNdEx >= 0; iNdEx-- { { size, err := m.Peers[iNdEx].MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintRpc(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x12 } } if m.TopicID != nil { i -= len(*m.TopicID) copy(dAtA[i:], *m.TopicID) i = encodeVarintRpc(dAtA, i, uint64(len(*m.TopicID))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *PeerInfo) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *PeerInfo) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *PeerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.XXX_unrecognized != nil { i -= len(m.XXX_unrecognized) copy(dAtA[i:], m.XXX_unrecognized) } if m.SignedPeerRecord != nil { i -= len(m.SignedPeerRecord) copy(dAtA[i:], m.SignedPeerRecord) i = encodeVarintRpc(dAtA, i, uint64(len(m.SignedPeerRecord))) i-- dAtA[i] = 0x12 } if m.PeerID != nil { i -= len(m.PeerID) copy(dAtA[i:], m.PeerID) i = encodeVarintRpc(dAtA, i, uint64(len(m.PeerID))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *TopicDescriptor) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *TopicDescriptor) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *TopicDescriptor) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.XXX_unrecognized != nil { i -= len(m.XXX_unrecognized) copy(dAtA[i:], m.XXX_unrecognized) } 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 } if m.Auth != nil { { size, err := m.Auth.MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintRpc(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x12 } if m.Name != nil { i -= len(*m.Name) copy(dAtA[i:], *m.Name) i = encodeVarintRpc(dAtA, i, uint64(len(*m.Name))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *TopicDescriptor_AuthOpts) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *TopicDescriptor_AuthOpts) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *TopicDescriptor_AuthOpts) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.XXX_unrecognized != nil { i -= len(m.XXX_unrecognized) copy(dAtA[i:], m.XXX_unrecognized) } if len(m.Keys) > 0 { 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 } } if m.Mode != nil { i = encodeVarintRpc(dAtA, i, uint64(*m.Mode)) i-- dAtA[i] = 0x8 } return len(dAtA) - i, nil } func (m *TopicDescriptor_EncOpts) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *TopicDescriptor_EncOpts) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *TopicDescriptor_EncOpts) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.XXX_unrecognized != nil { i -= len(m.XXX_unrecognized) copy(dAtA[i:], m.XXX_unrecognized) } if len(m.KeyHashes) > 0 { 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 } } if m.Mode != nil { i = encodeVarintRpc(dAtA, i, uint64(*m.Mode)) i-- dAtA[i] = 0x8 } return len(dAtA) - i, nil } func encodeVarintRpc(dAtA []byte, offset int, v uint64) int { offset -= sovRpc(v) base := offset for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) v >>= 7 offset++ } dAtA[offset] = uint8(v) return base } func (m *RPC) Size() (n int) { if m == nil { return 0 } var l int _ = l if len(m.Subscriptions) > 0 { for _, e := range m.Subscriptions { l = e.Size() n += 1 + l + sovRpc(uint64(l)) } } if len(m.Publish) > 0 { for _, e := range m.Publish { l = e.Size() n += 1 + l + sovRpc(uint64(l)) } } if m.Control != nil { l = m.Control.Size() n += 1 + l + sovRpc(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *RPC_SubOpts) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Subscribe != nil { n += 2 } if m.Topicid != nil { l = len(*m.Topicid) n += 1 + l + sovRpc(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *Message) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.From != nil { l = len(m.From) n += 1 + l + sovRpc(uint64(l)) } if m.Data != nil { l = len(m.Data) n += 1 + l + sovRpc(uint64(l)) } if m.Seqno != nil { l = len(m.Seqno) n += 1 + l + sovRpc(uint64(l)) } if len(m.TopicIDs) > 0 { for _, s := range m.TopicIDs { l = len(s) n += 1 + l + sovRpc(uint64(l)) } } if m.Signature != nil { l = len(m.Signature) n += 1 + l + sovRpc(uint64(l)) } if m.Key != nil { l = len(m.Key) n += 1 + l + sovRpc(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *ControlMessage) Size() (n int) { if m == nil { return 0 } var l int _ = l if len(m.Ihave) > 0 { for _, e := range m.Ihave { l = e.Size() n += 1 + l + sovRpc(uint64(l)) } } if len(m.Iwant) > 0 { for _, e := range m.Iwant { l = e.Size() n += 1 + l + sovRpc(uint64(l)) } } if len(m.Graft) > 0 { for _, e := range m.Graft { l = e.Size() n += 1 + l + sovRpc(uint64(l)) } } if len(m.Prune) > 0 { for _, e := range m.Prune { l = e.Size() n += 1 + l + sovRpc(uint64(l)) } } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *ControlIHave) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.TopicID != nil { l = len(*m.TopicID) n += 1 + l + sovRpc(uint64(l)) } if len(m.MessageIDs) > 0 { for _, s := range m.MessageIDs { l = len(s) n += 1 + l + sovRpc(uint64(l)) } } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *ControlIWant) Size() (n int) { if m == nil { return 0 } var l int _ = l if len(m.MessageIDs) > 0 { for _, s := range m.MessageIDs { l = len(s) n += 1 + l + sovRpc(uint64(l)) } } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *ControlGraft) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.TopicID != nil { l = len(*m.TopicID) n += 1 + l + sovRpc(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *ControlPrune) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.TopicID != nil { l = len(*m.TopicID) n += 1 + l + sovRpc(uint64(l)) } if len(m.Peers) > 0 { for _, e := range m.Peers { l = e.Size() n += 1 + l + sovRpc(uint64(l)) } } if m.Backoff != nil { n += 1 + sovRpc(uint64(*m.Backoff)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *PeerInfo) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.PeerID != nil { l = len(m.PeerID) n += 1 + l + sovRpc(uint64(l)) } if m.SignedPeerRecord != nil { l = len(m.SignedPeerRecord) n += 1 + l + sovRpc(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *TopicDescriptor) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Name != nil { l = len(*m.Name) n += 1 + l + sovRpc(uint64(l)) } if m.Auth != nil { l = m.Auth.Size() n += 1 + l + sovRpc(uint64(l)) } if m.Enc != nil { l = m.Enc.Size() n += 1 + l + sovRpc(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *TopicDescriptor_AuthOpts) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Mode != nil { n += 1 + sovRpc(uint64(*m.Mode)) } if len(m.Keys) > 0 { for _, b := range m.Keys { l = len(b) n += 1 + l + sovRpc(uint64(l)) } } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func (m *TopicDescriptor_EncOpts) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Mode != nil { n += 1 + sovRpc(uint64(*m.Mode)) } if len(m.KeyHashes) > 0 { for _, b := range m.KeyHashes { l = len(b) n += 1 + l + sovRpc(uint64(l)) } } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } return n } func sovRpc(x uint64) (n int) { return (math_bits.Len64(x|1) + 6) / 7 } func sozRpc(x uint64) (n int) { return sovRpc(uint64((x << 1) ^ uint64((int64(x) >> 63)))) } func (m *RPC) 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 ErrIntOverflowRpc } 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: RPC: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: RPC: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Subscriptions", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Subscriptions = append(m.Subscriptions, &RPC_SubOpts{}) if err := m.Subscriptions[len(m.Subscriptions)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Publish", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Publish = append(m.Publish, &Message{}) if err := m.Publish[len(m.Publish)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Control", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } if m.Control == nil { m.Control = &ControlMessage{} } if err := m.Control.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *RPC_SubOpts) 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 ErrIntOverflowRpc } 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: SubOpts: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: SubOpts: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Subscribe", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= int(b&0x7F) << shift if b < 0x80 { break } } b := bool(v != 0) m.Subscribe = &b case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Topicid", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } 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 ErrInvalidLengthRpc } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Topicid = &s iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Message) 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 ErrIntOverflowRpc } 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: Message: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Message: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field From", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.From = append(m.From[:0], dAtA[iNdEx:postIndex]...) if m.From == nil { m.From = []byte{} } iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Data = append(m.Data[:0], dAtA[iNdEx:postIndex]...) if m.Data == nil { m.Data = []byte{} } iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Seqno", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Seqno = append(m.Seqno[:0], dAtA[iNdEx:postIndex]...) if m.Seqno == nil { m.Seqno = []byte{} } iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TopicIDs", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } 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 ErrInvalidLengthRpc } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.TopicIDs = append(m.TopicIDs, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Signature", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Signature = append(m.Signature[:0], dAtA[iNdEx:postIndex]...) if m.Signature == nil { m.Signature = []byte{} } iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Key", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Key = append(m.Key[:0], dAtA[iNdEx:postIndex]...) if m.Key == nil { m.Key = []byte{} } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ControlMessage) 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 ErrIntOverflowRpc } 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: ControlMessage: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ControlMessage: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Ihave", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Ihave = append(m.Ihave, &ControlIHave{}) if err := m.Ihave[len(m.Ihave)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Iwant", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Iwant = append(m.Iwant, &ControlIWant{}) if err := m.Iwant[len(m.Iwant)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Graft", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Graft = append(m.Graft, &ControlGraft{}) if err := m.Graft[len(m.Graft)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Prune", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Prune = append(m.Prune, &ControlPrune{}) if err := m.Prune[len(m.Prune)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ControlIHave) 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 ErrIntOverflowRpc } 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: ControlIHave: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ControlIHave: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TopicID", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } 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 ErrInvalidLengthRpc } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.TopicID = &s iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field MessageIDs", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } 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 ErrInvalidLengthRpc } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.MessageIDs = append(m.MessageIDs, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ControlIWant) 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 ErrIntOverflowRpc } 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: ControlIWant: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ControlIWant: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field MessageIDs", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } 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 ErrInvalidLengthRpc } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.MessageIDs = append(m.MessageIDs, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ControlGraft) 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 ErrIntOverflowRpc } 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: ControlGraft: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ControlGraft: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TopicID", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } 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 ErrInvalidLengthRpc } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.TopicID = &s iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ControlPrune) 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 ErrIntOverflowRpc } 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: ControlPrune: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ControlPrune: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TopicID", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } 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 ErrInvalidLengthRpc } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.TopicID = &s iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Peers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Peers = append(m.Peers, &PeerInfo{}) if err := m.Peers[len(m.Peers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 3: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Backoff", wireType) } var v uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= uint64(b&0x7F) << shift if b < 0x80 { break } } m.Backoff = &v default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PeerInfo) 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 ErrIntOverflowRpc } 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: PeerInfo: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PeerInfo: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field PeerID", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.PeerID = append(m.PeerID[:0], dAtA[iNdEx:postIndex]...) if m.PeerID == nil { m.PeerID = []byte{} } iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SignedPeerRecord", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.SignedPeerRecord = append(m.SignedPeerRecord[:0], dAtA[iNdEx:postIndex]...) if m.SignedPeerRecord == nil { m.SignedPeerRecord = []byte{} } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *TopicDescriptor) 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 ErrIntOverflowRpc } 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: TopicDescriptor: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: TopicDescriptor: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } 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 ErrInvalidLengthRpc } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } s := string(dAtA[iNdEx:postIndex]) m.Name = &s iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Auth", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } if m.Auth == nil { m.Auth = &TopicDescriptor_AuthOpts{} } if err := m.Auth.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Enc", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } if m.Enc == nil { m.Enc = &TopicDescriptor_EncOpts{} } if err := m.Enc.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *TopicDescriptor_AuthOpts) 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 ErrIntOverflowRpc } 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: AuthOpts: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: AuthOpts: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Mode", wireType) } var v TopicDescriptor_AuthOpts_AuthMode for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= TopicDescriptor_AuthOpts_AuthMode(b&0x7F) << shift if b < 0x80 { break } } m.Mode = &v case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Keys", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.Keys = append(m.Keys, make([]byte, postIndex-iNdEx)) copy(m.Keys[len(m.Keys)-1], dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *TopicDescriptor_EncOpts) 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 ErrIntOverflowRpc } 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: EncOpts: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: EncOpts: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Mode", wireType) } var v TopicDescriptor_EncOpts_EncMode for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= TopicDescriptor_EncOpts_EncMode(b&0x7F) << shift if b < 0x80 { break } } m.Mode = &v case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field KeyHashes", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowRpc } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthRpc } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthRpc } if postIndex > l { return io.ErrUnexpectedEOF } m.KeyHashes = append(m.KeyHashes, make([]byte, postIndex-iNdEx)) copy(m.KeyHashes[len(m.KeyHashes)-1], dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipRpc(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) < 0 { return ErrInvalidLengthRpc } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func skipRpc(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 depth := 0 for iNdEx < l { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowRpc } 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, ErrIntOverflowRpc } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } iNdEx++ if dAtA[iNdEx-1] < 0x80 { break } } case 1: iNdEx += 8 case 2: var length int for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowRpc } 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, ErrInvalidLengthRpc } iNdEx += length case 3: depth++ case 4: if depth == 0 { return 0, ErrUnexpectedEndOfGroupRpc } depth-- case 5: iNdEx += 4 default: return 0, fmt.Errorf("proto: illegal wireType %d", wireType) } if iNdEx < 0 { return 0, ErrInvalidLengthRpc } if depth == 0 { return iNdEx, nil } } return 0, io.ErrUnexpectedEOF } var ( ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group") )