mocks

Documentation

Index

• type Config
  • func (_m *Config) BridgeResponseURL() *url.URL
  • func (_m *Config) DatabaseMaximumTxDuration() time.Duration
  • func (_m *Config) DatabaseURL() string
  • func (_m *Config) DefaultHTTPAllowUnrestrictedNetworkAccess() bool
  • func (_m *Config) DefaultHTTPLimit() int64
  • func (_m *Config) DefaultHTTPTimeout() models.Duration
  • func (_m *Config) DefaultMaxHTTPAttempts() uint
  • func (_m *Config) JobPipelineMaxRunDuration() time.Duration
  • func (_m *Config) JobPipelineMaxTaskDuration() time.Duration
  • func (_m *Config) JobPipelineParallelism() uint8
  • func (_m *Config) JobPipelineReaperInterval() time.Duration
  • func (_m *Config) JobPipelineReaperThreshold() time.Duration
  • func (_m *Config) TriggerFallbackDBPollInterval() time.Duration
• type ORM
  • func (_m *ORM) AwaitRun(ctx context.Context, runID int64) error
  • func (_m *ORM) CreateRun(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)
  • func (_m *ORM) CreateSpec(ctx context.Context, db *gorm.DB, taskDAG pipeline.TaskDAG, ...) (int32, error)
  • func (_m *ORM) DB() *gorm.DB
  • func (_m *ORM) DeleteRunsOlderThan(threshold time.Duration) error
  • func (_m *ORM) FindBridge(name models.TaskType) (models.BridgeType, error)
  • func (_m *ORM) InsertFinishedRunWithResults(ctx context.Context, run pipeline.Run, trrs []pipeline.TaskRunResult) (int64, error)
  • func (_m *ORM) ListenForNewRuns() (postgres.Subscription, error)
  • func (_m *ORM) ProcessNextUnfinishedRun(ctx context.Context, fn pipeline.ProcessRunFunc) (bool, error)
  • func (_m *ORM) ResultsForRun(ctx context.Context, runID int64) ([]pipeline.Result, error)
  • func (_m *ORM) RunFinished(runID int64) (bool, error)

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() string

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

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

JobPipelineMaxRunDuration provides a mock function with given fields:

func (*Config) JobPipelineMaxTaskDuration

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

JobPipelineMaxTaskDuration 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

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

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

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

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