worker

package
v0.19.786 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2026 License: AGPL-3.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 signals.RequestSignal) error

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

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 5m @task-timeout 3m

func (*Workflows) EventLoop 

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

func (*Workflows) PollDependencies 

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

TODO(ja): Components don't have a status field, so we can't update them if this fails. Not sure if that's a problem or not.

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

func (*Workflows) Provision 

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

@temporal-gen workflow

func (*Workflows) QueueBuild 

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

@temporal-gen workflow

func (*Workflows) Restarted 

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

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

func (*Workflows) UpdateComponentType 

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

@temporal-gen workflow

type WorkflowsParams 

type WorkflowsParams struct {
	fx.In

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

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.