mocks

package
v1.13.3 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

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 added in v1.6.0 

func NewConfig(t mockConstructorTestingTNewConfig) *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.

func (*Config) BridgeCacheTTL added in v1.11.0 

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

BridgeCacheTTL provides a mock function with given fields:

func (*Config) BridgeResponseURL 

func (_m *Config) BridgeResponseURL() *url.URL

BridgeResponseURL provides a mock function with given fields:

func (*Config) DatabaseURL 

func (_m *Config) DatabaseURL() url.URL

DatabaseURL provides a mock function with given fields:

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) JobPipelineMaxRunDuration added in v0.9.10 

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

JobPipelineMaxRunDuration provides a mock function with given fields:

func (*Config) JobPipelineReaperInterval 

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

JobPipelineReaperInterval provides a mock function with given fields:

func (*Config) JobPipelineReaperThreshold 

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

JobPipelineReaperThreshold provides a mock function with given fields:

func (*Config) TriggerFallbackDBPollInterval added in v0.9.6 

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

TriggerFallbackDBPollInterval provides a mock function with given fields:

type ETHKeyStore added in v0.10.11 

type ETHKeyStore struct {
	mock.Mock
}

ETHKeyStore is an autogenerated mock type for the ETHKeyStore type

func NewETHKeyStore added in v1.6.0 

func NewETHKeyStore(t mockConstructorTestingTNewETHKeyStore) *ETHKeyStore

NewETHKeyStore creates a new instance of ETHKeyStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ETHKeyStore) GetRoundRobinAddress added in v0.10.11 

func (_m *ETHKeyStore) GetRoundRobinAddress(chainID *big.Int, addrs ...common.Address) (common.Address, error)

GetRoundRobinAddress provides a mock function with given fields: chainID, addrs

type ORM 

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func NewORM added in v1.6.0 

func NewORM(t mockConstructorTestingTNewORM) *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.

func (*ORM) Close added in v1.12.0 

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 added in v1.0.0 

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 added in v0.10.3 

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

FindRun provides a mock function with given fields: id

func (*ORM) GetAllRuns added in v0.10.8 

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

GetAllRuns provides a mock function with given fields:

func (*ORM) GetQ added in v1.1.0 

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

GetQ provides a mock function with given fields:

func (*ORM) GetUnfinishedRuns added in v0.10.10 

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 added in v1.13.0 

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

HealthReport provides a mock function with given fields:

func (*ORM) Healthy added in v1.12.0 

func (_m *ORM) Healthy() error

Healthy provides a mock function with given fields:

func (*ORM) InsertFinishedRun added in v0.10.5 

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 added in v1.4.0 

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 added in v1.1.0 

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

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

func (*ORM) Name added in v1.13.0 

func (_m *ORM) Name() string

Name provides a mock function with given fields:

func (*ORM) Ready added in v1.12.0 

func (_m *ORM) Ready() error

Ready provides a mock function with given fields:

func (*ORM) Start added in v1.12.0 

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

Start provides a mock function with given fields: _a0

func (*ORM) StoreRun added in v0.10.10 

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 added in v0.10.10 

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 added in v0.10.8 

type PipelineParamUnmarshaler struct {
	mock.Mock
}

PipelineParamUnmarshaler is an autogenerated mock type for the PipelineParamUnmarshaler type

func NewPipelineParamUnmarshaler added in v1.6.0 

func NewPipelineParamUnmarshaler(t mockConstructorTestingTNewPipelineParamUnmarshaler) *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.

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 

type Runner struct {
	mock.Mock
}

Runner is an autogenerated mock type for the Runner type

func NewRunner added in v1.6.0 

func NewRunner(t mockConstructorTestingTNewRunner) *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.

func (*Runner) Close added in v0.10.3 

func (_m *Runner) Close() error

Close provides a mock function with given fields:

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) HealthReport added in v1.13.0 

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

HealthReport provides a mock function with given fields:

func (*Runner) Healthy added in v0.10.8 

func (_m *Runner) Healthy() error

Healthy provides a mock function with given fields:

func (*Runner) InsertFinishedRun added in v0.10.5 

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 added in v1.4.0 

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 added in v1.13.0 

func (_m *Runner) Name() string

Name provides a mock function with given fields:

func (*Runner) OnRunFinished added in v1.0.0 

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

OnRunFinished provides a mock function with given fields: _a0

func (*Runner) Ready added in v0.10.8 

func (_m *Runner) Ready() error

Ready provides a mock function with given fields:

func (*Runner) ResumeRun added in v1.0.0 

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 added in v0.10.10 

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 added in v0.10.3 

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

Start provides a mock function with given fields: _a0

type Task 

type Task struct {
	mock.Mock
}

Task is an autogenerated mock type for the Task type

func NewTask added in v1.6.0 

func NewTask(t mockConstructorTestingTNewTask) *Task

NewTask creates a new instance of Task. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Task) Base added in v1.1.0 

func (_m *Task) Base() *pipeline.BaseTask

Base provides a mock function with given fields:

func (*Task) DotID 

func (_m *Task) DotID() string

DotID provides a mock function with given fields:

func (*Task) ID added in v1.1.0 

func (_m *Task) ID() int

ID provides a mock function with given fields:

func (*Task) Inputs added in v1.1.0 

func (_m *Task) Inputs() []pipeline.TaskDependency

Inputs provides a mock function with given fields:

func (*Task) OutputIndex 

func (_m *Task) OutputIndex() int32

OutputIndex provides a mock function with given fields:

func (*Task) Outputs added in v1.1.0 

func (_m *Task) Outputs() []pipeline.Task

Outputs provides a mock function with given fields:

func (*Task) Run 

func (_m *Task) Run(ctx context.Context, lggr logger.Logger, vars pipeline.Vars, inputs []pipeline.Result) (pipeline.Result, pipeline.RunInfo)

Run provides a mock function with given fields: ctx, lggr, vars, inputs

func (*Task) TaskMaxBackoff added in v1.1.0 

func (_m *Task) TaskMaxBackoff() time.Duration

TaskMaxBackoff provides a mock function with given fields:

func (*Task) TaskMinBackoff added in v1.1.0 

func (_m *Task) TaskMinBackoff() time.Duration

TaskMinBackoff provides a mock function with given fields:

func (*Task) TaskRetries added in v1.1.0 

func (_m *Task) TaskRetries() uint32

TaskRetries provides a mock function with given fields:

func (*Task) TaskTimeout added in v0.9.7 

func (_m *Task) TaskTimeout() (time.Duration, bool)

TaskTimeout provides a mock function with given fields:

func (*Task) Type 

func (_m *Task) Type() pipeline.TaskType

Type provides a mock function with given fields:

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.