reporter

Documentation

Index

• type AttestationEventReporter
  • func EventListener(logger *zap.Logger) *AttestationEventReporter
  • func (re *AttestationEventReporter) ReportMessagePublication(msg *MessagePublication)
  • func (re *AttestationEventReporter) ReportVAAQuorum(msg *vaa.VAA)
  • func (re *AttestationEventReporter) Subscribe() *activeSubscription
  • func (re *AttestationEventReporter) Unsubscribe(clientId int)
• type MessagePublication

Types

type AttestationEventReporter

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

func EventListener

func EventListener(logger *zap.Logger) *AttestationEventReporter

func (*AttestationEventReporter) ReportMessagePublication

func (re *AttestationEventReporter) ReportMessagePublication(msg *MessagePublication)

ReportMessagePublication is invoked when an on-chain message is observed.

func (*AttestationEventReporter) ReportVAAQuorum

func (re *AttestationEventReporter) ReportVAAQuorum(msg *vaa.VAA)

ReportVAAQuorum is invoked when quorum is reached.

func (*AttestationEventReporter) Subscribe

func (re *AttestationEventReporter) Subscribe() *activeSubscription

func (*AttestationEventReporter) Unsubscribe

func (re *AttestationEventReporter) Unsubscribe(clientId int)

type MessagePublication

type MessagePublication struct {
	VAA vaa.VAA
	// The native transaction identifier from the EmitterAddress interaction.
	InitiatingTxID common.Hash
}

MessagePublication is a VAA along with a transaction identifer from the EmiterChain