workflowexecution

Documentation

Index

• type CollectionDeleteRequest
  • func (r *CollectionDeleteRequest) Validate() error
• type CollectionGetRequest
  • func (r *CollectionGetRequest) SetStream(stream runtime.RequestUnidiStream)
• type CollectionGetResponse
• type DeleteRequest
  • func (r *DeleteRequest) Validate() error
• type DeleteResponse
• type GetRequest
• type GetResponse
• type Handler
  • func Handle(mc model.ClientSet, kc *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) Delete(req DeleteRequest) error
  • func (h Handler) Get(req GetRequest) (GetResponse, error)
  • func (Handler) Kind() string
  • func (h Handler) RouteRerunRequest(req RouteRerunRequest) error
  • func (h Handler) RouteStopRequest(req RouteStopRequest) error
  • func (h Handler) SubResourceHandlers() []runtime.IResourceHandler
• type RouteRerunRequest
  • func (r *RouteRerunRequest) Validate() error
• type RouteStopRequest
  • func (r *RouteStopRequest) Validate() error
• type UpdateRequest
  • func (r *UpdateRequest) Validate() error

Types

type CollectionDeleteRequest

type CollectionDeleteRequest struct {
	model.WorkflowExecutionDeleteInputs
}

func (*CollectionDeleteRequest) Validate

func (r *CollectionDeleteRequest) Validate() error

type CollectionGetRequest

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

	runtime.RequestCollection[
		predicate.WorkflowExecution, workflowexecution.OrderOption,
	] `query:",inline"`

	Stream *runtime.RequestUnidiStream

	ID object.ID `query:"id"`
}

func (*CollectionGetRequest) SetStream

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

type CollectionGetResponse

type CollectionGetResponse []*model.WorkflowExecutionOutput

type DeleteRequest

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

func (*DeleteRequest) Validate

func (r *DeleteRequest) Validate() error

type DeleteResponse

type DeleteResponse = *model.WorkflowExecutionDeleteInput

type GetRequest

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

type GetResponse

type GetResponse = *model.WorkflowExecutionOutput

type Handler

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

func Handle

func Handle(mc model.ClientSet, kc *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) Delete

func (h Handler) Delete(req DeleteRequest) error

func (Handler) Get

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

func (Handler) Kind

func (Handler) Kind() string

func (Handler) RouteRerunRequest

func (h Handler) RouteRerunRequest(req RouteRerunRequest) error

func (Handler) RouteStopRequest

func (h Handler) RouteStopRequest(req RouteStopRequest) error

RouteStopRequest terminates the workflow execution.

func (Handler) SubResourceHandlers

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

type RouteRerunRequest

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

func (*RouteRerunRequest) Validate

func (r *RouteRerunRequest) Validate() error

type RouteStopRequest

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

func (*RouteStopRequest) Validate

func (r *RouteStopRequest) Validate() error

type UpdateRequest

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

	Status string `json:"status"`
}

func (*UpdateRequest) Validate

func (r *UpdateRequest) Validate() error