worker

package
v0.19.821 Latest Latest
Warning

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

 Go to latest Published: Mar 3, 2026 License: AGPL-3.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HealthcheckCheckRestartWorkflowsID 

func HealthcheckCheckRestartWorkflowsID(req *HealthcheckCheckRestartRequest) string

func HealthcheckJobRunnerWorkflowsID 

func HealthcheckJobRunnerWorkflowsID(req *HealthcheckJobRunnerRequest) string

func HealthcheckUpdateNeededWorkflowsID 

func HealthcheckUpdateNeededWorkflowsID(req *HealthcheckUpdateNeededRequest) string

Types

type HealthCheckRequest 

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

Run a cron to check the health of a runner

type HealthcheckCheckRestartRequest 

type HealthcheckCheckRestartRequest struct {
	HeartbeatID string `validate:"required"`
	RunnerID    string `validate:"required"`
}

type HealthcheckCheckRestartResponse 

type HealthcheckCheckRestartResponse struct {
	ShouldRestart bool
}

type HealthcheckJobRunnerRequest 

type HealthcheckJobRunnerRequest struct {
	HealthCheckID string `validate:"required"`
	RunnerID      string `validate:"required"`
}

type HealthcheckJobRunnerResponse 

type HealthcheckJobRunnerResponse struct {
	ShouldRestart bool `json:"should_restart,omitzero"`
}

type HealthcheckUpdateNeededRequest 

type HealthcheckUpdateNeededRequest struct {
	HeartbeatID string `validate:"required"`
	RunnerID    string `validate:"required"`
}

type HealthcheckUpdateNeededResponse 

type HealthcheckUpdateNeededResponse struct {
	ShouldUpdate bool `json:"should_update,omitzero"`
}

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 workflow

func (*Workflows) Delete 

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

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

func (*Workflows) Deprovision 

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

@temporal-gen 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 workflow

func (*Workflows) ForceShutdown 

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

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

func (*Workflows) GracefulShutdown 

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

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

func (*Workflows) HealthCheck 

func (w *Workflows) HealthCheck(ctx workflow.Context, req *HealthCheckRequest) error

func (*Workflows) HealthcheckCheckRestart 

func (w *Workflows) HealthcheckCheckRestart(
	ctx workflow.Context,
	req *HealthcheckCheckRestartRequest,
) (*HealthcheckCheckRestartResponse, error)

@temporal-gen workflow @execution-timeout 3m @task-timeout 5m @id-callback HealthcheckCheckRestartWorkflowsID

func (*Workflows) HealthcheckJobRunner 

func (w *Workflows) HealthcheckJobRunner(ctx workflow.Context, req *HealthcheckJobRunnerRequest) (*HealthcheckJobRunnerResponse, error)

@temporal-gen workflow @execution-timeout 3m @task-timeout 5m @id-callback HealthcheckJobRunnerWorkflowsID

func (*Workflows) HealthcheckUpdateNeeded 

func (w *Workflows) HealthcheckUpdateNeeded(
	ctx workflow.Context,
	req *HealthcheckUpdateNeededRequest,
) (*HealthcheckUpdateNeededResponse, error)

@temporal-gen workflow @execution-timeout 2m @task-timeout 5m @id-callback HealthcheckUpdateNeededWorkflowsID

func (*Workflows) InstallStackVersionRun 

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

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

func (*Workflows) MngFetchToken 

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

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

func (*Workflows) MngShutdown 

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

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

func (*Workflows) MngUpdate 

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

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

func (*Workflows) MngVMShutdown 

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

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

func (*Workflows) OfflineCheck 

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

@temporal-gen workflow

func (*Workflows) ProcessJob 

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

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

func (*Workflows) Provision 

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

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

func (*Workflows) ProvisionServiceAccount 

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

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

func (*Workflows) Reprovision 

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

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

func (*Workflows) ReprovisionServiceAccount 

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

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

func (*Workflows) Restart 

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

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

func (*Workflows) UpdateVersion 

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

@temporal-gen 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.