workflow

Documentation

Index

• type CollectionDeleteRequest
• type CollectionGetRequest
  • func (r *CollectionGetRequest) SetStream(stream runtime.RequestUnidiStream)
• type CollectionGetResponse
• type CreateRequest
  • func (r *CreateRequest) Validate() error
• type CreateResponse
• type DeleteRequest
  • func (r *DeleteRequest) Validate() error
• type DeleteResponse
• type GetRequest
• type GetResponse
• type Handler
  • func Handle(mc model.ClientSet, k8sConfig *rest.Config, wc pkgworkflow.Client) Handler
  • func (h Handler) CollectionDelete(req CollectionDeleteRequest) error
  • func (h Handler) CollectionGet(req CollectionGetRequest) (CollectionGetResponse, int, error)
  • func (h Handler) Create(req CreateRequest) (CreateResponse, error)
  • func (h Handler) Delete(req DeleteRequest) (err error)
  • func (h Handler) Get(req GetRequest) (GetResponse, error)
  • func (Handler) Kind() string
  • func (h Handler) RouteGetLatestExecutionRequest(req RouteGetLatestExecutionRequest) (RouteGetLatestExecutionResponse, error)
  • func (h Handler) RouteRun(req RouteRunRequest) (RouteRunResponse, error)
  • func (h Handler) SubResourceHandlers() []runtime.IResourceHandler
  • func (h Handler) Update(req UpdateRequest) error
• type RouteGetLatestExecutionRequest
• type RouteGetLatestExecutionResponse
• type RouteRunRequest
  • func (r *RouteRunRequest) Validate() error
• type RouteRunResponse
• type ServiceCreateMeta
• type UpdateRequest
  • func (r *UpdateRequest) Validate() error
• type WorkflowStepApprovalValidator
  • func (s *WorkflowStepApprovalValidator) Set(input *model.WorkflowStepCreateInput)
  • func (s *WorkflowStepApprovalValidator) Validate(ctx *gin.Context, client *model.Client) error
• type WorkflowStepServiceValidator
  • func (s *WorkflowStepServiceValidator) Set(input *model.WorkflowStepCreateInput)
  • func (s *WorkflowStepServiceValidator) Validate(ctx *gin.Context, client *model.Client) error
• type WorkflowStepValidator

Types

type CollectionDeleteRequest

type CollectionDeleteRequest = model.WorkflowDeleteInputs

type CollectionGetRequest

type CollectionGetRequest struct {
	model.WorkflowQueryInputs `path:",inline"`

	runtime.RequestCollection[
		predicate.Workflow, workflow.OrderOption,
	] `query:",inline"`

	Stream *runtime.RequestUnidiStream
}

func (*CollectionGetRequest) SetStream

func (r *CollectionGetRequest) SetStream(stream runtime.RequestUnidiStream)

type CollectionGetResponse

type CollectionGetResponse = []*model.WorkflowOutput

type CreateRequest

type CreateRequest struct {
	model.WorkflowCreateInput `path:",inline" json:",inline"`
}

func (*CreateRequest) Validate

func (r *CreateRequest) Validate() error

type CreateResponse

type CreateResponse = *model.WorkflowOutput

type DeleteRequest

type DeleteRequest struct {
	model.WorkflowQueryInput `path:",inline"`
}

func (*DeleteRequest) Validate

func (r *DeleteRequest) Validate() error

type DeleteResponse

type DeleteResponse = *model.WorkflowDeleteInput

type GetRequest

type GetRequest struct {
	model.WorkflowQueryInput `path:",inline"`
}

type GetResponse

type GetResponse = *model.WorkflowOutput

type Handler

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

func Handle

func Handle(mc model.ClientSet, k8sConfig *rest.Config, wc pkgworkflow.Client) Handler

func (Handler) CollectionDelete

func (h Handler) CollectionDelete(req CollectionDeleteRequest) error

func (Handler) CollectionGet

func (h Handler) CollectionGet(req CollectionGetRequest) (CollectionGetResponse, int, error)

func (Handler) Create

func (h Handler) Create(req CreateRequest) (CreateResponse, error)

func (Handler) Delete

func (h Handler) Delete(req DeleteRequest) (err error)

func (Handler) Get

func (h Handler) Get(req GetRequest) (GetResponse, error)

func (Handler) Kind

func (Handler) Kind() string

func (Handler) RouteGetLatestExecutionRequest

func (h Handler) RouteGetLatestExecutionRequest(req RouteGetLatestExecutionRequest) (
	RouteGetLatestExecutionResponse,
	error,
)

func (Handler) RouteRun

func (h Handler) RouteRun(req RouteRunRequest) (RouteRunResponse, error)

func (Handler) SubResourceHandlers

func (h Handler) SubResourceHandlers() []runtime.IResourceHandler

func (Handler) Update

func (h Handler) Update(req UpdateRequest) error

type RouteGetLatestExecutionRequest

type RouteGetLatestExecutionRequest struct {
	model.WorkflowQueryInput `path:",inline"`
	// contains filtered or unexported fields
}

type RouteGetLatestExecutionResponse

type RouteGetLatestExecutionResponse = *model.WorkflowExecutionOutput

type RouteRunRequest

type RouteRunRequest struct {
	model.WorkflowQueryInput `path:",inline"`

	Variables   map[string]string `json:"variables,omitempty"`
	Description string            `json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteRunRequest) Validate

func (r *RouteRunRequest) Validate() error

type RouteRunResponse

type RouteRunResponse = *model.WorkflowExecutionOutput

type ServiceCreateMeta

type ServiceCreateMeta struct {
	Project     *model.ProjectQueryInput     `json:"project"`
	Environment *model.EnvironmentQueryInput `json:"environment"`
}

type UpdateRequest

type UpdateRequest struct {
	model.WorkflowUpdateInput `path:",inline" json:",inline"`
}

func (*UpdateRequest) Validate

func (r *UpdateRequest) Validate() error

type WorkflowStepApprovalValidator

type WorkflowStepApprovalValidator struct {
	*model.WorkflowStepCreateInput
}

WorkflowStepApprovalValidator validates the attributes of an approval workflow step.

func (*WorkflowStepApprovalValidator) Set

func (s *WorkflowStepApprovalValidator) Set(input *model.WorkflowStepCreateInput)

func (*WorkflowStepApprovalValidator) Validate

func (s *WorkflowStepApprovalValidator) Validate(ctx *gin.Context, client *model.Client) error

type WorkflowStepServiceValidator

type WorkflowStepServiceValidator struct {
	*model.WorkflowStepCreateInput `path:",inline" json:",inline"`
}

WorkflowStepServiceValidator validates the attributes of a service workflow step.

func (*WorkflowStepServiceValidator) Set

func (s *WorkflowStepServiceValidator) Set(input *model.WorkflowStepCreateInput)

func (*WorkflowStepServiceValidator) Validate

func (s *WorkflowStepServiceValidator) Validate(ctx *gin.Context, client *model.Client) error

type WorkflowStepValidator

type WorkflowStepValidator interface {
	Set(*model.WorkflowStepCreateInput)
	// Validate validates the attributes of the workflow step.
	Validate(*gin.Context, *model.Client) error
}