Versions in this module Expand all Collapse all v2 v2.3.3 Oct 19, 2023 Changes in this version + type DefaultSubscriber struct + func (DefaultSubscriber) OnMessage(*Message) + func (DefaultSubscriber) OnQuit() + type Message struct + Payload interface{} + Topic Topic + type MessageBus interface + Close func() + Publish func(topic Topic, payload interface{}) + PublishSafe func(topic Topic, payload interface{}) + PublishSync func(topic Topic, payload interface{}) + Register func(topic Topic, sub Subscriber) + UnRegister func(topic Topic, sub Subscriber) + func NewMessageBus() MessageBus + type Subscriber interface + OnMessage func(*Message) + OnQuit func() + type Topic int + const BlacklistStateKeyAdd + const BlacklistStateKeyDel + const BlacklistTxIdAdd + const BlacklistTxIdDel + const BlockInfo + const BuildProposal + const CertManageCertsAliasDelete + const CertManageCertsAliasUpdate + const CertManageCertsDelete + const CertManageCertsFreeze + const CertManageCertsRevoke + const CertManageCertsUnfreeze + const ChainConfig + const CommitBlock + const ContractEventInfo + const Invalid + const MaxbftEpochConf + const ProposeBlock + const ProposeState + const ProposedBlock + const PubkeyManageAdd + const PubkeyManageDelete + const RecvConsensusMsg + const RecvConsistentMsg + const RecvSyncBlockMsg + const RecvTxPoolMsg + const RwSetVerifyFailTxs + const SendConsensusMsg + const SendConsistentMsg + const SendSyncBlockMsg + const SendTxPoolMsg + const TxPoolSignal + const VerifyBlock + const VerifyResult + func (i Topic) String() string