Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2023 Changes in this version + var File_offchainreporting2_median_config_proto protoreflect.FileDescriptor + var File_offchainreporting2_median_observation_proto protoreflect.FileDescriptor + func DecodeValue(s []byte) (*big.Int, error) + func Deviates(thresholdPPB uint64, old *big.Int, new *big.Int) bool + func EncodeValue(i *big.Int) ([]byte, error) + func MaxValue() *big.Int + func MinValue() *big.Int + type DataSource interface + Observe func(context.Context, types.ReportTimestamp) (*big.Int, error) + type MedianContract interface + LatestRoundRequested func(ctx context.Context, lookback time.Duration) (configDigest types.ConfigDigest, epoch uint32, round uint8, err error) + LatestTransmissionDetails func(ctx context.Context) (configDigest types.ConfigDigest, epoch uint32, round uint8, ...) + type NumericalMedianConfigProto struct + AlphaAcceptInfinite bool + AlphaAcceptPpb uint64 + AlphaReportInfinite bool + AlphaReportPpb uint64 + DeltaCNanoseconds uint64 + func (*NumericalMedianConfigProto) Descriptor() ([]byte, []int) + func (*NumericalMedianConfigProto) ProtoMessage() + func (x *NumericalMedianConfigProto) GetAlphaAcceptInfinite() bool + func (x *NumericalMedianConfigProto) GetAlphaAcceptPpb() uint64 + func (x *NumericalMedianConfigProto) GetAlphaReportInfinite() bool + func (x *NumericalMedianConfigProto) GetAlphaReportPpb() uint64 + func (x *NumericalMedianConfigProto) GetDeltaCNanoseconds() uint64 + func (x *NumericalMedianConfigProto) ProtoReflect() protoreflect.Message + func (x *NumericalMedianConfigProto) Reset() + func (x *NumericalMedianConfigProto) String() string + type NumericalMedianFactory struct + ContractTransmitter MedianContract + DataSource DataSource + JuelsPerFeeCoinDataSource DataSource + Logger commontypes.Logger + OnchainConfigCodec OnchainConfigCodec + ReportCodec ReportCodec + func (fac NumericalMedianFactory) NewReportingPlugin(configuration types.ReportingPluginConfig) (types.ReportingPlugin, types.ReportingPluginInfo, error) + type NumericalMedianObservationProto struct + JuelsPerFeeCoin []byte + Timestamp uint32 + Value []byte + func (*NumericalMedianObservationProto) Descriptor() ([]byte, []int) + func (*NumericalMedianObservationProto) ProtoMessage() + func (x *NumericalMedianObservationProto) GetJuelsPerFeeCoin() []byte + func (x *NumericalMedianObservationProto) GetTimestamp() uint32 + func (x *NumericalMedianObservationProto) GetValue() []byte + func (x *NumericalMedianObservationProto) ProtoReflect() protoreflect.Message + func (x *NumericalMedianObservationProto) Reset() + func (x *NumericalMedianObservationProto) String() string + type OffchainConfig struct + AlphaAcceptInfinite bool + AlphaAcceptPPB uint64 + AlphaReportInfinite bool + AlphaReportPPB uint64 + DeltaC time.Duration + func DecodeOffchainConfig(b []byte) (OffchainConfig, error) + func (c OffchainConfig) Encode() []byte + type OnchainConfig struct + Max *big.Int + Min *big.Int + type OnchainConfigCodec interface + Decode func([]byte) (OnchainConfig, error) + Encode func(OnchainConfig) ([]byte, error) + type ParsedAttributedObservation struct + JuelsPerFeeCoin *big.Int + Observer commontypes.OracleID + Timestamp uint32 + Value *big.Int + type ReportCodec interface + BuildReport func([]ParsedAttributedObservation) (types.Report, error) + MaxReportLength func(n int) (int, error) + MedianFromReport func(types.Report) (*big.Int, error) + type StandardOnchainConfigCodec struct + func (StandardOnchainConfigCodec) Decode(b []byte) (OnchainConfig, error) + func (StandardOnchainConfigCodec) Encode(c OnchainConfig) ([]byte, error)