Help us shape the future of Go! Take the 2026 Go Developer Survey

workflows

package
v0.19.1252 Latest Latest
Warning

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

Go to latest
Published: Oct 19, 2026 License: AGPL-3.0 Imports: 18 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
	StatusActivities          *statusactivities.Activities
	ControlPlaneActivities    *controlplanejob.Activities
	Activities                *activities.Activities
	QueueActivities           *queueactivities.Activities
	Enqueuer                  *enqueuer.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
	ControlPlaneActs *controlplanejob.Activities

	// queues / signals
	QueueActs                 *queueactivities.Activities
	QueueClient               *queueclient.Client
	Enqueuer                  *enqueuer.Enqueuer
	EmitterActs               *emitteractivities.Activities
	HandlerActs               *handleractivities.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
	EnqueuerWorkflows     *enqueuer.Workflows
	HandlerWorkflows      *handler.Workflows
	ControlPlaneWorkflows *controlplanejob.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