common

func CheckPageRow ¶

func CheckPageRow(c echo.Context) (page int, row int, err error)

func GetHTTPRequest ¶ added in v0.4.1

func GetHTTPRequest(URL string, username string, password string) ([]byte, error)

func GetJSONRawBody ¶

func GetJSONRawBody(c echo.Context) (map[string]interface{}, error)

func IsNotFoundError ¶ added in v0.5.1

func IsNotFoundError(err error) bool

func ReturnErrorMsg ¶

func ReturnErrorMsg(c echo.Context, msg string) error

func ReturnInternalError ¶

func ReturnInternalError(c echo.Context, err error, reason string) error

func UrlDecode ¶ added in v0.2.1

func UrlDecode(text string) string

func UrlEncode ¶ added in v0.2.1

func UrlEncode(text string) string

func ValidateTaskClearOptions ¶ added in v0.3.1

func ValidateTaskClearOptions(opt model.TaskClearOption) error

func WorkflowDagID ¶ added in v0.5.1

func WorkflowDagID(workflow *model.Workflow) string

WorkflowDagID returns the Airflow DAG ID for the given workflow. workflow_key is used when set (stable runtime key); falls back to workflow.ID for legacy records.