handlers

Documentation

Index

• func NewDAG(engineFactory engine.Factory) server.New
• type DAGHandler
  • func (h *DAGHandler) Configure(api *operations.DaguAPI)
  • func (h *DAGHandler) Create(params operations.CreateDagParams) (*models.CreateDagResponse, *response.CodedError)
  • func (h *DAGHandler) Delete(params operations.DeleteDagParams) *response.CodedError
  • func (h *DAGHandler) GetDetail(params operations.GetDagDetailsParams) (*models.GetDagDetailsResponse, *response.CodedError)
  • func (h *DAGHandler) GetList(_ operations.ListDagsParams) (*models.ListDagsResponse, *response.CodedError)
  • func (h *DAGHandler) PostAction(params operations.PostDagActionParams) (*models.PostDagActionResponse, *response.CodedError)
  • func (h *DAGHandler) Search(params operations.SearchDagsParams) (*models.SearchDagsResponse, *response.CodedError)

Functions

func NewDAG

func NewDAG(engineFactory engine.Factory) server.New

Types

type DAGHandler

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

func (*DAGHandler) Configure

func (h *DAGHandler) Configure(api *operations.DaguAPI)

func (*DAGHandler) Create

func (h *DAGHandler) Create(params operations.CreateDagParams) (*models.CreateDagResponse, *response.CodedError)

func (*DAGHandler) Delete

func (h *DAGHandler) Delete(params operations.DeleteDagParams) *response.CodedError

func (*DAGHandler) GetDetail

func (h *DAGHandler) GetDetail(params operations.GetDagDetailsParams) (*models.GetDagDetailsResponse, *response.CodedError)

func (*DAGHandler) GetList

func (h *DAGHandler) GetList(_ operations.ListDagsParams) (*models.ListDagsResponse, *response.CodedError)

func (*DAGHandler) PostAction

func (h *DAGHandler) PostAction(params operations.PostDagActionParams) (*models.PostDagActionResponse, *response.CodedError)

func (*DAGHandler) Search

func (h *DAGHandler) Search(params operations.SearchDagsParams) (*models.SearchDagsResponse, *response.CodedError)