p2p

Documentation

Overview

package manage 实现多种类型p2p兼容管理

Index

• func RegisterP2PCreate(p2pType string, create CreateP2P)
• type CreateP2P
  • func LoadP2PCreate(p2pType string) CreateP2P
• type IP2P
• type Manager
  • func NewP2PMgr(cfg *types.Chain33Config) *Manager
  • func (mgr *Manager) Close()
  • func (mgr *Manager) PubBroadCast(hash string, data interface{}, eventTy int) error
  • func (mgr *Manager) SetQueueClient(cli queue.Client)
  • func (mgr *Manager) Wait()

Functions

func RegisterP2PCreate

func RegisterP2PCreate(p2pType string, create CreateP2P)

RegisterP2PCreate register p2p create func

Types

type CreateP2P

type CreateP2P func(mgr *Manager, subCfg []byte) IP2P

CreateP2P p2p creator

func LoadP2PCreate

func LoadP2PCreate(p2pType string) CreateP2P

LoadP2PCreate load p2p create func

type IP2P

type IP2P interface {
	StartP2P()
	CloseP2P()
}

IP2P p2p interface

type Manager

type Manager struct {
	SysAPI   client.QueueProtocolAPI
	Client   queue.Client
	ChainCfg *types.Chain33Config
	PubSub   *pubsub.PubSub
	// contains filtered or unexported fields
}

Manager p2p manager

func NewP2PMgr

func NewP2PMgr(cfg *types.Chain33Config) *Manager

NewP2PMgr new p2p manager

func (*Manager) Close

func (mgr *Manager) Close()

Close close p2p

func (*Manager) PubBroadCast

func (mgr *Manager) PubBroadCast(hash string, data interface{}, eventTy int) error

PubBroadCast 兼容多种类型p2p广播消息, 避免重复接交易或者区块

func (*Manager) SetQueueClient

func (mgr *Manager) SetQueueClient(cli queue.Client)

SetQueueClient set the queue

func (*Manager) Wait

func (mgr *Manager) Wait()

Wait wait p2p