Documentation
¶
Index ¶
- Constants
- func Child(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[ChildInput, ChildResult]
- func Child1(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
- func Child2(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
- func Child3(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
- func Child4(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
- func Child5(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
- func ConcurrencyRoundRobin(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[ConcurrencyInput, ConcurrencyResult]
- func DagWorkflow(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[any, DagResult]
- func DeepParent(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
- func DurableSleep(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DurableSleepInput, DurableSleepOutput]
- func Lower(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[EventInput, LowerResult]
- func OnFailure(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[any, OnFailureSuccessResult]
- func Parent(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[ParentInput, ParentResult]
- func Simple(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[SimpleInput, SimpleResult]
- func Upper(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[EventInput, UpperResult]
- type AlwaysFailsOutput
- type ChildInput
- type ChildResult
- type ConcurrencyInput
- type ConcurrencyResult
- type DagResult
- type DeepInput
- type DeepResult
- type DurableSleepInput
- type DurableSleepOutput
- type EventInput
- type LowerOutput
- type LowerResult
- type LowerTaskOutput
- type OnFailureOutput
- type OnFailureSuccessResult
- type ParentInput
- type ParentResult
- type SimpleInput
- type SimpleOutput
- type SimpleResult
- type SleepOutput
- type SumOutput
- type TransformedOutput
- type TransformerOutput
- type UpperResult
- type UpperTaskOutput
- type ValueOutput
Constants ¶
View Source
const SimpleEvent = "simple-event:create"
Variables ¶
This section is empty.
Functions ¶
func Child ¶
func Child(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[ChildInput, ChildResult]
func Child1 ¶
func Child1(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
func Child2 ¶
func Child2(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
func Child3 ¶
func Child3(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
func Child4 ¶
func Child4(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
func Child5 ¶
func Child5(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
func ConcurrencyRoundRobin ¶
func ConcurrencyRoundRobin(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[ConcurrencyInput, ConcurrencyResult]
func DagWorkflow ¶
func DagWorkflow(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[any, DagResult]
func DeepParent ¶
func DeepParent(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DeepInput, DeepResult]
func DurableSleep ¶
func DurableSleep(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[DurableSleepInput, DurableSleepOutput]
func Lower ¶
func Lower(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[EventInput, LowerResult]
func OnFailure ¶
func OnFailure(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[any, OnFailureSuccessResult]
func Parent ¶
func Parent(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[ParentInput, ParentResult]
func Simple ¶
func Simple(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[SimpleInput, SimpleResult]
func Upper ¶
func Upper(hatchet *v1.HatchetClient) workflow.WorkflowDeclaration[EventInput, UpperResult]
Types ¶
type AlwaysFailsOutput ¶
type AlwaysFailsOutput struct {
TransformedMessage string
}
type ChildInput ¶
type ChildInput struct {
N int `json:"n"`
}
type ChildResult ¶
type ChildResult struct {
One ValueOutput `json:"one"`
}
type ConcurrencyInput ¶
type ConcurrencyResult ¶
type ConcurrencyResult struct {
ToLower TransformedOutput
}
type DagResult ¶
type DagResult struct {
Step1 SimpleOutput
Step2 SimpleOutput
}
type DeepResult ¶
type DeepResult struct {
Transformer TransformerOutput
}
type DurableSleepInput ¶
type DurableSleepInput struct {
Message string
}
type DurableSleepOutput ¶
type DurableSleepOutput struct {
Sleep SleepOutput
}
type EventInput ¶
type EventInput struct {
Message string
}
type LowerOutput ¶
type LowerOutput struct {
TransformedMessage string
}
type LowerResult ¶
type LowerResult struct {
Lower LowerTaskOutput
}
type LowerTaskOutput ¶
type LowerTaskOutput struct {
TransformedMessage string
}
type OnFailureOutput ¶
type OnFailureOutput struct {
FailureRan bool
}
type OnFailureSuccessResult ¶
type OnFailureSuccessResult struct {
AlwaysFails AlwaysFailsOutput
}
type ParentInput ¶
type ParentInput struct {
N int `json:"n"`
}
type ParentResult ¶
type ParentResult struct {
Sum *SumOutput `json:"sum,omitempty"`
}
type SimpleInput ¶
type SimpleInput struct {
Message string
}
type SimpleOutput ¶
type SimpleOutput struct {
Step int
}
type SimpleResult ¶
type SimpleResult struct {
ToLower LowerOutput
}
type SleepOutput ¶
type SleepOutput struct {
TransformedMessage string
}
type TransformedOutput ¶
type TransformedOutput struct {
TransformedMessage string
}
type TransformerOutput ¶
type TransformerOutput struct {
Sum int
}
type UpperResult ¶
type UpperResult struct {
Upper UpperTaskOutput
}
type UpperTaskOutput ¶
type UpperTaskOutput struct {
TransformedMessage string
}
type ValueOutput ¶
type ValueOutput struct {
Value int `json:"value"`
}
Click to show internal directories.
Click to hide internal directories.