response

Documentation

Index

• func NewAPIError(message, detailedMessage string) *models.APIError
• func ToCondition(cond *dag.Condition) *models.Condition
• func ToDAG(d *dag.DAG) *models.Dag
• func ToDagDetail(d *dag.DAG) *models.DagDetail
• func ToDagListItem(s *persistence.DAGStatus) *models.DagListItem
• func ToDagLogGridItem(name string, vals []scheduler.NodeStatus) *models.DagLogGridItem
• func ToDagLogResponse(logs []*domain.StatusFile) *models.DagLogResponse
• func ToDagSchedulerLogResponse(logFile, content string) *models.DagSchedulerLogResponse
• func ToDagStatus(s *domain.Status) *models.DagStatus
• func ToDagStatusDetail(s *domain.Status) *models.DagStatusDetail
• func ToDagStatusFile(status *domain.StatusFile) *models.DagStatusFile
• func ToDagStatusWithDetails(dagStatus *persistence.DAGStatus) *models.DagStatusWithDetails
• func ToDagStepLogResponse(logFile, content string, step *domain.Node) *models.DagStepLogResponse
• func ToGetDagDetailResponse(workflowStatus *persistence.DAGStatus, tab string) *models.GetDagDetailsResponse
• func ToHandlerOn(handlerOn dag.HandlerOn) *models.HandlerOn
• func ToListDagResponse(dagStatusList []*persistence.DAGStatus, errs []string, hasError bool) *models.ListDagsResponse
• func ToNode(node *domain.Node) *models.StatusNode
• func ToRepeatPolicy(repeatPolicy dag.RepeatPolicy) *models.RepeatPolicy
• func ToSchedule(s *dag.Schedule) *models.Schedule
• func ToSearchDAGsMatchItem(match *grep.Match) *models.SearchDagsMatchItem
• func ToSearchDAGsResponse(ret []*persistence.GrepResult, errs []string) *models.SearchDagsResponse
• func ToSearchDAGsResultItem(workflow *persistence.GrepResult) *models.SearchDagsResultItem
• func ToStepObject(step *dag.Step) *models.StepObject
• type CodedError
  • func NewBadRequestError(err error) *CodedError
  • func NewCodedError(code int, apiError *models.APIError) *CodedError
  • func NewInternalError(err error) *CodedError
  • func NewNotFoundError(err error) *CodedError

Functions

func NewAPIError

func NewAPIError(message, detailedMessage string) *models.APIError

func ToCondition

func ToCondition(cond *dag.Condition) *models.Condition

func ToDAG

func ToDAG(d *dag.DAG) *models.Dag

func ToDagDetail

func ToDagDetail(d *dag.DAG) *models.DagDetail

func ToDagListItem

func ToDagListItem(s *persistence.DAGStatus) *models.DagListItem

func ToDagLogGridItem

func ToDagLogGridItem(name string, vals []scheduler.NodeStatus) *models.DagLogGridItem

func ToDagLogResponse

func ToDagLogResponse(logs []*domain.StatusFile) *models.DagLogResponse

func ToDagSchedulerLogResponse

func ToDagSchedulerLogResponse(logFile, content string) *models.DagSchedulerLogResponse

func ToDagStatus

func ToDagStatus(s *domain.Status) *models.DagStatus

func ToDagStatusDetail

func ToDagStatusDetail(s *domain.Status) *models.DagStatusDetail

func ToDagStatusFile

func ToDagStatusFile(status *domain.StatusFile) *models.DagStatusFile

func ToDagStatusWithDetails

func ToDagStatusWithDetails(dagStatus *persistence.DAGStatus) *models.DagStatusWithDetails

func ToDagStepLogResponse

func ToDagStepLogResponse(logFile, content string, step *domain.Node) *models.DagStepLogResponse

func ToGetDagDetailResponse

func ToGetDagDetailResponse(
	workflowStatus *persistence.DAGStatus,
	tab string,
) *models.GetDagDetailsResponse

func ToHandlerOn

func ToHandlerOn(handlerOn dag.HandlerOn) *models.HandlerOn

func ToListDagResponse

func ToListDagResponse(
	dagStatusList []*persistence.DAGStatus,
	errs []string,
	hasError bool,
) *models.ListDagsResponse

func ToNode

func ToNode(node *domain.Node) *models.StatusNode

func ToRepeatPolicy

func ToRepeatPolicy(repeatPolicy dag.RepeatPolicy) *models.RepeatPolicy

func ToSchedule

func ToSchedule(s *dag.Schedule) *models.Schedule

func ToSearchDAGsMatchItem

func ToSearchDAGsMatchItem(match *grep.Match) *models.SearchDagsMatchItem

func ToSearchDAGsResponse

func ToSearchDAGsResponse(ret []*persistence.GrepResult, errs []string) *models.SearchDagsResponse

func ToSearchDAGsResultItem

func ToSearchDAGsResultItem(workflow *persistence.GrepResult) *models.SearchDagsResultItem

func ToStepObject

func ToStepObject(step *dag.Step) *models.StepObject

Types

type CodedError

type CodedError struct {
	Code     int
	APIError *models.APIError
}

func NewBadRequestError

func NewBadRequestError(err error) *CodedError

func NewCodedError

func NewCodedError(code int, apiError *models.APIError) *CodedError

func NewInternalError

func NewInternalError(err error) *CodedError

func NewNotFoundError

func NewNotFoundError(err error) *CodedError