p2p

package
v0.33.12 Latest Latest
Warning

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

 Go to latest Published: May 28, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DefaultNodeInfo 

type DefaultNodeInfo struct {
	ProtocolVersion      ProtocolVersion      `protobuf:"bytes,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version"`
	DefaultNodeID        string               `protobuf:"bytes,2,opt,name=default_node_id,json=defaultNodeId,proto3" json:"default_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                DefaultNodeInfoOther `protobuf:"bytes,8,opt,name=other,proto3" json:"other"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*DefaultNodeInfo) Descriptor 

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

func (*DefaultNodeInfo) GetChannels 

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

func (*DefaultNodeInfo) GetDefaultNodeID 

func (m *DefaultNodeInfo) GetDefaultNodeID() string

func (*DefaultNodeInfo) GetListenAddr 

func (m *DefaultNodeInfo) GetListenAddr() string

func (*DefaultNodeInfo) GetMoniker 

func (m *DefaultNodeInfo) GetMoniker() string

func (*DefaultNodeInfo) GetNetwork 

func (m *DefaultNodeInfo) GetNetwork() string

func (*DefaultNodeInfo) GetOther 

func (m *DefaultNodeInfo) GetOther() DefaultNodeInfoOther

func (*DefaultNodeInfo) GetProtocolVersion 

func (m *DefaultNodeInfo) GetProtocolVersion() ProtocolVersion

func (*DefaultNodeInfo) GetVersion 

func (m *DefaultNodeInfo) GetVersion() string

func (*DefaultNodeInfo) ProtoMessage 

func (*DefaultNodeInfo) ProtoMessage()

func (*DefaultNodeInfo) Reset 

func (m *DefaultNodeInfo) Reset()

func (*DefaultNodeInfo) String 

func (m *DefaultNodeInfo) String() string

func (*DefaultNodeInfo) XXX_DiscardUnknown 

func (m *DefaultNodeInfo) XXX_DiscardUnknown()

func (*DefaultNodeInfo) XXX_Marshal 

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

func (*DefaultNodeInfo) XXX_Merge 

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

func (*DefaultNodeInfo) XXX_Size 

func (m *DefaultNodeInfo) XXX_Size() int

func (*DefaultNodeInfo) XXX_Unmarshal 

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

type DefaultNodeInfoOther 

type DefaultNodeInfoOther struct {
	TxIndex              string   `protobuf:"bytes,1,opt,name=tx_index,json=txIndex,proto3" json:"tx_index,omitempty"`
	RPCAdddress          string   `protobuf:"bytes,2,opt,name=rpc_address,json=rpcAddress,proto3" json:"rpc_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DefaultNodeInfoOther) Descriptor 

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

func (*DefaultNodeInfoOther) GetRPCAdddress 

func (m *DefaultNodeInfoOther) GetRPCAdddress() string

func (*DefaultNodeInfoOther) GetTxIndex 

func (m *DefaultNodeInfoOther) GetTxIndex() string

func (*DefaultNodeInfoOther) ProtoMessage 

func (*DefaultNodeInfoOther) ProtoMessage()

func (*DefaultNodeInfoOther) Reset 

func (m *DefaultNodeInfoOther) Reset()

func (*DefaultNodeInfoOther) String 

func (m *DefaultNodeInfoOther) String() string

func (*DefaultNodeInfoOther) XXX_DiscardUnknown 

func (m *DefaultNodeInfoOther) XXX_DiscardUnknown()

func (*DefaultNodeInfoOther) XXX_Marshal 

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

func (*DefaultNodeInfoOther) XXX_Merge 

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

func (*DefaultNodeInfoOther) XXX_Size 

func (m *DefaultNodeInfoOther) XXX_Size() int

func (*DefaultNodeInfoOther) XXX_Unmarshal 

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

type Message 

type Message struct {
	// Types that are valid to be assigned to Sum:
	//	*Message_PexRequest
	//	*Message_PexAddrs
	Sum                  isMessage_Sum `protobuf_oneof:"sum"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetPexAddrs 

func (m *Message) GetPexAddrs() *PexAddrs

func (*Message) GetPexRequest 

func (m *Message) GetPexRequest() *PexRequest

func (*Message) GetSum 

func (m *Message) GetSum() isMessage_Sum

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type Message_PexAddrs 

type Message_PexAddrs struct {
	PexAddrs *PexAddrs `protobuf:"bytes,2,opt,name=pex_addrs,json=pexAddrs,proto3,oneof" json:"pex_addrs,omitempty"`
}

type Message_PexRequest 

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

type NetAddress 

type NetAddress 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"`
	Str                  string   `protobuf:"bytes,4,opt,name=str,proto3" json:"str,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NetAddress) Descriptor 

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

func (*NetAddress) GetID 

func (m *NetAddress) GetID() string

func (*NetAddress) GetIP 

func (m *NetAddress) GetIP() string

func (*NetAddress) GetPort 

func (m *NetAddress) GetPort() uint32

func (*NetAddress) GetStr 

func (m *NetAddress) GetStr() string

func (*NetAddress) ProtoMessage 

func (*NetAddress) ProtoMessage()

func (*NetAddress) Reset 

func (m *NetAddress) Reset()

func (*NetAddress) String 

func (m *NetAddress) String() string

func (*NetAddress) XXX_DiscardUnknown 

func (m *NetAddress) XXX_DiscardUnknown()

func (*NetAddress) XXX_Marshal 

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

func (*NetAddress) XXX_Merge 

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

func (*NetAddress) XXX_Size 

func (m *NetAddress) XXX_Size() int

func (*NetAddress) XXX_Unmarshal 

func (m *NetAddress) 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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) Reset 

func (m *Packet) Reset()

func (*Packet) String 

func (m *Packet) String() string

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                  int32    `protobuf:"varint,2,opt,name=eof,proto3" json:"eof,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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() int32

func (*PacketMsg) ProtoMessage 

func (*PacketMsg) ProtoMessage()

func (*PacketMsg) Reset 

func (m *PacketMsg) Reset()

func (*PacketMsg) String 

func (m *PacketMsg) String() string

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PacketPing) Descriptor 

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

func (*PacketPing) ProtoMessage 

func (*PacketPing) ProtoMessage()

func (*PacketPing) Reset 

func (m *PacketPing) Reset()

func (*PacketPing) String 

func (m *PacketPing) String() string

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PacketPong) Descriptor 

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

func (*PacketPong) ProtoMessage 

func (*PacketPong) ProtoMessage()

func (*PacketPong) Reset 

func (m *PacketPong) Reset()

func (*PacketPong) String 

func (m *PacketPong) String() string

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

type Packet_PacketPing 

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

type Packet_PacketPong 

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

type PexAddrs 

type PexAddrs struct {
	Addrs                []NetAddress `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PexAddrs) Descriptor 

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

func (*PexAddrs) GetAddrs 

func (m *PexAddrs) GetAddrs() []NetAddress

func (*PexAddrs) ProtoMessage 

func (*PexAddrs) ProtoMessage()

func (*PexAddrs) Reset 

func (m *PexAddrs) Reset()

func (*PexAddrs) String 

func (m *PexAddrs) String() string

func (*PexAddrs) XXX_DiscardUnknown 

func (m *PexAddrs) XXX_DiscardUnknown()

func (*PexAddrs) XXX_Marshal 

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

func (*PexAddrs) XXX_Merge 

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

func (*PexAddrs) XXX_Size 

func (m *PexAddrs) XXX_Size() int

func (*PexAddrs) XXX_Unmarshal 

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

type PexRequest 

type PexRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PexRequest) Descriptor 

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

func (*PexRequest) ProtoMessage 

func (*PexRequest) ProtoMessage()

func (*PexRequest) Reset 

func (m *PexRequest) Reset()

func (*PexRequest) String 

func (m *PexRequest) String() string

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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) ProtoMessage 

func (*ProtocolVersion) ProtoMessage()

func (*ProtocolVersion) Reset 

func (m *ProtocolVersion) Reset()

func (*ProtocolVersion) String 

func (m *ProtocolVersion) String() string

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.