workflows

package
v0.19.857 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Activities

type Activities struct {
	JobActivities     *jobactivities.Activities
	FlowActivities    *flowactivities.Activities
	SignalsActivities *signalsactivities.Activities
	StatusActivities  *statusactivities.Activities
	Activities        *activities.Activities
	QueueActivities   *queueactivities.Activities
	HandlerActivities *handleractivities.Activities
	QueueClient       *queueclient.Client
}

func NewActivities

func NewActivities(params Params) *Activities

func (*Activities) AllActivities

func (a *Activities) AllActivities() []any

type Params

type Params struct {
	fx.In

	Activities *activities.Activities
	// runner jobs
	JobActivities *jobactivities.Activities
	// workflows
	FlowActivities *flowactivities.Activities
	// shared statuses tooling
	StatusActivities *statusactivities.Activities

	// queues / signals
	QueueActs         *queueactivities.Activities
	QueueClient       *queueclient.Client
	HandlerActs       *handleractivities.Activities
	SignalsActivities *signalsactivities.Activities
}

type WorkflowParams

type WorkflowParams struct {
	fx.In

	JobWorkflows      *job.Workflows
	WorkflowWorkflows *workflow.Workflows
	QueueWorkflows    *queue.Workflows
	HandlerWorkflows  *handler.Workflows
}

type Workflows

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

func NewWorkflows

func NewWorkflows(params WorkflowParams) *Workflows

func (*Workflows) AllWorkflows

func (w *Workflows) AllWorkflows() []interface{}

Directories

Path Synopsis
job

Jump to

Keyboard shortcuts

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