p2p

package
v0.35.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 20, 2022 License: Apache-2.0 Imports: 9 Imported by: 80

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthConn        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConn          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupConn = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPex        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPex          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPex = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type AuthSigMessage 

type AuthSigMessage struct {
	PubKey crypto.PublicKey `protobuf:"bytes,1,opt,name=pub_key,json=pubKey,proto3" json:"pub_key"`
	Sig    []byte           `protobuf:"bytes,2,opt,name=sig,proto3" json:"sig,omitempty"`
}

func (*AuthSigMessage) Descriptor 

func (*AuthSigMessage) Descriptor() ([]byte, []int)

func (*AuthSigMessage) GetPubKey 

func (m *AuthSigMessage) GetPubKey() crypto.PublicKey

func (*AuthSigMessage) GetSig 

func (m *AuthSigMessage) GetSig() []byte

func (*AuthSigMessage) Marshal 

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

func (*AuthSigMessage) MarshalTo 

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

func (*AuthSigMessage) MarshalToSizedBuffer 

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

func (*AuthSigMessage) ProtoMessage 

func (*AuthSigMessage) ProtoMessage()

func (*AuthSigMessage) Reset 

func (m *AuthSigMessage) Reset()

func (*AuthSigMessage) Size 

func (m *AuthSigMessage) Size() (n int)

func (*AuthSigMessage) String 

func (m *AuthSigMessage) String() string

func (*AuthSigMessage) Unmarshal 

func (m *AuthSigMessage) Unmarshal(dAtA []byte) error

func (*AuthSigMessage) XXX_DiscardUnknown 

func (m *AuthSigMessage) XXX_DiscardUnknown()

func (*AuthSigMessage) XXX_Marshal 

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

func (*AuthSigMessage) XXX_Merge 

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

func (*AuthSigMessage) XXX_Size 

func (m *AuthSigMessage) XXX_Size() int

func (*AuthSigMessage) XXX_Unmarshal 

func (m *AuthSigMessage) XXX_Unmarshal(b []byte) error

type NodeInfo added in v0.35.0 

type NodeInfo struct {
	ProtocolVersion ProtocolVersion `protobuf:"bytes,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version"`
	NodeID          string          `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ListenAddr      string          `protobuf:"bytes,3,opt,name=listen_addr,json=listenAddr,proto3" json:"listen_addr,omitempty"`
	Network         string          `protobuf:"bytes,4,opt,name=network,proto3" json:"network,omitempty"`
	Version         string          `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Channels        []byte          `protobuf:"bytes,6,opt,name=channels,proto3" json:"channels,omitempty"`
	Moniker         string          `protobuf:"bytes,7,opt,name=moniker,proto3" json:"moniker,omitempty"`
	Other           NodeInfoOther   `protobuf:"bytes,8,opt,name=other,proto3" json:"other"`
}

func (*NodeInfo) Descriptor added in v0.35.0 

func (*NodeInfo) Descriptor() ([]byte, []int)

func (*NodeInfo) GetChannels added in v0.35.0 

func (m *NodeInfo) GetChannels() []byte

func (*NodeInfo) GetListenAddr added in v0.35.0 

func (m *NodeInfo) GetListenAddr() string

func (*NodeInfo) GetMoniker added in v0.35.0 

func (m *NodeInfo) GetMoniker() string

func (*NodeInfo) GetNetwork added in v0.35.0 

func (m *NodeInfo) GetNetwork() string

func (*NodeInfo) GetNodeID added in v0.35.0 

func (m *NodeInfo) GetNodeID() string

func (*NodeInfo) GetOther added in v0.35.0 

func (m *NodeInfo) GetOther() NodeInfoOther

func (*NodeInfo) GetProtocolVersion added in v0.35.0 

func (m *NodeInfo) GetProtocolVersion() ProtocolVersion

func (*NodeInfo) GetVersion added in v0.35.0 

func (m *NodeInfo) GetVersion() string

func (*NodeInfo) Marshal added in v0.35.0 

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

func (*NodeInfo) MarshalTo added in v0.35.0 

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

func (*NodeInfo) MarshalToSizedBuffer added in v0.35.0 

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

func (*NodeInfo) ProtoMessage added in v0.35.0 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset added in v0.35.0 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size added in v0.35.0 

func (m *NodeInfo) Size() (n int)

func (*NodeInfo) String added in v0.35.0 

func (m *NodeInfo) String() string

func (*NodeInfo) Unmarshal added in v0.35.0 

func (m *NodeInfo) Unmarshal(dAtA []byte) error

func (*NodeInfo) XXX_DiscardUnknown added in v0.35.0 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal added in v0.35.0 

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

func (*NodeInfo) XXX_Merge added in v0.35.0 

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

func (*NodeInfo) XXX_Size added in v0.35.0 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal added in v0.35.0 

func (m *NodeInfo) XXX_Unmarshal(b []byte) error

type NodeInfoOther added in v0.35.0 

type NodeInfoOther struct {
	TxIndex    string `protobuf:"bytes,1,opt,name=tx_index,json=txIndex,proto3" json:"tx_index,omitempty"`
	RPCAddress string `protobuf:"bytes,2,opt,name=rpc_address,json=rpcAddress,proto3" json:"rpc_address,omitempty"`
}

func (*NodeInfoOther) Descriptor added in v0.35.0 

func (*NodeInfoOther) Descriptor() ([]byte, []int)

func (*NodeInfoOther) GetRPCAddress added in v0.35.0 

func (m *NodeInfoOther) GetRPCAddress() string

func (*NodeInfoOther) GetTxIndex added in v0.35.0 

func (m *NodeInfoOther) GetTxIndex() string

func (*NodeInfoOther) Marshal added in v0.35.0 

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

func (*NodeInfoOther) MarshalTo added in v0.35.0 

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

func (*NodeInfoOther) MarshalToSizedBuffer added in v0.35.0 

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

func (*NodeInfoOther) ProtoMessage added in v0.35.0 

func (*NodeInfoOther) ProtoMessage()

func (*NodeInfoOther) Reset added in v0.35.0 

func (m *NodeInfoOther) Reset()

func (*NodeInfoOther) Size added in v0.35.0 

func (m *NodeInfoOther) Size() (n int)

func (*NodeInfoOther) String added in v0.35.0 

func (m *NodeInfoOther) String() string

func (*NodeInfoOther) Unmarshal added in v0.35.0 

func (m *NodeInfoOther) Unmarshal(dAtA []byte) error

func (*NodeInfoOther) XXX_DiscardUnknown added in v0.35.0 

func (m *NodeInfoOther) XXX_DiscardUnknown()

func (*NodeInfoOther) XXX_Marshal added in v0.35.0 

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

func (*NodeInfoOther) XXX_Merge added in v0.35.0 

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

func (*NodeInfoOther) XXX_Size added in v0.35.0 

func (m *NodeInfoOther) XXX_Size() int

func (*NodeInfoOther) XXX_Unmarshal added in v0.35.0 

func (m *NodeInfoOther) XXX_Unmarshal(b []byte) error

type Packet 

type Packet struct {
	// Types that are valid to be assigned to Sum:
	//	*Packet_PacketPing
	//	*Packet_PacketPong
	//	*Packet_PacketMsg
	Sum isPacket_Sum `protobuf_oneof:"sum"`
}

func (*Packet) Descriptor 

func (*Packet) Descriptor() ([]byte, []int)

func (*Packet) GetPacketMsg 

func (m *Packet) GetPacketMsg() *PacketMsg

func (*Packet) GetPacketPing 

func (m *Packet) GetPacketPing() *PacketPing

func (*Packet) GetPacketPong 

func (m *Packet) GetPacketPong() *PacketPong

func (*Packet) GetSum 

func (m *Packet) GetSum() isPacket_Sum

func (*Packet) Marshal 

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

func (*Packet) MarshalTo 

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

func (*Packet) MarshalToSizedBuffer 

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

func (*Packet) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) Reset 

func (m *Packet) Reset()

func (*Packet) Size 

func (m *Packet) Size() (n int)

func (*Packet) String 

func (m *Packet) String() string

func (*Packet) Unmarshal 

func (m *Packet) Unmarshal(dAtA []byte) error

func (*Packet) XXX_DiscardUnknown 

func (m *Packet) XXX_DiscardUnknown()

func (*Packet) XXX_Marshal 

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

func (*Packet) XXX_Merge 

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

func (*Packet) XXX_OneofWrappers 

func (*Packet) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Packet) XXX_Size 

func (m *Packet) XXX_Size() int

func (*Packet) XXX_Unmarshal 

func (m *Packet) XXX_Unmarshal(b []byte) error

type PacketMsg 

type PacketMsg struct {
	ChannelID int32  `protobuf:"varint,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	EOF       bool   `protobuf:"varint,2,opt,name=eof,proto3" json:"eof,omitempty"`
	Data      []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*PacketMsg) Descriptor 

func (*PacketMsg) Descriptor() ([]byte, []int)

func (*PacketMsg) GetChannelID 

func (m *PacketMsg) GetChannelID() int32

func (*PacketMsg) GetData 

func (m *PacketMsg) GetData() []byte

func (*PacketMsg) GetEOF 

func (m *PacketMsg) GetEOF() bool

func (*PacketMsg) Marshal 

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

func (*PacketMsg) MarshalTo 

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

func (*PacketMsg) MarshalToSizedBuffer 

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

func (*PacketMsg) ProtoMessage 

func (*PacketMsg) ProtoMessage()

func (*PacketMsg) Reset 

func (m *PacketMsg) Reset()

func (*PacketMsg) Size 

func (m *PacketMsg) Size() (n int)

func (*PacketMsg) String 

func (m *PacketMsg) String() string

func (*PacketMsg) Unmarshal 

func (m *PacketMsg) Unmarshal(dAtA []byte) error

func (*PacketMsg) XXX_DiscardUnknown 

func (m *PacketMsg) XXX_DiscardUnknown()

func (*PacketMsg) XXX_Marshal 

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

func (*PacketMsg) XXX_Merge 

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

func (*PacketMsg) XXX_Size 

func (m *PacketMsg) XXX_Size() int

func (*PacketMsg) XXX_Unmarshal 

func (m *PacketMsg) XXX_Unmarshal(b []byte) error

type PacketPing 

type PacketPing struct {
}

func (*PacketPing) Descriptor 

func (*PacketPing) Descriptor() ([]byte, []int)

func (*PacketPing) Marshal 

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

func (*PacketPing) MarshalTo 

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

func (*PacketPing) MarshalToSizedBuffer 

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

func (*PacketPing) ProtoMessage 

func (*PacketPing) ProtoMessage()

func (*PacketPing) Reset 

func (m *PacketPing) Reset()

func (*PacketPing) Size 

func (m *PacketPing) Size() (n int)

func (*PacketPing) String 

func (m *PacketPing) String() string

func (*PacketPing) Unmarshal 

func (m *PacketPing) Unmarshal(dAtA []byte) error

func (*PacketPing) XXX_DiscardUnknown 

func (m *PacketPing) XXX_DiscardUnknown()

func (*PacketPing) XXX_Marshal 

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

func (*PacketPing) XXX_Merge 

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

func (*PacketPing) XXX_Size 

func (m *PacketPing) XXX_Size() int

func (*PacketPing) XXX_Unmarshal 

func (m *PacketPing) XXX_Unmarshal(b []byte) error

type PacketPong 

type PacketPong struct {
}

func (*PacketPong) Descriptor 

func (*PacketPong) Descriptor() ([]byte, []int)

func (*PacketPong) Marshal 

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

func (*PacketPong) MarshalTo 

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

func (*PacketPong) MarshalToSizedBuffer 

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

func (*PacketPong) ProtoMessage 

func (*PacketPong) ProtoMessage()

func (*PacketPong) Reset 

func (m *PacketPong) Reset()

func (*PacketPong) Size 

func (m *PacketPong) Size() (n int)

func (*PacketPong) String 

func (m *PacketPong) String() string

func (*PacketPong) Unmarshal 

func (m *PacketPong) Unmarshal(dAtA []byte) error

func (*PacketPong) XXX_DiscardUnknown 

func (m *PacketPong) XXX_DiscardUnknown()

func (*PacketPong) XXX_Marshal 

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

func (*PacketPong) XXX_Merge 

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

func (*PacketPong) XXX_Size 

func (m *PacketPong) XXX_Size() int

func (*PacketPong) XXX_Unmarshal 

func (m *PacketPong) XXX_Unmarshal(b []byte) error

type Packet_PacketMsg 

type Packet_PacketMsg struct {
	PacketMsg *PacketMsg `protobuf:"bytes,3,opt,name=packet_msg,json=packetMsg,proto3,oneof" json:"packet_msg,omitempty"`
}

func (*Packet_PacketMsg) MarshalTo 

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

func (*Packet_PacketMsg) MarshalToSizedBuffer 

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

func (*Packet_PacketMsg) Size 

func (m *Packet_PacketMsg) Size() (n int)

type Packet_PacketPing 

type Packet_PacketPing struct {
	PacketPing *PacketPing `protobuf:"bytes,1,opt,name=packet_ping,json=packetPing,proto3,oneof" json:"packet_ping,omitempty"`
}

func (*Packet_PacketPing) MarshalTo 

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

func (*Packet_PacketPing) MarshalToSizedBuffer 

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

func (*Packet_PacketPing) Size 

func (m *Packet_PacketPing) Size() (n int)

type Packet_PacketPong 

type Packet_PacketPong struct {
	PacketPong *PacketPong `protobuf:"bytes,2,opt,name=packet_pong,json=packetPong,proto3,oneof" json:"packet_pong,omitempty"`
}

func (*Packet_PacketPong) MarshalTo 

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

func (*Packet_PacketPong) MarshalToSizedBuffer 

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

func (*Packet_PacketPong) Size 

func (m *Packet_PacketPong) Size() (n int)

type PeerAddressInfo added in v0.35.0 

type PeerAddressInfo struct {
	Address         string     `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	LastDialSuccess *time.Time `protobuf:"bytes,2,opt,name=last_dial_success,json=lastDialSuccess,proto3,stdtime" json:"last_dial_success,omitempty"`
	LastDialFailure *time.Time `protobuf:"bytes,3,opt,name=last_dial_failure,json=lastDialFailure,proto3,stdtime" json:"last_dial_failure,omitempty"`
	DialFailures    uint32     `protobuf:"varint,4,opt,name=dial_failures,json=dialFailures,proto3" json:"dial_failures,omitempty"`
}

func (*PeerAddressInfo) Descriptor added in v0.35.0 

func (*PeerAddressInfo) Descriptor() ([]byte, []int)

func (*PeerAddressInfo) GetAddress added in v0.35.0 

func (m *PeerAddressInfo) GetAddress() string

func (*PeerAddressInfo) GetDialFailures added in v0.35.0 

func (m *PeerAddressInfo) GetDialFailures() uint32

func (*PeerAddressInfo) GetLastDialFailure added in v0.35.0 

func (m *PeerAddressInfo) GetLastDialFailure() *time.Time

func (*PeerAddressInfo) GetLastDialSuccess added in v0.35.0 

func (m *PeerAddressInfo) GetLastDialSuccess() *time.Time

func (*PeerAddressInfo) Marshal added in v0.35.0 

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

func (*PeerAddressInfo) MarshalTo added in v0.35.0 

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

func (*PeerAddressInfo) MarshalToSizedBuffer added in v0.35.0 

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

func (*PeerAddressInfo) ProtoMessage added in v0.35.0 

func (*PeerAddressInfo) ProtoMessage()

func (*PeerAddressInfo) Reset added in v0.35.0 

func (m *PeerAddressInfo) Reset()

func (*PeerAddressInfo) Size added in v0.35.0 

func (m *PeerAddressInfo) Size() (n int)

func (*PeerAddressInfo) String added in v0.35.0 

func (m *PeerAddressInfo) String() string

func (*PeerAddressInfo) Unmarshal added in v0.35.0 

func (m *PeerAddressInfo) Unmarshal(dAtA []byte) error

func (*PeerAddressInfo) XXX_DiscardUnknown added in v0.35.0 

func (m *PeerAddressInfo) XXX_DiscardUnknown()

func (*PeerAddressInfo) XXX_Marshal added in v0.35.0 

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

func (*PeerAddressInfo) XXX_Merge added in v0.35.0 

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

func (*PeerAddressInfo) XXX_Size added in v0.35.0 

func (m *PeerAddressInfo) XXX_Size() int

func (*PeerAddressInfo) XXX_Unmarshal added in v0.35.0 

func (m *PeerAddressInfo) XXX_Unmarshal(b []byte) error

type PeerInfo added in v0.35.0 

type PeerInfo struct {
	ID            string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	AddressInfo   []*PeerAddressInfo `protobuf:"bytes,2,rep,name=address_info,json=addressInfo,proto3" json:"address_info,omitempty"`
	LastConnected *time.Time         `protobuf:"bytes,3,opt,name=last_connected,json=lastConnected,proto3,stdtime" json:"last_connected,omitempty"`
	Inactive      bool               `protobuf:"varint,4,opt,name=inactive,proto3" json:"inactive,omitempty"`
}

func (*PeerInfo) Descriptor added in v0.35.0 

func (*PeerInfo) Descriptor() ([]byte, []int)

func (*PeerInfo) GetAddressInfo added in v0.35.0 

func (m *PeerInfo) GetAddressInfo() []*PeerAddressInfo

func (*PeerInfo) GetID added in v0.35.0 

func (m *PeerInfo) GetID() string

func (*PeerInfo) GetInactive added in v0.35.7 

func (m *PeerInfo) GetInactive() bool

func (*PeerInfo) GetLastConnected added in v0.35.0 

func (m *PeerInfo) GetLastConnected() *time.Time

func (*PeerInfo) Marshal added in v0.35.0 

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

func (*PeerInfo) MarshalTo added in v0.35.0 

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

func (*PeerInfo) MarshalToSizedBuffer added in v0.35.0 

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

func (*PeerInfo) ProtoMessage added in v0.35.0 

func (*PeerInfo) ProtoMessage()

func (*PeerInfo) Reset added in v0.35.0 

func (m *PeerInfo) Reset()

func (*PeerInfo) Size added in v0.35.0 

func (m *PeerInfo) Size() (n int)

func (*PeerInfo) String added in v0.35.0 

func (m *PeerInfo) String() string

func (*PeerInfo) Unmarshal added in v0.35.0 

func (m *PeerInfo) Unmarshal(dAtA []byte) error

func (*PeerInfo) XXX_DiscardUnknown added in v0.35.0 

func (m *PeerInfo) XXX_DiscardUnknown()

func (*PeerInfo) XXX_Marshal added in v0.35.0 

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

func (*PeerInfo) XXX_Merge added in v0.35.0 

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

func (*PeerInfo) XXX_Size added in v0.35.0 

func (m *PeerInfo) XXX_Size() int

func (*PeerInfo) XXX_Unmarshal added in v0.35.0 

func (m *PeerInfo) XXX_Unmarshal(b []byte) error

type PexAddress added in v0.35.0 

type PexAddress struct {
	ID   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	IP   string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
}

func (*PexAddress) Descriptor added in v0.35.0 

func (*PexAddress) Descriptor() ([]byte, []int)

func (*PexAddress) GetID added in v0.35.0 

func (m *PexAddress) GetID() string

func (*PexAddress) GetIP added in v0.35.0 

func (m *PexAddress) GetIP() string

func (*PexAddress) GetPort added in v0.35.0 

func (m *PexAddress) GetPort() uint32

func (*PexAddress) Marshal added in v0.35.0 

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

func (*PexAddress) MarshalTo added in v0.35.0 

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

func (*PexAddress) MarshalToSizedBuffer added in v0.35.0 

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

func (*PexAddress) ProtoMessage added in v0.35.0 

func (*PexAddress) ProtoMessage()

func (*PexAddress) Reset added in v0.35.0 

func (m *PexAddress) Reset()

func (*PexAddress) Size added in v0.35.0 

func (m *PexAddress) Size() (n int)

func (*PexAddress) String added in v0.35.0 

func (m *PexAddress) String() string

func (*PexAddress) Unmarshal added in v0.35.0 

func (m *PexAddress) Unmarshal(dAtA []byte) error

func (*PexAddress) XXX_DiscardUnknown added in v0.35.0 

func (m *PexAddress) XXX_DiscardUnknown()

func (*PexAddress) XXX_Marshal added in v0.35.0 

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

func (*PexAddress) XXX_Merge added in v0.35.0 

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

func (*PexAddress) XXX_Size added in v0.35.0 

func (m *PexAddress) XXX_Size() int

func (*PexAddress) XXX_Unmarshal added in v0.35.0 

func (m *PexAddress) XXX_Unmarshal(b []byte) error

type PexAddressV2 added in v0.35.0 

type PexAddressV2 struct {
	URL string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
}

func (*PexAddressV2) Descriptor added in v0.35.0 

func (*PexAddressV2) Descriptor() ([]byte, []int)

func (*PexAddressV2) GetURL added in v0.35.0 

func (m *PexAddressV2) GetURL() string

func (*PexAddressV2) Marshal added in v0.35.0 

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

func (*PexAddressV2) MarshalTo added in v0.35.0 

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

func (*PexAddressV2) MarshalToSizedBuffer added in v0.35.0 

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

func (*PexAddressV2) ProtoMessage added in v0.35.0 

func (*PexAddressV2) ProtoMessage()

func (*PexAddressV2) Reset added in v0.35.0 

func (m *PexAddressV2) Reset()

func (*PexAddressV2) Size added in v0.35.0 

func (m *PexAddressV2) Size() (n int)

func (*PexAddressV2) String added in v0.35.0 

func (m *PexAddressV2) String() string

func (*PexAddressV2) Unmarshal added in v0.35.0 

func (m *PexAddressV2) Unmarshal(dAtA []byte) error

func (*PexAddressV2) XXX_DiscardUnknown added in v0.35.0 

func (m *PexAddressV2) XXX_DiscardUnknown()

func (*PexAddressV2) XXX_Marshal added in v0.35.0 

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

func (*PexAddressV2) XXX_Merge added in v0.35.0 

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

func (*PexAddressV2) XXX_Size added in v0.35.0 

func (m *PexAddressV2) XXX_Size() int

func (*PexAddressV2) XXX_Unmarshal added in v0.35.0 

func (m *PexAddressV2) XXX_Unmarshal(b []byte) error

type PexMessage added in v0.35.0 

type PexMessage struct {
	// Types that are valid to be assigned to Sum:
	//	*PexMessage_PexRequest
	//	*PexMessage_PexResponse
	//	*PexMessage_PexRequestV2
	//	*PexMessage_PexResponseV2
	Sum isPexMessage_Sum `protobuf_oneof:"sum"`
}

func (*PexMessage) Descriptor added in v0.35.0 

func (*PexMessage) Descriptor() ([]byte, []int)

func (*PexMessage) GetPexRequest added in v0.35.0 

func (m *PexMessage) GetPexRequest() *PexRequest

func (*PexMessage) GetPexRequestV2 added in v0.35.0 

func (m *PexMessage) GetPexRequestV2() *PexRequestV2

func (*PexMessage) GetPexResponse added in v0.35.0 

func (m *PexMessage) GetPexResponse() *PexResponse

func (*PexMessage) GetPexResponseV2 added in v0.35.0 

func (m *PexMessage) GetPexResponseV2() *PexResponseV2

func (*PexMessage) GetSum added in v0.35.0 

func (m *PexMessage) GetSum() isPexMessage_Sum

func (*PexMessage) Marshal added in v0.35.0 

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

func (*PexMessage) MarshalTo added in v0.35.0 

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

func (*PexMessage) MarshalToSizedBuffer added in v0.35.0 

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

func (*PexMessage) ProtoMessage added in v0.35.0 

func (*PexMessage) ProtoMessage()

func (*PexMessage) Reset added in v0.35.0 

func (m *PexMessage) Reset()

func (*PexMessage) Size added in v0.35.0 

func (m *PexMessage) Size() (n int)

func (*PexMessage) String added in v0.35.0 

func (m *PexMessage) String() string

func (*PexMessage) Unmarshal added in v0.35.0 

func (m *PexMessage) Unmarshal(dAtA []byte) error

func (*PexMessage) Unwrap added in v0.35.0 

func (m *PexMessage) Unwrap() (proto.Message, error)

Unwrap implements the p2p Wrapper interface and unwraps a wrapped PEX message.

func (*PexMessage) Wrap added in v0.35.0 

func (m *PexMessage) Wrap(pb proto.Message) error

Wrap implements the p2p Wrapper interface and wraps a PEX message.

func (*PexMessage) XXX_DiscardUnknown added in v0.35.0 

func (m *PexMessage) XXX_DiscardUnknown()

func (*PexMessage) XXX_Marshal added in v0.35.0 

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

func (*PexMessage) XXX_Merge added in v0.35.0 

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

func (*PexMessage) XXX_OneofWrappers added in v0.35.0 

func (*PexMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PexMessage) XXX_Size added in v0.35.0 

func (m *PexMessage) XXX_Size() int

func (*PexMessage) XXX_Unmarshal added in v0.35.0 

func (m *PexMessage) XXX_Unmarshal(b []byte) error

type PexMessage_PexRequest added in v0.35.0 

type PexMessage_PexRequest struct {
	PexRequest *PexRequest `protobuf:"bytes,1,opt,name=pex_request,json=pexRequest,proto3,oneof" json:"pex_request,omitempty"`
}

func (*PexMessage_PexRequest) MarshalTo added in v0.35.0 

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

func (*PexMessage_PexRequest) MarshalToSizedBuffer added in v0.35.0 

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

func (*PexMessage_PexRequest) Size added in v0.35.0 

func (m *PexMessage_PexRequest) Size() (n int)

type PexMessage_PexRequestV2 added in v0.35.0 

type PexMessage_PexRequestV2 struct {
	PexRequestV2 *PexRequestV2 `protobuf:"bytes,3,opt,name=pex_request_v2,json=pexRequestV2,proto3,oneof" json:"pex_request_v2,omitempty"`
}

func (*PexMessage_PexRequestV2) MarshalTo added in v0.35.0 

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

func (*PexMessage_PexRequestV2) MarshalToSizedBuffer added in v0.35.0 

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

func (*PexMessage_PexRequestV2) Size added in v0.35.0 

func (m *PexMessage_PexRequestV2) Size() (n int)

type PexMessage_PexResponse added in v0.35.0 

type PexMessage_PexResponse struct {
	PexResponse *PexResponse `protobuf:"bytes,2,opt,name=pex_response,json=pexResponse,proto3,oneof" json:"pex_response,omitempty"`
}

func (*PexMessage_PexResponse) MarshalTo added in v0.35.0 

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

func (*PexMessage_PexResponse) MarshalToSizedBuffer added in v0.35.0 

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

func (*PexMessage_PexResponse) Size added in v0.35.0 

func (m *PexMessage_PexResponse) Size() (n int)

type PexMessage_PexResponseV2 added in v0.35.0 

type PexMessage_PexResponseV2 struct {
	PexResponseV2 *PexResponseV2 `protobuf:"bytes,4,opt,name=pex_response_v2,json=pexResponseV2,proto3,oneof" json:"pex_response_v2,omitempty"`
}

func (*PexMessage_PexResponseV2) MarshalTo added in v0.35.0 

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

func (*PexMessage_PexResponseV2) MarshalToSizedBuffer added in v0.35.0 

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

func (*PexMessage_PexResponseV2) Size added in v0.35.0 

func (m *PexMessage_PexResponseV2) Size() (n int)

type PexRequest 

type PexRequest struct {
}

func (*PexRequest) Descriptor 

func (*PexRequest) Descriptor() ([]byte, []int)

func (*PexRequest) Marshal 

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

func (*PexRequest) MarshalTo 

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

func (*PexRequest) MarshalToSizedBuffer 

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

func (*PexRequest) ProtoMessage 

func (*PexRequest) ProtoMessage()

func (*PexRequest) Reset 

func (m *PexRequest) Reset()

func (*PexRequest) Size 

func (m *PexRequest) Size() (n int)

func (*PexRequest) String 

func (m *PexRequest) String() string

func (*PexRequest) Unmarshal 

func (m *PexRequest) Unmarshal(dAtA []byte) error

func (*PexRequest) XXX_DiscardUnknown 

func (m *PexRequest) XXX_DiscardUnknown()

func (*PexRequest) XXX_Marshal 

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

func (*PexRequest) XXX_Merge 

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

func (*PexRequest) XXX_Size 

func (m *PexRequest) XXX_Size() int

func (*PexRequest) XXX_Unmarshal 

func (m *PexRequest) XXX_Unmarshal(b []byte) error

type PexRequestV2 added in v0.35.0 

type PexRequestV2 struct {
}

func (*PexRequestV2) Descriptor added in v0.35.0 

func (*PexRequestV2) Descriptor() ([]byte, []int)

func (*PexRequestV2) Marshal added in v0.35.0 

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

func (*PexRequestV2) MarshalTo added in v0.35.0 

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

func (*PexRequestV2) MarshalToSizedBuffer added in v0.35.0 

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

func (*PexRequestV2) ProtoMessage added in v0.35.0 

func (*PexRequestV2) ProtoMessage()

func (*PexRequestV2) Reset added in v0.35.0 

func (m *PexRequestV2) Reset()

func (*PexRequestV2) Size added in v0.35.0 

func (m *PexRequestV2) Size() (n int)

func (*PexRequestV2) String added in v0.35.0 

func (m *PexRequestV2) String() string

func (*PexRequestV2) Unmarshal added in v0.35.0 

func (m *PexRequestV2) Unmarshal(dAtA []byte) error

func (*PexRequestV2) XXX_DiscardUnknown added in v0.35.0 

func (m *PexRequestV2) XXX_DiscardUnknown()

func (*PexRequestV2) XXX_Marshal added in v0.35.0 

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

func (*PexRequestV2) XXX_Merge added in v0.35.0 

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

func (*PexRequestV2) XXX_Size added in v0.35.0 

func (m *PexRequestV2) XXX_Size() int

func (*PexRequestV2) XXX_Unmarshal added in v0.35.0 

func (m *PexRequestV2) XXX_Unmarshal(b []byte) error

type PexResponse added in v0.35.0 

type PexResponse struct {
	Addresses []PexAddress `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses"`
}

func (*PexResponse) Descriptor added in v0.35.0 

func (*PexResponse) Descriptor() ([]byte, []int)

func (*PexResponse) GetAddresses added in v0.35.0 

func (m *PexResponse) GetAddresses() []PexAddress

func (*PexResponse) Marshal added in v0.35.0 

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

func (*PexResponse) MarshalTo added in v0.35.0 

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

func (*PexResponse) MarshalToSizedBuffer added in v0.35.0 

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

func (*PexResponse) ProtoMessage added in v0.35.0 

func (*PexResponse) ProtoMessage()

func (*PexResponse) Reset added in v0.35.0 

func (m *PexResponse) Reset()

func (*PexResponse) Size added in v0.35.0 

func (m *PexResponse) Size() (n int)

func (*PexResponse) String added in v0.35.0 

func (m *PexResponse) String() string

func (*PexResponse) Unmarshal added in v0.35.0 

func (m *PexResponse) Unmarshal(dAtA []byte) error

func (*PexResponse) XXX_DiscardUnknown added in v0.35.0 

func (m *PexResponse) XXX_DiscardUnknown()

func (*PexResponse) XXX_Marshal added in v0.35.0 

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

func (*PexResponse) XXX_Merge added in v0.35.0 

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

func (*PexResponse) XXX_Size added in v0.35.0 

func (m *PexResponse) XXX_Size() int

func (*PexResponse) XXX_Unmarshal added in v0.35.0 

func (m *PexResponse) XXX_Unmarshal(b []byte) error

type PexResponseV2 added in v0.35.0 

type PexResponseV2 struct {
	Addresses []PexAddressV2 `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses"`
}

func (*PexResponseV2) Descriptor added in v0.35.0 

func (*PexResponseV2) Descriptor() ([]byte, []int)

func (*PexResponseV2) GetAddresses added in v0.35.0 

func (m *PexResponseV2) GetAddresses() []PexAddressV2

func (*PexResponseV2) Marshal added in v0.35.0 

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

func (*PexResponseV2) MarshalTo added in v0.35.0 

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

func (*PexResponseV2) MarshalToSizedBuffer added in v0.35.0 

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

func (*PexResponseV2) ProtoMessage added in v0.35.0 

func (*PexResponseV2) ProtoMessage()

func (*PexResponseV2) Reset added in v0.35.0 

func (m *PexResponseV2) Reset()

func (*PexResponseV2) Size added in v0.35.0 

func (m *PexResponseV2) Size() (n int)

func (*PexResponseV2) String added in v0.35.0 

func (m *PexResponseV2) String() string

func (*PexResponseV2) Unmarshal added in v0.35.0 

func (m *PexResponseV2) Unmarshal(dAtA []byte) error

func (*PexResponseV2) XXX_DiscardUnknown added in v0.35.0 

func (m *PexResponseV2) XXX_DiscardUnknown()

func (*PexResponseV2) XXX_Marshal added in v0.35.0 

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

func (*PexResponseV2) XXX_Merge added in v0.35.0 

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

func (*PexResponseV2) XXX_Size added in v0.35.0 

func (m *PexResponseV2) XXX_Size() int

func (*PexResponseV2) XXX_Unmarshal added in v0.35.0 

func (m *PexResponseV2) XXX_Unmarshal(b []byte) error

type ProtocolVersion 

type ProtocolVersion struct {
	P2P   uint64 `protobuf:"varint,1,opt,name=p2p,proto3" json:"p2p,omitempty"`
	Block uint64 `protobuf:"varint,2,opt,name=block,proto3" json:"block,omitempty"`
	App   uint64 `protobuf:"varint,3,opt,name=app,proto3" json:"app,omitempty"`
}

func (*ProtocolVersion) Descriptor 

func (*ProtocolVersion) Descriptor() ([]byte, []int)

func (*ProtocolVersion) GetApp 

func (m *ProtocolVersion) GetApp() uint64

func (*ProtocolVersion) GetBlock 

func (m *ProtocolVersion) GetBlock() uint64

func (*ProtocolVersion) GetP2P 

func (m *ProtocolVersion) GetP2P() uint64

func (*ProtocolVersion) Marshal 

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

func (*ProtocolVersion) MarshalTo 

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

func (*ProtocolVersion) MarshalToSizedBuffer 

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

func (*ProtocolVersion) ProtoMessage 

func (*ProtocolVersion) ProtoMessage()

func (*ProtocolVersion) Reset 

func (m *ProtocolVersion) Reset()

func (*ProtocolVersion) Size 

func (m *ProtocolVersion) Size() (n int)

func (*ProtocolVersion) String 

func (m *ProtocolVersion) String() string

func (*ProtocolVersion) Unmarshal 

func (m *ProtocolVersion) Unmarshal(dAtA []byte) error

func (*ProtocolVersion) XXX_DiscardUnknown 

func (m *ProtocolVersion) XXX_DiscardUnknown()

func (*ProtocolVersion) XXX_Marshal 

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

func (*ProtocolVersion) XXX_Merge 

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

func (*ProtocolVersion) XXX_Size 

func (m *ProtocolVersion) XXX_Size() int

func (*ProtocolVersion) XXX_Unmarshal 

func (m *ProtocolVersion) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.