p2p

Jul 10, 2020

Changes in this version

+ const PublishBandWithPeersInfo

+ const PublishConnectPeersInfo

+ const PublishOnlinePeersInfo

+ var ErrNoBootNode = errors.New("can not get bootNode")

+ type ConnectionGater struct

+ func NewConnectionGater() *ConnectionGater

+ func (cg *ConnectionGater) InterceptAccept(network.ConnMultiaddrs) bool

+ func (cg *ConnectionGater) InterceptAddrDial(p peer.ID, addr ma.Multiaddr) bool

+ func (cg *ConnectionGater) InterceptPeerDial(peer.ID) bool

+ func (cg *ConnectionGater) InterceptSecured(network.Direction, peer.ID, network.ConnMultiaddrs) bool

+ func (cg *ConnectionGater) InterceptUpgraded(network.Conn) (bool, control.DisconnectReason)

+ type EventBroadcastMsg struct

+ Message interface{}

+ Type MessageType

+ type EventConfirmAckMsg struct

+ Block *protos.ConfirmAckBlock

+ From string

+ type EventFrontiersReqMsg struct

+ PeerID string

+ type EventPovBulkPullReqMsg struct

+ From string

+ Req *protos.PovBulkPullReq

+ type EventPovBulkPullRspMsg struct

+ From string

+ Resp *protos.PovBulkPullRsp

+ type EventPovPeerStatusMsg struct

+ From string

+ Status *protos.PovStatus

+ type EventSendMsgToSingleMsg struct

+ Message interface{}

+ PeerID string

+ Type MessageType

type QlcNode

+ MessageTopic *pubsub.Topic

+ type WhiteList struct

Dec 18, 2019

Changes in this version

+ const ConnectBootstrapInterval

+ const PingTimeInterval

type StreamManager

+ func (sm *StreamManager) AddOnlineInfo(info *types.PeerInfo)

+ func (sm *StreamManager) AddOrUpdateOnlineInfo(info *types.PeerInfo)

Dec 12, 2019

Changes in this version

+ const QlcMDnsFOUND

type StreamManager

+ func (sm *StreamManager) AddOrUpdateStream(info *types.PeerInfo)

+ func (sm *StreamManager) GetOnlinePeersInfo(pr *[]*types.PeerInfo)

Nov 15, 2019

Changes in this version

+ const BlockTopic

+ const Intranet

+ const MaxPeersNumForRandom

+ const MaxPingTimeOutTimes

+ const MaxStreamNum

+ const MessagePriorityHigh

+ const MessagePriorityLow

+ const MessagePriorityNormal

+ const MsgTopic

+ const PublicNet

+ var ErrPingSelf = errors.New("cannot ping self")

type Dispatcher

+ func (dp *Dispatcher) PutSyncMessage(msg *Message)

+ type Pinger struct

+ func NewPinger(h host.Host) *Pinger

+ func (p *Pinger) Ping(ctx context.Context, pid peer.ID) (<-chan ping.Result, error)

type QlcNode

+ MessageSub pubsub.Subscription

+ func (node *QlcNode) GetBandwidthStats(stats *p2pmetrics.Stats)

type QlcService

+ func (ns *QlcService) PutSyncMessage(msg *Message)

type ServiceSync

+ func (ss *ServiceSync) GetSyncState(s *common.SyncState)

type StreamManager

+ func (sm *StreamManager) SetQlcNodeAndMaxStreamNum(node *QlcNode)

Jul 31, 2019

Changes in this version

+ const PovBulkPullReq

+ const PovBulkPullRsp

+ const PovPublishReq

+ const PovStatus

type Stream

+ func (s *Stream) SendMessageToChan(message []byte)

+ func (s *Stream) SendMessageToCtrlChan(message []byte)

type StreamManager

+ func (sm *StreamManager) IsConnectWithPeerId(peerID string) bool

May 25, 2019

Changes in this version

type ServiceSync

+ func (ss *ServiceSync) LastSyncTime(t time.Time)

May 13, 2019

Changes in this version

+ var ErrCloseStream = errors.New("stream close error")

type StreamManager

+ func (sm *StreamManager) GetAllConnectPeersInfo(p map[string]string)

Apr 29, 2019

Changes in this version

type Message

+ func NewMessage(messageType MessageType, from string, data []byte, content []byte) *Message

+ func (msg *Message) String() string

Mar 14, 2019

Changes in this version

+ const MessageResponse

type BaseMessage

+ func (msg *BaseMessage) Content() []byte

type EventQueue

+ func NewEventQueue() *EventQueue

type Message

+ Content func() []byte

type QlcNode

+ func (node *QlcNode) SendMessageToPeers(messageName string, value interface{}, peerID string)

type QlcService

+ func (ns *QlcService) SendMessageToPeers(messageName string, value interface{}, peerID string)

type Service

+ SendMessageToPeers func(messageName string, value interface{}, peerID string)

type Stream

+ func (s *Stream) SendMessageToPeer(messageType string, data []byte) error

+ func (s *Stream) SendMessageToPeers(messageType string, data []byte) error

type StreamManager

+ func (sm *StreamManager) SendMessageToPeers(messageName string, v interface{}, peerID string)

Jan 23, 2019

Changes in this version

type StreamManager

+ func (sm *StreamManager) PeerCounts() int

Dec 28, 2018

Changes in this version

+ const BulkPullRequest

+ const BulkPullRsp

+ const BulkPushBlock

+ const ConfirmAck

+ const ConfirmReq

+ const EachTimeFoundPeersLimit

+ const FindPeerInterval

+ const FrontierRequest

+ const FrontierRsp

+ const ID

+ const PingSize

+ const PublishReq

+ const QlcMessageDataCheckSumEndIdx

+ const QlcMessageDataLengthEndIdx

+ const QlcMessageHeaderCheckSumEndIdx

+ const QlcMessageHeaderLength

+ const QlcMessageMagicNumberEndIdx

+ const QlcMessageReservedEndIdx

+ const QlcMessageTypeEndIdx

+ const QlcMessageVersionEndIdx

+ const QlcProtocolFOUND

+ const QlcProtocolID

+ const SyncInterval

+ var ErrInvalidDataCheckSum = errors.New("invalid data checksum")

+ var ErrInvalidHeaderCheckSum = errors.New("invalid header checksum")

+ var ErrInvalidMagicNumber = errors.New("invalid magic number")

+ var ErrInvalidMessageDataLength = errors.New("invalid message data length")

+ var ErrInvalidMessageHeaderLength = errors.New("invalid message header length")

+ var ErrNoStream = errors.New("no stream")

+ var ErrPeerIsNotConnected = errors.New("peer is not connected")

+ var ErrShouldCloseConnectionAndExitLoop = errors.New("should close connection and exit loop")

+ var ErrStreamIsNotConnected = errors.New("stream is not connected")

+ var MagicNumber = []byte

+ func Equal(a []byte, b []byte) bool

+ func FromUint32(v uint32) []byte

+ func NewQlcMessage(data []byte, currentVersion byte, messagetype string) []byte

+ func Ping(ctx context.Context, h host.Host, p peer.ID) (<-chan time.Duration, error)

+ func Uint32(data []byte) uint32

+ type BaseMessage struct

+ func (msg *BaseMessage) Data() []byte

+ func (msg *BaseMessage) Hash() string

+ func (msg *BaseMessage) MessageFrom() string

+ func (msg *BaseMessage) MessageType() MessageType

+ func (msg *BaseMessage) String() string

+ type DiscoveryOption func(context.Context, host.Host) (localdiscovery.Service, error)

+ type Dispatcher struct

+ func NewDispatcher() *Dispatcher

+ func (dp *Dispatcher) Deregister(subscribers ...*Subscriber)

+ func (dp *Dispatcher) PutMessage(msg Message)

+ func (dp *Dispatcher) Register(subscribers ...*Subscriber)

+ func (dp *Dispatcher) Start()

+ func (dp *Dispatcher) Stop()

+ type Event struct

+ func NewEvent() *Event

+ func (e *Event) Notify(eventtype EventType, value interface{}) (err error)

+ func (e *Event) NotifyAll() (errs []error)

+ func (e *Event) NotifySubscriber(eventfunc EventFunc, value interface{})

+ func (e *Event) Subscribe(eventtype EventType, eventfunc EventFunc) EventSubscriber

+ func (e *Event) UnSubscribe(eventtype EventType, subscriber EventSubscriber) (err error)

+ type EventFunc func(v interface{})

+ type EventQueue struct

+ Consensus *Event

+ func NeweventQueue() *EventQueue

+ func (eq *EventQueue) GetEvent(eventName string) *Event

+ type EventSubscriber chan interface

+ type EventType int16

+ const EventConfirmAck

+ const EventConfirmReq

+ const EventConfirmedBlock

+ const EventPublish

+ const EventSyncBlock

+ type Message interface

+ Data func() []byte

+ Hash func() string

+ MessageFrom func() string

+ MessageType func() MessageType

+ func NewBaseMessage(messageType MessageType, from string, data []byte) Message

+ type MessageService struct

+ func NewMessageService(netService *QlcService, ledger *ledger.Ledger) *MessageService

+ func (ms *MessageService) Start()

+ func (ms *MessageService) Stop()

+ type MessageType string

+ type PeersSlice []interface

+ type PingService struct

+ Host host.Host

+ func NewPingService(h host.Host) *PingService

+ func (p *PingService) PingHandler(s inet.Stream)

+ func (ps *PingService) Ping(ctx context.Context, p peer.ID) (<-chan time.Duration, error)

+ type QlcMessage struct

+ func ParseQlcMessage(data []byte) (*QlcMessage, error)

+ func (message *QlcMessage) DataCheckSum() uint32

+ func (message *QlcMessage) DataLength() uint32

+ func (message *QlcMessage) HeaderCheckSum() uint32

+ func (message *QlcMessage) HeaderData() []byte

+ func (message *QlcMessage) MagicNumber() []byte

+ func (message *QlcMessage) MessageData() []byte

+ func (message *QlcMessage) MessageType() MessageType

+ func (message *QlcMessage) ParseMessageData(data []byte) error

+ func (message *QlcMessage) Reserved() []byte

+ func (message *QlcMessage) VerifyData() error

+ func (message *QlcMessage) VerifyHeader() error

+ func (message *QlcMessage) Version() byte

+ type QlcNode struct

+ ID peer.ID

+ func NewNode(config *config.Config) (*QlcNode, error)

+ func (node *QlcNode) BroadcastMessage(messageName string, data []byte)

+ func (node *QlcNode) GetID() string

+ func (node *QlcNode) HandlePeerFound(p pstore.PeerInfo)

+ func (node *QlcNode) SendMessageToPeer(messageName string, data []byte, peerID string) error

+ func (node *QlcNode) SetQlcService(ns *QlcService)

+ func (node *QlcNode) StartServices() error

+ func (node *QlcNode) Stop()

+ func (node *QlcNode) StreamManager() *StreamManager

+ type QlcService struct

+ func NewQlcService(cfg *config.Config) (*QlcService, error)

+ func (ns *QlcService) Broadcast(name string, msg []byte)

+ func (ns *QlcService) Deregister(subscribers ...*Subscriber)

+ func (ns *QlcService) Init() error

+ func (ns *QlcService) MessageEvent() *EventQueue

+ func (ns *QlcService) Node() *QlcNode

+ func (ns *QlcService) PutMessage(msg Message)

+ func (ns *QlcService) Register(subscribers ...*Subscriber)

+ func (ns *QlcService) SendMessageToPeer(messageName string, data []byte, peerID string) error

+ func (ns *QlcService) Start() error

+ func (ns *QlcService) Status() int32

+ func (ns *QlcService) Stop() error

+ type Service interface

+ Broadcast func(string, []byte)

+ MessageEvent func() *EventQueue

+ Node func() *QlcNode

+ SendMessageToPeer func(messageName string, data []byte, peerID string) error

+ type ServiceSync struct

+ func NewSyncService(netService *QlcService, ledger *ledger.Ledger) *ServiceSync

+ func (ss *ServiceSync) Start()

+ func (ss *ServiceSync) Stop()

+ type Stream struct

+ func NewStream(stream libnet.Stream, node *QlcNode) *Stream

+ func NewStreamFromPID(pid peer.ID, node *QlcNode) *Stream

+ func (s *Stream) Connect() error

+ func (s *Stream) IsConnected() bool

+ func (s *Stream) SendMessage(messageType string, data []byte) error

+ func (s *Stream) StartLoop()

+ func (s *Stream) String() string

+ func (s *Stream) Write(data []byte) error

+ func (s *Stream) WriteQlcMessage(message []byte) error

+ type StreamManager struct

+ func NewStreamManager() *StreamManager

+ func (sm *StreamManager) Add(s libnet.Stream)

+ func (sm *StreamManager) AddStream(stream *Stream)

+ func (sm *StreamManager) BroadcastMessage(messageName string, messageContent []byte)

+ func (sm *StreamManager) CloseStream(peerID string)

+ func (sm *StreamManager) CreateStreamWithPeer(pid peer.ID)

+ func (sm *StreamManager) Find(pid peer.ID) *Stream

+ func (sm *StreamManager) FindByPeerID(peerID string) *Stream

+ func (sm *StreamManager) RandomPeer() (string, error)

+ func (sm *StreamManager) RemoveStream(s *Stream)

+ func (sm *StreamManager) SetQlcNode(node *QlcNode)

+ func (sm *StreamManager) Start()

+ func (sm *StreamManager) Stop()

+ type Subscriber struct

+ func NewSubscriber(id interface{}, msgChan chan Message, doFilter bool, msgType MessageType) *Subscriber

+ func (s *Subscriber) DoFilter() bool

+ func (s *Subscriber) ID() interface{}

+ func (s *Subscriber) MessageChan() chan Message

+ func (s *Subscriber) MessageType() MessageType