Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2023 Changes in this version + const EnableDangerousDevelopmentMode + const MaxOracles + type BinaryNetworkEndpointFactory interface + NewEndpoint func(cd ConfigDigest, peerIDs []string, v1bootstrappers []string, ...) (commontypes.BinaryNetworkEndpoint, error) + PeerID func() string + type BootstrapperFactory interface + NewBootstrapper func(cd ConfigDigest, peerIDs []string, v1bootstrappers []string, ...) (commontypes.Bootstrapper, error) + type ConfigDigest [16]byte + func BytesToConfigDigest(b []byte) (ConfigDigest, error) + func (c *ConfigDigest) Scan(value interface{}) error + func (c ConfigDigest) Hex() string + func (c ConfigDigest) Value() (driver.Value, error) + type ConfigOverride struct + AlphaPPB uint64 + DeltaC time.Duration + type ConfigOverrider interface + ConfigOverride func() *ConfigOverride + type ContractConfig struct + ConfigDigest ConfigDigest + Encoded []byte + EncodedConfigVersion uint64 + Signers []common.Address + Threshold uint8 + Transmitters []common.Address + type ContractConfigSubscription interface + Close func() + Configs func() <-chan ContractConfig + type ContractConfigTracker interface + ConfigFromLogs func(ctx context.Context, changedInBlock uint64) (ContractConfig, error) + LatestBlockHeight func(ctx context.Context) (blockheight uint64, err error) + LatestConfigDetails func(ctx context.Context) (changedInBlock uint64, configDigest ConfigDigest, err error) + SubscribeToNewConfigs func(ctx context.Context) (ContractConfigSubscription, error) + type ContractTransmitter interface + ChainID func() *big.Int + FromAddress func() common.Address + LatestRoundRequested func(ctx context.Context, lookback time.Duration) (configDigest ConfigDigest, epoch uint32, round uint8, err error) + LatestTransmissionDetails func(ctx context.Context) (configDigest ConfigDigest, epoch uint32, round uint8, latestAnswer Observation, ...) + Transmit func(ctx context.Context, report []byte, rs, ss [][32]byte, vs [32]byte) error + type DataSource interface + Observe func(context.Context, ReportTimestamp) (Observation, 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) + ReadConfig func(ctx context.Context) (*ContractConfig, error) + ReadState func(ctx context.Context, configDigest ConfigDigest) (*PersistentState, error) + StorePendingTransmission func(context.Context, ReportTimestamp, PendingTransmission) error + WriteConfig func(ctx context.Context, config ContractConfig) error + WriteState func(ctx context.Context, configDigest ConfigDigest, state PersistentState) error + type LocalConfig struct + BlockchainTimeout time.Duration + ContractConfigConfirmations uint16 + ContractConfigTrackerPollInterval time.Duration + ContractConfigTrackerSubscribeInterval time.Duration + ContractTransmitterTransmitTimeout time.Duration + DataSourceGracePeriod time.Duration + DataSourceTimeout time.Duration + DatabaseTimeout time.Duration + DevelopmentMode string + SkipContractConfigConfirmations bool + type Observation *big.Int + type OffchainPublicKey ed25519.PublicKey + type OnChainSigningAddress common.Address + type PendingTransmission struct + Median Observation + Rs [][32]byte + SerializedReport []byte + Ss [][32]byte + Time time.Time + Vs [32]byte + type PersistentState struct + Epoch uint32 + HighestReceivedEpoch []uint32 + HighestSentEpoch uint32 + func (ps PersistentState) Equal(ps2 PersistentState) bool + type PrivateKeys interface + ConfigDiffieHellman func(base *[curve25519.ScalarSize]byte) (sharedPoint *[curve25519.PointSize]byte, err error) + PublicKeyAddressOnChain func() OnChainSigningAddress + PublicKeyConfig func() [curve25519.PointSize]byte + PublicKeyOffChain func() OffchainPublicKey + SignOffChain func(msg []byte) (signature []byte, err error) + SignOnChain func(msg []byte) (signature []byte, err error) + type ReportTimestamp struct + ConfigDigest ConfigDigest + Epoch uint32 + Round uint8 + type SharedSecretEncryptionPublicKey [curve25519.PointSize]byte