v1_workflows

package
v0.67.0 Latest Latest
Warning

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

Go to latest
Published: Jun 27, 2025 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const SimpleEvent = "simple-event:create"

> Run workflow on event

Variables

This section is empty.

Functions

func LowerWithFilter

> Declare with filter

func NonRetryableError

NonRetryableError returns a workflow which throws a non-retryable error

func OnCron

> Workflow Definition Cron Trigger

func RateLimit

> Dynamic Rate Limit

func Retries

Simple retries example that always fails

func RetriesWithCount

Retries example that succeeds after a certain number of retries

func StaticRateLimit

> Static Rate Limit

func WithBackoff

Retries example with simple backoff (no configuration in this API version)

Types

type AlwaysFailsOutput

type AlwaysFailsOutput struct {
	TransformedMessage string
}

type BackoffInput

type BackoffInput struct{}

type BackoffResult

type BackoffResult struct{}

type CancellationInput

type CancellationInput struct{}

type CancellationResult

type CancellationResult struct {
	Completed bool
}

type ChildInput

type ChildInput struct {
	N int `json:"n"`
}

type ConcurrencyInput

type ConcurrencyInput struct {
	Message string
	Tier    string
	Account string
}

type DagInput

type DagInput struct {
	Message string
}

type DagResult

type DagResult struct {
	Step1 SimpleOutput
	Step2 SimpleOutput
}

type DagWithConditionsInput

type DagWithConditionsInput struct {
	Message string
}

type DagWithConditionsResult

type DagWithConditionsResult struct {
	Step1 SimpleOutput
	Step2 SimpleOutput
}

type DurableEventInput

type DurableEventInput struct {
	Message string
}

type DurableEventOutput

type DurableEventOutput struct {
	Data EventData
}

type DurableSleepInput

type DurableSleepInput struct {
	Message string
}

type DurableSleepOutput

type DurableSleepOutput struct {
	TransformedMessage string
}

type EventData

type EventData struct {
	Message string
}

type EventInput

type EventInput struct {
	Message string
}

type JobResult

type JobResult struct {
	TransformedMessage string `json:"TransformedMessage"`
}

type LowerTaskOutput

type LowerTaskOutput struct {
	TransformedMessage string
}

type NonRetryableInput

type NonRetryableInput struct{}

type NonRetryableResult

type NonRetryableResult struct{}

type OnCronInput

type OnCronInput struct {
	Message string `json:"Message"`
}

type OnCronOutput

type OnCronOutput struct {
	Job JobResult `json:"job"`
}

type OnFailureOutput

type OnFailureOutput struct {
	FailureRan bool
}

type OnFailureSuccessResult

type OnFailureSuccessResult struct {
	AlwaysFails AlwaysFailsOutput
}

type ParentInput

type ParentInput struct {
	N int `json:"n"`
}

type PriorityInput

type PriorityInput struct {
	UserId string `json:"userId"`
}

type PriorityOutput

type PriorityOutput struct {
	TransformedMessage string `json:"TransformedMessage"`
}

type RandomSum

type RandomSum struct {
	Sum int `json:"sum"`
}

RandomSum represents the output of the sum task

type RateLimitInput

type RateLimitInput struct {
	UserId string `json:"userId"`
}

type RateLimitOutput

type RateLimitOutput struct {
	TransformedMessage string `json:"TransformedMessage"`
}

type Result

type Result struct {
	Step PriorityOutput
}

type RetriesInput

type RetriesInput struct{}

type RetriesResult

type RetriesResult struct{}

type RetriesWithCountInput

type RetriesWithCountInput struct{}

type RetriesWithCountResult

type RetriesWithCountResult struct {
	Message string `json:"message"`
}

type SimpleInput

type SimpleInput struct {
	Message string
}

type SimpleOutput

type SimpleOutput struct {
	Step int
}

type SimpleResult

type SimpleResult struct {
	TransformedMessage string
}

type StepOutput

type StepOutput struct {
	RandomNumber int `json:"randomNumber"`
}

StepOutput represents the output of most tasks in this workflow

type StickyDagResult

type StickyDagResult struct {
	StickyTask1 StickyResult `json:"sticky-task-1"`
	StickyTask2 StickyResult `json:"sticky-task-2"`
}

type StickyInput

type StickyInput struct{}

type StickyResult

type StickyResult struct {
	Result string `json:"result"`
}

type SumOutput

type SumOutput struct {
	Result int `json:"result"`
}

type TaskConditionWorkflowResult

type TaskConditionWorkflowResult struct {
	Start        StepOutput `json:"start"`
	WaitForSleep StepOutput `json:"waitForSleep"`
	WaitForEvent StepOutput `json:"waitForEvent"`
	SkipOnEvent  StepOutput `json:"skipOnEvent"`
	LeftBranch   StepOutput `json:"leftBranch"`
	RightBranch  StepOutput `json:"rightBranch"`
	Sum          RandomSum  `json:"sum"`
}

TaskConditionWorkflowResult represents the aggregate output of all tasks

type TimeoutInput

type TimeoutInput struct{}

type TimeoutResult

type TimeoutResult struct {
	Completed bool
}

type TransformedOutput

type TransformedOutput struct {
	TransformedMessage string
}

type UpperTaskOutput

type UpperTaskOutput struct {
	TransformedMessage string
}

type ValueOutput

type ValueOutput struct {
	Value int `json:"value"`
}

Jump to

Keyboard shortcuts

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