types

type Action struct {
	// Required. The service that this belongs to
	Service string

	// Required. The verb to perform.
	Verb string

	// Optional. A way to unique identify the step.
	Subresource string
}

type RandomScheduleOpt string

type RateLimit struct {
	Units int    `yaml:"units,omitempty"`
	Key   string `yaml:"key,omitempty"`
}

type RateLimitDuration string

type RateLimitOpts struct {
	Max      int
	Duration RateLimitDuration
}

type Workflow struct {
	Name string `yaml:"name,omitempty"`

	Concurrency *WorkflowConcurrency `yaml:"concurrency,omitempty"`

	Version string `yaml:"version,omitempty"`

	Description string `yaml:"description,omitempty"`

	Triggers WorkflowTriggers `yaml:"triggers"`

	Jobs map[string]WorkflowJob `yaml:"jobs"`

	OnFailureJob *WorkflowJob `yaml:"onFailureJob,omitempty"`
}

type WorkflowConcurrency struct {
	ActionID string `yaml:"action,omitempty"`

	MaxRuns int32 `yaml:"maxRuns,omitempty"`

	LimitStrategy WorkflowConcurrencyLimitStrategy `yaml:"limitStrategy,omitempty"`
}

type WorkflowConcurrencyLimitStrategy string

type WorkflowEvent struct {
	Name string `yaml:"name,omitempty"`
}

type WorkflowJob struct {
	Description string `yaml:"description,omitempty"`

	Steps []WorkflowStep `yaml:"steps"`
}

type WorkflowOnCron struct {
	Schedule string `yaml:"schedule,omitempty"`
}

type WorkflowStep struct {
	Name       string                 `yaml:"name,omitempty"`
	ID         string                 `yaml:"id,omitempty"`
	ActionID   string                 `yaml:"action"`
	Timeout    string                 `yaml:"timeout,omitempty"`
	With       map[string]interface{} `yaml:"with,omitempty"`
	Parents    []string               `yaml:"parents,omitempty"`
	Retries    int                    `yaml:"retries"`
	RateLimits []RateLimit            `yaml:"rateLimits,omitempty"`
}

type WorkflowTriggers struct {
	Events    []string    `yaml:"events,omitempty"`
	Cron      []string    `yaml:"crons,omitempty"`
	Schedules []time.Time `yaml:"schedules,omitempty"`
}