worker

package
v0.19.986 Latest Latest
Warning

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

Go to latest
Published: Jun 2, 2026 License: AGPL-3.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BuildRequest added in v0.19.986

type BuildRequest struct {
	ID          string `json:"id"`
	BuildID     string `json:"build_id"`
	SandboxMode bool   `json:"sandbox_mode"`
}

type Worker

type Worker struct {
	worker.Worker
}

func New

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

type WorkerParams

type WorkerParams struct {
	fx.In

	Cfg     *internal.Config
	Tclient temporalclient.Client
	Wkflows *Workflows
	Acts    *activities.Activities
	L       *zap.Logger
	LC      fx.Lifecycle

	Interceptors []interceptor.WorkerInterceptor `group:"interceptors"`

	SharedActs      *workflows.Activities
	SharedWorkflows *workflows.Workflows
}

type Workflows

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

func NewWorkflows

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

func (*Workflows) All

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

func (*Workflows) Build

func (w *Workflows) Build(ctx workflow.Context, sreq BuildRequest) error

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

type WorkflowsParams

type WorkflowsParams struct {
	fx.In

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL