chainlink

Feb 14, 2023

Changes in this version

type ApplicationOpts

+ MailMon *utils.MailboxMonitor

Dec 8, 2022

Changes in this version

type Config

+ func (c *Config) SetFrom(f *Config)

type GeneralConfigOpts

+ func (o *GeneralConfigOpts) ParseConfig(config string) error

+ func (o *GeneralConfigOpts) ParseSecrets(secrets string) (err error)

Nov 3, 2022

Changes in this version

type Application

+ GetAuditLogger func() audit.AuditLogger

type ApplicationOpts

+ AuditLogger audit.AuditLogger

type ChainlinkApplication

+ AuditLogger audit.AuditLogger

+ func (app *ChainlinkApplication) GetAuditLogger() audit.AuditLogger

+ type ConfigV2 interface

+ ConfigTOML func() (user, effective string)

+ type GeneralConfigOpts struct

+ OverrideFn func(*Config, *Secrets)

+ SkipEnv bool

+ func (o *GeneralConfigOpts) ParseTOML(config, secrets string) error

+ func (o GeneralConfigOpts) New(lggr logger.Logger) (coreconfig.GeneralConfig, error)

+ func (o GeneralConfigOpts) NewAndLogger() (coreconfig.GeneralConfig, logger.Logger, func() error, error)

type Secrets

+ func (s *Secrets) TOMLString() (string, error)

Sep 30, 2022

Changes in this version

type Config

+ Starknet StarknetConfigs

+ type StarknetConfig struct

+ ChainID *string

+ Enabled *bool

+ Nodes StarknetNodes

+ func (c *StarknetConfig) ValidateConfig() (err error)

+ type StarknetConfigs []*StarknetConfig

+ func (cs StarknetConfigs) ValidateConfig() (err error)

+ type StarknetNodes []*stkcfg.Node

+ func (ns StarknetNodes) ValidateConfig() (err error)

Sep 1, 2022

Changes in this version

+ func NewGeneralConfig(configToml string, secretsToml string, context *cli.Context) (coreconfig.GeneralConfig, error)

type Config

+ func (c *Config) SetDefaults()

+ func (c *Config) Validate() error

type EVMConfig

+ func (c *EVMConfig) ValidateConfig() (err error)

+ type EVMConfigs []*EVMConfig

+ func (cs EVMConfigs) ValidateConfig() (err error)

+ type EVMNodes []*evmcfg.Node

+ func (ns EVMNodes) ValidateConfig() (err error)

+ type Secrets struct

+ func (s *Secrets) SetOverrides(context *cli.Context) error

+ func (s *Secrets) Validate() error

type SolanaConfig

+ func (c *SolanaConfig) ValidateConfig() (err error)

+ type SolanaConfigs []*SolanaConfig

+ func (cs SolanaConfigs) ValidateConfig() (err error)

+ type SolanaNodes []*solcfg.Node

+ func (ns SolanaNodes) ValidateConfig() (err error)

type TerraConfig

+ func (c *TerraConfig) ValidateConfig() (err error)

+ type TerraConfigs []*TerraConfig

+ func (cs TerraConfigs) ValidateConfig() (err error)

+ type TerraNodes []*tercfg.Node

+ func (ns TerraNodes) ValidateConfig() (err error)

Aug 8, 2022

Changes in this version

type Application

+ SecretGenerator func() SecretGenerator

type ApplicationOpts

+ SecretGenerator SecretGenerator

type ChainlinkApplication

+ func (app *ChainlinkApplication) SecretGenerator() SecretGenerator

type Chains

+ StarkNet starknet.ChainSet

+ type FilePersistedSecretGenerator struct

+ func (f FilePersistedSecretGenerator) Generate(rootDir string) ([]byte, error)

+ type SecretGenerator interface

+ Generate func(string) ([]byte, error)

Jul 20, 2022

Changes in this version

type Application

+ ConfigDump func(context.Context) (string, error)

type ChainlinkApplication

+ func (app *ChainlinkApplication) ConfigDump(ctx context.Context) (string, error)

+ type Config struct

+ EVM []EVMConfig

+ Solana []SolanaConfig

+ Terra []TerraConfig

+ func (c *Config) TOMLString() (string, error)

+ type EVMConfig struct

+ ChainID *utils.Big

+ Enabled *bool

+ Nodes []evmcfg.Node

+ type SolanaConfig struct

+ ChainID string

+ Enabled *bool

+ Nodes []solcfg.Node

+ type TerraConfig struct

+ ChainID string

+ Enabled *bool

+ Nodes []tercfg.Node

Jun 21, 2022

Changes in this version

type ApplicationOpts

+ RestrictedHTTPClient *http.Client

+ UnrestrictedHTTPClient *http.Client

May 2, 2022

Changes in this version

type Chains

+ Solana solana.ChainSet

Apr 18, 2022

Changes in this version

type Application

+ TxmORM func() txmgr.ORM

type ApplicationOpts

+ CloseLogger func() error

type ChainlinkApplication

+ func (app *ChainlinkApplication) TxmORM() txmgr.ORM

Mar 3, 2022

Changes in this version

type Application

+ GetChains func() Chains

+ TerraORM func() terratypes.ORM

type ApplicationOpts

+ Chains Chains

type ChainlinkApplication

+ Chains Chains

+ func (app *ChainlinkApplication) GetChains() Chains

+ func (app *ChainlinkApplication) TerraORM() terratypes.ORM

+ type Chains struct

+ EVM evm.ChainSet

+ Terra terra.ChainSet

Jan 25, 2022

Changes in this version

type Application

+ BPTXMORM func() bulletprooftxmanager.ORM

+ BridgeORM func() bridges.ORM

+ GetChainSet func() evm.ChainSet

+ GetEventBroadcaster func() pg.EventBroadcaster

+ GetSqlxDB func() *sqlx.DB

+ GetWebAuthnConfiguration func() sessions.WebAuthnConfiguration

+ ID func() uuid.UUID

+ SessionORM func() sessions.ORM

+ SetLogLevel func(lvl zapcore.Level) error

+ SetServiceLogLevel func(ctx context.Context, service string, level zapcore.Level) error

+ type ApplicationOpts struct

+ ChainSet evm.ChainSet

+ Config config.GeneralConfig

+ EventBroadcaster pg.EventBroadcaster

+ ExternalInitiatorManager webhook.ExternalInitiatorManager

+ KeyStore keystore.Master

+ Logger logger.Logger

+ ShutdownSignal shutdown.Signal

+ SqlxDB *sqlx.DB

+ Version string

type ChainlinkApplication

+ ChainSet evm.ChainSet

+ Nurse *health.Nurse

+ func (app *ChainlinkApplication) BPTXMORM() bulletprooftxmanager.ORM

+ func (app *ChainlinkApplication) BridgeORM() bridges.ORM

+ func (app *ChainlinkApplication) GetChainSet() evm.ChainSet

+ func (app *ChainlinkApplication) GetEventBroadcaster() pg.EventBroadcaster

+ func (app *ChainlinkApplication) GetSqlxDB() *sqlx.DB

+ func (app *ChainlinkApplication) GetWebAuthnConfiguration() sessions.WebAuthnConfiguration

+ func (app *ChainlinkApplication) ID() uuid.UUID

+ func (app *ChainlinkApplication) SessionORM() sessions.ORM

+ func (app *ChainlinkApplication) SetLogLevel(lvl zapcore.Level) error

+ func (app *ChainlinkApplication) SetServiceLogLevel(ctx context.Context, serviceName string, level zapcore.Level) error

Oct 19, 2021

Changes in this version

type Application

+ DeleteJob func(ctx context.Context, jobID int32) error

+ EVMORM func() evm.ORM

+ GetEVMConfig func() config.EVMConfig

type ChainlinkApplication

+ EVMConfig config.EVMConfig

+ func (app *ChainlinkApplication) DeleteJob(ctx context.Context, jobID int32) error

+ func (app *ChainlinkApplication) EVMORM() evm.ORM

+ func (app *ChainlinkApplication) GetEVMConfig() config.EVMConfig

Aug 9, 2021

Changes in this version

type Application

+ GetConfig func() *config.Config

+ GetEthClient func() eth.Client

+ ReplayFromBlock func(number uint64) error

type ChainlinkApplication

+ Config *config.Config

+ func (app *ChainlinkApplication) GetConfig() *config.Config

+ func (app *ChainlinkApplication) GetEthClient() eth.Client

+ func (app *ChainlinkApplication) ReplayFromBlock(number uint64) error

Jul 26, 2021

Changes in this version

type Application

+ ResumeJobV2 func(ctx context.Context, run *pipeline.Run) (bool, error)

type ChainlinkApplication

+ func (app *ChainlinkApplication) ResumeJobV2(ctx context.Context, run *pipeline.Run) (bool, error)

Jun 21, 2021

Changes in this version

type Application

+ GetFeedsService func() feeds.Service

+ GetHeadBroadcaster func() httypes.HeadBroadcasterRegistry

+ GetHealthChecker func() health.Checker

+ GetKeyStore func() *keystore.Master

+ JobORM func() job.ORM

+ JobSpawner func() job.Spawner

+ PipelineORM func() pipeline.ORM

+ RunWebhookJobV2 func(ctx context.Context, jobUUID uuid.UUID, pipelineInput interface{}, ...) (int64, error)

type ChainlinkApplication

+ FeedsService feeds.Service

+ HealthChecker health.Checker

+ KeyStore *keystore.Master

+ TxManager bulletprooftxmanager.TxManager

+ func (app *ChainlinkApplication) GetFeedsService() feeds.Service

+ func (app *ChainlinkApplication) GetHeadBroadcaster() httypes.HeadBroadcasterRegistry

+ func (app *ChainlinkApplication) GetHealthChecker() health.Checker

+ func (app *ChainlinkApplication) GetKeyStore() *keystore.Master

+ func (app *ChainlinkApplication) JobSpawner() job.Spawner

+ func (app *ChainlinkApplication) PipelineORM() pipeline.ORM

+ func (app *ChainlinkApplication) RunWebhookJobV2(ctx context.Context, jobUUID uuid.UUID, pipelineInput interface{}, ...) (int64, error)

May 10, 2021

Changes in this version

type Application

+ GetLogger func() *logger.Logger

+ SetServiceLogger func(ctx context.Context, service string, level zapcore.Level) error

type ChainlinkApplication

+ func (app *ChainlinkApplication) GetLogger() *logger.Logger

+ func (app *ChainlinkApplication) SetServiceLogger(ctx context.Context, serviceName string, level zapcore.Level) error

Mar 22, 2021

Changes in this version

type ChainlinkApplication

+ HeadBroadcaster *services.HeadBroadcaster

Feb 1, 2021

Changes in this version

type Application

+ GetExternalInitiatorManager func() ExternalInitiatorManager

type ChainlinkApplication

+ ExternalInitiatorManager ExternalInitiatorManager

+ func (app *ChainlinkApplication) GetExternalInitiatorManager() ExternalInitiatorManager

+ type ExternalInitiatorManager interface

+ DeleteJob func(db *gorm.DB, jobID *models.ID) error

+ Notify func(models.JobSpec, *strpkg.Store) error

Jan 18, 2021

Changes in this version

type Application

+ GetJobORM func() job.ORM

type ChainlinkApplication

+ JobORM job.ORM

+ func (app *ChainlinkApplication) GetJobORM() job.ORM

+ func (app *ChainlinkApplication) StopIfStarted() error

+ type StartCloser interface

+ Close func() error

+ Start func() error

Nov 23, 2020

Changes in this version

type Application

+ AwaitRun func(ctx context.Context, runID int64) error

+ RunJobV2 func(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)

type ChainlinkApplication

+ func (app *ChainlinkApplication) AwaitRun(ctx context.Context, runID int64) error

+ func (app *ChainlinkApplication) RunJobV2(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)

Nov 2, 2020

Changes in this version

type Application

+ AddJobV2 func(ctx context.Context, job job.Spec) (int32, error)

+ DeleteJobV2 func(ctx context.Context, jobID int32) error

type ChainlinkApplication

+ EventBroadcaster postgres.EventBroadcaster

+ func (app *ChainlinkApplication) AddJobV2(ctx context.Context, job job.Spec) (int32, error)

+ func (app *ChainlinkApplication) DeleteJobV2(ctx context.Context, jobID int32) error

Jul 27, 2020

Changes in this version

type ChainlinkApplication

+ LogBroadcaster eth.LogBroadcaster

Jun 15, 2020

Changes in this version

type ChainlinkApplication

+ EthBroadcaster bulletprooftxmanager.EthBroadcaster

Apr 20, 2020

Changes in this version

+ type Application interface

+ AddJob func(job models.JobSpec) error

+ AddServiceAgreement func(*models.ServiceAgreement) error

+ ArchiveJob func(*models.ID) error

+ GetStatsPusher func() synchronization.StatsPusher

+ GetStore func() *store.Store

+ NewBox func() packr.Box

+ Start func() error

+ Stop func() error

+ WakeSessionReaper func()

+ func NewApplication(config *orm.Config, onConnectCallbacks ...func(Application)) Application

+ type ChainlinkApplication struct

+ Exiter func(int)

+ FluxMonitor fluxmonitor.Service

+ GasUpdater services.GasUpdater

+ HeadTracker *services.HeadTracker

+ JobSubscriber services.JobSubscriber

+ RunQueue services.RunQueue

+ Scheduler *services.Scheduler

+ SessionReaper services.SleeperTask

+ StatsPusher synchronization.StatsPusher

+ Store *store.Store

+ func (app *ChainlinkApplication) AddJob(job models.JobSpec) error

+ func (app *ChainlinkApplication) AddServiceAgreement(sa *models.ServiceAgreement) error

+ func (app *ChainlinkApplication) ArchiveJob(ID *models.ID) error

+ func (app *ChainlinkApplication) GetStatsPusher() synchronization.StatsPusher

+ func (app *ChainlinkApplication) GetStore() *store.Store

+ func (app *ChainlinkApplication) NewBox() packr.Box

+ func (app *ChainlinkApplication) Start() error

+ func (app *ChainlinkApplication) Stop() error

+ func (app *ChainlinkApplication) WakeSessionReaper()