activities

package
v1.2.2 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 2025 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExecuteSignalWithStart

func ExecuteSignalWithStart(
	ctx workflow.Context,
	params SignalWithStartActivityParams,
) error

ExecuteSignalWithStart is a wrapper for the SignalWithStartActivity execution.

Types

type Activities

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

Activities represents common activities that can be used by many workflows.

func NewActivities

func NewActivities(temporal temporalclient.Client) *Activities

NewActivities will create new common activities.

func (*Activities) SignalWithStartActivity

func (a *Activities) SignalWithStartActivity(
	ctx context.Context,
	params SignalWithStartActivityParams,
) (SignalWithStartActivityResults, error)

SignalWithStartActivity is an activity that will signal a workflow and start if before if it does not exist.

type SignalWithStartActivityParams

type SignalWithStartActivityParams struct {
	SignalName     string
	SignalParams   any
	WorkflowID     string
	WorkflowName   string
	WorkflowParams any
	TaskQueue      string
}

SignalWithStartActivityParams is the params for the SignalWithStartActivity activity.

type SignalWithStartActivityResults

type SignalWithStartActivityResults struct{}

SignalWithStartActivityResults is the results from the SignalWithStartActivity activity.

Jump to

Keyboard shortcuts

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