network

package

Go to main page

Versions in this module

v1

v1.0.11

Aug 10, 2020

v1.0.11-alpha1

Aug 6, 2020

v1.0.10

Jul 23, 2020

v1.0.10-beta1

Jul 15, 2020

v1.0.10-alpha1

Jul 15, 2020

v1.0.9

Jun 9, 2020

v1.0.9-beta1

Jun 11, 2020

v1.0.9-alpha1

Jun 5, 2020

v1.0.8

Mar 12, 2020

v1.0.8-beta6

Mar 18, 2020

v1.0.8-beta5

Mar 16, 2020

v1.0.8-beta4

Mar 13, 2020

v1.0.8-beta3

Mar 12, 2020

v1.0.8-beta2

Mar 6, 2020

v1.0.8-alpha3

Mar 10, 2020

v1.0.8-alpha2

Mar 5, 2020

v1.0.8-alpha1

Mar 5, 2020

v1.0.7

Feb 13, 2020

Changes in this version

+ const BasePort

+ const BizMessageIDLength

+ const BlockInfoNotifyMsg

+ const BlockResponseMsg

+ const CastRewardSignGot

+ const CastRewardSignReq

+ const CastVerifyMsg

+ const DEFAULT_MAX_PEER_SIZE_PER_IP

+ const DefaultBucketGroupName

+ const DefaultBucketGroupSize

+ const FastGroupName

+ const FastGroupSize

+ const ForkChainSliceReq

+ const ForkChainSliceResponse

+ const ForkFindAncestorReq

+ const ForkFindAncestorResponse

+ const FullNodeVirtualGroupID

+ const GroupMinRowSize

+ const MaxFastSize

+ const MaxPendingSend

+ const MaxSendListSize

+ const MaxSendPriority

+ const MaxUnhandledMessageCount

+ const NewBlockMsg

+ const NodeIDLength

+ const NormalGroupName

+ const NormalGroupSize

+ const P2PMessageCodeBase

+ const PacketHeadSize

+ const PacketLenSize

+ const PacketTypeSize

+ const RelayTestTimeOut

+ const ReqBlock

+ const ReqProposalBlock

+ const ResponseProposalBlock

+ const SuperBasePort

+ const TxSyncNotify

+ const TxSyncReq

+ const TxSyncResponse

+ const VerifiedCastMsg

+ const Version

+ const WaitTimeout

+ var DataType_name = map[int32]string

+ var DataType_value = map[string]int32

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

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

+ var Logger *logrus.Logger

+ var MessageType_name = map[int32]string

+ var MessageType_value = map[string]int32

+ func Init(config *common.ConfManager, consensusHandler MsgHandler, ...) (err error)

+ func IsJoinedThisGroup(members []NodeID) bool

+ func OnP2PAccepted(id uint64, session uint32, p2pType uint32, ip string, port uint16)

+ func OnP2PChecked(p2pType uint32, privateIP string, publicIP string)

+ func OnP2PConnected(id uint64, session uint32, p2pType uint32)

+ func OnP2PDisconnected(id uint64, session uint32, p2pCode uint32)

+ func OnP2PListened(ip string, port uint16, latency uint64)

+ func OnP2PLoginSign() unsafe.Pointer

+ func OnP2PRecved(id uint64, session uint32, data []byte)

+ func OnP2PSendWaited(session uint32, peerID uint64)

+ func P2PClose() — darwin/amd64, linux/amd64, windows/amd64

+ func P2PConfig(id uint64) — darwin/amd64, linux/amd64, windows/amd64

+ func P2PConnect(id uint64, ip string, port uint16) — darwin/amd64, linux/amd64, windows/amd64

+ func P2PListen(ip string, port uint16) — darwin/amd64, linux/amd64, windows/amd64

+ func P2PLoginSign() unsafe.Pointer — darwin/amd64, linux/amd64, windows/amd64

+ func P2PProxy(ip string, port uint16) — darwin/amd64, linux/amd64, windows/amd64

+ func P2PSend(session uint32, data []byte) — darwin/amd64, linux/amd64, windows/amd64

+ func P2PShutdown(session uint32) — darwin/amd64, linux/amd64, windows/amd64

+ type BizMessageID = [BizMessageIDLength]byte

+ type BufferPool struct

+ func (pool *BufferPool) Print()

+ type BufferPoolItem struct

+ type Conn struct

+ ID string

+ IP string

+ Port string

+ type DataType int32

+ const DataType_DataGlobal

+ const DataType_DataGlobalRandom

+ const DataType_DataGroup

+ const DataType_DataGroupColumn

+ const DataType_DataGroupRow

+ const DataType_DataNormal

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

+ func (x DataType) String() string

+ type FlowMeter struct

+ type FlowMeterItem struct

+ type Group struct

+ ID string

+ func (g *Group) Broadcast(msg *MsgData)

+ func (g *Group) Len() int

+ func (g *Group) Less(i, j int) bool

+ func (g *Group) Swap(i, j int)

+ type GroupManager struct

+ func (gm *GroupManager) Broadcast(ID string, msg *MsgData, members []string, code uint32)

+ func (gm *GroupManager) BroadcastExternal(ID string, msg *MsgData, members []string, code uint32)

+ type Kad struct

+ func (kad *Kad) Close()

+ func (kad *Kad) Lookup(targetID NodeID) []*Node

+ func (kad *Kad) Self() *Node

+ type Message struct

+ Body []byte

+ ChainID uint16

+ Code uint32

+ ProtocolVersion uint16

+ func (m Message) Hash() string

+ type MessageManager struct

+ type MessageType int32

+ const MessageType_MessageData

+ const MessageType_MessageFindnode

+ const MessageType_MessageNeighbors

+ const MessageType_MessageNone

+ const MessageType_MessagePing

+ const MessageType_MessagePong

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

+ func (x MessageType) String() string

+ type MsgData struct

+ BizMessageID []byte

+ Data []byte

+ DataType DataType

+ Expiration uint64

+ GroupID string

+ MessageCode uint32

+ MessageID uint64

+ MessageInfo uint32

+ RelayCount int32

+ SrcNodeID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MsgData) ProtoMessage()

+ func (m *MsgData) GetBizMessageID() []byte

+ func (m *MsgData) GetData() []byte

+ func (m *MsgData) GetDataType() DataType

+ func (m *MsgData) GetExpiration() uint64

+ func (m *MsgData) GetGroupID() string

+ func (m *MsgData) GetMessageCode() uint32

+ func (m *MsgData) GetMessageID() uint64

+ func (m *MsgData) GetMessageInfo() uint32

+ func (m *MsgData) GetRelayCount() int32

+ func (m *MsgData) GetSrcNodeID() []byte

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

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

+ func (m *MsgData) Reset()

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

+ func (m *MsgData) String() string

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

+ func (m *MsgData) XXX_DiscardUnknown()

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

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

+ func (m *MsgData) XXX_Size() int

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

+ type MsgDigest []byte

+ type MsgFindNode struct

+ Expiration uint64

+ Target []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MsgFindNode) ProtoMessage()

+ func (m *MsgFindNode) GetExpiration() uint64

+ func (m *MsgFindNode) GetTarget() []byte

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

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

+ func (m *MsgFindNode) Reset()

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

+ func (m *MsgFindNode) String() string

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

+ func (m *MsgFindNode) XXX_DiscardUnknown()

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

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

+ func (m *MsgFindNode) XXX_Size() int

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

+ type MsgHandler interface

+ Handle func(sourceID string, msg Message) error

+ type MsgNeighbors struct

+ Expiration uint64

+ Nodes []*RpcNode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MsgNeighbors) ProtoMessage()

+ func (m *MsgNeighbors) GetExpiration() uint64

+ func (m *MsgNeighbors) GetNodes() []*RpcNode

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

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

+ func (m *MsgNeighbors) Reset()

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

+ func (m *MsgNeighbors) String() string

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

+ func (m *MsgNeighbors) XXX_DiscardUnknown()

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

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

+ func (m *MsgNeighbors) XXX_Size() int

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

+ type MsgPing struct

+ ChainID uint32

+ CurTime uint64

+ Expiration uint64

+ From *RpcEndPoint

+ PK []byte

+ Sign []byte

+ To *RpcEndPoint

+ Version int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MsgPing) ProtoMessage()

+ func (m *MsgPing) GetChainID() uint32

+ func (m *MsgPing) GetCurTime() uint64

+ func (m *MsgPing) GetExpiration() uint64

+ func (m *MsgPing) GetFrom() *RpcEndPoint

+ func (m *MsgPing) GetPK() []byte

+ func (m *MsgPing) GetSign() []byte

+ func (m *MsgPing) GetTo() *RpcEndPoint

+ func (m *MsgPing) GetVersion() int32

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

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

+ func (m *MsgPing) Reset()

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

+ func (m *MsgPing) String() string

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

+ func (m *MsgPing) XXX_DiscardUnknown()

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

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

+ func (m *MsgPing) XXX_Size() int

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

+ type MsgPong struct

+ VerifyResult bool

+ Version int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MsgPong) ProtoMessage()

+ func (m *MsgPong) GetVerifyResult() bool

+ func (m *MsgPong) GetVersion() int32

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

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

+ func (m *MsgPong) Reset()

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

+ func (m *MsgPong) String() string

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

+ func (m *MsgPong) XXX_DiscardUnknown()

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

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

+ func (m *MsgPong) XXX_Size() int

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

+ type NetCore struct

+ ID NodeID

+ func (nc *NetCore) InitNetCore(cfg NetCoreConfig) (*NetCore, error)

+ type NetCoreConfig struct

+ ChainID uint16

+ ID NodeID

+ ListenAddr *net.UDPAddr

+ NatIP string

+ NatPort uint16

+ NatTraversalEnable bool

+ ProtocolVersion uint16

+ Seeds []*Node

+ type NetInterface interface

+ type Network interface

+ AddProposers func(proposers []*Proposer)

+ Broadcast func(msg Message) error

+ BuildGroupNet func(groupID string, members []string)

+ BuildProposerGroupNet func(proposers []*Proposer)

+ ConnInfo func() []Conn

+ DissolveGroupNet func(groupID string)

+ Send func(id string, msg Message) error

+ SpreadAmongGroup func(groupID string, msg Message) error

+ SpreadToGroup func(groupID string, groupMembers []string, msg Message, digest MsgDigest) error

+ TransmitToNeighbor func(msg Message, blacklist []string) error

+ func GetNetInstance() Network

+ type NetworkConfig struct

+ ChainID uint16

+ IsSuper bool

+ NatAddr string

+ NatPort uint16

+ NodeIDHex string

+ PK string

+ ProtocolVersion uint16

+ SK string

+ SeedAddr string

+ SeedIDs []string

+ TestMode bool

+ type Node struct

+ ID NodeID

+ IP net.IP

+ NatType int

+ Port int

+ func InitSelfNode(isSuper bool, ID NodeID) (*Node, error)

+ func NewNode(ID NodeID, IP net.IP, port int) *Node

+ func (n *Node) Incomplete() bool

+ func (n *Node) String() string

+ type NodeID [NodeIDLength]byte

+ func NewNodeID(hex string) *NodeID

+ func (netID NodeID) IsValid() bool

+ func (nid *NodeID) SetBytes(b []byte)

+ func (nid NodeID) Bytes() []byte

+ func (nid NodeID) GetHexString() string

+ type Peer struct

+ ID NodeID

+ IP net.IP

+ Port int

+ func (p *Peer) AuthContext() *PeerAuthContext

+ func (p *Peer) IsCompatible() bool

+ type PeerAuthContext struct

+ CurTime uint64

+ PK []byte

+ Sign []byte

+ func (pa *PeerAuthContext) Verify() (bool, string)

+ type PeerIPSet struct

+ Limit uint

+ func (s *PeerIPSet) Add(ip string) bool

+ func (s *PeerIPSet) Remove(ip string)

+ func (s PeerIPSet) Contains(ip string) bool

+ func (s PeerIPSet) Len() int

+ type PeerManager struct

+ func (pm *PeerManager) ConnInfo() []Conn

+ type PeerSource int32

+ const PeerSourceGroup

+ const PeerSourceKad

+ const PeerSourceUnkown

+ type Proposer struct

+ ID NodeID

+ Stake uint64

+ type ProposerBucket struct

+ func (pb *ProposerBucket) AddProposers(proposers []*Proposer)

+ func (pb *ProposerBucket) Broadcast(msg *MsgData, code uint32)

+ func (pb *ProposerBucket) Build(proposers []*Proposer)

+ func (pb *ProposerBucket) GroupNameByIndex(index int) string

+ func (pb *ProposerBucket) IsContained(proposer *Proposer) bool

+ func (pb *ProposerBucket) Len() int

+ func (pb *ProposerBucket) Less(i, j int) bool

+ func (pb *ProposerBucket) Swap(i, j int)

+ type ProposerManager struct

+ func (pm *ProposerManager) AddProposers(proposers []*Proposer)

+ func (pm *ProposerManager) Broadcast(msg *MsgData, code uint32)

+ func (pm *ProposerManager) Build(proposers []*Proposer)

+ func (pm *ProposerManager) Len() int

+ func (pm *ProposerManager) Less(i, j int) bool

+ func (pm *ProposerManager) Swap(i, j int)

+ type RpcEndPoint struct

+ IP string

+ Port int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func MakeEndPoint(addr *net.UDPAddr, tcpPort int32) RpcEndPoint

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

+ func (*RpcEndPoint) ProtoMessage()

+ func (m *RpcEndPoint) GetIP() string

+ func (m *RpcEndPoint) GetPort() int32

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

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

+ func (m *RpcEndPoint) Reset()

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

+ func (m *RpcEndPoint) String() string

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

+ func (m *RpcEndPoint) XXX_DiscardUnknown()

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

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

+ func (m *RpcEndPoint) XXX_Size() int

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

+ type RpcNode struct

+ ID string

+ IP string

+ Port int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RpcNode) ProtoMessage()

+ func (m *RpcNode) GetID() string

+ func (m *RpcNode) GetIP() string

+ func (m *RpcNode) GetPort() int32

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

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

+ func (m *RpcNode) Reset()

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

+ func (m *RpcNode) String() string

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

+ func (m *RpcNode) XXX_DiscardUnknown()

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

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

+ func (m *RpcNode) XXX_Size() int

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

+ type SendList struct

+ type SendListItem struct

+ type SendPriorityType uint32

+ const SendPriorityHigh

+ const SendPriorityLow

+ const SendPriorityMedium

+ type Server struct

+ Self *Node

+ func (s *Server) AddGroup(groupID string, members []string) *Group

+ func (s *Server) AddProposers(proposers []*Proposer)

+ func (s *Server) Broadcast(msg Message) error

+ func (s *Server) BuildGroupNet(groupID string, members []string)

+ func (s *Server) BuildProposerGroupNet(proposers []*Proposer)

+ func (s *Server) ConnInfo() []Conn

+ func (s *Server) DissolveGroupNet(groupID string)

+ func (s *Server) RemoveGroup(ID string)

+ func (s *Server) Send(id string, msg Message) error

+ func (s *Server) SpreadAmongGroup(groupID string, msg Message) error

+ func (s *Server) SpreadToGroup(groupID string, groupMembers []string, msg Message, digest MsgDigest) error

+ func (s *Server) TransmitToNeighbor(msg Message, blacklist []string) error

v1.0.7-beta2

Feb 7, 2020

v1.0.7-alpha3

Feb 6, 2020

v1.0.7-alpha2

Jan 10, 2020

v0

v0.9.8

Jul 18, 2019

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