Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dht_pb

package

Go to main page

Versions in this module

v0

v0.20.1

Feb 12, 2023

v0.15.0

Mar 30, 2022

Changes in this version

+ var ErrIntOverflowDht = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthDht = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupDht = fmt.Errorf("proto: unexpected end of group")

+ var Message_ConnectionType_name = map[int32]string

+ var Message_ConnectionType_value = map[string]int32

+ var Message_MessageType_name = map[int32]string

+ var Message_MessageType_value = map[string]int32

+ func Connectedness(c Message_ConnectionType) network.Connectedness

+ func PBPeerToPeerInfo(pbp Message_Peer) peer.AddrInfo

+ func PBPeersToPeerInfos(pbps []Message_Peer) []*peer.AddrInfo

+ type Message struct

+ CloserPeers []Message_Peer

+ ClusterLevelRaw int32

+ Key []byte

+ ProviderPeers []Message_Peer

+ Record *pb.Record

+ Type Message_MessageType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewMessage(typ Message_MessageType, key []byte, level int) *Message

+ func (*Message) Descriptor() ([]byte, []int)

+ func (*Message) ProtoMessage()

+ func (m *Message) GetCloserPeers() []Message_Peer

+ func (m *Message) GetClusterLevel() int

+ func (m *Message) GetClusterLevelRaw() int32

+ func (m *Message) GetKey() []byte

+ func (m *Message) GetProviderPeers() []Message_Peer

+ func (m *Message) GetRecord() *pb.Record

+ func (m *Message) GetType() Message_MessageType

+ func (m *Message) Marshal() (dAtA []byte, err error)

+ func (m *Message) MarshalTo(dAtA []byte) (int, error)

+ func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Message) Reset()

+ func (m *Message) SetClusterLevel(level int)

+ func (m *Message) Size() (n int)

+ func (m *Message) String() string

+ func (m *Message) Unmarshal(dAtA []byte) error

+ func (m *Message) XXX_DiscardUnknown()

+ func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Message) XXX_Merge(src proto.Message)

+ func (m *Message) XXX_Size() int

+ func (m *Message) XXX_Unmarshal(b []byte) error

+ type MessageSender interface

+ SendMessage func(ctx context.Context, p peer.ID, pmes *Message) error

+ SendRequest func(ctx context.Context, p peer.ID, pmes *Message) (*Message, error)

+ type Message_ConnectionType int32

+ const Message_CANNOT_CONNECT

+ const Message_CAN_CONNECT

+ const Message_CONNECTED

+ const Message_NOT_CONNECTED

+ func ConnectionType(c network.Connectedness) Message_ConnectionType

+ func (Message_ConnectionType) EnumDescriptor() ([]byte, []int)

+ func (x Message_ConnectionType) String() string

+ type Message_MessageType int32

+ const Message_ADD_PROVIDER

+ const Message_FIND_NODE

+ const Message_GET_PROVIDERS

+ const Message_GET_VALUE

+ const Message_PING

+ const Message_PUT_VALUE

+ func (Message_MessageType) EnumDescriptor() ([]byte, []int)

+ func (x Message_MessageType) String() string

+ type Message_Peer struct

+ Addrs [][]byte

+ Connection Message_ConnectionType

+ Id byteString

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func PeerInfosToPBPeers(n network.Network, peers []peer.AddrInfo) []Message_Peer

+ func PeerRoutingInfosToPBPeers(peers []PeerRoutingInfo) []Message_Peer

+ func RawPeerInfosToPBPeers(peers []peer.AddrInfo) []Message_Peer

+ func (*Message_Peer) Descriptor() ([]byte, []int)

+ func (*Message_Peer) ProtoMessage()

+ func (m *Message_Peer) Addresses() []ma.Multiaddr

+ func (m *Message_Peer) GetAddrs() [][]byte

+ func (m *Message_Peer) GetConnection() Message_ConnectionType

+ func (m *Message_Peer) Marshal() (dAtA []byte, err error)

+ func (m *Message_Peer) MarshalTo(dAtA []byte) (int, error)

+ func (m *Message_Peer) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Message_Peer) Reset()

+ func (m *Message_Peer) Size() (n int)

+ func (m *Message_Peer) String() string

+ func (m *Message_Peer) Unmarshal(dAtA []byte) error

+ func (m *Message_Peer) XXX_DiscardUnknown()

+ func (m *Message_Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Message_Peer) XXX_Merge(src proto.Message)

+ func (m *Message_Peer) XXX_Size() int

+ func (m *Message_Peer) XXX_Unmarshal(b []byte) error

+ type PeerRoutingInfo struct

+ type ProtocolMessenger struct

+ func NewProtocolMessenger(msgSender MessageSender, opts ...ProtocolMessengerOption) (*ProtocolMessenger, error)

+ func (pm *ProtocolMessenger) GetClosestPeers(ctx context.Context, p peer.ID, id peer.ID) ([]*peer.AddrInfo, error)

+ func (pm *ProtocolMessenger) GetProviders(ctx context.Context, p peer.ID, key multihash.Multihash) ([]*peer.AddrInfo, []*peer.AddrInfo, error)

+ func (pm *ProtocolMessenger) GetValue(ctx context.Context, p peer.ID, key string) (*recpb.Record, []*peer.AddrInfo, error)

+ func (pm *ProtocolMessenger) Ping(ctx context.Context, p peer.ID) error

+ func (pm *ProtocolMessenger) PutProvider(ctx context.Context, p peer.ID, key multihash.Multihash, host host.Host) error

+ func (pm *ProtocolMessenger) PutValue(ctx context.Context, p peer.ID, rec *recpb.Record) error

+ type ProtocolMessengerOption func(*ProtocolMessenger) error

v0.15.0-daot.0

Apr 1, 2022