Versions in this module Expand all Collapse all v0 v0.8.18 Oct 1, 2020 v0.8.17 Sep 28, 2020 Changes in this version + const MaxOracles + type BinaryMessageWithSender struct + Msg []byte + Sender OracleID + type BinaryNetworkEndpoint interface + Broadcast func(payload []byte) + Close func() error + Receive func() <-chan BinaryMessageWithSender + SendTo func(payload []byte, to OracleID) + Start func() error + type BinaryNetworkEndpointFactory interface + MakeEndpoint func(cd ConfigDigest, peerIDs []string, bootstrappers []string, ...) (BinaryNetworkEndpoint, error) + PeerID func() string + type Bootstrapper interface + Close func() error + Start func() error + type BootstrapperFactory interface + MakeBootstrapper func(cd ConfigDigest, peerIDs []string, bootstrappers []string, ...) (Bootstrapper, error) + type ConfigDigest [16]byte + func BytesToConfigDigest(b []byte) (g ConfigDigest) + func (c *ConfigDigest) Scan(value interface{}) error + func (c ConfigDigest) Hex() string + func (c ConfigDigest) Value() (driver.Value, error) + 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 + FromAddress func() common.Address + LatestTransmissionDetails func(ctx context.Context) (configDigest ConfigDigest, epoch uint32, round uint8, latestAnswer Observation, ...) + Transmit func(report []byte, rs, ss [][32]byte, vs [32]byte) (*types.Transaction, error) + type DataSource interface + Observe func(context.Context) (Observation, error) + type Database interface + DeletePendingTransmission func(PendingTransmissionKey) error + DeletePendingTransmissionsOlderThan func(time.Time) error + PendingTransmissionsWithConfigDigest func(ConfigDigest) (map[PendingTransmissionKey]PendingTransmission, error) + ReadConfig func() (*ContractConfig, error) + ReadState func(configDigest ConfigDigest) (*PersistentState, error) + StorePendingTransmission func(PendingTransmissionKey, PendingTransmission) error + WriteConfig func(config ContractConfig) error + WriteState func(configDigest ConfigDigest, state PersistentState) error + type LocalConfig struct + BlockchainTimeout time.Duration + ContractConfigConfirmations uint16 + ContractConfigTrackerPollInterval time.Duration + ContractConfigTrackerSubscribeInterval time.Duration + DataSourceTimeout time.Duration + type LogFields map[string]interface + type Logger interface + Debug func(msg string, fields LogFields) + Error func(msg string, fields LogFields) + Info func(msg string, fields LogFields) + Trace func(msg string, fields LogFields) + Warn func(msg string, fields LogFields) + type MonitoringEndpoint interface + SendLog func(log []byte) + type Observation *big.Int + type OffchainPublicKey ed25519.PublicKey + type OnChainSigningAddress common.Address + type OracleID int + type PendingTransmission struct + Median Observation + Rs [][32]byte + SerializedReport []byte + Ss [][32]byte + Time time.Time + Vs [32]byte + type PendingTransmissionKey struct + ConfigDigest ConfigDigest + Epoch uint32 + Round uint8 + type PersistentState struct + Epoch uint32 + HighestReceivedEpoch []uint32 + HighestSentEpoch uint32 + 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 SharedSecretEncryptionPublicKey [curve25519.PointSize]byte
Go to main page