workflowstep

Documentation

Index

• func GetStateFromSteps[T kclient.Object](ctx context.Context, client kclient.Client, generation int64, steps ...T) (lastRun string, output string, _ types.WorkflowState, _ error)
• func NewStep(namespace, workflowExecutionName, afterStepName string, generation int64, ...) *v1.WorkflowStep
• func WorkflowStepMatchesStepID(step *v1.WorkflowStep, stepID string) bool
• type Handler
  • func New(invoker *invoke.Invoker) *Handler
  • func (h *Handler) Preconditions(next router.Handler) router.Handler
  • func (h *Handler) RunIf(req router.Request, resp router.Response) (err error)
  • func (h *Handler) RunInvoke(req router.Request, resp router.Response) error
  • func (h *Handler) RunSubflow(req router.Request, resp router.Response) error
  • func (h *Handler) RunWhile(req router.Request, _ router.Response) (err error)

Functions

func GetStateFromSteps

func GetStateFromSteps[T kclient.Object](ctx context.Context, client kclient.Client, generation int64, steps ...T) (lastRun string, output string, _ types.WorkflowState, _ error)

func NewStep

func NewStep(namespace, workflowExecutionName, afterStepName string, generation int64, step types.Step) *v1.WorkflowStep

func WorkflowStepMatchesStepID

func WorkflowStepMatchesStepID(step *v1.WorkflowStep, stepID string) bool

Types

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

func New

func New(invoker *invoke.Invoker) *Handler

func (*Handler) Preconditions

func (h *Handler) Preconditions(next router.Handler) router.Handler

func (*Handler) RunIf

func (h *Handler) RunIf(req router.Request, resp router.Response) (err error)

func (*Handler) RunInvoke

func (h *Handler) RunInvoke(req router.Request, resp router.Response) error

func (*Handler) RunSubflow

func (h *Handler) RunSubflow(req router.Request, resp router.Response) error

func (*Handler) RunWhile

func (h *Handler) RunWhile(req router.Request, _ router.Response) (err error)