workflow

package
v0.71.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 19, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var WorkflowFS embed.FS
View Source
var WorkflowPathURI = "/v1/api/endly/workflow/{ProjectID}"

Functions

func DefineWorkflowComponent

func DefineWorkflowComponent(ctx context.Context, srv *datly.Service) error

Types

type AssetView

type AssetView struct {
	Id            string  `sqlx:"ID"`
	Location      string  `sqlx:"LOCATION"`
	Description   *string `sqlx:"DESCRIPTION"`
	WorkflowId    string  `sqlx:"WORKFLOW_ID"`
	IsDir         *int    `sqlx:"IS_DIR"`
	Template      *string `sqlx:"TEMPLATE"`
	InstanceIndex *int    `sqlx:"INSTANCE_INDEX"`
	InstanceTag   *string `sqlx:"INSTANCE_TAG"`
	Position      *int    `sqlx:"POSITION"`
	Format        *string `sqlx:"FORMAT"`
	Codec         *string `sqlx:"CODEC"`
}

type TaskView

type TaskView struct {
	Id            string  `sqlx:"ID"`
	WorkflowId    string  `sqlx:"WORKFLOW_ID"`
	ParentId      *string `sqlx:"PARENT_ID"`
	Position      *int    `sqlx:"POSITION"`
	Tag           string  `sqlx:"TAG"`
	Init          *string `jsonx:"inline" sqlx:"INIT"`
	Post          *string `jsonx:"inline" sqlx:"POST"`
	Description   *string `sqlx:"DESCRIPTION"`
	WhenExpr      *string `sqlx:"WHEN_EXPR"`
	ExitExpr      *string `sqlx:"EXIT_EXPR"`
	OnError       *string `sqlx:"ON_ERROR"`
	Deferred      *string `sqlx:"DEFERRED"`
	Service       *string `sqlx:"SERVICE"`
	Action        *string `sqlx:"ACTION"`
	Input         *string `sqlx:"INPUT"`
	InputUri      *string `sqlx:"INPUT_URI"`
	Async         *int    `sqlx:"ASYNC"`
	SkipExpr      *string `sqlx:"SKIP_EXPR"`
	IsTemplate    *int    `sqlx:"IS_TEMPLATE"`
	SubPath       *string `sqlx:"SUB_PATH"`
	RangeExpr     *string `sqlx:"RANGE_EXPR"`
	Data          *string `jsonx:"inline" sqlx:"DATA"`
	Variables     *string `jsonx:"inline" sqlx:"VARIABLES"`
	Extracts      *string `jsonx:"inline" sqlx:"EXTRACTS"`
	SleepTimeMs   *int    `sqlx:"SLEEP_TIME_MS"`
	ThinkTimeMs   *int    `sqlx:"THINK_TIME_MS"`
	Logging       *int    `sqlx:"LOGGING"`
	RepeatRun     *int    `sqlx:"REPEAT_RUN"`
	InstanceIndex *int    `sqlx:"INSTANCE_INDEX"`
	InstanceTag   *string `sqlx:"INSTANCE_TAG"`
}

type WorkflowInput

type WorkflowInput struct {
	ProjectID string            `parameter:",kind=path,in=ProjectID"`
	ID        []string          `parameter:",kind=form,in=id" predicate:"in,group=0,w,ID"`
	Has       *WorkflowInputHas `setMarker:"true" format:"-" sqlx:"-" diff:"-"`
}

type WorkflowInputHas

type WorkflowInputHas struct {
	ProjectID bool
	ID        bool
}

type WorkflowOutput

type WorkflowOutput struct {
	Data []*WorkflowView `parameter:",kind=output,in=view" view:"workflow" sql:"uri=workflow/workflow_view.sql"`
}

type WorkflowView

type WorkflowView struct {
	Id            string       `sqlx:"ID"`
	ParentId      *string      `sqlx:"PARENT_ID"`
	Position      *int         `sqlx:"POSITION"`
	Revision      *string      `sqlx:"REVISION"`
	Uri           string       `sqlx:"URI"`
	ProjectId     string       `sqlx:"PROJECT_ID"`
	Name          string       `sqlx:"NAME"`
	Init          *string      `jsonx:"inline" sqlx:"INIT"`
	Post          *string      `jsonx:"inline" sqlx:"POST"`
	Template      *string      `sqlx:"TEMPLATE"`
	InstanceIndex *int         `sqlx:"INSTANCE_INDEX"`
	InstanceTag   *string      `sqlx:"INSTANCE_TAG"`
	Task          []*TaskView  `on:"Id:ID=WorkflowId:WORKFLOW_ID" sql:"uri=workflow/task.sql"`
	Asset         []*AssetView `on:"Id:ID=WorkflowId:WORKFLOW_ID" sql:"uri=workflow/asset.sql"`
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL