workflows

package
v0.19.903 Latest Latest
Warning

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

Go to latest
Published: Apr 30, 2026 License: AGPL-3.0 Imports: 17 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
	EmitterActivities         *emitteractivities.Activities
	HandlerActivities         *handleractivities.Activities
	QueueClient               *queueclient.Client
	EmitterClient             *emitterclient.Client
	SignalLifecycleActivities *signal.SignalLifecycleActivities
}

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
	EmitterActs               *emitteractivities.Activities
	HandlerActs               *handleractivities.Activities
	SignalsActivities         *signalsactivities.Activities
	SignalLifecycleActivities *signal.SignalLifecycleActivities
	EmitterClient             *emitterclient.Client
}

type WorkflowParams

type WorkflowParams struct {
	fx.In

	JobWorkflows          *job.Workflows
	WorkflowWorkflows     *workflow.Workflows
	QueueWorkflows        *queue.Workflows
	QueueEmitterWorkflows *queueemitter.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