Documentation
¶
Index ¶
- func AsJobLoop(f any) any
- func AsManagementJobLoop(f any) any
- func AsOperationsJobLoop(f any) any
- func New(handlers []jobs.JobHandler, jobGroup models.AppRunnerJobGroup, ...) *jobLoop
- func WithJobLoops(f any) any
- func WithManagementJobLoops(f any) any
- func WithOperationsJobLoops(f any) any
- type BaseParams
- type Healthcheck
- type JobLoop
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AsManagementJobLoop ¶
func AsOperationsJobLoop ¶
func New ¶
func New(handlers []jobs.JobHandler, jobGroup models.AppRunnerJobGroup, params BaseParams, opts ...Option) *jobLoop
func WithJobLoops ¶
func WithManagementJobLoops ¶
func WithOperationsJobLoops ¶
Types ¶
type BaseParams ¶
type BaseParams struct {
fx.In
LC fx.Lifecycle
Shutdowner fx.Shutdowner
Client nuonrunner.Client
Settings *settings.Settings
Cfg *runnerconfig.Config
ErrRecorder *errs.Recorder
MW metrics.Writer
L *zap.Logger `name:"system"`
ProcessRegistrar *process.Registrar
Audit *audit.Writer
Drainer *drain.Drainer
}
type Healthcheck ¶
type Option ¶ added in v0.19.1126
type Option func(*jobLoop)
Option configures a job loop beyond its handlers and group.
func WithIdleHook ¶ added in v0.19.1126
WithIdleHook registers work to run when a poll finds no jobs, rate-limited to idleHookInterval. The image-actions loop uses it to collect cached action images only while it isn't running one.
Source Files
¶
- base_params.go
- exec_job.go
- exec_job_step.go
- exec_job_steps.go
- fx.go
- healthcheck.go
- job_cleanup.go
- job_handler.go
- job_step_cleanup.go
- job_step_execute.go
- job_step_initialize.go
- job_step_initializing.go
- job_step_outputs.go
- job_step_reset.go
- job_step_validate.go
- jobloop.go
- lifecycle.go
- monitor_job.go
- sandbox.go
- status_coalescer.go
- worker.go
Click to show internal directories.
Click to hide internal directories.