Versions in this module Expand all Collapse all v0 v0.0.7 Sep 22, 2021 Changes in this version + const DefaultInitSendStreamSize + const DefaultListenAddress + const DefaultMaxConnCountEachPeer + const DefaultMaxPeerCount + const DefaultPeerEliminationStrategy + const DefaultPubSubMaxMessageSize + const DefaultSendStreamMaxCount + const NetProtocolTemplatePrefix + var ErrorNetRunning = errors.New("net running") + var ErrorNotBelongToChain = errors.New("node not belong to chain") + var ErrorPubSubExisted = errors.New("pub-sub service existed") + var ErrorPubSubNotExist = errors.New("pub-sub service not exist") + var ErrorTopicNotSubscribed = errors.New("topic has not been subscribed") + var ErrorTopicSubscribed = errors.New("topic has been subscribed") + var ErrorWrongAddressOrUnsupported = errors.New("wrong address or address unsupported") + func CreateProtocolIdWithChainIdAndMsgFlag(chainId, msgFlag string) protocol.ID + func InitLogger(globalNetLogger api.Logger, pubSubLogCreator func(chainId string) api.Logger) + func LoadChainIdAndFlagWithProtocolId(protocolId protocol.ID) (string, string, error) + func SetListenAddrStr(hc *host.HostConfig, listenAddrStr string) error + type LiquidNet struct + func NewLiquidNet() (*LiquidNet, error) + func (l *LiquidNet) AddAC(chainId string, ac api.AccessControlProvider) + func (l *LiquidNet) AddSeed(seed string) error + func (l *LiquidNet) AddTrustRoot(chainId string, rootCertByte []byte) error + func (l *LiquidNet) BroadcastWithChainId(chainId string, topic string, data []byte) error + func (l *LiquidNet) CancelDirectMsgHandle(chainId string, msgFlag string) error + func (l *LiquidNet) CancelSubscribeWithChainId(chainId string, topic string) error + func (l *LiquidNet) ChainNodesInfo(chainId string) ([]*api.ChainNodeInfo, error) + func (l *LiquidNet) CheckRevokeTlsCerts(ac api.AccessControlProvider, certManageSystemContractPayload []byte) error + func (l *LiquidNet) CryptoConfig() *cryptoConfig + func (l *LiquidNet) DirectMsgHandle(chainId string, msgFlag string, handler api.DirectMsgHandler) error + func (l *LiquidNet) ExtensionsConfig() *extensionsConfig + func (l *LiquidNet) GetNodeUid() string + func (l *LiquidNet) GetNodeUidByCertId(certId string) (string, error) + func (l *LiquidNet) HostConfig() *lHost.HostConfig + func (l *LiquidNet) InitPubSub(chainId string, maxMessageSize int) error + func (l *LiquidNet) IsRunning() bool + func (l *LiquidNet) PubSubConfig() *pubSubConfig + func (l *LiquidNet) ReVerifyTrustRoots(chainId string) + func (l *LiquidNet) RefreshSeeds(seeds []string) error + func (l *LiquidNet) RefreshTrustRoots(chainId string, rootsCertsBytes [][]byte) error + func (l *LiquidNet) SendMsg(chainId string, targetPeer string, msgFlag string, data []byte) error + func (l *LiquidNet) SetMsgPriority(msgFlag string, priority uint8) + func (l *LiquidNet) Start() error + func (l *LiquidNet) Stop() error + func (l *LiquidNet) SubscribeWithChainId(chainId string, topic string, handler api.PubSubMsgHandler) error