Versions in this module Expand all Collapse all v1 v1.5.1 Dec 9, 2022 v1.5.0 Dec 8, 2022 Changes in this version type Topic + const HotStuffEpochConf v1.0.0 Nov 7, 2022 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 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