worker

package

v0.19.786 Latest Latest Go to latest Published: Feb 13, 2026 License: AGPL-3.0 Imports: 29 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/nuonco/nuon

Links

Open Source Insights

Documentation ¶

Index ¶

type Params
type Worker
- func New(params WorkerParams) (*Worker, error)
type WorkerParams
type Workflows
- func NewWorkflows(params Params) (*Workflows, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Params ¶

type Params struct {
	fx.In

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

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

	SharedActs      *workflows.Activities
	SharedWorkflows *workflows.Workflows

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

	L  *zap.Logger
	LC fx.Lifecycle
}

type Workflows ¶

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

func NewWorkflows ¶

func NewWorkflows(params Params) (*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 @execution-timeout 1m @task-timeout 30s

func (*Workflows) Deprovision ¶

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

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

func (*Workflows) EventLoop ¶

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

func (*Workflows) ExecuteFlow ¶

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

@temporal-gen workflow @execution-timeout 720h

func (*Workflows) PollDependencies ¶

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

@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 @execution-timeout 30m @task-timeout 15m

func (*Workflows) Reprovision ¶

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

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

func (*Workflows) UpdateSandbox ¶

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

@temporal-gen workflow

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
activities
ecrrepository

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