p2pcommon

package

Go to main page

Versions in this module

v1

v1.3.3

Nov 16, 2019

Changes in this version

+ const CertVersion0001

+ const DefaultActorMsgTTL

+ const DefaultNodeTTL

+ const DefaultPeerIDExt

+ const DefaultPkKeyExt

+ const DefaultPkKeyPrefix

+ const DefaultPubKeyExt

+ const DesignatedNodeTTL

+ const HSCodeAuthFail

+ const HSCodeInvalidState

+ const HSCodeNoMatchedVersion

+ const HSCodeNoPermission

+ const HSCodeWrongHSReq

+ const HSError

+ const HSMagicLength

+ const HSMaxVersionCnt

+ const HSVerCntLength

+ const HSVersionLength

+ const MAGICRaftSnap

+ const MaxConcurrentHandshake

+ const MaximumAergoVersion

+ const MinimumAergoVersion

+ const P2PSubAddr

+ const PeerFirstInterval

+ const PeerQueryInterval

+ const PolarisQueryInterval

+ const RaftSnapSubAddr

+ const V030HSHeaderLength

+ const WaitingPeerManagerInterval

+ var AcceptedInboundVersions = []P2PVersion

+ var AttemptingOutboundVersions = []P2PVersion

+ var ErrInvalidCertField = errors.New("invalid field in certificate ")

+ var ErrInvalidCertVersion = errors.New("invalid certificate version")

+ var ErrInvalidKey = errors.New("invalid key in certificate ")

+ var ErrInvalidPeerID = errors.New("invalid peer id in certificate ")

+ var ErrInvalidRole = errors.New("invalid peer role")

+ var ErrMalformedCert = errors.New("malformed certificate data")

+ var ErrNoWaiting = errors.New("no waiting peer exists")

+ var ErrVerificationFailed = errors.New("signature verification failed")

+ var ExperimentalVersions = []P2PVersion

+ func CheckVersion(version string) bool

+ type AergoVersion = semver.Version

+ func ParseAergoVersion(verStr string) (AergoVersion, error)

+ type AgentCertificateV1 struct

+ AgentAddress []string

+ AgentID types.PeerID

+ BPID types.PeerID

+ BPPubKey *btcec.PublicKey

+ CreateTime time.Time

+ ExpireTime time.Time

+ Signature *btcec.Signature

+ Version uint32

+ func (c *AgentCertificateV1) IsNeedUpdate(t time.Time, bufTerm time.Duration) bool

+ func (c *AgentCertificateV1) IsValidInTime(t time.Time, errTolerance time.Duration) bool

+ type AsyncHandler interface

+ Handle func(msg Message, msgBody MessageBody, ttl time.Duration)

+ HandleOrNot func(msg Message, msgBody MessageBody) bool

+ type AttrModifier struct

+ ID types.PeerID

+ Role types.PeerRole

+ type CertificateManager interface

+ AddCertificate func(cert *AgentCertificateV1)

+ CanHandle func(bpID types.PeerID) bool

+ CreateCertificate func(remoteMeta PeerMeta) (*AgentCertificateV1, error)

+ GetCertificates func() []*AgentCertificateV1

+ GetProducers func() []types.PeerID

+ Start func()

+ Stop func()

+ type ConnWorkResult struct

+ ConnInfo RemoteInfo

+ Inbound bool

+ Meta PeerMeta

+ P2PVer uint32

+ Result error

+ Seq uint32

+ TargetPeer *WaitingPeer

+ type HSHandler interface

+ Handle func(s io.ReadWriteCloser, ttl time.Duration) (*HandshakeResult, error)

+ type HSHandlerFactory interface

+ CreateHSHandler func(outbound bool, pid types.PeerID) HSHandler

+ type HSHeadReq struct

+ Magic uint32

+ Versions []P2PVersion

+ func (h HSHeadReq) Marshal() []byte

+ type HSHeadResp struct

+ Magic uint32

+ RespCode uint32

+ func (h *HSHeadResp) Unmarshal(b []byte)

+ func (h HSHeadResp) Marshal() []byte

+ type HSHeader struct

+ Magic uint32

+ Version P2PVersion

+ func (h *HSHeader) Unmarshal(b []byte)

+ func (h HSHeader) Marshal() []byte

+ type HSRespCode = uint32

+ type HandlerAdvice interface

+ PostHandle func(msg Message, msgBody MessageBody)

+ PreHandle func()

+ type HandshakeResult struct

+ BestBlockHash types.BlockID

+ BestBlockNo types.BlockNo

+ Certificates []*AgentCertificateV1

+ Hidden bool

+ Meta PeerMeta

+ MsgRW MsgReadWriter

+ type InternalService interface

+ CertificateManager func() CertificateManager

+ GetChainAccessor func() types.ChainAccessor

+ LocalSettings func() LocalSettings

+ RoleManager func() PeerRoleManager

+ SelfMeta func() PeerMeta

+ SelfNodeID func() types.PeerID

+ type ListManager interface

+ IsBanned func(addr string, pid types.PeerID) (bool, time.Time)

+ RefineList func()

+ Start func()

+ Stop func()

+ Summary func() map[string]interface{}

+ type LocalSettings struct

+ AgentID types.PeerID

+ InternalZones []*net.IPNet

+ type MessageBody interface

type MessageHandler

+ AddAdvice func(advice HandlerAdvice)

+ type MessageValue struct

+ func NewLiteMessageValue(protocol SubProtocol, msgID, originalID MsgID, timestamp int64) *MessageValue

+ func NewMessageValue(protocol SubProtocol, msgID, originalID MsgID, timestamp int64, payload []byte) *MessageValue

+ func NewSimpleMsgVal(protocol SubProtocol, msgID MsgID) *MessageValue

+ func NewSimpleRespMsgVal(protocol SubProtocol, msgID MsgID, originalID MsgID) *MessageValue

+ func (m *MessageValue) ID() MsgID

+ func (m *MessageValue) Length() uint32

+ func (m *MessageValue) OriginalID() MsgID

+ func (m *MessageValue) Payload() []byte

+ func (m *MessageValue) SetPayload(payload []byte)

+ func (m *MessageValue) Subprotocol() SubProtocol

+ func (m *MessageValue) Timestamp() int64

type MoFactory

+ NewRaftMsgOrder func(msgType raftpb.MessageType, raftMsg *raftpb.Message) MsgOrder

+ NewTossMsgOrder func(orgMsg Message) MsgOrder

+ type MsgIOListener interface

+ OnRead func(protocol SubProtocol, read int)

+ OnWrite func(protocol SubProtocol, write int)

type MsgOrder

+ CancelSend func(pi RemotePeer)

type MsgReadWriter

+ AddIOListener func(l MsgIOListener)

+ Close func() error

+ ReadMsg func() (Message, error)

+ WriteMsg func(msg Message) error

type NTContainer

+ GenesisChainID func() *types.ChainID

+ SelfMeta func() PeerMeta

+ type P2PVersion uint32

+ const P2PVersion031

+ const P2PVersion032

+ const P2PVersion033

+ const P2PVersion200

+ const P2PVersionUnknown

+ func (v P2PVersion) String() string

+ func (v P2PVersion) Uint32() uint32

+ type PeerAccessor interface

+ GetPeer func(ID types.PeerID) (RemotePeer, bool)

+ GetPeerBlockInfos func() []types.PeerBlockInfo

+ SelfMeta func() PeerMeta

+ type PeerEventListener interface

+ OnPeerConnect func(pid types.PeerID)

+ OnPeerDisconnect func(peer RemotePeer)

+ type PeerFactory interface

+ CreateRemotePeer func(remoteInfo RemoteInfo, seq uint32, rw MsgReadWriter) RemotePeer

+ type PeerFinder interface

+ CheckAndFill func()

type PeerManager

+ AddDesignatedPeer func(meta PeerMeta)

+ AddPeerEventListener func(l PeerEventListener)

+ ListDesignatedPeers func() []PeerMeta

+ RemoveDesignatedPeer func(peerID types.PeerID)

+ UpdatePeerRole func(changes []AttrModifier)

type PeerMeta

+ Addresses []types.Multiaddr

+ ProducerIDs []types.PeerID

+ Role types.PeerRole

+ Version string

+ func FromPeerAddressNew(addr *types.PeerAddress) PeerMeta

+ func NewMetaWith1Addr(id types.PeerID, addr string, port uint32, version string) PeerMeta

+ func (m *PeerMeta) GetVersion() string

+ func (m PeerMeta) Equals(o PeerMeta) bool

+ func (m PeerMeta) PrimaryAddress() string

+ func (m PeerMeta) PrimaryPort() uint32

+ type PeerRoleManager interface

+ FilterBPNoticeReceiver func(block *types.Block, pm PeerManager, targetZone PeerZone) []RemotePeer

+ FilterNewBlockNoticeReceiver func(block *types.Block, pm PeerManager) []RemotePeer

+ GetRole func(pid types.PeerID) types.PeerRole

+ SelfRole func() types.PeerRole

+ UpdateBP func(toAdd []types.PeerID, toRemove []types.PeerID)

+ type PeerZone bool

+ const ExternalZone

+ const InternalZone

+ func (z PeerZone) String() string

+ type RemoteConn struct

+ IP net.IP

+ Outbound bool

+ Port uint32

+ type RemoteInfo struct

+ AcceptedRole types.PeerRole

+ Certificates []*AgentCertificateV1

+ Connection RemoteConn

+ Designated bool

+ Hidden bool

+ Meta PeerMeta

+ Zone PeerZone

type RemotePeer

+ AcceptedRole func() types.PeerRole

+ AddCertificate func(cert *AgentCertificateV1)

+ AddMessageHandler func(subProtocol SubProtocol, handler MessageHandler)

+ ChangeRole func(role types.PeerRole)

+ LastStatus func() *types.LastBlockStatus

+ RemoteInfo func() RemoteInfo

+ Version func() string

+ type ReportType int

+ const Fail

+ const Send

+ const Skip

type SubProtocol

+ const AddressesRequest

+ const AddressesResponse

+ const BlockProducedNotice

+ const CertificateRenewedNotice

+ const GetAncestorRequest

+ const GetAncestorResponse

+ const GetBlockHeadersRequest

+ const GetBlockHeadersResponse

+ const GetBlocksRequest

+ const GetBlocksResponse

+ const GetClusterRequest

+ const GetClusterResponse

+ const GetHashByNoRequest

+ const GetHashByNoResponse

+ const GetHashesRequest

+ const GetHashesResponse

+ const GetTXsRequest

+ const GetTXsResponse

+ const GoAway

+ const IssueCertificateRequest

+ const IssueCertificateResponse

+ const NewBlockNotice

+ const NewTxNotice

+ const PingRequest

+ const PingResponse

+ const RaftWrapperMessage

+ const StatusRequest

+ type TxNoticeTracer interface

+ RegisterTxNotice func(txIDs []types.TxID, cnt int, alreadySent []types.PeerID)

+ ReportNotSend func(txIDs []types.TxID, cnt int)

+ ReportSend func(txIDs []types.TxID, peerID types.PeerID)

+ type VersionedHandshaker interface

+ DoForInbound func(ctx context.Context) (*HandshakeResult, error)

+ DoForOutbound func(ctx context.Context) (*HandshakeResult, error)

+ GetMsgRW func() MsgReadWriter

+ type VersionedManager interface

+ FindBestP2PVersion func(versions []P2PVersion) P2PVersion

+ GetBestChainID func() *types.ChainID

+ GetChainID func(no types.BlockNo) *types.ChainID

+ GetVersionedHandshaker func(version P2PVersion, peerID types.PeerID, rwc io.ReadWriteCloser) (VersionedHandshaker, error)

+ type WaitingPeer struct

+ Designated bool

+ LastResult error

+ Meta PeerMeta

+ NextTrial time.Time

+ TrialCnt int

+ type WaitingPeerManager interface

+ CheckAndConnect func()

+ InstantConnect func(meta PeerMeta)

+ OnDiscoveredPeers func(metas []PeerMeta) int

+ OnInboundConn func(s network.Stream)

+ OnWorkDone func(result ConnWorkResult)

v1.0.5

May 22, 2019

v1.0.4

May 2, 2019

v1.0.3

Apr 22, 2019

v1.0.2

Apr 16, 2019

v1.0.1

Apr 15, 2019

v1.0.0

Apr 12, 2019

Changes in this version

+ const AergoP2PSub

+ const IDLength

+ const MAGICMain

+ const MAGICTest

+ const MaxBlockHeaderResponseCount

+ const MaxBlockResponseCount

+ const MaxPayloadLength

+ const P2PVersion030

+ const SigLength

+ var EmptyID = MsgID(uuid.Nil)

+ type ActorService interface

+ CallRequest func(actor string, msg interface{}, timeout time.Duration) (interface{}, error)

+ CallRequestDefaultTimeout func(actor string, msg interface{}) (interface{}, error)

+ FutureRequest func(actor string, msg interface{}, timeout time.Duration) *actor.Future

+ FutureRequestDefaultTimeout func(actor string, msg interface{}) *actor.Future

+ GetChainAccessor func() types.ChainAccessor

+ SendRequest func(actor string, msg interface{})

+ TellRequest func(actor string, msg interface{})

+ type Message interface

+ ID func() MsgID

+ Length func() uint32

+ OriginalID func() MsgID

+ Payload func() []byte

+ Subprotocol func() SubProtocol

+ Timestamp func() int64

+ type MessageHandler interface

+ CheckAuth func(msgHeader Message, msgBody proto.Message) error

+ Handle func(msgHeader Message, msgBody proto.Message)

+ ParsePayload func([]byte) (proto.Message, error)

+ PostHandle func(msgHeader Message, msgBody proto.Message)

+ PreHandle func()

+ type MoFactory interface

+ NewMsgBPBroadcastOrder func(noticeMsg *types.BlockProducedNotice) MsgOrder

+ NewMsgBlkBroadcastOrder func(noticeMsg *types.NewBlockNotice) MsgOrder

+ NewMsgBlockRequestOrder func(respReceiver ResponseReceiver, protocolID SubProtocol, message PbMessage) MsgOrder

+ NewMsgRequestOrder func(expecteResponse bool, protocolID SubProtocol, message PbMessage) MsgOrder

+ NewMsgResponseOrder func(reqID MsgID, protocolID SubProtocol, message PbMessage) MsgOrder

+ NewMsgTxBroadcastOrder func(noticeMsg *types.NewTransactionsNotice) MsgOrder

+ type MsgID [IDLength]byte

+ func MustParseBytes(b []byte) MsgID

+ func NewMsgID() (m MsgID)

+ func ParseBytesToMsgID(b []byte) (MsgID, error)

+ func (id MsgID) String() string

+ func (id MsgID) UUID() uuid.UUID

+ type MsgOrder interface

+ GetMsgID func() MsgID

+ GetProtocolID func() SubProtocol

+ IsNeedSign func() bool

+ IsRequest func() bool

+ SendTo func(p RemotePeer) error

+ Timestamp func() int64

+ type MsgReadWriter interface

+ type MsgReader interface

+ ReadMsg func() (Message, error)

+ type MsgSigner interface

+ SignMsg func(msg *types.P2PMessage) error

+ VerifyMsg func(msg *types.P2PMessage, senderID peer.ID) error

+ type MsgWriter interface

+ WriteMsg func(msg Message) error

+ type NTContainer interface

+ ChainID func() *types.ChainID

+ GetNetworkTransport func() NetworkTransport

+ type NetworkTransport interface

+ AddStreamHandler func(pid protocol.ID, handler inet.StreamHandler)

+ ClosePeerConnection func(peerID peer.ID) bool

+ FindPeer func(peerID peer.ID) bool

+ GetAddressesOfPeer func(peerID peer.ID) []string

+ GetOrCreateStream func(meta PeerMeta, protocolID protocol.ID) (inet.Stream, error)

+ GetOrCreateStreamWithTTL func(meta PeerMeta, protocolID protocol.ID, ttl time.Duration) (inet.Stream, error)

+ PrivateKey func() crypto.PrivKey

+ PublicKey func() crypto.PubKey

+ SelfMeta func() PeerMeta

+ SelfNodeID func() peer.ID

+ Start func() error

+ Stop func() error

+ type PbMessage interface

+ type PeerManager interface

+ AddNewPeer func(peer PeerMeta)

+ GetPeer func(ID peer.ID) (RemotePeer, bool)

+ GetPeerAddresses func(noHidden bool, showSelf bool) []*message.PeerInfo

+ GetPeerBlockInfos func() []types.PeerBlockInfo

+ GetPeers func() []RemotePeer

+ NotifyPeerAddressReceived func([]PeerMeta)

+ NotifyPeerHandshake func(peerID peer.ID)

+ RemovePeer func(peer RemotePeer)

+ SelfMeta func() PeerMeta

+ SelfNodeID func() peer.ID

+ Start func() error

+ Stop func() error

+ type PeerMeta struct

+ Designated bool

+ Hidden bool

+ ID peer.ID

+ IPAddress string

+ Outbound bool

+ Port uint32

+ func FromPeerAddress(addr *types.PeerAddress) PeerMeta

+ func NewMetaFromStatus(status *types.Status, outbound bool) PeerMeta

+ func (m PeerMeta) ToPeerAddress() types.PeerAddress

+ type RemotePeer interface

+ ConsumeRequest func(msgID MsgID)

+ GetReceiver func(id MsgID) ResponseReceiver

+ ID func() peer.ID

+ LastNotice func() *types.LastBlockStatus

+ MF func() MoFactory

+ ManageNumber func() uint32

+ Meta func() PeerMeta

+ Name func() string

+ PushTxsNotice func(txHashes []types.TxID)

+ RunPeer func()

+ SendAndWaitMessage func(msg MsgOrder, ttl time.Duration) error

+ SendMessage func(msg MsgOrder)

+ State func() types.PeerState

+ Stop func()

+ UpdateBlkCache func(blkHash []byte, blkNumber uint64) bool

+ UpdateLastNotice func(blkHash []byte, blkNumber uint64)

+ UpdateTxCache func(hashes []types.TxID) []types.TxID

+ type ResponseReceiver func(Message, proto.Message) bool

+ type SubProtocol uint32

+ func (i SubProtocol) String() string

+ func (i SubProtocol) Uint32() uint32

+ type SyncManager interface

+ HandleBlockProducedNotice func(peer RemotePeer, block *types.Block)

+ HandleGetBlockResponse func(peer RemotePeer, msg Message, resp *types.GetBlockResponse)

+ HandleNewBlockNotice func(peer RemotePeer, data *types.NewBlockNotice)

+ HandleNewTxNotice func(peer RemotePeer, hashes []types.TxID, data *types.NewTransactionsNotice)

v1.0.0-rc1

Mar 28, 2019

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