wes

type CancelRunRequest struct {
	RunID string
}

type CancelRunResponse struct {
	RunID string `json:"run_id"`
}

type Client interface {
	ListRuns(ctx context.Context, req *ListRunsRequest) (*ListRunsResponse, error)
	RunWorkflow(ctx context.Context, req *RunWorkflowRequest) (*RunWorkflowResponse, error)
	GetRunLog(ctx context.Context, req *GetRunLogRequest) (*GetRunLogResponse, error)
	CancelRun(ctx context.Context, req *CancelRunRequest) (*CancelRunResponse, error)
}

type ErrorResp struct {
	Msg        string `json:"msg"`
	StatusCode int32  `json:"status_code"`
}

type GetRunLogRequest struct {
	RunID string
}

type GetRunLogResponse struct {
	RunID    string                 `json:"run_id"`
	Request  RunRequest             `json:"request"`
	State    RunState               `json:"state"`
	RunLog   Log                    `json:"run_log"`
	TaskLogs []Log                  `json:"task_logs"`
	Outputs  map[string]interface{} `json:"outputs"`
}

type ListRunsRequest struct {
	PageSize  *int64
	PageToken *string
	TagFilter *string
}

type ListRunsResponse struct {
	Runs          []RunStatus `json:"runs"`
	NextPageToken string      `json:"next_page_token"`
}

type Log struct {
	Name      string   `json:"name"`
	Cmd       []string `json:"cmd"`
	StartTime *Time    `json:"start_time"`
	EndTime   *Time    `json:"end_time"`
	Stdout    string   `json:"stdout"`
	Stderr    string   `json:"stderr"`
	Log       string   `json:"log"`
	ExitCode  *int32   `json:"exit_code"`
}

type Options struct {
	Endpoint string
	BasePath string
	Timeout  int
	Retry    int
}

type RunRequest struct {
	WorkflowParams           map[string]interface{} `json:"workflow_params"`
	WorkflowType             string                 `json:"workflow_type"`
	WorkflowTypeVersion      string                 `json:"workflow_type_version"`
	Tags                     map[string]interface{} `json:"tags"`
	WorkflowEngineParameters map[string]interface{} `json:"workflow_engine_parameters"`
}

type RunState string

type RunStatus struct {
	RunID string   `json:"run_id"`
	State RunState `json:"state"`
}

type RunWorkflowRequest struct {
	RunRequest
	WorkflowAttachment map[string]string // the string is file path
}

type RunWorkflowResponse struct {
	RunID string `json:"run_id"`
}

type Time time.Time