Versions in this module Expand all Collapse all v1 v1.0.1 Sep 18, 2024 v1.0.0 May 17, 2024 Changes in this version + var DefaultBufferCapacity = 100 + type EventBus struct + func NewDefault(l log.Logger) *EventBus + func (b *EventBus) NumClientSubscriptions(clientID string) int + func (b *EventBus) NumClients() int + func (b *EventBus) Observe(ctx context.Context, observe func(tmpubsub.Message) error, ...) error + func (b *EventBus) OnStart(ctx context.Context) error + func (b *EventBus) OnStop() + func (b *EventBus) Publish(eventValue string, eventData types.EventData) error + func (b *EventBus) PublishEventBlockSyncStatus(data types.EventDataBlockSyncStatus) error + func (b *EventBus) PublishEventCompleteProposal(data types.EventDataCompleteProposal) error + func (b *EventBus) PublishEventEvidenceValidated(evidence types.EventDataEvidenceValidated) error + func (b *EventBus) PublishEventLock(data types.EventDataRoundState) error + func (b *EventBus) PublishEventNewBlock(data types.EventDataNewBlock) error + func (b *EventBus) PublishEventNewBlockHeader(data types.EventDataNewBlockHeader) error + func (b *EventBus) PublishEventNewEvidence(evidence types.EventDataNewEvidence) error + func (b *EventBus) PublishEventNewRound(data types.EventDataNewRound) error + func (b *EventBus) PublishEventNewRoundStep(data types.EventDataRoundState) error + func (b *EventBus) PublishEventPolka(data types.EventDataRoundState) error + func (b *EventBus) PublishEventRelock(data types.EventDataRoundState) error + func (b *EventBus) PublishEventStateSyncStatus(data types.EventDataStateSyncStatus) error + func (b *EventBus) PublishEventTimeoutPropose(data types.EventDataRoundState) error + func (b *EventBus) PublishEventTimeoutWait(data types.EventDataRoundState) error + func (b *EventBus) PublishEventTx(data types.EventDataTx) error + func (b *EventBus) PublishEventValidBlock(data types.EventDataRoundState) error + func (b *EventBus) PublishEventValidatorSetUpdates(data types.EventDataValidatorSetUpdates) error + func (b *EventBus) PublishEventVote(data types.EventDataVote) error + func (b *EventBus) SubscribeWithArgs(ctx context.Context, args tmpubsub.SubscribeArgs) (Subscription, error) + func (b *EventBus) Unsubscribe(ctx context.Context, args tmpubsub.UnsubscribeArgs) error + func (b *EventBus) UnsubscribeAll(ctx context.Context, subscriber string) error + type Subscription interface + ID func() string + Next func(context.Context) (tmpubsub.Message, error)
Go to main page