mercury

Documentation

Index

• type HTTPClient
• type MercuryReport
• type MercuryTransmitter
  • func NewTransmitter(lggr logger.Logger, httpClient HTTPClient, fromAccount common.Address, ...) *MercuryTransmitter
  • func (mt *MercuryTransmitter) FromAccount() ocrtypes.Account
  • func (mt *MercuryTransmitter) LatestConfigDigestAndEpoch(ctx context.Context) (cd ocrtypes.ConfigDigest, epoch uint32, err error)
  • func (mt *MercuryTransmitter) Transmit(ctx context.Context, reportCtx ocrtypes.ReportContext, report ocrtypes.Report, ...) error
• type ReportCodec
  • func (r ReportCodec) BuildReport(paos []median.ParsedAttributedObservation) (types.Report, error)
  • func (ReportCodec) MaxReportLength(_ int) int
  • func (ReportCodec) MedianFromReport(report types.Report) (*big.Int, error)

Types

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type MercuryReport

type MercuryReport struct {
	Payload     hexutil.Bytes
	FromAccount common.Address
}

type MercuryTransmitter

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

func NewTransmitter

func NewTransmitter(lggr logger.Logger, httpClient HTTPClient, fromAccount common.Address, reportURL, username, password string) *MercuryTransmitter

func (*MercuryTransmitter) FromAccount

func (mt *MercuryTransmitter) FromAccount() ocrtypes.Account

func (*MercuryTransmitter) LatestConfigDigestAndEpoch

func (mt *MercuryTransmitter) LatestConfigDigestAndEpoch(ctx context.Context) (cd ocrtypes.ConfigDigest, epoch uint32, err error)

LatestConfigDigestAndEpoch retrieves the latest config digest and epoch from the OCR2 contract. It is plugin independent, in particular avoids use of the plugin specific generated evm wrappers by using the evm client Call directly for functions/events that are part of OCR2Abstract.

func (*MercuryTransmitter) Transmit

func (mt *MercuryTransmitter) Transmit(ctx context.Context, reportCtx ocrtypes.ReportContext, report ocrtypes.Report, signatures []ocrtypes.AttributedOnchainSignature) error

Transmit sends the report to the on-chain smart contract's Transmit method.

type ReportCodec

type ReportCodec struct {
	FeedID [32]byte
}

func (ReportCodec) BuildReport

func (r ReportCodec) BuildReport(paos []median.ParsedAttributedObservation) (types.Report, error)

func (ReportCodec) MaxReportLength

func (ReportCodec) MaxReportLength(_ int) int

func (ReportCodec) MedianFromReport

func (ReportCodec) MedianFromReport(report types.Report) (*big.Int, error)