mocks

package
v0.10.4 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2021 License: MIT Imports: 9 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 (*Config) BridgeResponseURL 

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

BridgeResponseURL provides a mock function with given fields:

func (*Config) DatabaseMaximumTxDuration 

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

DatabaseMaximumTxDuration 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) DefaultHTTPAllowUnrestrictedNetworkAccess 

func (_m *Config) DefaultHTTPAllowUnrestrictedNetworkAccess() bool

DefaultHTTPAllowUnrestrictedNetworkAccess 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) DefaultMaxHTTPAttempts 

func (_m *Config) DefaultMaxHTTPAttempts() uint

DefaultMaxHTTPAttempts 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) JobPipelineParallelism 

func (_m *Config) JobPipelineParallelism() uint8

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

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func (*ORM) AwaitRun 

func (_m *ORM) AwaitRun(ctx context.Context, runID int64) error

AwaitRun provides a mock function with given fields: ctx, runID

func (*ORM) CreateRun 

func (_m *ORM) CreateRun(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)

CreateRun provides a mock function with given fields: ctx, jobID, meta

func (*ORM) CreateSpec 

func (_m *ORM) CreateSpec(ctx context.Context, db *gorm.DB, taskDAG pipeline.TaskDAG, maxTaskTimeout models.Interval) (int32, error)

CreateSpec provides a mock function with given fields: ctx, db, taskDAG, maxTaskTimeout

func (*ORM) DB added in v0.9.10 

func (_m *ORM) DB() *gorm.DB

DB provides a mock function with given fields:

func (*ORM) DeleteRunsOlderThan 

func (_m *ORM) DeleteRunsOlderThan(threshold time.Duration) error

DeleteRunsOlderThan provides a mock function with given fields: threshold

func (*ORM) FindBridge 

func (_m *ORM) FindBridge(name models.TaskType) (models.BridgeType, error)

FindBridge provides a mock function with given fields: name

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

func (_m *ORM) InsertFinishedRunWithResults(ctx context.Context, run pipeline.Run, trrs []pipeline.TaskRunResult) (int64, error)

InsertFinishedRunWithResults provides a mock function with given fields: ctx, run, trrs

func (*ORM) ListenForNewRuns 

func (_m *ORM) ListenForNewRuns() (postgres.Subscription, error)

ListenForNewRuns provides a mock function with given fields:

func (*ORM) ProcessNextUnfinishedRun added in v0.9.10 

func (_m *ORM) ProcessNextUnfinishedRun(ctx context.Context, fn pipeline.ProcessRunFunc) (bool, error)

ProcessNextUnfinishedRun provides a mock function with given fields: ctx, fn

func (*ORM) ResultsForRun 

func (_m *ORM) ResultsForRun(ctx context.Context, runID int64) ([]pipeline.Result, error)

ResultsForRun provides a mock function with given fields: ctx, runID

func (*ORM) RunFinished 

func (_m *ORM) RunFinished(runID int64) (bool, error)

RunFinished provides a mock function with given fields: runID

type Runner added in v0.10.3 

type Runner struct {
	mock.Mock
}

Runner is an autogenerated mock type for the Runner type

func (*Runner) AwaitRun added in v0.10.3 

func (_m *Runner) AwaitRun(ctx context.Context, runID int64) error

AwaitRun provides a mock function with given fields: ctx, runID

func (*Runner) Close added in v0.10.3 

func (_m *Runner) Close() error

Close provides a mock function with given fields:

func (*Runner) CreateRun added in v0.10.3 

func (_m *Runner) CreateRun(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)

CreateRun provides a mock function with given fields: ctx, jobID, meta

func (*Runner) ExecuteAndInsertNewRun added in v0.10.3 

func (_m *Runner) ExecuteAndInsertNewRun(ctx context.Context, spec pipeline.Spec, l logger.Logger) (int64, pipeline.FinalResult, error)

ExecuteAndInsertNewRun provides a mock function with given fields: ctx, spec, l

func (*Runner) ExecuteRun added in v0.10.3 

func (_m *Runner) ExecuteRun(ctx context.Context, spec pipeline.Spec, l logger.Logger) (pipeline.TaskRunResults, error)

ExecuteRun provides a mock function with given fields: ctx, spec, l

func (*Runner) InsertFinishedRunWithResults added in v0.10.3 

func (_m *Runner) InsertFinishedRunWithResults(ctx context.Context, run pipeline.Run, trrs pipeline.TaskRunResults) (int64, error)

InsertFinishedRunWithResults provides a mock function with given fields: ctx, run, trrs

func (*Runner) ResultsForRun added in v0.10.3 

func (_m *Runner) ResultsForRun(ctx context.Context, runID int64) ([]pipeline.Result, error)

ResultsForRun provides a mock function with given fields: ctx, runID

func (*Runner) Start added in v0.10.3 

func (_m *Runner) Start() error

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