reporter

Documentation

Index

• func BigTableWriter(events *AttestationEventReporter, connectionConfig *BigTableConnectionConfig) func(ctx context.Context) error
• type AttestationEventReporter
  • func EventListener(logger *zap.Logger) *AttestationEventReporter
  • func (re *AttestationEventReporter) ReportMessagePublication(msg *MessagePublication)
  • func (re *AttestationEventReporter) ReportVAAQuorum(msg *vaa.VAA)
  • func (re *AttestationEventReporter) ReportVAAStateUpdate(msg *vaa.VAA)
  • func (re *AttestationEventReporter) ReportVerifiedPeerSignature(msg *VerifiedPeerSignature)
  • func (re *AttestationEventReporter) Subscribe() *activeSubscription
  • func (re *AttestationEventReporter) Unsubscribe(clientId int)
• type BigTableConnectionConfig
• type MessagePublication
• type VerifiedPeerSignature

Functions

func BigTableWriter

func BigTableWriter(events *AttestationEventReporter, connectionConfig *BigTableConnectionConfig) func(ctx context.Context) error

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) ReportVAAStateUpdate

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

ReportVAAStateUpdate is invoked each time the local VAAState is updated.

func (*AttestationEventReporter) ReportVerifiedPeerSignature

func (re *AttestationEventReporter) ReportVerifiedPeerSignature(msg *VerifiedPeerSignature)

ReportVerifiedPeerSignature is invoked after a SignedObservation is verified.

func (*AttestationEventReporter) Subscribe

func (re *AttestationEventReporter) Subscribe() *activeSubscription

func (*AttestationEventReporter) Unsubscribe

func (re *AttestationEventReporter) Unsubscribe(clientId int)

type BigTableConnectionConfig

type BigTableConnectionConfig struct {
	GcpProjectID    string
	GcpInstanceName string
	GcpKeyFilePath  string
	TableName       string
}

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

type VerifiedPeerSignature

type VerifiedPeerSignature struct {
	// The chain the transaction took place on
	EmitterChain vaa.ChainID
	// EmitterAddress of the contract that emitted the Message
	EmitterAddress vaa.Address
	// Sequence of the VAA
	Sequence uint64
	// The address of the Guardian that observed and signed the message
	GuardianAddress common.Address
	// Transaction Identifier of the initiating event
	Signature []byte
}

VerifiedPeerSignature is a message observation from a Guardian that has been verified to be authentic and authorized to contribute to VAA quorum (ie. within the Guardian set).