p2pcommon

package

Go to main page

Versions in this module

v1

v1.11.1

Jun 4, 2019

v1.11.0

Jun 4, 2019

v1.3.1

Nov 6, 2019

v1.3.0

Oct 7, 2019

Changes in this version

+ const MaximumAergoVersion

+ const MinimumAergoVersion

+ func CheckVersion(version string) bool

+ type AergoVersion = semver.Version

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

+ type InternalService interface

+ GetChainAccessor func() types.ChainAccessor

+ SelfMeta func() PeerMeta

+ SelfNodeID func() types.PeerID

+ SelfRole func() PeerRole

type NTContainer

+ SelfMeta func() PeerMeta

type TxNoticeTracer

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

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

v1.2.3

Sep 6, 2019

Changes in this version

type PeerRoleManager

+ SelfRole func() PeerRole

v1.2.2

Aug 27, 2019

v1.2.1

Aug 22, 2019

Changes in this version

type MsgOrder

+ CancelSend func(pi RemotePeer)

+ type ReportType int

+ const Fail

+ const Send

+ const Skip

+ type TxNoticeTracer interface

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

+ Report func(reportType ReportType, txIDs []types.TxID, peerCnt int)

v1.2.0

Aug 7, 2019

Changes in this version

+ const HSCodeAuthFail

+ const HSCodeInvalidState

+ const HSCodeNoMatchedVersion

+ const HSCodeNoPermission

+ const HSCodeWrongHSReq

+ const MAGICRaftSnap

+ const RaftSnapSubAddr

+ 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 PeerRole

+ type ChainType uint8

+ const DPOS

+ const RAFT

+ func (i ChainType) String() string

+ type HSRespCode = uint32

+ type HandlerAdvice interface

+ PostHandle func(msg Message, msgBody MessageBody)

+ PreHandle func()

+ 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 MessageHandler

+ AddAdvice func(advice HandlerAdvice)

type MoFactory

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

+ type MsgIOListener interface

+ OnRead func(protocol SubProtocol, read int)

+ OnWrite func(protocol SubProtocol, write int)

type MsgReadWriter

+ AddIOListener func(l MsgIOListener)

+ Close func() error

+ ReadMsg func() (Message, error)

+ WriteMsg func(msg Message) error

type P2PVersion

+ const P2PVersion032

type PeerAccessor

+ SelfMeta func() PeerMeta

+ type PeerAttribute struct

+ Chain ChainType

+ Producer bool

+ RaftRole PeerRole

+ type PeerFactory interface

+ CreateRemotePeer func(meta PeerMeta, seq uint32, status *types.Status, stream network.Stream, ...) RemotePeer

type PeerManager

+ AddDesignatedPeer func(meta PeerMeta)

+ AddPeerEventListener func(l PeerEventListener)

+ ListDesignatedPeers func() []PeerMeta

+ RemoveDesignatedPeer func(peerID types.PeerID)

+ UpdatePeerRole func(changes []AttrModifier)

+ type PeerRole uint8

+ const BlockProducer

+ const RaftProducer

+ const RaftWatcher

+ const UnknownRole

+ const Watcher

+ func (i PeerRole) String() string

+ type PeerRoleManager interface

+ GetRole func(pid types.PeerID) PeerRole

+ NotifyNewBlockMsg func(mo MsgOrder, peers []RemotePeer) (skipped, sent int)

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

type RemotePeer

+ ChangeRole func(role PeerRole)

+ Role func() PeerRole

type SubProtocol

+ const AddressesRequest

+ const AddressesResponse

+ const BlockProducedNotice

+ 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 NewBlockNotice

+ const NewTxNotice

+ const PingRequest

+ const PingResponse

+ const RaftWrapperMessage

+ const StatusRequest

type WaitingPeerManager

+ InstantConnect func(meta PeerMeta)

v1.1.2

Jun 28, 2019

v1.1.1

Jun 17, 2019

v1.1.0

Jun 4, 2019

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

type NetworkTransport

+ PrivateKey func() crypto.PrivKey

+ PublicKey func() crypto.PubKey

+ SelfNodeID func() peer.ID

+ type PbMessage interface

type PeerManager

+ NotifyPeerHandshake func(peerID peer.ID)

type RemotePeer

+ LastNotice func() *types.LastBlockStatus

v1.0.0-rc1

Mar 28, 2019

v0

v0.9.0

Jun 3, 2019

Changes in this version

+ const DefaultActorMsgTTL

+ const DefaultNodeTTL

+ const DefaultPeerIDExt

+ const DefaultPkKeyExt

+ const DefaultPkKeyPrefix

+ const DefaultPubKeyExt

+ const DesignatedNodeTTL

+ const ErrNoMatchedVersion

+ const ErrWrongHSReq

+ const HSError

+ const HSMagicLength

+ const HSMaxVersionCnt

+ const HSVerCntLength

+ const HSVersionLength

+ const IDLength

+ const LegacyP2PSubAddr

+ const MAGICMain

+ const MAGICTest

+ const MaxBlockHeaderResponseCount

+ const MaxBlockResponseCount

+ const MaxConcurrentHandshake

+ const MaxPayloadLength

+ const P2PSubAddr

+ const PeerFirstInterval

+ const PeerQueryInterval

+ const PolarisQueryInterval

+ const SigLength

+ const UnknownVersion

+ const V030HSHeaderLength

+ const WaitingPeerManagerInterval

+ var EmptyID = MsgID(uuid.Nil)

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

+ 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 ConnWorkResult struct

+ Inbound bool

+ Meta PeerMeta

+ P2PVer uint32

+ Result error

+ Seq uint32

+ TargetPeer *WaitingPeer

+ type FlushableWriter interface

+ Flush func() error

+ type HSHandler interface

+ Handle func(r io.Reader, w io.Writer, ttl time.Duration) (MsgReadWriter, *types.Status, error)

+ type HSHandlerFactory interface

+ CreateHSHandler func(p2pVersion P2PVersion, 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 HandlerFactory interface

+ InsertHandlers func(peer RemotePeer)

+ type Message interface

+ ID func() MsgID

+ Length func() uint32

+ OriginalID func() MsgID

+ Payload func() []byte

+ Subprotocol func() SubProtocol

+ Timestamp func() int64

+ type MessageBody interface

+ type MessageHandler interface

+ CheckAuth func(msg Message, msgBody MessageBody) error

+ Handle func(msg Message, msgBody MessageBody)

+ ParsePayload func([]byte) (MessageBody, error)

+ PostHandle func(msg Message, msgBody MessageBody)

+ PreHandle func()

+ 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 interface

+ NewMsgBPBroadcastOrder func(noticeMsg *types.BlockProducedNotice) MsgOrder

+ NewMsgBlkBroadcastOrder func(noticeMsg *types.NewBlockNotice) MsgOrder

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

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

+ NewMsgResponseOrder func(reqID MsgID, protocolID SubProtocol, message MessageBody) 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 types.PeerID) 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 core.ProtocolID, handler network.StreamHandler)

+ ClosePeerConnection func(peerID types.PeerID) bool

+ FindPeer func(peerID types.PeerID) bool

+ GetAddressesOfPeer func(peerID types.PeerID) []string

+ GetOrCreateStream func(meta PeerMeta, protocolIDs ...core.ProtocolID) (core.Stream, error)

+ GetOrCreateStreamWithTTL func(meta PeerMeta, ttl time.Duration, protocolIDs ...core.ProtocolID) (core.Stream, error)

+ SelfMeta func() PeerMeta

+ Start func() error

+ Stop func() error

+ type P2PVersion uint32

+ const P2PVersion030

+ const P2PVersion031

+ 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

+ type PeerEventListener interface

+ OnPeerConnect func(pid types.PeerID)

+ OnPeerDisconnect func(peer RemotePeer)

+ type PeerFinder interface

+ CheckAndFill func()

+ type PeerManager interface

+ AddNewPeer func(peer PeerMeta)

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

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

+ GetPeerBlockInfos func() []types.PeerBlockInfo

+ GetPeers func() []RemotePeer

+ NotifyPeerAddressReceived func([]PeerMeta)

+ RemovePeer func(peer RemotePeer)

+ SelfMeta func() PeerMeta

+ SelfNodeID func() types.PeerID

+ Start func() error

+ Stop func() error

+ type PeerMeta struct

+ Designated bool

+ Hidden bool

+ ID types.PeerID

+ IPAddress string

+ Outbound bool

+ Port uint32

+ Version string

+ func FromPeerAddress(addr *types.PeerAddress) PeerMeta

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

+ func (m *PeerMeta) GetVersion() string

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

+ type RemotePeer interface

+ AddMessageHandler func(subProtocol SubProtocol, handler MessageHandler)

+ ConsumeRequest func(msgID MsgID)

+ GetReceiver func(id MsgID) ResponseReceiver

+ ID func() types.PeerID

+ LastStatus 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

+ Version func() string

+ type ResponseReceiver func(Message, MessageBody) 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)

+ type VersionedHandshaker interface

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

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

+ GetMsgRW func() MsgReadWriter

+ type VersionedManager interface

+ FindBestP2PVersion func(versions []P2PVersion) P2PVersion

+ GetVersionedHandshaker func(version P2PVersion, peerID types.PeerID, r io.Reader, w io.Writer) (VersionedHandshaker, error)

+ InjectHandlers func(version P2PVersion, peer RemotePeer)

+ type WaitingPeer struct

+ LastResult error

+ Meta PeerMeta

+ NextTrial time.Time

+ TrialCnt int

+ type WaitingPeerManager interface

+ CheckAndConnect func()

+ OnDiscoveredPeers func(metas []PeerMeta) int

+ OnInboundConn func(s network.Stream)

+ OnInboundConnLegacy func(s network.Stream)

+ OnWorkDone func(result ConnWorkResult)

Other modules containing this package

github.com/aergoio/aergo/v2

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