events

Documentation

Index

• type Distributor
  • func NewDistributor() *Distributor
  • func (d *Distributor) AddConsumer(consumer protocol.Consumer)
  • func (d *Distributor) BlockFinalized(block *flow.Header)
  • func (d *Distributor) BlockProcessable(block *flow.Header)
  • func (d *Distributor) EpochCommittedPhaseStarted(epoch uint64, first *flow.Header)
  • func (d *Distributor) EpochEmergencyFallbackTriggered()
  • func (d *Distributor) EpochSetupPhaseStarted(epoch uint64, first *flow.Header)
  • func (d *Distributor) EpochTransition(newEpoch uint64, first *flow.Header)
• type Heights
• type Noop
  • func NewNoop() *Noop
  • func (n Noop) BlockFinalized(block *flow.Header)
  • func (n Noop) BlockProcessable(block *flow.Header)
  • func (n Noop) EpochCommittedPhaseStarted(epoch uint64, first *flow.Header)
  • func (n Noop) EpochEmergencyFallbackTriggered()
  • func (n Noop) EpochSetupPhaseStarted(epoch uint64, first *flow.Header)
  • func (n Noop) EpochTransition(newEpoch uint64, first *flow.Header)
• type OnViewCallback
• type Views

Types

type Distributor

type Distributor struct {
	// contains filtered or unexported fields
}

Distributor distributes events to a list of subscribers.

func NewDistributor

func NewDistributor() *Distributor

NewDistributor returns a new events distributor.

func (*Distributor) AddConsumer

func (d *Distributor) AddConsumer(consumer protocol.Consumer)

func (*Distributor) BlockFinalized

func (d *Distributor) BlockFinalized(block *flow.Header)

func (*Distributor) BlockProcessable

func (d *Distributor) BlockProcessable(block *flow.Header)

func (*Distributor) EpochCommittedPhaseStarted

func (d *Distributor) EpochCommittedPhaseStarted(epoch uint64, first *flow.Header)

func (*Distributor) EpochEmergencyFallbackTriggered

func (d *Distributor) EpochEmergencyFallbackTriggered()

func (*Distributor) EpochSetupPhaseStarted

func (d *Distributor) EpochSetupPhaseStarted(epoch uint64, first *flow.Header)

func (*Distributor) EpochTransition

func (d *Distributor) EpochTransition(newEpoch uint64, first *flow.Header)

type Heights

type Heights interface {

	// OnHeight registers the callback for the given height.
	OnHeight(height uint64, callback func())
}

Heights enables subscribing to specific heights. The callback is invoked when the given height is finalized.

type Noop

type Noop struct{}

Noop is a no-op implementation of protocol.Consumer.

func NewNoop

func NewNoop() *Noop

func (Noop) BlockFinalized

func (n Noop) BlockFinalized(block *flow.Header)

func (Noop) BlockProcessable

func (n Noop) BlockProcessable(block *flow.Header)

func (Noop) EpochCommittedPhaseStarted

func (n Noop) EpochCommittedPhaseStarted(epoch uint64, first *flow.Header)

func (Noop) EpochEmergencyFallbackTriggered

func (n Noop) EpochEmergencyFallbackTriggered()

func (Noop) EpochSetupPhaseStarted

func (n Noop) EpochSetupPhaseStarted(epoch uint64, first *flow.Header)

func (Noop) EpochTransition

func (n Noop) EpochTransition(newEpoch uint64, first *flow.Header)

type OnViewCallback

type OnViewCallback func(*flow.Header)

OnViewCallback is the type of callback triggered by view events.

type Views

type Views interface {
	// OnView registers the callback for the given view.
	OnView(view uint64, callback OnViewCallback)
}

Views enables subscribing to specific views. The callback is invoked when the first block of the given view is finalized.