Versions in this module Expand all Collapse all v0 v0.1.0 Oct 9, 2024 Changes in this version + const MaxAllowedBlocks + var File_mercury_observation_v1_proto protoreflect.FileDescriptor + func GetConsensusLatestBlock(paos []PAO, f int) (hash []byte, num int64, ts uint64, err error) + func GetConsensusMaxFinalizedBlockNum(paos []PAO, f int) (int64, error) + func ValidateCurrentBlock(rf v1.ReportFields) error + type BlockProto struct + Hash []byte + Num int64 + Ts uint64 + func (*BlockProto) Descriptor() ([]byte, []int) + func (*BlockProto) ProtoMessage() + func (x *BlockProto) GetHash() []byte + func (x *BlockProto) GetNum() int64 + func (x *BlockProto) GetTs() uint64 + func (x *BlockProto) ProtoReflect() protoreflect.Message + func (x *BlockProto) Reset() + func (x *BlockProto) String() string + type DataSource interface + Observe func(ctx context.Context, repts types.ReportTimestamp, ...) (v1.Observation, error) + type Factory struct + func NewFactory(ds DataSource, lggr logger.Logger, occ mercurytypes.OnchainConfigCodec, ...) Factory + func (fac Factory) NewMercuryPlugin(ctx context.Context, configuration ocr3types.MercuryPluginConfig) (ocr3types.MercuryPlugin, ocr3types.MercuryPluginInfo, error) + type MercuryObservationProto struct + Ask []byte + BenchmarkPrice []byte + Bid []byte + CurrentBlockHash []byte + CurrentBlockNum int64 + CurrentBlockTimestamp uint64 + CurrentBlockValid bool + LatestBlocks []*BlockProto + MaxFinalizedBlockNumber int64 + MaxFinalizedBlockNumberValid bool + PricesValid bool + Timestamp uint32 + func (*MercuryObservationProto) Descriptor() ([]byte, []int) + func (*MercuryObservationProto) ProtoMessage() + func (x *MercuryObservationProto) GetAsk() []byte + func (x *MercuryObservationProto) GetBenchmarkPrice() []byte + func (x *MercuryObservationProto) GetBid() []byte + func (x *MercuryObservationProto) GetCurrentBlockHash() []byte + func (x *MercuryObservationProto) GetCurrentBlockNum() int64 + func (x *MercuryObservationProto) GetCurrentBlockTimestamp() uint64 + func (x *MercuryObservationProto) GetCurrentBlockValid() bool + func (x *MercuryObservationProto) GetLatestBlocks() []*BlockProto + func (x *MercuryObservationProto) GetMaxFinalizedBlockNumber() int64 + func (x *MercuryObservationProto) GetMaxFinalizedBlockNumberValid() bool + func (x *MercuryObservationProto) GetPricesValid() bool + func (x *MercuryObservationProto) GetTimestamp() uint32 + func (x *MercuryObservationProto) ProtoReflect() protoreflect.Message + func (x *MercuryObservationProto) Reset() + func (x *MercuryObservationProto) String() string + type PAO interface + GetAsk func() (*big.Int, bool) + GetBid func() (*big.Int, bool) + GetCurrentBlockHash func() ([]byte, bool) + GetCurrentBlockNum func() (int64, bool) + GetCurrentBlockTimestamp func() (uint64, bool) + GetLatestBlocks func() []v1.Block + GetMaxFinalizedBlockNumber func() (int64, bool) + func NewParsedAttributedObservation(ts uint32, observer commontypes.OracleID, bp *big.Int, bid *big.Int, ...) PAO
Go to main page