Versions in this module Expand all Collapse all v3 v3.0.1 Dec 27, 2023 v3.0.0 Dec 23, 2022 Changes in this version + var ErrorChainMsgBusBeenBound = errors.New("chain msg bus has been bound") + var ErrorNetNotRunning = errors.New("net instance is not running") + var ErrorNetType = errors.New("error net type") + var GlobalNetLogger protocol.Logger + func CreateFlagWithPrefixAndMsgType(prefix string, msgType netPb.NetMsg_MsgType) string + func CreateMsgHandlerForMsgBus(netService *NetService, topic msgbus.Topic, logMsgDescription string, ...) func(chainId string, node string, data []byte) error + func HandleMsgBusSubscriberOnMessage(netService *NetService, msgType netPb.NetMsg_MsgType, logMsgDescription string, ...) error + func NewNetMsg(msg []byte, msgType netPb.NetMsg_MsgType, to string) *netPb.NetMsg + type ConfigWatcher struct + func (cw *ConfigWatcher) Module() string + func (cw *ConfigWatcher) Watch(chainConfig *configPb.ChainConfig) error + type ConsensusMsgSubscriber struct + func (cms *ConsensusMsgSubscriber) OnMessage(message *msgbus.Message) + func (cms *ConsensusMsgSubscriber) OnQuit() + type ConsistentMsgSubscriber struct + func (cms *ConsistentMsgSubscriber) OnMessage(message *msgbus.Message) + func (cms *ConsistentMsgSubscriber) OnQuit() + type MsgForMsgBusHandler func(chainId string, from string, msg []byte) error + type NetContractEventSubscribe struct + func (n *NetContractEventSubscribe) OnMessage(msg *msgbus.Message) + func (n *NetContractEventSubscribe) OnQuit() + type NetFactory struct + func (nf *NetFactory) Apply(opts ...NetOption) error + func (nf *NetFactory) NewNet(netType protocol.NetType, opts ...NetOption) (protocol.Net, error) + type NetOption func(cfg *NetFactory) error + func WithBlackAddresses(blackAddresses ...string) NetOption + func WithBlackNodeIds(blackNodeIds ...string) NetOption + func WithCrypto(pkMode bool, keyFile string, certFile string) NetOption + func WithInsecurity(isInsecurity bool) NetOption + func WithListenAddr(addr string) NetOption + func WithMaxConnCountAllowed(max int) NetOption + func WithMaxPeerCountAllowed(max int) NetOption + func WithMsgCompression(enable bool) NetOption + func WithPeerEliminationStrategy(strategy int) NetOption + func WithPeerStreamPoolSize(size int) NetOption + func WithPktEnable(pktEnable bool) NetOption + func WithPriorityControlEnable(priorityCtrlEnable bool) NetOption + func WithPubSubMaxMessageSize(size int) NetOption + func WithReadySignalC(signalC chan struct{}) NetOption + func WithSeeds(seeds ...string) NetOption + type NetService struct + func NewNetService(chainId string, localNet protocol.Net, ac protocol.AccessControlProvider) *NetService + func (ns *NetService) Apply(opts ...NetServiceOption) error + func (ns *NetService) BroadcastMsg(msg []byte, msgType netPb.NetMsg_MsgType) error + func (ns *NetService) CancelConsensusSubscribe(msgType netPb.NetMsg_MsgType) error + func (ns *NetService) CancelSubscribe(msgType netPb.NetMsg_MsgType) error + func (ns *NetService) ConfigWatcher() protocol.Watcher + func (ns *NetService) ConsensusBroadcastMsg(msg []byte, msgType netPb.NetMsg_MsgType) error + func (ns *NetService) ConsensusSubscribe(msgType netPb.NetMsg_MsgType, handler protocol.MsgHandler) error + func (ns *NetService) GetChainNodesInfo() ([]*protocol.ChainNodeInfo, error) + func (ns *NetService) GetChainNodesInfoProvider() protocol.ChainNodesInfoProvider + func (ns *NetService) GetNodeUidByCertId(certId string) (string, error) + func (ns *NetService) NetConfigSubscribe() msgbus.Subscriber + func (ns *NetService) ReceiveMsg(msgType netPb.NetMsg_MsgType, handler protocol.MsgHandler) error + func (ns *NetService) SendMsg(msg []byte, msgType netPb.NetMsg_MsgType, to ...string) error + func (ns *NetService) Start() error + func (ns *NetService) Stop() error + func (ns *NetService) Subscribe(msgType netPb.NetMsg_MsgType, handler protocol.MsgHandler) error + func (ns *NetService) VmWatcher() protocol.VmWatcher + type NetServiceFactory struct + func (nsf *NetServiceFactory) NewNetService(net protocol.Net, chainId string, ac protocol.AccessControlProvider, ...) (protocol.NetService, error) + type NetServiceOption func(ns *NetService) error + func WithConsensusNodeUid(consensusNodeUid ...string) NetServiceOption + func WithMsgBus(msgBus msgbus.MessageBus) NetServiceOption + type SyncBlockMsgSubscriber struct + func (cms *SyncBlockMsgSubscriber) OnMessage(message *msgbus.Message) + func (cms *SyncBlockMsgSubscriber) OnQuit() + type TxPoolMsgSubscriber struct + func (cms *TxPoolMsgSubscriber) OnMessage(message *msgbus.Message) + func (cms *TxPoolMsgSubscriber) OnQuit() + type VmWatcher struct + func (v *VmWatcher) Callback(contractName string, _ []byte) error + func (v *VmWatcher) ContractNames() []string + func (v *VmWatcher) Module() string Other modules containing this package chainmaker.org/chainmaker/consensus-utils/v2