worker

package
v0.19.921 Latest Latest
Warning

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

 Go to latest Published: May 7, 2026 License: AGPL-3.0 Imports: 53 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExecuteWorkflowIDCallback 

func ExecuteWorkflowIDCallback(req signals.RequestSignal) string

Types

type NuonDNSChart 

type NuonDNSChart struct {
	Enabled  bool   `mapstructure:"enabled,omitempty"`
	ID       string `mapstructure:"id,omitempty"`
	Chart    string `mapstructure:"chart,omitempty"`
	Revision string `mapstructure:"revision,omitempty"`
}

type NuonDNSDomain 

type NuonDNSDomain struct {
	ZoneID      string   `mapstructure:"zone_id,omitempty"`
	Name        string   `mapstructure:"name,omitempty"`
	Nameservers []string `mapstructure:"nameservers,omitempty"`
}

type NuonDNSOutputs 

type NuonDNSOutputs struct {
	Enabled bool `mapstructure:"enabled,omitempty"`

	PublicDomain   NuonDNSDomain `mapstructure:"public_domain,omitempty"`
	InternalDomain NuonDNSDomain `mapstructure:"internal_domain,omitempty"`

	ALBIngressController NuonDNSChart `mapstructure:"alb_ingress_controller,omitempty"`
	ExternalDNS          NuonDNSChart `mapstructure:"external_dns,omitempty"`
	CertManager          NuonDNSChart `mapstructure:"cert_manager,omitempty"`
	IngressNginx         NuonDNSChart `mapstructure:"ingress_nginx,omitempty"`
}

type NuonDNSSandboxOutputs 

type NuonDNSSandboxOutputs struct {
	DNS NuonDNSOutputs `mapstructure:"nuon_dns"`
}

type Params 

type Params struct {
	fx.In

	Cfg                 *internal.Config
	DB                  *gorm.DB `name:"psql"`
	V                   *validator.Validate
	MW                  metrics.Writer
	EVClient            teventloop.Client
	Analytics           temporalanalytics.Writer
	Templates           *cloudformation.Templates
	SandboxWorkflows    *sandbox.Workflows
	StackWorkflows      *stack.Workflows
	ComponentsWorkflows *components.Workflows
	ActionsWorkflows    *actions.Workflows
	StateWorkflows      *state.Workflows
	L                   *zap.Logger
}

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
	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 Params) (*Workflows, error)

func (*Workflows) ActionWorkflowTriggers 

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

func (*Workflows) All 

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

func (*Workflows) AwaitRunnerHealthy 

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

@temporal-gen-v2 workflow @execution-timeout 1h @task-timeout 30s

func (*Workflows) Created 

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

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

func (*Workflows) DeprovisionDNS 

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

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

func (*Workflows) DeprovisionRunner 

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

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

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

@temporal-gen-v2 workflow @execution-timeout 720h @id-generator ExecuteWorkflowIDCallback

func (*Workflows) Forget 

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

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

func (*Workflows) GenerateStateAdmin 

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

@temporal-gen-v2 workflow @execution-timeout 60m @task-timeout 30m @id-template {{.CallerID}}-generate-state-admin

func (*Workflows) PollDependencies 

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

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

func (*Workflows) ProvisionDNS 

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

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

func (*Workflows) ProvisionRunner 

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

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

func (*Workflows) ReprovisionRunner 

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

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

func (*Workflows) RerunFlow 

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

@temporal-gen-v2 workflow @execution-timeout 720h @id-template {{.Req.ID}}-execute-workflow-{{.Req.InstallWorkflowID}}-rerun-flow

func (*Workflows) Restarted 

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

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

func (*Workflows) SyncSecrets 

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

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

func (*Workflows) Updated 

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

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

func (*Workflows) WorkflowApproval 

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

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

func (*Workflows) WorkflowApproveAll 

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

@temporal-gen-v2 workflow @execution-timeout 1m @task-timeout 2m

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.