chainlink

package
v0.10.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 25, 2021 License: MIT Imports: 51 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Application 

type Application interface {
	Start() error
	Stop() error
	GetLogger() *logger.Logger
	GetHealthChecker() health.Checker
	GetStore() *strpkg.Store
	GetEthClient() eth.Client
	GetConfig() *config.Config
	GetKeyStore() *keystore.Master
	GetStatsPusher() synchronization.StatsPusher
	GetHeadBroadcaster() httypes.HeadBroadcasterRegistry
	WakeSessionReaper()
	AddServiceAgreement(*models.ServiceAgreement) error
	NewBox() packr.Box

	// V1 Jobs (JSON specified)
	services.RunManager // For managing job runs.
	AddJob(job models.JobSpec) error
	ArchiveJob(models.JobID) error
	GetExternalInitiatorManager() webhook.ExternalInitiatorManager

	// V2 Jobs (TOML specified)
	JobSpawner() job.Spawner
	JobORM() job.ORM
	PipelineORM() pipeline.ORM
	AddJobV2(ctx context.Context, job job.Job, name null.String) (job.Job, error)
	DeleteJobV2(ctx context.Context, jobID int32) error
	RunWebhookJobV2(ctx context.Context, jobUUID uuid.UUID, requestBody string, meta pipeline.JSONSerializable) (int64, error)
	ResumeJobV2(ctx context.Context, run *pipeline.Run) (bool, error)
	// Testing only
	RunJobV2(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)
	SetServiceLogger(ctx context.Context, service string, level zapcore.Level) error

	// Feeds
	GetFeedsService() feeds.Service

	// ReplayFromBlock of blocks
	ReplayFromBlock(number uint64) error
}

Application implements the common functions used in the core node.

func NewApplication 

func NewApplication(cfg *config.Config, ethClient eth.Client, advisoryLocker postgres.AdvisoryLocker, onConnectCallbacks ...func(Application)) (Application, error)

NewApplication initializes a new store if one is not already present at the configured root directory (default: ~/.chainlink), the logger at the same directory and returns the Application to be used by the node.

type ChainlinkApplication 

type ChainlinkApplication struct {
	Exiter          func(int)
	HeadTracker     httypes.Tracker
	HeadBroadcaster httypes.HeadBroadcaster
	TxManager       bulletprooftxmanager.TxManager
	StatsPusher     synchronization.StatsPusher
	services.RunManager
	RunQueue         services.RunQueue
	JobSubscriber    services.JobSubscriber
	LogBroadcaster   log.Broadcaster
	EventBroadcaster postgres.EventBroadcaster

	FluxMonitor  fluxmonitor.Service
	FeedsService feeds.Service

	Scheduler *services.Scheduler

	Store                    *strpkg.Store
	Config                   *config.Config
	KeyStore                 *keystore.Master
	ExternalInitiatorManager webhook.ExternalInitiatorManager
	SessionReaper            utils.SleeperTask

	HealthChecker health.Checker
	// contains filtered or unexported fields
}

ChainlinkApplication contains fields for the JobSubscriber, Scheduler, and Store. The JobSubscriber and Scheduler are also available in the services package, but the Store has its own package.

func (*ChainlinkApplication) AddJob 

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

AddJob adds a job to the store and the scheduler. If there was an error from adding the job to the store, the job will not be added to the scheduler.

func (*ChainlinkApplication) AddJobV2 added in v0.9.3 

func (app *ChainlinkApplication) AddJobV2(ctx context.Context, j job.Job, name null.String) (job.Job, error)

func (*ChainlinkApplication) AddServiceAgreement 

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

AddServiceAgreement adds a Service Agreement which includes a job that needs to be scheduled.

func (*ChainlinkApplication) ArchiveJob 

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

ArchiveJob silences the job from the system, preventing future job runs. It is idempotent and can be run as many times as you like.

func (*ChainlinkApplication) DeleteJobV2 added in v0.9.3 

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

func (*ChainlinkApplication) GetConfig added in v0.10.11 

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

func (*ChainlinkApplication) GetEthClient added in v0.10.11 

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

func (*ChainlinkApplication) GetExternalInitiatorManager added in v0.9.10 

func (app *ChainlinkApplication) GetExternalInitiatorManager() webhook.ExternalInitiatorManager

func (*ChainlinkApplication) GetFeedsService added in v0.10.8 

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

func (*ChainlinkApplication) GetHeadBroadcaster added in v0.10.8 

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

func (*ChainlinkApplication) GetHealthChecker added in v0.10.8 

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

func (*ChainlinkApplication) GetKeyStore added in v0.10.8 

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

func (*ChainlinkApplication) GetLogger added in v0.10.6 

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

func (*ChainlinkApplication) GetStatsPusher 

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

func (*ChainlinkApplication) GetStore 

func (app *ChainlinkApplication) GetStore() *strpkg.Store

GetStore returns the pointer to the store for the ChainlinkApplication.

func (*ChainlinkApplication) JobORM added in v0.9.9 

func (app *ChainlinkApplication) JobORM() job.ORM

func (*ChainlinkApplication) JobSpawner added in v0.10.8 

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

func (*ChainlinkApplication) NewBox 

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

NewBox returns the packr.Box instance that holds the static assets to be delivered by the router.

func (*ChainlinkApplication) PipelineORM added in v0.10.8 

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

func (*ChainlinkApplication) ReplayFromBlock added in v0.10.11 

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

func (*ChainlinkApplication) ResumeJobV2 added in v0.10.10 

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

func (*ChainlinkApplication) RunJobV2 added in v0.9.6 

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

Only used for local testing, not supported by the UI.

func (*ChainlinkApplication) RunWebhookJobV2 added in v0.10.8 

func (app *ChainlinkApplication) RunWebhookJobV2(ctx context.Context, jobUUID uuid.UUID, requestBody string, meta pipeline.JSONSerializable) (int64, error)

func (*ChainlinkApplication) SetServiceLogger added in v0.10.6 

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

SetServiceLogger sets the Logger for a given service and stores the setting in the db

func (*ChainlinkApplication) Start 

func (app *ChainlinkApplication) Start() error

Start all necessary services. If successful, nil will be returned. Also listens for interrupt signals from the operating system so that the application can be properly closed before the application exits.

func (*ChainlinkApplication) Stop 

func (app *ChainlinkApplication) Stop() error

Stop allows the application to exit by halting schedules, closing logs, and closing the DB connection.

func (*ChainlinkApplication) StopIfStarted added in v0.9.9 

func (app *ChainlinkApplication) StopIfStarted() error

func (*ChainlinkApplication) WakeSessionReaper 

func (app *ChainlinkApplication) WakeSessionReaper()

WakeSessionReaper wakes up the reaper to do its reaping.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.