types

Documentation

Index

• func ToYAML(ctx context.Context, workflow *Workflow) ([]byte, error)
• type Action
  • func ParseActionID(actionID string) (Action, error)
  • func (o Action) IntegrationVerbString() string
  • func (o Action) String() string
• type RandomScheduleOpt
• type RateLimit
• type RateLimitDuration
• type RateLimitOpts
• type Workflow
  • func DefaultLoader() []*Workflow
  • func ParseYAML(ctx context.Context, yamlBytes []byte) (Workflow, error)
  • func ReadAllValidFilesInDir(filedir string) ([]*Workflow, error)
  • func ReadHatchetYAMLFileBytes(filepath string) (*Workflow, error)
• type WorkflowConcurrency
• type WorkflowConcurrencyLimitStrategy
• type WorkflowEvent
• type WorkflowJob
• type WorkflowOnCron
• type WorkflowStep
• type WorkflowTriggers

Functions

func ToYAML

func ToYAML(ctx context.Context, workflow *Workflow) ([]byte, error)

Types

type Action

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
}

func ParseActionID

func ParseActionID(actionID string) (Action, error)

ParseActionID parses an action ID into its constituent parts.

func (Action) IntegrationVerbString

func (o Action) IntegrationVerbString() string

func (Action) String

func (o Action) String() string

type RandomScheduleOpt

type RandomScheduleOpt string

const (
	Random15Min  RandomScheduleOpt = "random_15_min"
	RandomHourly RandomScheduleOpt = "random_hourly"
	RandomDaily  RandomScheduleOpt = "random_daily"
)

type RateLimit

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

type RateLimitDuration

type RateLimitDuration string

const (
	Second RateLimitDuration = "second"
	Minute RateLimitDuration = "minute"
	Hour   RateLimitDuration = "hour"
)

type RateLimitOpts

type RateLimitOpts struct {
	Max      int
	Duration RateLimitDuration
}

type Workflow

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"`
}

func DefaultLoader

func DefaultLoader() []*Workflow

func ParseYAML

func ParseYAML(ctx context.Context, yamlBytes []byte) (Workflow, error)

func ReadAllValidFilesInDir

func ReadAllValidFilesInDir(filedir string) ([]*Workflow, error)

func ReadHatchetYAMLFileBytes

func ReadHatchetYAMLFileBytes(filepath string) (*Workflow, error)

ReadHatchetYAMLFileBytes reads a given YAML file from a filepath and return the parsed workflow file

type WorkflowConcurrency

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

	MaxRuns int32 `yaml:"maxRuns,omitempty"`

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

type WorkflowConcurrencyLimitStrategy

type WorkflowConcurrencyLimitStrategy string

const (
	CancelInProgress WorkflowConcurrencyLimitStrategy = "CANCEL_IN_PROGRESS"
	GroupRoundRobin  WorkflowConcurrencyLimitStrategy = "GROUP_ROUND_ROBIN"
)

type WorkflowEvent

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

type WorkflowJob

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

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

type WorkflowOnCron

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

type WorkflowStep

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

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