mocks

package

v2.7.0-beta1 Latest Latest Go to latest Published: Oct 27, 2023 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/smartcontractkit/chainlink

Documentation ¶

Index ¶

type Config
- func NewConfig(t interface{ ... }) *Config
type ORM
- func NewORM(t interface{ ... }) *ORM
type PipelineParamUnmarshaler
- func NewPipelineParamUnmarshaler(t interface{ ... }) *PipelineParamUnmarshaler
- func (_m *PipelineParamUnmarshaler) UnmarshalPipelineParam(val interface{}) error
type Runner
- func NewRunner(t interface{ ... }) *Runner

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	mock.Mock
}

Config is an autogenerated mock type for the Config type

func NewConfig ¶

func NewConfig(t interface {
	mock.TestingT
	Cleanup(func())
}) *Config

NewConfig creates a new instance of Config. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Config) DefaultHTTPLimit ¶

func (_m *Config) DefaultHTTPLimit() int64

DefaultHTTPLimit provides a mock function with given fields:

func (*Config) DefaultHTTPTimeout ¶

func (_m *Config) DefaultHTTPTimeout() models.Duration

DefaultHTTPTimeout provides a mock function with given fields:

func (*Config) MaxRunDuration ¶ added in v2.3.0

func (_m *Config) MaxRunDuration() time.Duration

MaxRunDuration provides a mock function with given fields:

func (*Config) ReaperInterval ¶ added in v2.3.0

func (_m *Config) ReaperInterval() time.Duration

ReaperInterval provides a mock function with given fields:

func (*Config) ReaperThreshold ¶ added in v2.3.0

func (_m *Config) ReaperThreshold() time.Duration

ReaperThreshold provides a mock function with given fields:

type ORM ¶

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func NewORM ¶

func NewORM(t interface {
	mock.TestingT
	Cleanup(func())
}) *ORM

NewORM creates a new instance of ORM. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ORM) Close ¶

func (_m *ORM) Close() error

Close provides a mock function with given fields:

func (*ORM) CreateRun ¶

func (_m *ORM) CreateRun(run *pipeline.Run, qopts ...pg.QOpt) error

CreateRun provides a mock function with given fields: run, qopts

func (*ORM) CreateSpec ¶

func (_m *ORM) CreateSpec(_a0 pipeline.Pipeline, maxTaskTimeout models.Interval, qopts ...pg.QOpt) (int32, error)

CreateSpec provides a mock function with given fields: _a0, maxTaskTimeout, qopts

func (*ORM) DeleteRun ¶

func (_m *ORM) DeleteRun(id int64) error

DeleteRun provides a mock function with given fields: id

func (*ORM) DeleteRunsOlderThan ¶

func (_m *ORM) DeleteRunsOlderThan(_a0 context.Context, _a1 time.Duration) error

DeleteRunsOlderThan provides a mock function with given fields: _a0, _a1

func (*ORM) FindRun ¶

func (_m *ORM) FindRun(id int64) (pipeline.Run, error)

FindRun provides a mock function with given fields: id

func (*ORM) GetAllRuns ¶

func (_m *ORM) GetAllRuns() ([]pipeline.Run, error)

GetAllRuns provides a mock function with given fields:

func (*ORM) GetQ ¶

func (_m *ORM) GetQ() pg.Q

GetQ provides a mock function with given fields:

func (*ORM) GetUnfinishedRuns ¶

func (_m *ORM) GetUnfinishedRuns(_a0 context.Context, _a1 time.Time, _a2 func(pipeline.Run) error) error

GetUnfinishedRuns provides a mock function with given fields: _a0, _a1, _a2

func (*ORM) HealthReport ¶

func (_m *ORM) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*ORM) InsertFinishedRun ¶

func (_m *ORM) InsertFinishedRun(run *pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error

InsertFinishedRun provides a mock function with given fields: run, saveSuccessfulTaskRuns, qopts

func (*ORM) InsertFinishedRuns ¶

func (_m *ORM) InsertFinishedRuns(run []*pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error

InsertFinishedRuns provides a mock function with given fields: run, saveSuccessfulTaskRuns, qopts

func (*ORM) InsertRun ¶

func (_m *ORM) InsertRun(run *pipeline.Run, qopts ...pg.QOpt) error

InsertRun provides a mock function with given fields: run, qopts

func (*ORM) Name ¶

func (_m *ORM) Name() string

Name provides a mock function with given fields:

func (*ORM) Ready ¶

func (_m *ORM) Ready() error

Ready provides a mock function with given fields:

func (*ORM) Start ¶

func (_m *ORM) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

func (*ORM) StoreRun ¶

func (_m *ORM) StoreRun(run *pipeline.Run, qopts ...pg.QOpt) (bool, error)

StoreRun provides a mock function with given fields: run, qopts

func (*ORM) UpdateTaskRunResult ¶

func (_m *ORM) UpdateTaskRunResult(taskID uuid.UUID, result pipeline.Result) (pipeline.Run, bool, error)

UpdateTaskRunResult provides a mock function with given fields: taskID, result

type PipelineParamUnmarshaler ¶

type PipelineParamUnmarshaler struct {
	mock.Mock
}

PipelineParamUnmarshaler is an autogenerated mock type for the PipelineParamUnmarshaler type

func NewPipelineParamUnmarshaler ¶

func NewPipelineParamUnmarshaler(t interface {
	mock.TestingT
	Cleanup(func())
}) *PipelineParamUnmarshaler

NewPipelineParamUnmarshaler creates a new instance of PipelineParamUnmarshaler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PipelineParamUnmarshaler) UnmarshalPipelineParam ¶

func (_m *PipelineParamUnmarshaler) UnmarshalPipelineParam(val interface{}) error

UnmarshalPipelineParam provides a mock function with given fields: val

type Runner ¶

type Runner struct {
	mock.Mock
}

Runner is an autogenerated mock type for the Runner type

func NewRunner ¶

func NewRunner(t interface {
	mock.TestingT
	Cleanup(func())
}) *Runner

NewRunner creates a new instance of Runner. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Runner) Close ¶

func (_m *Runner) Close() error

Close provides a mock function with given fields:

func (*Runner) ExecuteAndInsertFinishedRun ¶

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 ¶

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) HealthReport ¶

func (_m *Runner) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*Runner) InsertFinishedRun ¶

func (_m *Runner) InsertFinishedRun(run *pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error

InsertFinishedRun provides a mock function with given fields: run, saveSuccessfulTaskRuns, qopts

func (*Runner) InsertFinishedRuns ¶

func (_m *Runner) InsertFinishedRuns(runs []*pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error

InsertFinishedRuns provides a mock function with given fields: runs, saveSuccessfulTaskRuns, qopts

func (*Runner) Name ¶

func (_m *Runner) Name() string

Name provides a mock function with given fields:

func (*Runner) OnRunFinished ¶

func (_m *Runner) OnRunFinished(_a0 func(*pipeline.Run))

OnRunFinished provides a mock function with given fields: _a0

func (*Runner) Ready ¶

func (_m *Runner) Ready() error

Ready provides a mock function with given fields:

func (*Runner) ResumeRun ¶

func (_m *Runner) ResumeRun(taskID uuid.UUID, value interface{}, err error) error

ResumeRun provides a mock function with given fields: taskID, value, err

func (*Runner) Run ¶

func (_m *Runner) Run(ctx context.Context, run *pipeline.Run, l logger.Logger, saveSuccessfulTaskRuns bool, fn func(pg.Queryer) error) (bool, error)

Run provides a mock function with given fields: ctx, run, l, saveSuccessfulTaskRuns, fn

func (*Runner) Start ¶

func (_m *Runner) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL