Versions in this module Expand all Collapse all v0 v0.1.1 Nov 12, 2024 Changes in this version + type ReportPlus struct + ReportWithInfo ReportWithInfo[RI] + TransmissionScheduleOverride *TransmissionSchedule + type TransmissionSchedule struct + TransmissionDelays []time.Duration + Transmitters []commontypes.OracleID v0.1.1-beta Nov 26, 2024 v0.0.1 Jul 24, 2024 Changes in this version + const MaxMaxMercuryObservationLength + const MaxMaxMercuryReportLength + const MaxMaxObservationLength + const MaxMaxOutcomeLength + const MaxMaxQueryLength + const MaxMaxReportCount + const MaxMaxReportLength + type ContractTransmitter interface + FromAccount func() (types.Account, error) + Transmit func(context.Context, types.ConfigDigest, uint64, ReportWithInfo[RI], ...) error + type CountingMercuryPlugin struct + func (p *CountingMercuryPlugin) Close() error + func (p *CountingMercuryPlugin) Observation(ctx context.Context, repts types.ReportTimestamp, previousReport types.Report) (types.Observation, error) + func (p *CountingMercuryPlugin) Report(repts types.ReportTimestamp, previousReport types.Report, ...) (bool, types.Report, error) + type CountingMercuryPluginFactory struct + func (fac *CountingMercuryPluginFactory) NewMercuryPlugin(_ MercuryPluginConfig) (MercuryPlugin, MercuryPluginInfo, error) + type Database interface + type MercuryPlugin interface + Close func() error + Observation func(ctx context.Context, repts types.ReportTimestamp, previousReport types.Report) (types.Observation, error) + Report func(repts types.ReportTimestamp, previousReport types.Report, ...) (bool, types.Report, error) + type MercuryPluginConfig struct + ConfigDigest types.ConfigDigest + EstimatedRoundInterval time.Duration + F int + MaxDurationObservation time.Duration + N int + OffchainConfig []byte + OnchainConfig []byte + OracleID commontypes.OracleID + type MercuryPluginFactory interface + NewMercuryPlugin func(MercuryPluginConfig) (MercuryPlugin, MercuryPluginInfo, error) + type MercuryPluginInfo struct + Limits MercuryPluginLimits + Name string + type MercuryPluginLimits struct + MaxObservationLength int + MaxReportLength int + type OnchainKeyring interface + MaxSignatureLength func() int + PublicKey func() types.OnchainPublicKey + Sign func(types.ConfigDigest, uint64, ReportWithInfo[RI]) (signature []byte, err error) + Verify func(_ types.OnchainPublicKey, _ types.ConfigDigest, seqNr uint64, ...) bool + type Outcome []byte + type OutcomeContext struct + Epoch uint64 + PreviousOutcome Outcome + Round uint64 + SeqNr uint64 + type ProtocolStateDatabase interface + ReadProtocolState func(ctx context.Context, configDigest types.ConfigDigest, key string) ([]byte, error) + WriteProtocolState func(ctx context.Context, configDigest types.ConfigDigest, key string, value []byte) error + type Quorum int + const OldQuorumByzQuorum + const OldQuorumFPlusOne + const OldQuorumNMinusF + const OldQuorumTwoFPlusOne + const QuorumByzQuorum + const QuorumFPlusOne + const QuorumNMinusF + const QuorumTwoFPlusOne + type ReportWithInfo struct + Info RI + Report types.Report + type ReportingPlugin interface + Close func() error + Observation func(ctx context.Context, outctx OutcomeContext, query types.Query) (types.Observation, error) + ObservationQuorum func(outctx OutcomeContext, query types.Query) (Quorum, error) + Outcome func(outctx OutcomeContext, query types.Query, aos []types.AttributedObservation) (Outcome, error) + Query func(ctx context.Context, outctx OutcomeContext) (types.Query, error) + Reports func(seqNr uint64, outcome Outcome) ([]ReportWithInfo[RI], error) + ShouldAcceptAttestedReport func(context.Context, uint64, ReportWithInfo[RI]) (bool, error) + ShouldTransmitAcceptedReport func(context.Context, uint64, ReportWithInfo[RI]) (bool, error) + ValidateObservation func(outctx OutcomeContext, query types.Query, ao types.AttributedObservation) error + type ReportingPluginConfig struct + ConfigDigest types.ConfigDigest + EstimatedRoundInterval time.Duration + F int + MaxDurationObservation time.Duration + MaxDurationQuery time.Duration + MaxDurationShouldAcceptAttestedReport time.Duration + MaxDurationShouldTransmitAcceptedReport time.Duration + N int + OffchainConfig []byte + OnchainConfig []byte + OracleID commontypes.OracleID + type ReportingPluginFactory interface + NewReportingPlugin func(ReportingPluginConfig) (ReportingPlugin[RI], ReportingPluginInfo, error) + type ReportingPluginInfo struct + Limits ReportingPluginLimits + Name string + type ReportingPluginLimits struct + MaxObservationLength int + MaxOutcomeLength int + MaxQueryLength int + MaxReportCount int + MaxReportLength int
Go to main page