worker

package

v0.19.921 Latest Latest Go to latest Published: May 7, 2026 License: AGPL-3.0 Imports: 43 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 OrgEventLoopRequest
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 OrgEventLoopRequest ¶

type OrgEventLoopRequest struct {
	OrgID       string
	SandboxMode bool
}

type Params ¶

type Params struct {
	fx.In

	Cfg       *internal.Config
	V         *validator.Validate
	MW        metrics.Writer
	EVClient  teventloop.Client
	Analytics temporalanalytics.Writer
	Features  *features.Features
}

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
	SharedWkflows    *workflows.Workflows
	SharedActivities *workflows.Activities
	WKflows          *Workflows
	Acts             *activities.Activities
	L                *zap.Logger
	LC               fx.Lifecycle
	Interceptors     []interceptor.WorkerInterceptor `group:"interceptors"`
	QueueClient      *queueclient.Client
}

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-v2 workflow

func (*Workflows) Delete ¶

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

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

func (*Workflows) Deprovision ¶

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

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

func (*Workflows) EnableFeatureFlags ¶

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

@temporal-gen-v2 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) ForceDelete ¶

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

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

func (*Workflows) ForceDeprovision ¶

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

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

func (*Workflows) ForceSandboxMode ¶

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

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

func (*Workflows) InviteAccepted ¶

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

inviteAccepted: is called when an invite is accepted

@temporal-gen-v2 workflow

func (*Workflows) InviteUser ¶

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

inviteCreated: is called when a new org invite is created_by

@temporal-gen-v2 workflow

func (*Workflows) ListWorkflowFns ¶ added in v0.19.850

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

ListWorkflowFns returns the list of workflow functions for registration

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) Reprovision ¶

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

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

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) RestartRunners ¶

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

@temporal-gen-v2 workflow @execution-timeout 30m @task-timeout 10s

func (*Workflows) StageSeed ¶

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

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

Directories ¶

Path	Synopsis
activities
iam
roles

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

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

Types ¶

type OrgEventLoopRequest ¶

type Params ¶

type Worker ¶

func New ¶

type WorkerParams ¶

type Workflows ¶

func NewWorkflows ¶

func (*Workflows) All ¶

func (*Workflows) Created ¶

func (*Workflows) Delete ¶

func (*Workflows) Deprovision ¶

func (*Workflows) EnableFeatureFlags ¶

func (*Workflows) EventLoop ¶

func (*Workflows) ForceDelete ¶

func (*Workflows) ForceDeprovision ¶

func (*Workflows) ForceSandboxMode ¶

func (*Workflows) InviteAccepted ¶

func (*Workflows) InviteUser ¶

func (*Workflows) ListWorkflowFns ¶ added in v0.19.850

func (*Workflows) Provision ¶

func (*Workflows) Reprovision ¶

func (*Workflows) Restart ¶

func (*Workflows) RestartRunners ¶

func (*Workflows) StageSeed ¶

Source Files ¶

Directories ¶