p2p

package
v0.8.14 Latest Latest
Warning

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

Go to latest
Published: Sep 15, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

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

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

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

func (*NodeInfo) GetChannels

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

func (*NodeInfo) GetListenAddr

func (m *NodeInfo) GetListenAddr() string

func (*NodeInfo) GetMoniker

func (m *NodeInfo) GetMoniker() string

func (*NodeInfo) GetNetwork

func (m *NodeInfo) GetNetwork() string

func (*NodeInfo) GetNodeID

func (m *NodeInfo) GetNodeID() string

func (*NodeInfo) GetOther

func (m *NodeInfo) GetOther() NodeInfoOther

func (*NodeInfo) GetProtocolVersion

func (m *NodeInfo) GetProtocolVersion() ProtocolVersion

func (*NodeInfo) GetVersion

func (m *NodeInfo) GetVersion() string

func (*NodeInfo) Marshal

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

func (*NodeInfo) MarshalTo

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

func (*NodeInfo) MarshalToSizedBuffer

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

func (*NodeInfo) ProtoMessage

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset

func (m *NodeInfo) Reset()

func (*NodeInfo) Size

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

func (*NodeInfo) String

func (m *NodeInfo) String() string

func (*NodeInfo) Unmarshal

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

func (*NodeInfo) XXX_DiscardUnknown

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal

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

func (*NodeInfo) XXX_Merge

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

func (*NodeInfo) XXX_Size

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal

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

type NodeInfoOther

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

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

func (*NodeInfoOther) GetRPCAddress

func (m *NodeInfoOther) GetRPCAddress() string

func (*NodeInfoOther) GetTxIndex

func (m *NodeInfoOther) GetTxIndex() string

func (*NodeInfoOther) Marshal

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

func (*NodeInfoOther) MarshalTo

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

func (*NodeInfoOther) MarshalToSizedBuffer

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

func (*NodeInfoOther) ProtoMessage

func (*NodeInfoOther) ProtoMessage()

func (*NodeInfoOther) Reset

func (m *NodeInfoOther) Reset()

func (*NodeInfoOther) Size

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

func (*NodeInfoOther) String

func (m *NodeInfoOther) String() string

func (*NodeInfoOther) Unmarshal

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

func (*NodeInfoOther) XXX_DiscardUnknown

func (m *NodeInfoOther) XXX_DiscardUnknown()

func (*NodeInfoOther) XXX_Marshal

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

func (*NodeInfoOther) XXX_Merge

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

func (*NodeInfoOther) XXX_Size

func (m *NodeInfoOther) XXX_Size() int

func (*NodeInfoOther) XXX_Unmarshal

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

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

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

func (*PeerAddressInfo) GetAddress

func (m *PeerAddressInfo) GetAddress() string

func (*PeerAddressInfo) GetDialFailures

func (m *PeerAddressInfo) GetDialFailures() uint32

func (*PeerAddressInfo) GetLastDialFailure

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

func (*PeerAddressInfo) GetLastDialSuccess

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

func (*PeerAddressInfo) Marshal

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

func (*PeerAddressInfo) MarshalTo

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

func (*PeerAddressInfo) MarshalToSizedBuffer

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

func (*PeerAddressInfo) ProtoMessage

func (*PeerAddressInfo) ProtoMessage()

func (*PeerAddressInfo) Reset

func (m *PeerAddressInfo) Reset()

func (*PeerAddressInfo) Size

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

func (*PeerAddressInfo) String

func (m *PeerAddressInfo) String() string

func (*PeerAddressInfo) Unmarshal

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

func (*PeerAddressInfo) XXX_DiscardUnknown

func (m *PeerAddressInfo) XXX_DiscardUnknown()

func (*PeerAddressInfo) XXX_Marshal

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

func (*PeerAddressInfo) XXX_Merge

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

func (*PeerAddressInfo) XXX_Size

func (m *PeerAddressInfo) XXX_Size() int

func (*PeerAddressInfo) XXX_Unmarshal

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

type PeerInfo

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"`
}

func (*PeerInfo) Descriptor

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

func (*PeerInfo) GetAddressInfo

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

func (*PeerInfo) GetID

func (m *PeerInfo) GetID() string

func (*PeerInfo) GetLastConnected

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

func (*PeerInfo) Marshal

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

func (*PeerInfo) MarshalTo

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

func (*PeerInfo) MarshalToSizedBuffer

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

func (*PeerInfo) ProtoMessage

func (*PeerInfo) ProtoMessage()

func (*PeerInfo) Reset

func (m *PeerInfo) Reset()

func (*PeerInfo) Size

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

func (*PeerInfo) String

func (m *PeerInfo) String() string

func (*PeerInfo) Unmarshal

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

func (*PeerInfo) XXX_DiscardUnknown

func (m *PeerInfo) XXX_DiscardUnknown()

func (*PeerInfo) XXX_Marshal

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

func (*PeerInfo) XXX_Merge

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

func (*PeerInfo) XXX_Size

func (m *PeerInfo) XXX_Size() int

func (*PeerInfo) XXX_Unmarshal

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

type PexAddress

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

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

func (*PexAddress) GetID

func (m *PexAddress) GetID() string

func (*PexAddress) GetIP

func (m *PexAddress) GetIP() string

func (*PexAddress) GetPort

func (m *PexAddress) GetPort() uint32

func (*PexAddress) Marshal

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

func (*PexAddress) MarshalTo

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

func (*PexAddress) MarshalToSizedBuffer

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

func (*PexAddress) ProtoMessage

func (*PexAddress) ProtoMessage()

func (*PexAddress) Reset

func (m *PexAddress) Reset()

func (*PexAddress) Size

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

func (*PexAddress) String

func (m *PexAddress) String() string

func (*PexAddress) Unmarshal

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

func (*PexAddress) XXX_DiscardUnknown

func (m *PexAddress) XXX_DiscardUnknown()

func (*PexAddress) XXX_Marshal

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

func (*PexAddress) XXX_Merge

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

func (*PexAddress) XXX_Size

func (m *PexAddress) XXX_Size() int

func (*PexAddress) XXX_Unmarshal

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

type PexAddressV2

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

func (*PexAddressV2) Descriptor

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

func (*PexAddressV2) GetURL

func (m *PexAddressV2) GetURL() string

func (*PexAddressV2) Marshal

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

func (*PexAddressV2) MarshalTo

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

func (*PexAddressV2) MarshalToSizedBuffer

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

func (*PexAddressV2) ProtoMessage

func (*PexAddressV2) ProtoMessage()

func (*PexAddressV2) Reset

func (m *PexAddressV2) Reset()

func (*PexAddressV2) Size

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

func (*PexAddressV2) String

func (m *PexAddressV2) String() string

func (*PexAddressV2) Unmarshal

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

func (*PexAddressV2) XXX_DiscardUnknown

func (m *PexAddressV2) XXX_DiscardUnknown()

func (*PexAddressV2) XXX_Marshal

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

func (*PexAddressV2) XXX_Merge

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

func (*PexAddressV2) XXX_Size

func (m *PexAddressV2) XXX_Size() int

func (*PexAddressV2) XXX_Unmarshal

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

type PexMessage

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

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

func (*PexMessage) GetPexRequest

func (m *PexMessage) GetPexRequest() *PexRequest

func (*PexMessage) GetPexRequestV2

func (m *PexMessage) GetPexRequestV2() *PexRequestV2

func (*PexMessage) GetPexResponse

func (m *PexMessage) GetPexResponse() *PexResponse

func (*PexMessage) GetPexResponseV2

func (m *PexMessage) GetPexResponseV2() *PexResponseV2

func (*PexMessage) GetSum

func (m *PexMessage) GetSum() isPexMessage_Sum

func (*PexMessage) Marshal

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

func (*PexMessage) MarshalTo

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

func (*PexMessage) MarshalToSizedBuffer

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

func (*PexMessage) ProtoMessage

func (*PexMessage) ProtoMessage()

func (*PexMessage) Reset

func (m *PexMessage) Reset()

func (*PexMessage) Size

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

func (*PexMessage) String

func (m *PexMessage) String() string

func (*PexMessage) Unmarshal

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

func (*PexMessage) Unwrap

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

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

func (*PexMessage) Wrap

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

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

func (*PexMessage) XXX_DiscardUnknown

func (m *PexMessage) XXX_DiscardUnknown()

func (*PexMessage) XXX_Marshal

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

func (*PexMessage) XXX_Merge

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

func (*PexMessage) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PexMessage) XXX_Size

func (m *PexMessage) XXX_Size() int

func (*PexMessage) XXX_Unmarshal

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

type PexMessage_PexRequest

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

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

func (*PexMessage_PexRequest) MarshalToSizedBuffer

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

func (*PexMessage_PexRequest) Size

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

type PexMessage_PexRequestV2

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

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

func (*PexMessage_PexRequestV2) MarshalToSizedBuffer

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

func (*PexMessage_PexRequestV2) Size

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

type PexMessage_PexResponse

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

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

func (*PexMessage_PexResponse) MarshalToSizedBuffer

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

func (*PexMessage_PexResponse) Size

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

type PexMessage_PexResponseV2

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

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

func (*PexMessage_PexResponseV2) MarshalToSizedBuffer

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

func (*PexMessage_PexResponseV2) Size

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

type PexRequestV2 struct {
}

func (*PexRequestV2) Descriptor

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

func (*PexRequestV2) Marshal

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

func (*PexRequestV2) MarshalTo

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

func (*PexRequestV2) MarshalToSizedBuffer

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

func (*PexRequestV2) ProtoMessage

func (*PexRequestV2) ProtoMessage()

func (*PexRequestV2) Reset

func (m *PexRequestV2) Reset()

func (*PexRequestV2) Size

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

func (*PexRequestV2) String

func (m *PexRequestV2) String() string

func (*PexRequestV2) Unmarshal

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

func (*PexRequestV2) XXX_DiscardUnknown

func (m *PexRequestV2) XXX_DiscardUnknown()

func (*PexRequestV2) XXX_Marshal

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

func (*PexRequestV2) XXX_Merge

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

func (*PexRequestV2) XXX_Size

func (m *PexRequestV2) XXX_Size() int

func (*PexRequestV2) XXX_Unmarshal

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

type PexResponse

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

func (*PexResponse) Descriptor

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

func (*PexResponse) GetAddresses

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

func (*PexResponse) Marshal

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

func (*PexResponse) MarshalTo

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

func (*PexResponse) MarshalToSizedBuffer

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

func (*PexResponse) ProtoMessage

func (*PexResponse) ProtoMessage()

func (*PexResponse) Reset

func (m *PexResponse) Reset()

func (*PexResponse) Size

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

func (*PexResponse) String

func (m *PexResponse) String() string

func (*PexResponse) Unmarshal

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

func (*PexResponse) XXX_DiscardUnknown

func (m *PexResponse) XXX_DiscardUnknown()

func (*PexResponse) XXX_Marshal

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

func (*PexResponse) XXX_Merge

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

func (*PexResponse) XXX_Size

func (m *PexResponse) XXX_Size() int

func (*PexResponse) XXX_Unmarshal

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

type PexResponseV2

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

func (*PexResponseV2) Descriptor

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

func (*PexResponseV2) GetAddresses

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

func (*PexResponseV2) Marshal

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

func (*PexResponseV2) MarshalTo

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

func (*PexResponseV2) MarshalToSizedBuffer

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

func (*PexResponseV2) ProtoMessage

func (*PexResponseV2) ProtoMessage()

func (*PexResponseV2) Reset

func (m *PexResponseV2) Reset()

func (*PexResponseV2) Size

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

func (*PexResponseV2) String

func (m *PexResponseV2) String() string

func (*PexResponseV2) Unmarshal

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

func (*PexResponseV2) XXX_DiscardUnknown

func (m *PexResponseV2) XXX_DiscardUnknown()

func (*PexResponseV2) XXX_Marshal

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

func (*PexResponseV2) XXX_Merge

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

func (*PexResponseV2) XXX_Size

func (m *PexResponseV2) XXX_Size() int

func (*PexResponseV2) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL