Versions in this module Expand all Collapse all v1 v1.1.0 Aug 7, 2026 Changes in this version + const PluginVersion + const Precision + const ZeroBytesSentinel + var BaseSchemaUint32 = getBaseSchema("uint32") + var BaseSchemaUint64 = getBaseSchema("uint64") + var FeeScalingFactor = decimal.NewFromInt(1e18) + var File_evm_streamlined_proto protoreflect.FileDescriptor + var PayloadTypes = getPayloadTypes() + func CalculateFee(tokenPriceInUSD decimal.Decimal, baseUSDFee decimal.Decimal) *big.Int + func ClampReportRange(r logger.Logger, report protocol.Report, maxReportRange protocol.Duration) uint64 + func EncodePackedBigInt(value *big.Int, typeStr string) ([]byte, error) + func EncodePaddedBigInt(v *big.Int, t string) (b []byte, err error) + func ExtractReportValues(report protocol.Report) (nativePrice, linkPrice decimal.Decimal, quote *protocol.Quote, err error) + func ExtractTimestamps(report protocol.Report) (validAfterSeconds, observationTimestampSeconds uint32, err error) + func LLOExtraHash(donID uint32) common.Hash + func LegacyReportContext(cd ocr2types.ConfigDigest, seqNr uint64, donID uint32) (ocr2types.ReportContext, error) + func SeqNrToEpochAndRound(seqNr uint64) (epoch uint32, round uint8, err error) + type ABIEncoder struct + func (a *ABIEncoder) UnmarshalJSON(data []byte) error + func (a ABIEncoder) EncodePacked(sv protocol.StreamValue) ([]byte, error) + func (a ABIEncoder) EncodePadded(sv protocol.StreamValue) ([]byte, error) + func (a ABIEncoder) MarshalJSON() ([]byte, error) + type BaseReportFields struct + ExpiresAt uint64 + FeedID common.Hash + LinkFee *big.Int + NativeFee *big.Int + Timestamp uint64 + ValidFromTimestamp uint64 + type LLOEVMStreamlinedReportWithContext struct + ConfigDigest []byte + PackedPayload []byte + SeqNr uint64 + func (*LLOEVMStreamlinedReportWithContext) Descriptor() ([]byte, []int) + func (*LLOEVMStreamlinedReportWithContext) ProtoMessage() + func (x *LLOEVMStreamlinedReportWithContext) GetConfigDigest() []byte + func (x *LLOEVMStreamlinedReportWithContext) GetPackedPayload() []byte + func (x *LLOEVMStreamlinedReportWithContext) GetSeqNr() uint64 + func (x *LLOEVMStreamlinedReportWithContext) ProtoReflect() protoreflect.Message + func (x *LLOEVMStreamlinedReportWithContext) Reset() + func (x *LLOEVMStreamlinedReportWithContext) String() string + type ReportCodecEVMABIEncodeUnpacked struct + func NewReportCodecEVMABIEncodeUnpacked(lggr logger.Logger, donID uint32) ReportCodecEVMABIEncodeUnpacked + func (r ReportCodecEVMABIEncodeUnpacked) Encode(report protocol.Report, cd llotypes.ChannelDefinition, ...) ([]byte, error) + func (r ReportCodecEVMABIEncodeUnpacked) Verify(cd llotypes.ChannelDefinition) error + type ReportCodecEVMABIEncodeUnpackedExpr struct + func NewReportCodecEVMABIEncodeUnpackedExpr(lggr logger.Logger, donID uint32) ReportCodecEVMABIEncodeUnpackedExpr + func (r ReportCodecEVMABIEncodeUnpackedExpr) Encode(report protocol.Report, cd llotypes.ChannelDefinition, ...) ([]byte, error) + func (r ReportCodecEVMABIEncodeUnpackedExpr) Verify(cd llotypes.ChannelDefinition) error + type ReportCodecEVMStreamlined struct + func NewReportCodecStreamlined(lggr logger.Logger) ReportCodecEVMStreamlined + func (rc ReportCodecEVMStreamlined) Encode(r protocol.Report, cd llotypes.ChannelDefinition, ...) (payload []byte, err error) + func (rc ReportCodecEVMStreamlined) Pack(digest types.ConfigDigest, seqNr uint64, report ocr2types.Report, ...) ([]byte, error) + func (rc ReportCodecEVMStreamlined) Verify(cd llotypes.ChannelDefinition) error + type ReportCodecPremiumLegacy struct + func NewReportCodecPremiumLegacy(lggr logger.Logger, donID uint32) ReportCodecPremiumLegacy + func (r ReportCodecPremiumLegacy) Decode(b []byte) (*v3.Report, error) + func (r ReportCodecPremiumLegacy) Encode(report protocol.Report, cd llotypes.ChannelDefinition, ...) ([]byte, error) + func (r ReportCodecPremiumLegacy) Pack(digest types.ConfigDigest, seqNr uint64, report ocr2types.Report, ...) ([]byte, error) + func (r ReportCodecPremiumLegacy) Verify(cd llotypes.ChannelDefinition) error + type ReportFormatEVMABIEncodeOpts struct + ABI []ABIEncoder + BaseUSDFee decimal.Decimal + ExpirationWindow uint32 + FeedID common.Hash + MaxReportRange protocol.Duration + TimeResolution protocol.TimeResolution + func (r *ReportFormatEVMABIEncodeOpts) Decode(opts []byte) error + func (r *ReportFormatEVMABIEncodeOpts) Encode() ([]byte, error) + type ReportFormatEVMPremiumLegacyOpts struct + BaseUSDFee decimal.Decimal + ExpirationWindow uint32 + FeedID common.Hash + MaxReportRange protocol.Duration + Multiplier *ubig.Big + func (r *ReportFormatEVMPremiumLegacyOpts) Decode(opts []byte) error + type ReportFormatEVMStreamlinedOpts struct + ABI []ABIEncoder + FeedID *common.Hash + MaxReportRange protocol.Duration + func (r *ReportFormatEVMStreamlinedOpts) Decode(opts []byte) error + func (r *ReportFormatEVMStreamlinedOpts) Encode() ([]byte, error)
Go to main page