NewBalanceMonitor returns a new balanceMonitor.

NewInitiatorSubscription creates a new InitiatorSubscription that feeds received logs to the callback func parameter.

NewJobSubscriber returns a new job subscriber.

NewRecurring create a new instance of Recurring, ready to use.

NewRun returns a complete run from a JobSpec.

NewRunExecutor initializes a RunExecutor.

NewRunManager returns a new job manager.

NewRunQueue initializes a RunQueue.

NewScheduler initializes the Scheduler instances with both Recurring and OneTime fields since jobs can contain tasks which utilize both.

NewSessionReaper creates a reaper that cleans stale sessions from the store.

ReceiveLogRequest parses the log and runs the job it indicated by its GetJobSpecID method.

StartJobSubscription constructs a JobSubscription which listens for and tracks event logs corresponding to the specified job.

ValidateBridgeType checks that the bridge type doesn't have a duplicate or invalid name or invalid url.

ValidateBridgeTypeNotExist checks that a bridge has not already been created.

ValidateExternalInitiator checks whether External Initiator parameters are safe for processing.

ValidateInitiator checks the Initiator for any application logic errors.

ValidateJob checks the job and its associated Initiators and Tasks for any application logic errors.

ValidateRun ensures that a run's initial preconditions have been met.

ValidateServiceAgreement checks the ServiceAgreement for any application logic errors.

InitiatorSubscription encapsulates all functionality needed to wrap an ethereum subscription for use with a Chainlink Initiator.

JobSubscription listens to event logs being pushed from the Ethereum Node to a job.

NullJobSubscriber implements Null pattern for JobSubscriber interface.

NullRunExecutor implements Null pattern for RunExecutor interface.

NullRunManager implements Null pattern for RunManager interface.

NullRunQueue implements Null pattern for RunQueue interface.

OneTime represents runs that are to be executed only once.

Recurring is used for runs that need to execute on a schedule, and is configured with cron.

RecurringScheduleJobError contains the field for the error message.

Scheduler contains fields for Recurring and OneTime for occurrences, a pointer to the store and a started field to indicate if the Scheduler has started or not.

JobSubscriber listens for push notifications of event logs from the ethereum node's websocket for specific jobs by subscribing to ethLogs.

go:generate mockery --name PrometheusBackend --output ../internal/mocks/ --case=underscore.

RunExecutor handles the actual running of the job tasks.

RunManager supplies methods for queueing, resuming and cancelling jobs in the RunQueue.

RunQueue safely handles coordinating job runs.