// Code generated by protoc-gen-gogo. DO NOT EDIT. // source: peer_record.proto package peer_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 // PeerRecord messages contain information that is useful to share with other peers. // Currently, a PeerRecord contains the public listen addresses for a peer, but this // is expected to expand to include other information in the future. // // PeerRecords are designed to be serialized to bytes and placed inside of // SignedEnvelopes before sharing with other peers. // See https://github.com/libp2p/go-libp2p-core/record/pb/envelope.proto for // the SignedEnvelope definition. type PeerRecord struct { // peer_id contains a libp2p peer id in its binary representation. PeerId []byte `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"` // seq contains a monotonically-increasing sequence counter to order PeerRecords in time. Seq uint64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"` // addresses is a list of public listen addresses for the peer. Addresses []*PeerRecord_AddressInfo `protobuf:"bytes,3,rep,name=addresses,proto3" json:"addresses,omitempty"` } func (m *PeerRecord) Reset() { *m = PeerRecord{} } func (m *PeerRecord) String() string { return proto.CompactTextString(m) } func (*PeerRecord) ProtoMessage() {} func (*PeerRecord) Descriptor() ([]byte, []int) { return fileDescriptor_dc0d8059ab0ad14d, []int{0} } func (m *PeerRecord) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PeerRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_PeerRecord.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 *PeerRecord) XXX_Merge(src proto.Message) { xxx_messageInfo_PeerRecord.Merge(m, src) } func (m *PeerRecord) XXX_Size() int { return m.Size() } func (m *PeerRecord) XXX_DiscardUnknown() { xxx_messageInfo_PeerRecord.DiscardUnknown(m) } var xxx_messageInfo_PeerRecord proto.InternalMessageInfo func (m *PeerRecord) GetPeerId() []byte { if m != nil { return m.PeerId } return nil } func (m *PeerRecord) GetSeq() uint64 { if m != nil { return m.Seq } return 0 } func (m *PeerRecord) GetAddresses() []*PeerRecord_AddressInfo { if m != nil { return m.Addresses } return nil } // AddressInfo is a wrapper around a binary multiaddr. It is defined as a // separate message to allow us to add per-address metadata in the future. type PeerRecord_AddressInfo struct { Multiaddr []byte `protobuf:"bytes,1,opt,name=multiaddr,proto3" json:"multiaddr,omitempty"` } func (m *PeerRecord_AddressInfo) Reset() { *m = PeerRecord_AddressInfo{} } func (m *PeerRecord_AddressInfo) String() string { return proto.CompactTextString(m) } func (*PeerRecord_AddressInfo) ProtoMessage() {} func (*PeerRecord_AddressInfo) Descriptor() ([]byte, []int) { return fileDescriptor_dc0d8059ab0ad14d, []int{0, 0} } func (m *PeerRecord_AddressInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PeerRecord_AddressInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_PeerRecord_AddressInfo.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 *PeerRecord_AddressInfo) XXX_Merge(src proto.Message) { xxx_messageInfo_PeerRecord_AddressInfo.Merge(m, src) } func (m *PeerRecord_AddressInfo) XXX_Size() int { return m.Size() } func (m *PeerRecord_AddressInfo) XXX_DiscardUnknown() { xxx_messageInfo_PeerRecord_AddressInfo.DiscardUnknown(m) } var xxx_messageInfo_PeerRecord_AddressInfo proto.InternalMessageInfo func (m *PeerRecord_AddressInfo) GetMultiaddr() []byte { if m != nil { return m.Multiaddr } return nil } func init() { proto.RegisterType((*PeerRecord)(nil), "peer.pb.PeerRecord") proto.RegisterType((*PeerRecord_AddressInfo)(nil), "peer.pb.PeerRecord.AddressInfo") } func init() { proto.RegisterFile("peer_record.proto", fileDescriptor_dc0d8059ab0ad14d) } var fileDescriptor_dc0d8059ab0ad14d = []byte{ // 189 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0x2c, 0x48, 0x4d, 0x2d, 0x8a, 0x2f, 0x4a, 0x4d, 0xce, 0x2f, 0x4a, 0xd1, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0x07, 0x09, 0xe9, 0x15, 0x24, 0x29, 0x2d, 0x66, 0xe4, 0xe2, 0x0a, 0x48, 0x4d, 0x2d, 0x0a, 0x02, 0xcb, 0x0a, 0x89, 0x73, 0x81, 0x65, 0xe2, 0x33, 0x53, 0x24, 0x18, 0x15, 0x18, 0x35, 0x78, 0x82, 0xd8, 0x40, 0x5c, 0xcf, 0x14, 0x21, 0x01, 0x2e, 0xe6, 0xe2, 0xd4, 0x42, 0x09, 0x26, 0x05, 0x46, 0x0d, 0x96, 0x20, 0x10, 0x53, 0xc8, 0x96, 0x8b, 0x33, 0x31, 0x25, 0xa5, 0x28, 0xb5, 0xb8, 0x38, 0xb5, 0x58, 0x82, 0x59, 0x81, 0x59, 0x83, 0xdb, 0x48, 0x5e, 0x0f, 0x6a, 0xac, 0x1e, 0xc2, 0x48, 0x3d, 0x47, 0x88, 0x22, 0xcf, 0xbc, 0xb4, 0xfc, 0x20, 0x84, 0x0e, 0x29, 0x6d, 0x2e, 0x6e, 0x24, 0x19, 0x21, 0x19, 0x2e, 0xce, 0xdc, 0xd2, 0x9c, 0x92, 0x4c, 0x90, 0x02, 0xa8, 0xd5, 0x08, 0x01, 0x27, 0x89, 0x13, 0x8f, 0xe4, 0x18, 0x2f, 0x3c, 0x92, 0x63, 0x7c, 0xf0, 0x48, 0x8e, 0x71, 0xc2, 0x63, 0x39, 0x86, 0x0b, 0x8f, 0xe5, 0x18, 0x6e, 0x3c, 0x96, 0x63, 0x48, 0x62, 0x03, 0xfb, 0xc7, 0x18, 0x10, 0x00, 0x00, 0xff, 0xff, 0xcb, 0x99, 0x56, 0x19, 0xe4, 0x00, 0x00, 0x00, } func (m *PeerRecord) 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 *PeerRecord) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *PeerRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if len(m.Addresses) > 0 { for iNdEx := len(m.Addresses) - 1; iNdEx >= 0; iNdEx-- { { size, err := m.Addresses[iNdEx].MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintPeerRecord(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x1a } } if m.Seq != 0 { i = encodeVarintPeerRecord(dAtA, i, uint64(m.Seq)) i-- dAtA[i] = 0x10 } if len(m.PeerId) > 0 { i -= len(m.PeerId) copy(dAtA[i:], m.PeerId) i = encodeVarintPeerRecord(dAtA, i, uint64(len(m.PeerId))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *PeerRecord_AddressInfo) 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 *PeerRecord_AddressInfo) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *PeerRecord_AddressInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if len(m.Multiaddr) > 0 { i -= len(m.Multiaddr) copy(dAtA[i:], m.Multiaddr) i = encodeVarintPeerRecord(dAtA, i, uint64(len(m.Multiaddr))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func encodeVarintPeerRecord(dAtA []byte, offset int, v uint64) int { offset -= sovPeerRecord(v) base := offset for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) v >>= 7 offset++ } dAtA[offset] = uint8(v) return base } func (m *PeerRecord) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.PeerId) if l > 0 { n += 1 + l + sovPeerRecord(uint64(l)) } if m.Seq != 0 { n += 1 + sovPeerRecord(uint64(m.Seq)) } if len(m.Addresses) > 0 { for _, e := range m.Addresses { l = e.Size() n += 1 + l + sovPeerRecord(uint64(l)) } } return n } func (m *PeerRecord_AddressInfo) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Multiaddr) if l > 0 { n += 1 + l + sovPeerRecord(uint64(l)) } return n } func sovPeerRecord(x uint64) (n int) { return (math_bits.Len64(x|1) + 6) / 7 } func sozPeerRecord(x uint64) (n int) { return sovPeerRecord(uint64((x << 1) ^ uint64((int64(x) >> 63)))) } func (m *PeerRecord) 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 ErrIntOverflowPeerRecord } 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: PeerRecord: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PeerRecord: 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 ErrIntOverflowPeerRecord } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthPeerRecord } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthPeerRecord } 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 != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Seq", wireType) } m.Seq = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowPeerRecord } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Seq |= uint64(b&0x7F) << shift if b < 0x80 { break } } case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Addresses", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowPeerRecord } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthPeerRecord } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthPeerRecord } if postIndex > l { return io.ErrUnexpectedEOF } m.Addresses = append(m.Addresses, &PeerRecord_AddressInfo{}) if err := m.Addresses[len(m.Addresses)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipPeerRecord(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthPeerRecord } if (iNdEx + skippy) < 0 { return ErrInvalidLengthPeerRecord } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PeerRecord_AddressInfo) 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 ErrIntOverflowPeerRecord } 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: AddressInfo: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: AddressInfo: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Multiaddr", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowPeerRecord } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthPeerRecord } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthPeerRecord } if postIndex > l { return io.ErrUnexpectedEOF } m.Multiaddr = append(m.Multiaddr[:0], dAtA[iNdEx:postIndex]...) if m.Multiaddr == nil { m.Multiaddr = []byte{} } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipPeerRecord(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthPeerRecord } if (iNdEx + skippy) < 0 { return ErrInvalidLengthPeerRecord } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func skipPeerRecord(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, ErrIntOverflowPeerRecord } 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, ErrIntOverflowPeerRecord } 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, ErrIntOverflowPeerRecord } 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, ErrInvalidLengthPeerRecord } iNdEx += length case 3: depth++ case 4: if depth == 0 { return 0, ErrUnexpectedEndOfGroupPeerRecord } depth-- case 5: iNdEx += 4 default: return 0, fmt.Errorf("proto: illegal wireType %d", wireType) } if iNdEx < 0 { return 0, ErrInvalidLengthPeerRecord } if depth == 0 { return iNdEx, nil } } return 0, io.ErrUnexpectedEOF } var ( ErrInvalidLengthPeerRecord = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPeerRecord = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPeerRecord = fmt.Errorf("proto: unexpected end of group") )