Documentation ¶
Index ¶
- type APIError
- type Condition
- type CreateDagResponse
- type Dag
- type DagDetail
- type DagListItem
- type DagLogGridItem
- type DagLogResponse
- type DagSchedulerLogResponse
- func (m *DagSchedulerLogResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *DagSchedulerLogResponse) MarshalBinary() ([]byte, error)
- func (m *DagSchedulerLogResponse) UnmarshalBinary(b []byte) error
- func (m *DagSchedulerLogResponse) Validate(formats strfmt.Registry) error
- type DagStatus
- type DagStatusDetail
- type DagStatusFile
- type DagStatusWithDetails
- type DagStepLogResponse
- type GetDagDetailsResponse
- type HandlerOn
- type ListDagsResponse
- type PostDagActionResponse
- type RepeatPolicy
- type Schedule
- type SearchDagsMatchItem
- type SearchDagsResponse
- type SearchDagsResultItem
- type StatusDetail
- type StatusNode
- type StepObject
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type APIError ¶
type APIError struct { // detailed message // Required: true DetailedMessage *string `json:"detailedMessage"` // message // Required: true Message *string `json:"message"` }
APIError Api error
swagger:model ApiError
func (*APIError) ContextValidate ¶
ContextValidate validates this Api error based on context it is used
func (*APIError) MarshalBinary ¶
MarshalBinary interface implementation
func (*APIError) UnmarshalBinary ¶
UnmarshalBinary interface implementation
type Condition ¶
type Condition struct { // condition Condition string `json:"Condition,omitempty"` // expected Expected string `json:"Expected,omitempty"` }
Condition condition
swagger:model condition
func (*Condition) ContextValidate ¶
ContextValidate validates this condition based on context it is used
func (*Condition) MarshalBinary ¶
MarshalBinary interface implementation
func (*Condition) UnmarshalBinary ¶
UnmarshalBinary interface implementation
type CreateDagResponse ¶
type CreateDagResponse struct { // dag ID // Required: true DagID *string `json:"DagID"` }
CreateDagResponse create dag response
swagger:model createDagResponse
func (*CreateDagResponse) ContextValidate ¶
ContextValidate validates this create dag response based on context it is used
func (*CreateDagResponse) MarshalBinary ¶
func (m *CreateDagResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*CreateDagResponse) UnmarshalBinary ¶
func (m *CreateDagResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type Dag ¶
type Dag struct { // default params // Required: true DefaultParams *string `json:"DefaultParams"` // description // Required: true Description *string `json:"Description"` // group // Required: true Group *string `json:"Group"` // name // Required: true Name *string `json:"Name"` // params // Required: true Params []string `json:"Params"` // schedule // Required: true Schedule []*Schedule `json:"Schedule"` // tags // Required: true Tags []string `json:"Tags"` }
Dag dag
swagger:model dag
func (*Dag) ContextValidate ¶
ContextValidate validate this dag based on the context it is used
func (*Dag) MarshalBinary ¶
MarshalBinary interface implementation
func (*Dag) UnmarshalBinary ¶
UnmarshalBinary interface implementation
type DagDetail ¶
type DagDetail struct { // default params // Required: true DefaultParams *string `json:"DefaultParams"` // delay // Required: true Delay *int64 `json:"Delay"` // description // Required: true Description *string `json:"Description"` // env // Required: true Env []string `json:"Env"` // group // Required: true Group *string `json:"Group"` // handler on // Required: true HandlerOn *HandlerOn `json:"HandlerOn"` // hist retention days // Required: true HistRetentionDays *int64 `json:"HistRetentionDays"` // location // Required: true Location *string `json:"Location"` // log dir // Required: true LogDir *string `json:"LogDir"` // max active runs // Required: true MaxActiveRuns *int64 `json:"MaxActiveRuns"` // name // Required: true Name *string `json:"Name"` // params // Required: true Params []string `json:"Params"` // preconditions // Required: true Preconditions []*Condition `json:"Preconditions"` // schedule // Required: true Schedule []*Schedule `json:"Schedule"` // steps // Required: true Steps []*StepObject `json:"Steps"` // tags // Required: true Tags []string `json:"Tags"` }
DagDetail dag detail
swagger:model dagDetail
func (*DagDetail) ContextValidate ¶
ContextValidate validate this dag detail based on the context it is used
func (*DagDetail) MarshalBinary ¶
MarshalBinary interface implementation
func (*DagDetail) UnmarshalBinary ¶
UnmarshalBinary interface implementation
type DagListItem ¶
type DagListItem struct { // d a g // Required: true DAG *Dag `json:"DAG"` // dir // Required: true Dir *string `json:"Dir"` // error // Required: true Error *string `json:"Error"` // error t // Required: true ErrorT *string `json:"ErrorT"` // file // Required: true File *string `json:"File"` // status // Required: true Status *DagStatus `json:"Status"` // suspended // Required: true Suspended *bool `json:"Suspended"` }
DagListItem dag list item
swagger:model dagListItem
func (*DagListItem) ContextValidate ¶
ContextValidate validate this dag list item based on the context it is used
func (*DagListItem) MarshalBinary ¶
func (m *DagListItem) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DagListItem) UnmarshalBinary ¶
func (m *DagListItem) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DagLogGridItem ¶
type DagLogGridItem struct { // name // Required: true Name *string `json:"Name"` // vals // Required: true Vals []int64 `json:"Vals"` }
DagLogGridItem dag log grid item
swagger:model dagLogGridItem
func (*DagLogGridItem) ContextValidate ¶
ContextValidate validates this dag log grid item based on context it is used
func (*DagLogGridItem) MarshalBinary ¶
func (m *DagLogGridItem) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DagLogGridItem) UnmarshalBinary ¶
func (m *DagLogGridItem) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DagLogResponse ¶
type DagLogResponse struct { // grid data // Required: true GridData []*DagLogGridItem `json:"GridData"` // logs // Required: true Logs []*DagStatusFile `json:"Logs"` }
DagLogResponse dag log response
swagger:model dagLogResponse
func (*DagLogResponse) ContextValidate ¶
ContextValidate validate this dag log response based on the context it is used
func (*DagLogResponse) MarshalBinary ¶
func (m *DagLogResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DagLogResponse) UnmarshalBinary ¶
func (m *DagLogResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DagSchedulerLogResponse ¶
type DagSchedulerLogResponse struct { // content // Required: true Content *string `json:"Content"` // log file // Required: true LogFile *string `json:"LogFile"` }
DagSchedulerLogResponse dag scheduler log response
swagger:model dagSchedulerLogResponse
func (*DagSchedulerLogResponse) ContextValidate ¶
func (m *DagSchedulerLogResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validates this dag scheduler log response based on context it is used
func (*DagSchedulerLogResponse) MarshalBinary ¶
func (m *DagSchedulerLogResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DagSchedulerLogResponse) UnmarshalBinary ¶
func (m *DagSchedulerLogResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DagStatus ¶
type DagStatus struct { // finished at // Required: true FinishedAt *string `json:"FinishedAt"` // log // Required: true Log *string `json:"Log"` // name // Required: true Name *string `json:"Name"` // params // Required: true Params *string `json:"Params"` // pid // Required: true Pid *int64 `json:"Pid"` // request Id // Required: true RequestID *string `json:"RequestId"` // started at // Required: true StartedAt *string `json:"StartedAt"` // status // Required: true Status *int64 `json:"Status"` // status text // Required: true StatusText *string `json:"StatusText"` }
DagStatus dag status
swagger:model dagStatus
func (*DagStatus) ContextValidate ¶
ContextValidate validates this dag status based on context it is used
func (*DagStatus) MarshalBinary ¶
MarshalBinary interface implementation
func (*DagStatus) UnmarshalBinary ¶
UnmarshalBinary interface implementation
type DagStatusDetail ¶
type DagStatusDetail struct { // finished at // Required: true FinishedAt *string `json:"FinishedAt"` // log // Required: true Log *string `json:"Log"` // name // Required: true Name *string `json:"Name"` // nodes // Required: true Nodes []*StatusNode `json:"Nodes"` // on cancel // Required: true OnCancel *StatusNode `json:"OnCancel"` // on exit // Required: true OnExit *StatusNode `json:"OnExit"` // on failure // Required: true OnFailure *StatusNode `json:"OnFailure"` // on success // Required: true OnSuccess *StatusNode `json:"OnSuccess"` // params // Required: true Params *string `json:"Params"` // pid // Required: true Pid *int64 `json:"Pid"` // request Id // Required: true RequestID *string `json:"RequestId"` // started at // Required: true StartedAt *string `json:"StartedAt"` // status // Required: true Status *int64 `json:"Status"` // status text // Required: true StatusText *string `json:"StatusText"` }
DagStatusDetail dag status detail
swagger:model dagStatusDetail
func (*DagStatusDetail) ContextValidate ¶
ContextValidate validate this dag status detail based on the context it is used
func (*DagStatusDetail) MarshalBinary ¶
func (m *DagStatusDetail) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DagStatusDetail) UnmarshalBinary ¶
func (m *DagStatusDetail) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DagStatusFile ¶
type DagStatusFile struct { // file // Required: true File *string `json:"File"` // status Status *DagStatusDetail `json:"Status,omitempty"` }
DagStatusFile dag status file
swagger:model dagStatusFile
func (*DagStatusFile) ContextValidate ¶
ContextValidate validate this dag status file based on the context it is used
func (*DagStatusFile) MarshalBinary ¶
func (m *DagStatusFile) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DagStatusFile) UnmarshalBinary ¶
func (m *DagStatusFile) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DagStatusWithDetails ¶
type DagStatusWithDetails struct { // d a g // Required: true DAG *DagDetail `json:"DAG"` // dir // Required: true Dir *string `json:"Dir"` // error // Required: true Error *string `json:"Error"` // error t // Required: true ErrorT *string `json:"ErrorT"` // file // Required: true File *string `json:"File"` // status // Required: true Status *DagStatusDetail `json:"Status"` // suspended // Required: true Suspended *bool `json:"Suspended"` }
DagStatusWithDetails dag status with details
swagger:model dagStatusWithDetails
func (*DagStatusWithDetails) ContextValidate ¶
ContextValidate validate this dag status with details based on the context it is used
func (*DagStatusWithDetails) MarshalBinary ¶
func (m *DagStatusWithDetails) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DagStatusWithDetails) UnmarshalBinary ¶
func (m *DagStatusWithDetails) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DagStepLogResponse ¶
type DagStepLogResponse struct { // content // Required: true Content *string `json:"Content"` // log file // Required: true LogFile *string `json:"LogFile"` // step // Required: true Step *StatusNode `json:"Step"` }
DagStepLogResponse dag step log response
swagger:model dagStepLogResponse
func (*DagStepLogResponse) ContextValidate ¶
ContextValidate validate this dag step log response based on the context it is used
func (*DagStepLogResponse) MarshalBinary ¶
func (m *DagStepLogResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DagStepLogResponse) UnmarshalBinary ¶
func (m *DagStepLogResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type GetDagDetailsResponse ¶
type GetDagDetailsResponse struct { // d a g // Required: true DAG *DagStatusWithDetails `json:"DAG"` // definition // Required: true Definition *string `json:"Definition"` // errors // Required: true Errors []string `json:"Errors"` // graph // Required: true Graph *string `json:"Graph"` // log data // Required: true LogData *DagLogResponse `json:"LogData"` // log Url // Required: true LogURL *string `json:"LogUrl"` // sc log // Required: true ScLog *DagSchedulerLogResponse `json:"ScLog"` // step log // Required: true StepLog *DagStepLogResponse `json:"StepLog"` // tab // Required: true Tab *string `json:"Tab"` // title // Required: true Title *string `json:"Title"` }
GetDagDetailsResponse get dag details response
swagger:model getDagDetailsResponse
func (*GetDagDetailsResponse) ContextValidate ¶
ContextValidate validate this get dag details response based on the context it is used
func (*GetDagDetailsResponse) MarshalBinary ¶
func (m *GetDagDetailsResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*GetDagDetailsResponse) UnmarshalBinary ¶
func (m *GetDagDetailsResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type HandlerOn ¶
type HandlerOn struct { // cancel Cancel *StepObject `json:"Cancel,omitempty"` // exit Exit *StepObject `json:"Exit,omitempty"` // failure Failure *StepObject `json:"Failure,omitempty"` // success Success *StepObject `json:"Success,omitempty"` }
HandlerOn handler on
swagger:model handlerOn
func (*HandlerOn) ContextValidate ¶
ContextValidate validate this handler on based on the context it is used
func (*HandlerOn) MarshalBinary ¶
MarshalBinary interface implementation
func (*HandlerOn) UnmarshalBinary ¶
UnmarshalBinary interface implementation
type ListDagsResponse ¶
type ListDagsResponse struct { // d a gs // Required: true DAGs []*DagListItem `json:"DAGs"` // errors // Required: true Errors []string `json:"Errors"` // has error // Required: true HasError *bool `json:"HasError"` }
ListDagsResponse list dags response
swagger:model listDagsResponse
func (*ListDagsResponse) ContextValidate ¶
ContextValidate validate this list dags response based on the context it is used
func (*ListDagsResponse) MarshalBinary ¶
func (m *ListDagsResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ListDagsResponse) UnmarshalBinary ¶
func (m *ListDagsResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type PostDagActionResponse ¶
type PostDagActionResponse struct { // new dag ID NewDagID string `json:"NewDagID,omitempty"` }
PostDagActionResponse post dag action response
swagger:model postDagActionResponse
func (*PostDagActionResponse) ContextValidate ¶
ContextValidate validates this post dag action response based on context it is used
func (*PostDagActionResponse) MarshalBinary ¶
func (m *PostDagActionResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*PostDagActionResponse) UnmarshalBinary ¶
func (m *PostDagActionResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type RepeatPolicy ¶
type RepeatPolicy struct { // interval Interval int64 `json:"Interval,omitempty"` // repeat Repeat bool `json:"Repeat,omitempty"` }
RepeatPolicy repeat policy
swagger:model repeatPolicy
func (*RepeatPolicy) ContextValidate ¶
ContextValidate validates this repeat policy based on context it is used
func (*RepeatPolicy) MarshalBinary ¶
func (m *RepeatPolicy) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*RepeatPolicy) UnmarshalBinary ¶
func (m *RepeatPolicy) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type Schedule ¶
type Schedule struct { // expression // Required: true Expression *string `json:"Expression"` }
Schedule schedule
swagger:model schedule
func (*Schedule) ContextValidate ¶
ContextValidate validates this schedule based on context it is used
func (*Schedule) MarshalBinary ¶
MarshalBinary interface implementation
func (*Schedule) UnmarshalBinary ¶
UnmarshalBinary interface implementation
type SearchDagsMatchItem ¶
type SearchDagsMatchItem struct { // line Line string `json:"Line,omitempty"` // line number LineNumber int64 `json:"LineNumber,omitempty"` // start line StartLine int64 `json:"StartLine,omitempty"` }
SearchDagsMatchItem search dags match item
swagger:model searchDagsMatchItem
func (*SearchDagsMatchItem) ContextValidate ¶
ContextValidate validates this search dags match item based on context it is used
func (*SearchDagsMatchItem) MarshalBinary ¶
func (m *SearchDagsMatchItem) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*SearchDagsMatchItem) UnmarshalBinary ¶
func (m *SearchDagsMatchItem) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type SearchDagsResponse ¶
type SearchDagsResponse struct { // errors // Required: true Errors []string `json:"Errors"` // results // Required: true Results []*SearchDagsResultItem `json:"Results"` }
SearchDagsResponse search dags response
swagger:model searchDagsResponse
func (*SearchDagsResponse) ContextValidate ¶
ContextValidate validate this search dags response based on the context it is used
func (*SearchDagsResponse) MarshalBinary ¶
func (m *SearchDagsResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*SearchDagsResponse) UnmarshalBinary ¶
func (m *SearchDagsResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type SearchDagsResultItem ¶
type SearchDagsResultItem struct { // d a g DAG *Dag `json:"DAG,omitempty"` // matches Matches []*SearchDagsMatchItem `json:"Matches"` // name Name string `json:"Name,omitempty"` }
SearchDagsResultItem search dags result item
swagger:model searchDagsResultItem
func (*SearchDagsResultItem) ContextValidate ¶
ContextValidate validate this search dags result item based on the context it is used
func (*SearchDagsResultItem) MarshalBinary ¶
func (m *SearchDagsResultItem) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*SearchDagsResultItem) UnmarshalBinary ¶
func (m *SearchDagsResultItem) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type StatusDetail ¶
type StatusDetail struct { // finished at FinishedAt string `json:"FinishedAt,omitempty"` // log Log string `json:"Log,omitempty"` // name Name string `json:"Name,omitempty"` // nodes Nodes []*StatusNode `json:"Nodes"` // on cancel OnCancel *StatusNode `json:"OnCancel,omitempty"` // on exit OnExit *StatusNode `json:"OnExit,omitempty"` // on failure OnFailure *StatusNode `json:"OnFailure,omitempty"` // on success OnSuccess *StatusNode `json:"OnSuccess,omitempty"` // params Params string `json:"Params,omitempty"` // pid Pid int64 `json:"Pid,omitempty"` // request Id RequestID string `json:"RequestId,omitempty"` // started at StartedAt string `json:"StartedAt,omitempty"` // status Status int64 `json:"Status,omitempty"` // status text StatusText string `json:"StatusText,omitempty"` }
StatusDetail status detail
swagger:model statusDetail
func (*StatusDetail) ContextValidate ¶
ContextValidate validate this status detail based on the context it is used
func (*StatusDetail) MarshalBinary ¶
func (m *StatusDetail) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*StatusDetail) UnmarshalBinary ¶
func (m *StatusDetail) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type StatusNode ¶
type StatusNode struct { // done count // Required: true DoneCount *int64 `json:"DoneCount"` // error // Required: true Error *string `json:"Error"` // finished at // Required: true FinishedAt *string `json:"FinishedAt"` // log // Required: true Log *string `json:"Log"` // retry count // Required: true RetryCount *int64 `json:"RetryCount"` // started at // Required: true StartedAt *string `json:"StartedAt"` // status // Required: true Status *int64 `json:"Status"` // status text // Required: true StatusText *string `json:"StatusText"` // step // Required: true Step *StepObject `json:"Step"` }
StatusNode status node
swagger:model statusNode
func (*StatusNode) ContextValidate ¶
ContextValidate validate this status node based on the context it is used
func (*StatusNode) MarshalBinary ¶
func (m *StatusNode) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*StatusNode) UnmarshalBinary ¶
func (m *StatusNode) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type StepObject ¶
type StepObject struct { // args // Required: true Args []string `json:"Args"` // cmd with args // Required: true CmdWithArgs *string `json:"CmdWithArgs"` // command // Required: true Command *string `json:"Command"` // depends // Required: true Depends []string `json:"Depends"` // description // Required: true Description *string `json:"Description"` // dir // Required: true Dir *string `json:"Dir"` // mail on error // Required: true MailOnError *bool `json:"MailOnError"` // name // Required: true Name *string `json:"Name"` // output // Required: true Output *string `json:"Output"` // preconditions // Required: true Preconditions []*Condition `json:"Preconditions"` // repeat policy // Required: true RepeatPolicy *RepeatPolicy `json:"RepeatPolicy"` // script // Required: true Script *string `json:"Script"` // stderr // Required: true Stderr *string `json:"Stderr"` // stdout // Required: true Stdout *string `json:"Stdout"` // variables // Required: true Variables []string `json:"Variables"` }
StepObject step object
swagger:model stepObject
func (*StepObject) ContextValidate ¶
ContextValidate validate this step object based on the context it is used
func (*StepObject) MarshalBinary ¶
func (m *StepObject) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*StepObject) UnmarshalBinary ¶
func (m *StepObject) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
Source Files ¶
- api_error.go
- condition.go
- create_dag_response.go
- dag.go
- dag_detail.go
- dag_list_item.go
- dag_log_grid_item.go
- dag_log_response.go
- dag_scheduler_log_response.go
- dag_status.go
- dag_status_detail.go
- dag_status_file.go
- dag_status_with_details.go
- dag_step_log_response.go
- get_dag_details_response.go
- handler_on.go
- list_dags_response.go
- post_dag_action_response.go
- repeat_policy.go
- schedule.go
- search_dags_match_item.go
- search_dags_response.go
- search_dags_result_item.go
- status_detail.go
- status_node.go
- step_object.go