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 BatchConfig struct {
	// MaxSize is the maximum number of items buffered before the batch is flushed.
	// Required, must be positive.
	MaxSize int32

	// MaxInterval is the maximum time to wait before flushing a partially-filled batch.
	// Optional; when unset, batches only flush on MaxSize.
	MaxInterval *time.Duration

	// GroupKey is a CEL expression evaluated against each item's input to partition items
	// into independent batches (e.g. "input.group"). Optional; when unset, all items
	// buffered for the task share a single batch.
	GroupKey *string

	// GroupMaxRuns limits the number of concurrent batches per group. Optional.
	GroupMaxRuns *int32

	// BroadcastOutput, when true, means the handler returns a single output value that is
	// broadcast as the result to every member of the batch, instead of a map keyed by
	// batch member id.
	BroadcastOutput bool
}

type Concurrency struct {
	Expression     string                            `yaml:"expression,omitempty"`
	MaxRuns        *int32                            `yaml:"maxRuns,omitempty"`
	LimitStrategy  *WorkflowConcurrencyLimitStrategy `yaml:"limitStrategy,omitempty"`
	Name           string                            `yaml:"name,omitempty"`
	IsTenantScoped bool                              `yaml:"isTenantScoped,omitempty"`

	// MaxRunsExpression is a CEL expression over task input computing the max runs for
	// that task's concurrency group; a group's effective limit is the value from its most
	// recently created task. Overrides MaxRuns per group.
	MaxRunsExpression *string `yaml:"maxRunsExpression,omitempty"`
}

type DefaultFilter struct {
	Expression string                 `json:"expression"`
	Scope      string                 `json:"scope"`
	Payload    map[string]interface{} `json:"payload,omitempty"`
}

type DesiredWorkerLabel struct {
	Value      any                    `yaml:"value,omitempty"`
	Required   bool                   `yaml:"required,omitempty"`
	Weight     int32                  `yaml:"weight,omitempty"`
	Comparator *WorkerLabelComparator `yaml:"comparator,omitempty"`
}

type RandomScheduleOpt string

type RateLimit struct {
	Key            string             `yaml:"key,omitempty"`
	KeyExpr        *string            `yaml:"keyExpr,omitempty"`
	Units          *int               `yaml:"units,omitempty"`
	UnitsExpr      *string            `yaml:"unitsExpr,omitempty"`
	LimitValueExpr *string            `yaml:"limitValueExpr,omitempty"`
	Duration       *RateLimitDuration `yaml:"duration,omitempty"`
}

type RateLimitDuration string

type RateLimitOpts struct {
	Max      int
	Duration RateLimitDuration
}

type StickyStrategy int32

type WorkerLabelComparator int32

type WorkflowConcurrency struct {
	Expression *string `yaml:"expression,omitempty"`

	MaxRuns int32 `yaml:"maxRuns,omitempty"`

	LimitStrategy WorkflowConcurrencyLimitStrategy `yaml:"limitStrategy,omitempty"`

	ActionID *string `yaml:"action,omitempty"`
}

type WorkflowConcurrencyLimitStrategy string

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

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