Versions in this module Expand all Collapse all v0 v0.0.1 May 19, 2021 Changes in this version + type Config struct + func (_m *Config) BridgeResponseURL() *url.URL + func (_m *Config) DatabaseMaximumTxDuration() time.Duration + func (_m *Config) DatabaseURL() url.URL + 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) JobPipelineReaperInterval() time.Duration + func (_m *Config) JobPipelineReaperThreshold() time.Duration + func (_m *Config) TriggerFallbackDBPollInterval() time.Duration + type ORM struct + 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) FindRun(id int64) (pipeline.Run, error) + func (_m *ORM) InsertFinishedRun(ctx context.Context, run pipeline.Run, trrs []pipeline.TaskRunResult, ...) (int64, error) + type Runner struct + func (_m *Runner) Close() error + func (_m *Runner) ExecuteAndInsertFinishedRun(ctx context.Context, spec pipeline.Spec, meta pipeline.JSONSerializable, ...) (int64, pipeline.FinalResult, error) + func (_m *Runner) ExecuteRun(ctx context.Context, spec pipeline.Spec, meta pipeline.JSONSerializable, ...) (pipeline.TaskRunResults, error) + func (_m *Runner) InsertFinishedRun(ctx context.Context, run pipeline.Run, trrs pipeline.TaskRunResults, ...) (int64, error) + func (_m *Runner) Start() error
Go to main page