worker

package
v0.19.921 Latest Latest
Warning

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

 Go to latest Published: May 7, 2026 License: AGPL-3.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CronShutdownVMRequest added in v0.19.850 

type CronShutdownVMRequest struct {
	RunnerID string `validate:"required" json:"runner_id"`
}

type OfflineCheckRequest 

type OfflineCheckRequest struct {
	RunnerID string `validate:"required" json:"runner_id"`
}

Check if a runner is offline

type Worker 

type Worker struct {
	worker.Worker
}

func New 

func New(params WorkerParams) (*Worker, error)

type WorkerParams 

type WorkerParams struct {
	fx.In

	V       *validator.Validate
	Cfg     *internal.Config
	Tclient temporalclient.Client
	Wkflows *Workflows
	Acts    *activities.Activities
	L       *zap.Logger
	Lc      fx.Lifecycle

	SharedActivities *workflows.Activities
	SharedWorkflows  *workflows.Workflows
	Interceptors     []interceptor.WorkerInterceptor `group:"interceptors"`
}

type WorkflowParams 

type WorkflowParams struct {
	fx.In

	V             *validator.Validate
	Cfg           *internal.Config
	MetricsWriter metrics.Writer
	EvClient      teventloop.Client
}

type Workflows 

type Workflows struct {
	// contains filtered or unexported fields
}

func NewWorkflows 

func NewWorkflows(params WorkflowParams) (*Workflows, error)

func (*Workflows) All 

func (w *Workflows) All() []any

func (*Workflows) Created 

func (w *Workflows) Created(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow

func (*Workflows) CronShutdownVM added in v0.19.850 

func (w *Workflows) CronShutdownVM(ctx workflow.Context, req *CronShutdownVMRequest) error

@temporal-gen-v2 workflow @execution-timeout 3m @task-timeout 5m

func (*Workflows) Delete 

func (w *Workflows) Delete(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

func (*Workflows) Deprovision 

func (w *Workflows) Deprovision(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

func (*Workflows) EventLoop 

func (w *Workflows) EventLoop(ctx workflow.Context, req eventloop.EventLoopRequest, pendingSignals []*signals.Signal) error

func (*Workflows) FlushOrphanedJobs 

func (w *Workflows) FlushOrphanedJobs(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow

func (*Workflows) ForceShutdown 

func (w *Workflows) ForceShutdown(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

func (*Workflows) GracefulShutdown 

func (w *Workflows) GracefulShutdown(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

func (*Workflows) InstallStackVersionRun 

func (w *Workflows) InstallStackVersionRun(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

func (*Workflows) MngFetchToken 

func (w *Workflows) MngFetchToken(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 10m @task-timeout 5m

func (*Workflows) MngRestart added in v0.19.850 

func (w *Workflows) MngRestart(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 10m @task-timeout 5m

func (*Workflows) MngShutdown 

func (w *Workflows) MngShutdown(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 10m @task-timeout 5m

func (*Workflows) MngUpdate 

func (w *Workflows) MngUpdate(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 10m @task-timeout 5m

func (*Workflows) MngVMShutdown 

func (w *Workflows) MngVMShutdown(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 10m @task-timeout 5m

func (*Workflows) OfflineCheck 

func (w *Workflows) OfflineCheck(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow

func (*Workflows) ProcessJob 

func (w *Workflows) ProcessJob(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

func (*Workflows) Provision 

func (w *Workflows) Provision(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

func (*Workflows) ProvisionServiceAccount 

func (w *Workflows) ProvisionServiceAccount(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

func (*Workflows) Reprovision 

func (w *Workflows) Reprovision(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

func (*Workflows) ReprovisionServiceAccount 

func (w *Workflows) ReprovisionServiceAccount(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

func (*Workflows) Restart 

func (w *Workflows) Restart(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 30m @task-timeout 1m

func (*Workflows) UpdateVersion 

func (w *Workflows) UpdateVersion(ctx workflow.Context, sreq signals.RequestSignal) error

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m

Source Files

View all Source files

Directories

Path Synopsis

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.