Help us shape the future of Go! Take the 2026 Go Developer Survey

mocks

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jun 23, 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 

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 

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 

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 

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

TriggerFallbackDBPollInterval provides a mock function with given fields:

type ETHKeyStore 

type ETHKeyStore struct {
	mock.Mock
}

ETHKeyStore is an autogenerated mock type for the ETHKeyStore type

func NewETHKeyStore 

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 

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 

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 

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) Healthy 

func (_m *ORM) Healthy() error

Healthy 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 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 

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 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 

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) Healthy 

func (_m *Runner) Healthy() error

Healthy 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

type Task 

type Task struct {
	mock.Mock
}

Task is an autogenerated mock type for the Task type

func NewTask 

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 

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 

func (_m *Task) ID() int

ID provides a mock function with given fields:

func (*Task) Inputs 

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 

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 

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

TaskMaxBackoff provides a mock function with given fields:

func (*Task) TaskMinBackoff 

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

TaskMinBackoff provides a mock function with given fields:

func (*Task) TaskRetries 

func (_m *Task) TaskRetries() uint32

TaskRetries provides a mock function with given fields:

func (*Task) TaskTimeout 

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.