graph

type Action struct {
	Service string      `json:"service,omitempty" yaml:"service,omitempty"`
	Method  string      `json:"method,omitempty" yaml:"method,omitempty"`
	Input   interface{} `json:"input,omitempty" yaml:"input,omitempty"`
}

type AwaitSpec struct {
	Mode    string `json:"mode,omitempty" yaml:"mode,omitempty"`       // all|first|anyError (defaults to all)
	Timeout string `json:"timeout,omitempty" yaml:"timeout,omitempty"` // duration string e.g. "10m"
	Group   string `json:"on,omitempty" yaml:"on,omitempty"`           // named emit group (optional)
	Merge   string `json:"merge,omitempty" yaml:"merge,omitempty"`     // append|replace
}

type EmitSpec struct {
	ForEach string `json:"forEach,omitempty" yaml:"forEach,omitempty"` // expression resolving to slice/array
	As      string `json:"as,omitempty" yaml:"as,omitempty"`           // loop variable name
	Task    *Task  `json:"task,omitempty" yaml:"task,omitempty"`       // template task
}

type Retry struct {
	Type       string  `json:"type,omitempty" yaml:"type,omitempty"` // fixed, exponential, none
	MaxRetries int     `json:"maxRetries,omitempty" yaml:"maxRetries,omitempty"`
	Delay      string  `json:"delay,omitempty" yaml:"delay,omitempty"`           // base delay (duration string)
	Multiplier float64 `json:"multiplier,omitempty" yaml:"multiplier,omitempty"` // exponential multiplier (>1)
	MaxDelay   string  `json:"maxDelay,omitempty" yaml:"maxDelay,omitempty"`
}

type Task struct {
	ID         string           `json:"id,omitempty" yaml:"id,omitempty"`
	TypeName   string           `json:"typeName,omitempty" yaml:"typeName,omitempty"`
	Name       string           `json:"name,omitempty" yaml:"name,omitempty"`
	Namespace  string           `json:"namespace,omitempty" yaml:"namespace,omitempty"`
	Init       state.Parameters `json:"init,omitempty" yaml:"init,omitempty"`
	When       string           `json:"when,omitempty" yaml:"when,omitempty"`
	Action     *Action          `json:"action,omitempty" yaml:"action,omitempty"`
	DependsOn  []string         `json:"dependsOn,omitempty" yaml:"dependsOn,omitempty"`
	Tasks      []*Task          `json:"tasks,omitempty" yaml:"tasks,omitempty"`
	Post       state.Parameters `json:"post,omitempty" yaml:"post,omitempty"`
	Template   *Template        `json:"template,omitempty" yaml:"template,omitempty"`
	Goto       []*Transition    `json:"goto,omitempty" yaml:"goto,omitempty"`
	Async      bool             `json:"async,omitempty" yaml:"async,omitempty"`
	AutoPause  *bool            `json:"autoPause,omitempty" yaml:"autoPause,omitempty"`
	Retry      *Retry           `json:"retry,omitempty" yaml:"retry,omitempty"`
	ScheduleIn string           `json:"scheduleIn,omitempty" yaml:"scheduleIn,omitempty"`
	// Async fan-out/fan-in extensions
	Emit  *EmitSpec  `json:"emit,omitempty" yaml:"emit,omitempty"`
	Await *AwaitSpec `json:"await,omitempty" yaml:"await,omitempty"`
}

type Template struct {
	Task     *Task             `json:"task,omitempty" yaml:"task,omitempty"`
	Selector *state.Parameters `json:"selector,omitempty" yaml:"selector,omitempty"`
}

type Transition struct {
	When string `json:"when,omitempty" yaml:"when,omitempty"`
	Task string `json:"task,omitempty" yaml:"task,omitempty"`
}