dsl

type Duration time.Duration

type Edge struct {
	From string `yaml:"from"`
	To   string `yaml:"to"`
}

type Flow struct {
	Version string `yaml:"version"`
	Name    string `yaml:"name"`
	Nodes   []Node `yaml:"nodes"`
	Edges   []Edge `yaml:"edges"`
	// contains filtered or unexported fields
}

type Node struct {
	ID   string `yaml:"id"`
	Type string `yaml:"type"`

	// task
	Invoker string       `yaml:"invoker"` // invocation kind; defaults to DefaultInvoker
	Target  string       `yaml:"target"`  // invoker-specific target; defaults to Subject
	Subject string       `yaml:"subject"` // nats-task subject (alias for Target)
	Timeout Duration     `yaml:"timeout"`
	Retry   *RetryPolicy `yaml:"retry"`

	// fanout
	Branches []string `yaml:"branches"`

	// fanin
	WaitFor    []string `yaml:"wait_for"`
	JoinPolicy string   `yaml:"join_policy"`

	// choice
	Rules []Rule `yaml:"rules"`

	// signal
	SignalName string `yaml:"signal_name"`
	OnTimeout  string `yaml:"on_timeout"`
}

type RetryPolicy struct {
	MaxAttempts int    `yaml:"max_attempts"`
	Backoff     string `yaml:"backoff"` // "exponential" | "linear" | "fixed" | "" (default fixed)
}

type Rule struct {
	When    string `yaml:"when"`
	Default bool   `yaml:"default"`
	To      string `yaml:"to"`
}