Versions in this module Expand all Collapse all v0 v0.2.3 Feb 27, 2015 v0.2.2 Feb 27, 2015 Changes in this version + 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) inet.Connectedness + func PBPeerToPeerInfo(pbp *Message_Peer) peer.PeerInfo + func PBPeersToPeerInfos(pbps []*Message_Peer) []peer.PeerInfo + type Message struct + CloserPeers []*Message_Peer + ClusterLevelRaw *int32 + Key *string + ProviderPeers []*Message_Peer + Record *Record + Type *Message_MessageType + XXX_unrecognized []byte + func NewMessage(typ Message_MessageType, key string, level int) *Message + func (*Message) ProtoMessage() + func (m *Message) GetCloserPeers() []*Message_Peer + func (m *Message) GetClusterLevel() int + func (m *Message) GetClusterLevelRaw() int32 + func (m *Message) GetKey() string + func (m *Message) GetProviderPeers() []*Message_Peer + func (m *Message) GetRecord() *Record + func (m *Message) GetType() Message_MessageType + func (m *Message) Loggable() map[string]interface{} + func (m *Message) Reset() + func (m *Message) SetClusterLevel(level int) + func (m *Message) String() string + type Message_ConnectionType int32 + const Message_CANNOT_CONNECT + const Message_CAN_CONNECT + const Message_CONNECTED + const Message_NOT_CONNECTED + func ConnectionType(c inet.Connectedness) Message_ConnectionType + func (x *Message_ConnectionType) UnmarshalJSON(data []byte) error + func (x Message_ConnectionType) Enum() *Message_ConnectionType + 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 (x *Message_MessageType) UnmarshalJSON(data []byte) error + func (x Message_MessageType) Enum() *Message_MessageType + func (x Message_MessageType) String() string + type Message_Peer struct + Addrs [][]byte + Connection *Message_ConnectionType + Id *string + XXX_unrecognized []byte + func PeerInfosToPBPeers(n inet.Network, peers []peer.PeerInfo) []*Message_Peer + func PeerRoutingInfosToPBPeers(peers []PeerRoutingInfo) []*Message_Peer + func RawPeerInfosToPBPeers(peers []peer.PeerInfo) []*Message_Peer + 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) GetId() string + func (m *Message_Peer) Reset() + func (m *Message_Peer) String() string + type PeerRoutingInfo struct + type Record struct + Author *string + Key *string + Signature []byte + Value []byte + XXX_unrecognized []byte + func (*Record) ProtoMessage() + func (m *Record) GetAuthor() string + func (m *Record) GetKey() string + func (m *Record) GetSignature() []byte + func (m *Record) GetValue() []byte + func (m *Record) Reset() + func (m *Record) String() string