Versions in this module Expand all Collapse all v0 v0.0.2 Mar 12, 2021 Changes in this version + const OCRContractConfigSubscriptionHandleLogTimeout + var OCRContractConfigSet = getConfigSetHash() + func NewDB(sqldb *sql.DB, oracleSpecID int32) ocrtypes.Database + func NewLogger(internal *logger.Logger, trace bool, saveError func(string)) ocrtypes.Logger + func ValidatedOracleSpecToml(config *orm.Config, tomlString string) (job.SpecDB, error) + type Delegate struct + func NewDelegate(db *gorm.DB, jobORM job.ORM, config *orm.Config, keyStore *KeyStore, ...) *Delegate + func (d Delegate) JobType() job.Type + func (d Delegate) ServicesForSpec(jobSpec job.SpecDB) (services []job.Service, err error) + type KeyStore struct + func NewKeyStore(db *gorm.DB, scryptParams utils.ScryptParams) *KeyStore + func (ks *KeyStore) Unlock(password string) error + func (ks KeyStore) ArchiveEncryptedOCRKeyBundle(key *ocrkey.EncryptedKeyBundle) error + func (ks KeyStore) ArchiveEncryptedP2PKey(key *p2pkey.EncryptedP2PKey) error + func (ks KeyStore) CreateEncryptedOCRKeyBundle(encryptedKey *ocrkey.EncryptedKeyBundle) error + func (ks KeyStore) DecryptedOCRKey(hash models.Sha256Hash) (ocrkey.KeyBundle, bool) + func (ks KeyStore) DecryptedP2PKey(peerID p2ppeer.ID) (p2pkey.Key, bool) + func (ks KeyStore) DecryptedP2PKeys() (keys []p2pkey.Key) + func (ks KeyStore) DeleteEncryptedOCRKeyBundle(key *ocrkey.EncryptedKeyBundle) error + func (ks KeyStore) DeleteEncryptedP2PKey(key *p2pkey.EncryptedP2PKey) error + func (ks KeyStore) ExportOCRKeyBundle(id models.Sha256Hash, newPassword string) ([]byte, error) + func (ks KeyStore) ExportP2PKey(ID int32, newPassword string) ([]byte, error) + func (ks KeyStore) FindEncryptedOCRKeyBundleByID(id models.Sha256Hash) (ocrkey.EncryptedKeyBundle, error) + func (ks KeyStore) FindEncryptedOCRKeyBundles() (keys []ocrkey.EncryptedKeyBundle, err error) + func (ks KeyStore) FindEncryptedP2PKeyByID(id int32) (*p2pkey.EncryptedP2PKey, error) + func (ks KeyStore) FindEncryptedP2PKeys() (keys []p2pkey.EncryptedP2PKey, err error) + func (ks KeyStore) GenerateEncryptedOCRKeyBundle() (ocrkey.KeyBundle, ocrkey.EncryptedKeyBundle, error) + func (ks KeyStore) GenerateEncryptedP2PKey() (p2pkey.Key, p2pkey.EncryptedP2PKey, error) + func (ks KeyStore) ImportOCRKeyBundle(keyJSON []byte, oldPassword string) (*ocrkey.EncryptedKeyBundle, error) + func (ks KeyStore) ImportP2PKey(keyJSON []byte, oldPassword string) (*p2pkey.EncryptedP2PKey, error) + func (ks KeyStore) UpsertEncryptedOCRKeyBundle(encryptedKey *ocrkey.EncryptedKeyBundle) error + func (ks KeyStore) UpsertEncryptedP2PKey(k *p2pkey.EncryptedP2PKey) error + type OCRContractConfigSubscription struct + func (sub *OCRContractConfigSubscription) Close() + func (sub *OCRContractConfigSubscription) Configs() <-chan ocrtypes.ContractConfig + func (sub *OCRContractConfigSubscription) HandleLog(lb log.Broadcast, err error) + func (sub *OCRContractConfigSubscription) IsV2Job() bool + func (sub *OCRContractConfigSubscription) JobID() models.JobID + func (sub *OCRContractConfigSubscription) JobIDV2() int32 + func (sub *OCRContractConfigSubscription) OnConnect() + func (sub *OCRContractConfigSubscription) OnDisconnect() + type OCRContractConfigTracker struct + func NewOCRContractConfigTracker(address gethCommon.Address, ...) (o *OCRContractConfigTracker, err error) + func (oc *OCRContractConfigTracker) ConfigFromLogs(ctx context.Context, changedInBlock uint64) (c ocrtypes.ContractConfig, err error) + func (oc *OCRContractConfigTracker) LatestBlockHeight(ctx context.Context) (blockheight uint64, err error) + func (oc *OCRContractConfigTracker) LatestConfigDetails(ctx context.Context) (changedInBlock uint64, configDigest ocrtypes.ConfigDigest, err error) + func (oc *OCRContractConfigTracker) SubscribeToNewConfigs(context.Context) (ocrtypes.ContractConfigSubscription, error) + type OCRContractTransmitter struct + func NewOCRContractTransmitter(address gethCommon.Address, ...) *OCRContractTransmitter + func (oc *OCRContractTransmitter) FromAddress() gethCommon.Address + func (oc *OCRContractTransmitter) LatestTransmissionDetails(ctx context.Context) (configDigest ocrtypes.ConfigDigest, epoch uint32, round uint8, ...) + func (oc *OCRContractTransmitter) Transmit(ctx context.Context, report []byte, rs, ss [][32]byte, vs [32]byte) error + type P2PPeer struct + Addr string + CreatedAt time.Time + ID string + PeerID string + UpdatedAt time.Time + func (P2PPeer) TableName() string + type Pstorewrapper struct + Peerstore p2ppeerstore.Peerstore + func NewPeerstoreWrapper(db *gorm.DB, writeInterval time.Duration, peerID models.PeerID) (*Pstorewrapper, error) + func (p *Pstorewrapper) Close() error + func (p *Pstorewrapper) Start() error + func (p *Pstorewrapper) WriteToDB() error + type SingletonPeerWrapper struct + Peer peer + PeerID models.PeerID + func NewSingletonPeerWrapper(keyStore *KeyStore, config *orm.Config, db *gorm.DB) *SingletonPeerWrapper + func (p *SingletonPeerWrapper) IsStarted() bool + func (p *SingletonPeerWrapper) Start() (err error) + func (p SingletonPeerWrapper) Close() (err error) + type Transmitter interface + CreateEthTransaction func(ctx context.Context, toAddress gethCommon.Address, payload []byte) error + FromAddress func() gethCommon.Address + func NewTransmitter(sqldb *sql.DB, fromAddress gethCommon.Address, gasLimit uint64) Transmitter
Go to main page