Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2023 Changes in this version + const EnableDangerousDevelopmentMode + const MaxMaxObservationLength + const MaxMaxQueryLength + const MaxMaxReportLength + const MaxOracles + type Account string + type AttributedObservation struct + Observation Observation + Observer commontypes.OracleID + func (ao AttributedObservation) Equal(other AttributedObservation) bool + type AttributedOnchainSignature struct + Signature []byte + Signer commontypes.OracleID + func (as AttributedOnchainSignature) Equal(other AttributedOnchainSignature) bool + type BinaryNetworkEndpointFactory interface + NewEndpoint func(cd ConfigDigest, peerIDs []string, ...) (commontypes.BinaryNetworkEndpoint, error) + PeerID func() string + type BinaryNetworkEndpointLimits struct + BytesCapacityPerOracle int + BytesRatePerOracle float64 + MaxMessageLength int + MessagesCapacityPerOracle int + MessagesRatePerOracle float64 + type BootstrapperFactory interface + NewBootstrapper func(cd ConfigDigest, peerIDs []string, ...) (commontypes.Bootstrapper, error) + type ConfigDatabase interface + ReadConfig func(ctx context.Context) (*ContractConfig, error) + WriteConfig func(ctx context.Context, config ContractConfig) error + type ConfigDigest [32]byte + func BytesToConfigDigest(b []byte) (ConfigDigest, error) + func (c *ConfigDigest) Scan(value interface{}) error + func (c ConfigDigest) Hex() string + func (c ConfigDigest) MarshalText() (text []byte, err error) + func (c ConfigDigest) String() string + func (c ConfigDigest) Value() (driver.Value, error) + type ConfigDigestPrefix uint16 + const ConfigDigestPrefixEVM + const ConfigDigestPrefixMercuryV02 + const ConfigDigestPrefixOCR1 + const ConfigDigestPrefixSolana + const ConfigDigestPrefixStarknet + const ConfigDigestPrefixTerra + func (prefix ConfigDigestPrefix) IsPrefixOf(configDigest ConfigDigest) bool + func (prefix ConfigDigestPrefix) String() string + type ConfigEncryptionPublicKey [curve25519.PointSize]byte + type ContractConfig struct + ConfigCount uint64 + ConfigDigest ConfigDigest + F uint8 + OffchainConfig []byte + OffchainConfigVersion uint64 + OnchainConfig []byte + Signers []OnchainPublicKey + Transmitters []Account + type ContractConfigTracker interface + LatestBlockHeight func(ctx context.Context) (blockHeight uint64, err error) + LatestConfig func(ctx context.Context, changedInBlock uint64) (ContractConfig, error) + LatestConfigDetails func(ctx context.Context) (changedInBlock uint64, configDigest ConfigDigest, err error) + Notify func() <-chan struct{} + type ContractTransmitter interface + FromAccount func() (Account, error) + LatestConfigDigestAndEpoch func(ctx context.Context) (configDigest ConfigDigest, epoch uint32, err error) + Transmit func(context.Context, ReportContext, Report, []AttributedOnchainSignature) error + type Database interface + DeletePendingTransmission func(context.Context, ReportTimestamp) error + DeletePendingTransmissionsOlderThan func(context.Context, time.Time) error + PendingTransmissionsWithConfigDigest func(context.Context, ConfigDigest) (map[ReportTimestamp]PendingTransmission, error) + ReadState func(ctx context.Context, configDigest ConfigDigest) (*PersistentState, error) + StorePendingTransmission func(context.Context, ReportTimestamp, PendingTransmission) error + WriteState func(ctx context.Context, configDigest ConfigDigest, state PersistentState) error + type LocalConfig struct + BlockchainTimeout time.Duration + ContractConfigConfirmations uint16 + ContractConfigTrackerPollInterval time.Duration + ContractTransmitterTransmitTimeout time.Duration + DatabaseTimeout time.Duration + DevelopmentMode string + SkipContractConfigConfirmations bool + type Observation []byte + type OffchainConfigDigester interface + ConfigDigest func(ContractConfig) (ConfigDigest, error) + ConfigDigestPrefix func() (ConfigDigestPrefix, error) + type OffchainKeyring interface + ConfigDiffieHellman func(point [curve25519.PointSize]byte) (sharedPoint [curve25519.PointSize]byte, err error) + ConfigEncryptionPublicKey func() ConfigEncryptionPublicKey + OffchainPublicKey func() OffchainPublicKey + OffchainSign func(msg []byte) (signature []byte, err error) + type OffchainPublicKey [ed25519.PublicKeySize]byte + type OnchainKeyring interface + MaxSignatureLength func() int + PublicKey func() OnchainPublicKey + Sign func(ReportContext, Report) (signature []byte, err error) + Verify func(_ OnchainPublicKey, _ ReportContext, _ Report, signature []byte) bool + type OnchainPublicKey []byte + type PendingTransmission struct + AttributedSignatures []AttributedOnchainSignature + ExtraHash [32]byte + Report Report + Time time.Time + type PersistentState struct + Epoch uint32 + HighestReceivedEpoch []uint32 + HighestSentEpoch uint32 + func (ps PersistentState) Equal(ps2 PersistentState) bool + type Query []byte + type Report []byte + type ReportContext struct + ExtraHash [32]byte + type ReportTimestamp struct + ConfigDigest ConfigDigest + Epoch uint32 + Round uint8 + type ReportingPlugin interface + Close func() error + Observation func(context.Context, ReportTimestamp, Query) (Observation, error) + Query func(context.Context, ReportTimestamp) (Query, error) + Report func(context.Context, ReportTimestamp, Query, []AttributedObservation) (bool, Report, error) + ShouldAcceptFinalizedReport func(context.Context, ReportTimestamp, Report) (bool, error) + ShouldTransmitAcceptedReport func(context.Context, ReportTimestamp, Report) (bool, error) + type ReportingPluginConfig struct + ConfigDigest ConfigDigest + EstimatedRoundInterval time.Duration + F int + MaxDurationObservation time.Duration + MaxDurationQuery time.Duration + MaxDurationReport time.Duration + MaxDurationShouldAcceptFinalizedReport time.Duration + MaxDurationShouldTransmitAcceptedReport time.Duration + N int + OffchainConfig []byte + OnchainConfig []byte + OracleID commontypes.OracleID + type ReportingPluginFactory interface + NewReportingPlugin func(ReportingPluginConfig) (ReportingPlugin, ReportingPluginInfo, error) + type ReportingPluginInfo struct + Limits ReportingPluginLimits + Name string + UniqueReports bool + type ReportingPluginLimits struct + MaxObservationLength int + MaxQueryLength int + MaxReportLength int