Documentation ¶
Index ¶
- type Config
- func (_m *Config) BridgeResponseURL() *url.URL
- func (_m *Config) DatabaseMaximumTxDuration() time.Duration
- func (_m *Config) DatabaseURL() url.URL
- func (_m *Config) DefaultHTTPAllowUnrestrictedNetworkAccess() bool
- func (_m *Config) DefaultHTTPLimit() int64
- func (_m *Config) DefaultHTTPTimeout() models.Duration
- func (_m *Config) DefaultMaxHTTPAttempts() uint
- func (_m *Config) EthGasLimitDefault() uint64
- func (_m *Config) EthMaxQueuedTransactions() uint64
- func (_m *Config) JobPipelineMaxRunDuration() time.Duration
- func (_m *Config) JobPipelineReaperInterval() time.Duration
- func (_m *Config) JobPipelineReaperThreshold() time.Duration
- func (_m *Config) TriggerFallbackDBPollInterval() time.Duration
- type ETHKeyStore
- type KeyStore
- type ORM
- func (_m *ORM) CreateRun(db *gorm.DB, run *pipeline.Run) error
- func (_m *ORM) CreateSpec(ctx context.Context, tx *gorm.DB, _a2 pipeline.Pipeline, ...) (int32, error)
- func (_m *ORM) DB() *gorm.DB
- func (_m *ORM) DeleteRunsOlderThan(threshold time.Duration) error
- func (_m *ORM) FindRun(id int64) (pipeline.Run, error)
- func (_m *ORM) GetAllRuns() ([]pipeline.Run, error)
- func (_m *ORM) GetUnfinishedRuns(now time.Time, fn func(pipeline.Run) error) error
- func (_m *ORM) InsertFinishedRun(db *gorm.DB, run pipeline.Run, trrs []pipeline.TaskRunResult, ...) (int64, error)
- func (_m *ORM) StoreRun(db *sql.DB, run *pipeline.Run) (bool, error)
- func (_m *ORM) UpdateTaskRunResult(db *sql.DB, taskID uuid.UUID, result interface{}) (pipeline.Run, bool, error)
- type PipelineParamUnmarshaler
- type Runner
- func (_m *Runner) Close() error
- func (_m *Runner) ExecuteAndInsertFinishedRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger, ...) (int64, pipeline.FinalResult, error)
- func (_m *Runner) ExecuteRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger) (pipeline.Run, pipeline.TaskRunResults, error)
- func (_m *Runner) Healthy() error
- func (_m *Runner) InsertFinishedRun(db *gorm.DB, run pipeline.Run, trrs pipeline.TaskRunResults, ...) (int64, error)
- func (_m *Runner) Ready() error
- func (_m *Runner) Run(ctx context.Context, run *pipeline.Run, l logger.Logger, ...) (bool, error)
- func (_m *Runner) Start() error
- func (_m *Runner) TestInsertFinishedRun(db *gorm.DB, jobID int32, jobName string, jobType string, specID int32) (int64, error)
- type TxManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
Config is an autogenerated mock type for the Config type
func (*Config) BridgeResponseURL ¶
BridgeResponseURL provides a mock function with given fields:
func (*Config) DatabaseMaximumTxDuration ¶
DatabaseMaximumTxDuration provides a mock function with given fields:
func (*Config) DatabaseURL ¶
DatabaseURL provides a mock function with given fields:
func (*Config) DefaultHTTPAllowUnrestrictedNetworkAccess ¶
DefaultHTTPAllowUnrestrictedNetworkAccess provides a mock function with given fields:
func (*Config) DefaultHTTPLimit ¶
DefaultHTTPLimit provides a mock function with given fields:
func (*Config) DefaultHTTPTimeout ¶
DefaultHTTPTimeout provides a mock function with given fields:
func (*Config) DefaultMaxHTTPAttempts ¶
DefaultMaxHTTPAttempts provides a mock function with given fields:
func (*Config) EthGasLimitDefault ¶ added in v0.10.9
EthGasLimitDefault provides a mock function with given fields:
func (*Config) EthMaxQueuedTransactions ¶ added in v0.10.9
EthMaxQueuedTransactions provides a mock function with given fields:
func (*Config) JobPipelineMaxRunDuration ¶ added in v0.9.10
JobPipelineMaxRunDuration provides a mock function with given fields:
func (*Config) JobPipelineReaperInterval ¶
JobPipelineReaperInterval provides a mock function with given fields:
func (*Config) JobPipelineReaperThreshold ¶
JobPipelineReaperThreshold provides a mock function with given fields:
func (*Config) TriggerFallbackDBPollInterval ¶ added in v0.9.6
TriggerFallbackDBPollInterval provides a mock function with given fields:
type ETHKeyStore ¶ added in v0.10.11
ETHKeyStore is an autogenerated mock type for the ETHKeyStore type
func (*ETHKeyStore) GetRoundRobinAddress ¶ added in v0.10.11
GetRoundRobinAddress provides a mock function with given fields: addrs
type ORM ¶
ORM is an autogenerated mock type for the ORM type
func (*ORM) CreateSpec ¶
func (_m *ORM) CreateSpec(ctx context.Context, tx *gorm.DB, _a2 pipeline.Pipeline, maxTaskTimeout models.Interval) (int32, error)
CreateSpec provides a mock function with given fields: ctx, tx, _a2, maxTaskTimeout
func (*ORM) DeleteRunsOlderThan ¶
DeleteRunsOlderThan provides a mock function with given fields: threshold
func (*ORM) GetAllRuns ¶ added in v0.10.8
GetAllRuns provides a mock function with given fields:
func (*ORM) GetUnfinishedRuns ¶ added in v0.10.10
GetUnfinishedRuns provides a mock function with given fields: now, fn
func (*ORM) InsertFinishedRun ¶ added in v0.10.5
func (_m *ORM) InsertFinishedRun(db *gorm.DB, run pipeline.Run, trrs []pipeline.TaskRunResult, saveSuccessfulTaskRuns bool) (int64, error)
InsertFinishedRun provides a mock function with given fields: db, run, trrs, saveSuccessfulTaskRuns
type PipelineParamUnmarshaler ¶ added in v0.10.8
PipelineParamUnmarshaler is an autogenerated mock type for the PipelineParamUnmarshaler type
func (*PipelineParamUnmarshaler) UnmarshalPipelineParam ¶ added in v0.10.8
func (_m *PipelineParamUnmarshaler) UnmarshalPipelineParam(val interface{}) error
UnmarshalPipelineParam provides a mock function with given fields: val
type Runner ¶ added in v0.10.3
Runner is an autogenerated mock type for the Runner type
func (*Runner) ExecuteAndInsertFinishedRun ¶ added in v0.10.5
func (_m *Runner) ExecuteAndInsertFinishedRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger, saveSuccessfulTaskRuns bool) (int64, pipeline.FinalResult, error)
ExecuteAndInsertFinishedRun provides a mock function with given fields: ctx, spec, vars, l, saveSuccessfulTaskRuns
func (*Runner) ExecuteRun ¶ added in v0.10.3
func (_m *Runner) ExecuteRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger) (pipeline.Run, pipeline.TaskRunResults, error)
ExecuteRun provides a mock function with given fields: ctx, spec, vars, l
func (*Runner) InsertFinishedRun ¶ added in v0.10.5
func (_m *Runner) InsertFinishedRun(db *gorm.DB, run pipeline.Run, trrs pipeline.TaskRunResults, saveSuccessfulTaskRuns bool) (int64, error)
InsertFinishedRun provides a mock function with given fields: db, run, trrs, saveSuccessfulTaskRuns
func (*Runner) Run ¶ added in v0.10.10
func (_m *Runner) Run(ctx context.Context, run *pipeline.Run, l logger.Logger, saveSuccessfulTaskRuns bool) (bool, error)
Run provides a mock function with given fields: ctx, run, l, saveSuccessfulTaskRuns
type TxManager ¶ added in v0.10.9
TxManager is an autogenerated mock type for the TxManager type
func (*TxManager) CreateEthTransaction ¶ added in v0.10.9
func (_m *TxManager) CreateEthTransaction(db *gorm.DB, fromAddress common.Address, toAddress common.Address, payload []byte, gasLimit uint64, meta interface{}, strategy bulletprooftxmanager.TxStrategy) (bulletprooftxmanager.EthTx, error)
CreateEthTransaction provides a mock function with given fields: db, fromAddress, toAddress, payload, gasLimit, meta, strategy