Documentation
¶
Index ¶
- func AssignFromHttpResponse(restyResp *resty.Response, resp interface{}) error
- func AssignToHttpRequest(req interface{}, restyRequest *resty.Request)
- type CancelRunRequest
- type CancelRunResponse
- type CancelSubmissionRequest
- type CancelSubmissionResponse
- type CheckSubmissionRequest
- type CheckSubmissionResponse
- type CreateSubmissionRequest
- type CreateSubmissionResponse
- type CreateWorkflowRequest
- type CreateWorkflowResponse
- type CreateWorkspaceRequest
- type CreateWorkspaceResponse
- type DataModel
- type DeleteDataModelRequest
- type DeleteDataModelResponse
- type DeleteSubmissionRequest
- type DeleteSubmissionResponse
- type DeleteWorkflowRequest
- type DeleteWorkflowResponse
- type DeleteWorkspaceRequest
- type DeleteWorkspaceResponse
- type Entity
- type ExposedOptions
- type GetDataModelRequest
- type GetDataModelResponse
- type GetWorkflowFileRequest
- type GetWorkflowFileResponse
- type GetWorkflowRequest
- type GetWorkflowResponse
- type GetWorkflowVersionRequest
- type GetWorkflowVersionResponse
- type Grid
- type ImportWorkspaceRequest
- type ImportWorkspaceResponse
- type InOutMaterial
- type ListAllDataModelRowIDsRequest
- type ListAllDataModelRowIDsResponse
- type ListDataModelRowsRequest
- type ListDataModelRowsResponse
- type ListDataModelsRequest
- type ListDataModelsResponse
- type ListRunsRequest
- type ListRunsResponse
- type ListSubmissionsRequest
- type ListSubmissionsResponse
- type ListTasksRequest
- type ListTasksResponse
- type ListWorkflowFilesRequest
- type ListWorkflowFilesResponse
- type ListWorkflowVersionsRequest
- type ListWorkflowVersionsResponse
- type ListWorkflowsRequest
- type ListWorkflowsResponse
- type ListWorkspacesRequest
- type ListWorkspacesResponse
- type NFSWorkspaceStorage
- type PatchDataModelRequest
- type PatchDataModelResponse
- type Row
- type RunItem
- type Status
- type SubmissionItem
- type TaskItem
- type UpdateWorkflowRequest
- type UpdateWorkflowResponse
- type UpdateWorkspaceRequest
- type UpdateWorkspaceResponse
- type WorkflowFile
- type WorkflowFileInfo
- type WorkflowItem
- type WorkflowParam
- type WorkflowVersion
- type WorkflowVersionBrief
- type WorkspaceItem
- type WorkspaceStorage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AssignFromHttpResponse ¶
func AssignToHttpRequest ¶
Types ¶
type CancelRunRequest ¶
type CancelRunRequest struct {
WorkspaceID string `path:"workspace_id"`
SubmissionID string `path:"submission_id"`
ID string `path:"id"`
}
func (*CancelRunRequest) ToGRPC ¶
func (req *CancelRunRequest) ToGRPC() *submissionproto.CancelRunRequest
type CancelRunResponse ¶
type CancelRunResponse struct {
}
func (*CancelRunResponse) FromGRPC ¶
func (resp *CancelRunResponse) FromGRPC(protoResp *submissionproto.CancelRunResponse)
type CancelSubmissionRequest ¶
type CancelSubmissionRequest struct {
WorkspaceID string `path:"workspace_id"`
ID string `path:"id"`
}
func (*CancelSubmissionRequest) ToGRPC ¶
func (req *CancelSubmissionRequest) ToGRPC() *submissionproto.CancelSubmissionRequest
type CancelSubmissionResponse ¶
type CancelSubmissionResponse struct {
}
func (*CancelSubmissionResponse) FromGRPC ¶
func (resp *CancelSubmissionResponse) FromGRPC(protoResp *submissionproto.CancelSubmissionResponse)
type CheckSubmissionRequest ¶
type CheckSubmissionRequest struct {
WorkspaceID string `path:"workspace_id"`
Name string `json:"name"`
}
func (*CheckSubmissionRequest) ToGRPC ¶
func (req *CheckSubmissionRequest) ToGRPC() *submissionproto.CheckSubmissionRequest
type CheckSubmissionResponse ¶
type CheckSubmissionResponse struct {
IsNameExist bool `json:"isNameExist"`
}
func (*CheckSubmissionResponse) FromGRPC ¶
func (resp *CheckSubmissionResponse) FromGRPC(protoResp *submissionproto.CheckSubmissionResponse)
type CreateSubmissionRequest ¶
type CreateSubmissionRequest struct {
WorkspaceID string `path:"workspace_id"`
Name string `json:"name"`
WorkflowID string `json:"workflowID"`
Description *string `json:"description"`
Type string `json:"type"`
Entity *Entity `json:"entity"`
ExposedOptions ExposedOptions `json:"exposedOptions"`
InOutMaterial *InOutMaterial `json:"inOutMaterial"`
}
func (*CreateSubmissionRequest) ToGRPC ¶
func (req *CreateSubmissionRequest) ToGRPC() *submissionproto.CreateSubmissionRequest
type CreateSubmissionResponse ¶
type CreateSubmissionResponse struct {
ID string `json:"id"`
}
func (*CreateSubmissionResponse) FromGRPC ¶
func (resp *CreateSubmissionResponse) FromGRPC(protoResp *submissionproto.CreateSubmissionResponse)
type CreateWorkflowRequest ¶
type CreateWorkflowRequest struct {
ID string `json:"id"`
WorkspaceID string `path:"workspace-id"`
Name string `json:"name" validate:"required,resName"`
Description string `json:"description" validate:"required,workspaceDesc"`
Language string `json:"language" validate:"required,oneof=WDL"`
Source string `json:"source" validate:"required,oneof=git"`
Url string `json:"url" validate:"required"`
Tag string `json:"tag" validate:"required"`
Token string `json:"token"`
MainWorkflowPath string `json:"mainWorkflowPath" validate:"required"`
}
func (*CreateWorkflowRequest) ToGRPC ¶
func (req *CreateWorkflowRequest) ToGRPC() *workspaceproto.CreateWorkflowRequest
type CreateWorkflowResponse ¶
type CreateWorkflowResponse struct {
ID string `json:"id"`
}
func (*CreateWorkflowResponse) FromGRPC ¶
func (resp *CreateWorkflowResponse) FromGRPC(protoResp *workspaceproto.CreateWorkflowResponse)
type CreateWorkspaceRequest ¶
type CreateWorkspaceRequest struct {
Name string `json:"name"`
Description string `json:"description"`
Storage *WorkspaceStorage `json:"storage"`
}
func (*CreateWorkspaceRequest) ToGRPC ¶
func (req *CreateWorkspaceRequest) ToGRPC() *workspaceproto.CreateWorkspaceRequest
type CreateWorkspaceResponse ¶
type CreateWorkspaceResponse struct {
Id string `json:"id"`
}
func (*CreateWorkspaceResponse) FromGRPC ¶
func (resp *CreateWorkspaceResponse) FromGRPC(protoResp *workspaceproto.CreateWorkspaceResponse)
type DeleteDataModelRequest ¶
type DeleteDataModelRequest struct {
ID string `path:"id"`
WorkspaceID string `path:"workspace_id"`
Headers []string `query:"headers,omitempty"`
RowIDs []string `query:"rowIDs,omitempty"`
}
func (*DeleteDataModelRequest) ToGRPC ¶
func (req *DeleteDataModelRequest) ToGRPC() *workspaceproto.DeleteDataModelRequest
type DeleteDataModelResponse ¶
type DeleteDataModelResponse struct{}
func (*DeleteDataModelResponse) FromGRPC ¶
func (resp *DeleteDataModelResponse) FromGRPC(protoResp *workspaceproto.DeleteDataModelResponse)
type DeleteSubmissionRequest ¶
type DeleteSubmissionRequest struct {
WorkspaceID string `path:"workspace_id"`
ID string `path:"id"`
}
func (*DeleteSubmissionRequest) ToGRPC ¶
func (req *DeleteSubmissionRequest) ToGRPC() *submissionproto.DeleteSubmissionRequest
type DeleteSubmissionResponse ¶
type DeleteSubmissionResponse struct {
}
func (*DeleteSubmissionResponse) FromGRPC ¶
func (resp *DeleteSubmissionResponse) FromGRPC(protoResp *submissionproto.DeleteSubmissionResponse)
type DeleteWorkflowRequest ¶
type DeleteWorkflowRequest struct {
ID string `path:"id"`
WorkspaceID string `path:"workspace-id"`
}
func (*DeleteWorkflowRequest) ToGRPC ¶
func (req *DeleteWorkflowRequest) ToGRPC() *workspaceproto.DeleteWorkflowRequest
type DeleteWorkflowResponse ¶
type DeleteWorkflowResponse struct {
}
func (*DeleteWorkflowResponse) FromGRPC ¶
func (resp *DeleteWorkflowResponse) FromGRPC(protoResp *workspaceproto.DeleteWorkflowResponse)
type DeleteWorkspaceRequest ¶
type DeleteWorkspaceRequest struct {
Id string `path:"id"`
}
func (*DeleteWorkspaceRequest) ToGRPC ¶
func (req *DeleteWorkspaceRequest) ToGRPC() *workspaceproto.DeleteWorkspaceRequest
type DeleteWorkspaceResponse ¶
type DeleteWorkspaceResponse struct {
}
func (*DeleteWorkspaceResponse) FromGRPC ¶
func (resp *DeleteWorkspaceResponse) FromGRPC(protoResp *workspaceproto.DeleteWorkspaceResponse)
type Entity ¶
type Entity struct {
DataModelID string `json:"dataModelID"`
DataModelRowIDs []string `json:"dataModelRowIDs"`
/** 输入配置,json 序列化后的 string
采用 json 序列化原因基于以下两点考虑:
- thrift/接口设计层面不允许 `Value` 类型不确定
- 在 inputs/outputs 层级进行序列化可使得 `bioos-server` 不处理 `Inputs`/`Outputs`(非 `this.xxx` 索引的输入) 就入库/提交给计算引擎,达到透传效果
*/
InputsTemplate string `json:"inputsTemplate"`
/** 输出配置,json 序列化后的 string
采用 json 序列化原因基于以下两点考虑:
- thrift/接口设计层面不允许 `Value` 类型不确定
- 在 inputs/outputs 层级进行序列化可使得 `bioos-server` 不处理 `Inputs`/`Outputs`(非 `this.xxx` 索引的输入) 就入库/提交给计算引擎,达到透传效果
*/
OutputsTemplate string `json:"outputsTemplate"`
}
type ExposedOptions ¶
type ExposedOptions struct {
ReadFromCache bool `json:"readFromCache"`
}
type GetDataModelRequest ¶
func (*GetDataModelRequest) ToGRPC ¶
func (req *GetDataModelRequest) ToGRPC() *workspaceproto.GetDataModelRequest
type GetDataModelResponse ¶
type GetDataModelResponse struct {
DataModel *DataModel `json:"dataModel,omitempty"`
Headers []string `json:"headers"`
}
func (*GetDataModelResponse) FromGRPC ¶
func (resp *GetDataModelResponse) FromGRPC(protoResp *workspaceproto.GetDataModelResponse)
type GetWorkflowFileRequest ¶
type GetWorkflowFileRequest struct {
ID string `path:"id"`
WorkspaceID string `path:"workspace-id"`
WorkflowID string `path:"workflow-id"`
}
func (*GetWorkflowFileRequest) ToGRPC ¶
func (req *GetWorkflowFileRequest) ToGRPC() *workspaceproto.GetWorkflowFileRequest
type GetWorkflowFileResponse ¶
type GetWorkflowFileResponse struct {
File *WorkflowFile `json:"file"`
}
func (*GetWorkflowFileResponse) FromGRPC ¶
func (resp *GetWorkflowFileResponse) FromGRPC(protoResp *workspaceproto.GetWorkflowFileResponse)
type GetWorkflowRequest ¶
func (*GetWorkflowRequest) ToGRPC ¶
func (req *GetWorkflowRequest) ToGRPC() *workspaceproto.GetWorkflowRequest
type GetWorkflowResponse ¶
type GetWorkflowResponse struct {
Workflow WorkflowItem `json:"workflow"`
}
func (*GetWorkflowResponse) FromGRPC ¶
func (resp *GetWorkflowResponse) FromGRPC(protoResp *workspaceproto.GetWorkflowResponse)
type GetWorkflowVersionRequest ¶
type GetWorkflowVersionRequest struct {
ID string `path:"id"`
WorkspaceID string `path:"workspace-id"`
WorkflowID string `path:"workflow-id"`
}
func (*GetWorkflowVersionRequest) ToGRPC ¶
func (req *GetWorkflowVersionRequest) ToGRPC() *workspaceproto.GetWorkflowVersionRequest
type GetWorkflowVersionResponse ¶
type GetWorkflowVersionResponse struct {
Version WorkflowVersion `json:"version"`
}
func (*GetWorkflowVersionResponse) FromGRPC ¶
func (resp *GetWorkflowVersionResponse) FromGRPC(protoResp *workspaceproto.GetWorkflowVersionResponse)
type ImportWorkspaceRequest ¶
type ImportWorkspaceResponse ¶
type ImportWorkspaceResponse struct {
Id string `json:"id"`
}
func (*ImportWorkspaceResponse) FromGRPC ¶
func (resp *ImportWorkspaceResponse) FromGRPC(protoResp *workspaceproto.ImportWorkspaceResponse)
type InOutMaterial ¶
type ListAllDataModelRowIDsRequest ¶
type ListAllDataModelRowIDsRequest struct {
WorkspaceID string `path:"workspace_id"`
ID string `path:"id"`
}
func (*ListAllDataModelRowIDsRequest) ToGRPC ¶
func (req *ListAllDataModelRowIDsRequest) ToGRPC() *workspaceproto.ListAllDataModelRowIDsRequest
type ListAllDataModelRowIDsResponse ¶
type ListAllDataModelRowIDsResponse struct {
RowIDs []string `json:"rowIDs"`
}
func (*ListAllDataModelRowIDsResponse) FromGRPC ¶
func (resp *ListAllDataModelRowIDsResponse) FromGRPC(protoResp *workspaceproto.ListAllDataModelRowIDsResponse)
type ListDataModelRowsRequest ¶
type ListDataModelRowsRequest struct {
WorkspaceID string `path:"workspace_id"`
ID string `path:"id"`
Page int32 `query:"page"`
Size int32 `query:"size"`
OrderBy string `query:"orderBy"`
SearchWord string `query:"searchWord"`
InSetIDs []string `query:"inSetIDs"`
RowIDs []string `query:"rowIDs"`
}
func (*ListDataModelRowsRequest) ToGRPC ¶
func (req *ListDataModelRowsRequest) ToGRPC() *workspaceproto.ListDataModelRowsRequest
type ListDataModelRowsResponse ¶
type ListDataModelRowsResponse struct {
Headers []string `json:"headers"`
Rows [][]string `json:"rows"`
Page int32 `json:"page"`
Size int32 `json:"size"`
Total int64 `json:"total"`
}
func (*ListDataModelRowsResponse) FromGRPC ¶
func (resp *ListDataModelRowsResponse) FromGRPC(protoResp *workspaceproto.ListDataModelRowsResponse)
type ListDataModelsRequest ¶
type ListDataModelsRequest struct {
WorkspaceID string `path:"workspace_id"`
Types []string `query:"types,omitempty"`
SearchWord string `query:"searchWord"`
IDs []string `query:"ids,omitempty"`
}
func (*ListDataModelsRequest) ToGRPC ¶
func (req *ListDataModelsRequest) ToGRPC() *workspaceproto.ListDataModelsRequest
type ListDataModelsResponse ¶
type ListDataModelsResponse struct {
Items []DataModel `json:"Items"`
}
func (*ListDataModelsResponse) BriefItems ¶
func (resp *ListDataModelsResponse) BriefItems() interface{}
func (*ListDataModelsResponse) FromGRPC ¶
func (resp *ListDataModelsResponse) FromGRPC(protoResp *workspaceproto.ListDataModelsResponse)
type ListRunsRequest ¶
type ListRunsRequest struct {
WorkspaceID string `path:"workspace_id"`
SubmissionID string `path:"submission_id"`
Page int `query:"page"`
Size int `query:"size"`
OrderBy string `query:"orderBy"`
SearchWord string `query:"searchWord"`
Status []string `query:"status,omitempty"`
IDs []string `query:"ids,omitempty"`
}
func (*ListRunsRequest) ToGRPC ¶
func (req *ListRunsRequest) ToGRPC() *submissionproto.ListRunsRequest
type ListRunsResponse ¶
type ListRunsResponse struct {
Page int `json:"page"`
Size int `json:"size"`
Total int `json:"total"`
Items []RunItem `json:"items"`
}
func (*ListRunsResponse) FromGRPC ¶
func (resp *ListRunsResponse) FromGRPC(protoResp *submissionproto.ListRunsResponse)
type ListSubmissionsRequest ¶
type ListSubmissionsRequest struct {
WorkspaceID string `path:"workspace_id"`
Page int `query:"page"`
Size int `query:"size"`
OrderBy string `query:"orderBy"`
SearchWord string `query:"searchWord"`
WorkflowID string `query:"workflowID,omitempty"`
Status []string `query:"status,omitempty"`
IDs []string `query:"ids,omitempty"`
}
func (*ListSubmissionsRequest) ToGRPC ¶
func (req *ListSubmissionsRequest) ToGRPC() *submissionproto.ListSubmissionsRequest
type ListSubmissionsResponse ¶
type ListSubmissionsResponse struct {
Page int `json:"page"`
Size int `json:"size"`
Total int `json:"total"`
Items []SubmissionItem `json:"items"`
}
func (*ListSubmissionsResponse) BriefItems ¶
func (resp *ListSubmissionsResponse) BriefItems() reflect.Value
func (*ListSubmissionsResponse) FromGRPC ¶
func (resp *ListSubmissionsResponse) FromGRPC(protoResp *submissionproto.ListSubmissionsResponse)
type ListTasksRequest ¶
type ListTasksRequest struct {
WorkspaceID string `path:"workspace_id"`
SubmissionID string `path:"submission_id"`
RunID string `path:"run_id"`
Page int `query:"page"`
Size int `query:"size"`
OrderBy string `query:"orderBy"`
}
func (*ListTasksRequest) ToGRPC ¶
func (req *ListTasksRequest) ToGRPC() *submissionproto.ListTasksRequest
type ListTasksResponse ¶
type ListTasksResponse struct {
Page int `json:"page"`
Size int `json:"size"`
Total int `json:"total"`
Items []TaskItem `json:"items"`
}
func (*ListTasksResponse) FromGRPC ¶
func (resp *ListTasksResponse) FromGRPC(protoResp *submissionproto.ListTasksResponse)
type ListWorkflowFilesRequest ¶
type ListWorkflowFilesRequest struct {
Page int `query:"page"`
Size int `query:"size"`
OrderBy string `query:"orderBy"`
IDs string `query:"ids"`
WorkspaceID string `path:"workspace-id"`
WorkflowID string `path:"workflow-id"`
WorkflowVersionID string `query:"workflowVersionID,omitempty"`
}
func (*ListWorkflowFilesRequest) ToGRPC ¶
func (req *ListWorkflowFilesRequest) ToGRPC() *workspaceproto.ListWorkflowFilesRequest
type ListWorkflowFilesResponse ¶
type ListWorkflowFilesResponse struct {
Page int `json:"page"`
Size int `json:"size"`
Total int `json:"total"`
WorkspaceID string `json:"workspaceID"`
WorkflowID string `json:"workflowID"`
Items []*WorkflowFile `json:"items"`
}
func (*ListWorkflowFilesResponse) FromGRPC ¶
func (resp *ListWorkflowFilesResponse) FromGRPC(protoResp *workspaceproto.ListWorkflowFilesResponse)
type ListWorkflowVersionsRequest ¶
type ListWorkflowVersionsRequest struct {
Page int `query:"page"`
Size int `query:"size"`
OrderBy string `query:"orderBy"`
IDs string `query:"ids"`
WorkspaceID string `path:"workspace-id"`
WorkflowID string `path:"workflow-id"`
}
func (*ListWorkflowVersionsRequest) ToGRPC ¶
func (req *ListWorkflowVersionsRequest) ToGRPC() *workspaceproto.ListWorkflowVersionsRequest
type ListWorkflowVersionsResponse ¶
type ListWorkflowVersionsResponse struct {
Page int `json:"page"`
Size int `json:"size"`
Total int `json:"total"`
WorkspaceID string `json:"workspaceID"`
WorkflowID string `json:"workflowID"`
Items []WorkflowVersion `json:"items"`
}
func (*ListWorkflowVersionsResponse) FromGRPC ¶
func (resp *ListWorkflowVersionsResponse) FromGRPC(protoResp *workspaceproto.ListWorkflowVersionsResponse)
type ListWorkflowsRequest ¶
type ListWorkflowsRequest struct {
Page int `query:"page"`
Size int `query:"size"`
OrderBy string `query:"orderBy"`
SearchWord string `query:"searchWord"`
IDs string `query:"ids"`
WorkspaceID string `path:"workspace-id"`
}
func (*ListWorkflowsRequest) ToGRPC ¶
func (req *ListWorkflowsRequest) ToGRPC() *workspaceproto.ListWorkflowRequest
type ListWorkflowsResponse ¶
type ListWorkflowsResponse struct {
Page int `json:"page"`
Size int `json:"size"`
Total int `json:"total"`
Items []WorkflowItem `json:"items"`
}
func (*ListWorkflowsResponse) BriefItems ¶
func (resp *ListWorkflowsResponse) BriefItems() reflect.Value
func (*ListWorkflowsResponse) FromGRPC ¶
func (resp *ListWorkflowsResponse) FromGRPC(protoResp *workspaceproto.ListWorkflowResponse)
type ListWorkspacesRequest ¶
type ListWorkspacesRequest struct {
Page int `query:"page"`
Size int `query:"size"`
OrderBy string `query:"orderBy"`
SearchWord string `query:"searchWord"`
IDs string `query:"ids"`
}
func (*ListWorkspacesRequest) ToGRPC ¶
func (req *ListWorkspacesRequest) ToGRPC() *workspaceproto.ListWorkspaceRequest
type ListWorkspacesResponse ¶
type ListWorkspacesResponse struct {
Page int `json:"page"`
Size int `json:"size"`
Total int `json:"total"`
Items []WorkspaceItem `json:"items"`
}
func (*ListWorkspacesResponse) BriefItems ¶
func (resp *ListWorkspacesResponse) BriefItems() reflect.Value
func (*ListWorkspacesResponse) FromGRPC ¶
func (resp *ListWorkspacesResponse) FromGRPC(protoResp *workspaceproto.ListWorkspaceResponse)
type NFSWorkspaceStorage ¶
type NFSWorkspaceStorage struct {
MountPath string `json:"mountPath"`
}
type PatchDataModelRequest ¶
type PatchDataModelRequest struct {
WorkspaceID string `path:"workspace_id"`
Name string `json:"name"`
Async bool `json:"async"`
Headers []string `json:"headers"`
Rows [][]string `json:"rows"`
}
func (*PatchDataModelRequest) ToGRPC ¶
func (req *PatchDataModelRequest) ToGRPC() *workspaceproto.PatchDataModelRequest
type PatchDataModelResponse ¶
type PatchDataModelResponse struct {
ID string `json:"id"`
}
func (*PatchDataModelResponse) FromGRPC ¶
func (resp *PatchDataModelResponse) FromGRPC(protoResp *workspaceproto.PatchDataModelResponse)
type RunItem ¶
type RunItem struct {
ID string `json:"id"`
Name string `json:"name"`
Status string `json:"status"`
StartTime int64 `json:"startTime"`
FinishTime *int64 `json:"finishTime"`
Duration int64 `json:"duration"`
EngineRunID string `json:"engineRunID"`
Inputs string `json:"inputs"`
Outputs string `json:"outputs"`
TaskStatus Status `json:"taskStatus"`
Log *string `json:"log"`
Message *string `json:"message"`
}
type Status ¶
type Status struct {
Count int64 `json:"count"`
Pending int64 `json:"pending"`
Succeeded int64 `json:"succeeded"`
Failed int64 `json:"failed"`
Running int64 `json:"running"`
Cancelling int64 `json:"cancelling"`
Cancelled int64 `json:"cancelled"`
Queued int64 `json:"queued"`
Initializing int64 `json:"initializing"`
}
type SubmissionItem ¶
type SubmissionItem struct {
ID string `json:"id"`
Name string `json:"name"`
Description *string `json:"description"`
Status string `json:"status"`
StartTime int64 `json:"startTime"`
FinishTime *int64 `json:"finishTime"`
Duration int64 `json:"duration"`
WorkflowVersion WorkflowVersionBrief `json:"workflowVersion"`
RunStatus Status `json:"runStatus"`
Entity *Entity `json:"entity"`
ExposedOptions ExposedOptions `json:"exposedOptions"`
InOutMaterial *InOutMaterial `json:"inOutMaterial"`
}
type UpdateWorkflowRequest ¶
type UpdateWorkflowRequest struct {
ID string `path:"id"`
Name string `json:"name"`
Description string `json:"description"`
WorkspaceID string `path:"workspace-id"`
}
func (*UpdateWorkflowRequest) ToGRPC ¶
func (req *UpdateWorkflowRequest) ToGRPC() *workspaceproto.UpdateWorkflowRequest
type UpdateWorkflowResponse ¶
type UpdateWorkflowResponse struct {
}
func (*UpdateWorkflowResponse) FromGRPC ¶
func (resp *UpdateWorkflowResponse) FromGRPC(protoResp *workspaceproto.UpdateWorkflowResponse)
type UpdateWorkspaceRequest ¶
type UpdateWorkspaceRequest struct {
ID string `path:"id"`
Name *string `json:"name,omitempty"`
Description *string `json:"description,omitempty"`
}
func (*UpdateWorkspaceRequest) ToGRPC ¶
func (req *UpdateWorkspaceRequest) ToGRPC() *workspaceproto.UpdateWorkspaceRequest
type UpdateWorkspaceResponse ¶
type UpdateWorkspaceResponse struct {
}
func (*UpdateWorkspaceResponse) FromGRPC ¶
func (resp *UpdateWorkspaceResponse) FromGRPC(protoResp *workspaceproto.UpdateWorkspaceResponse)
type WorkflowFile ¶
type WorkflowFileInfo ¶
type WorkflowItem ¶
type WorkflowParam ¶
type WorkflowVersion ¶
type WorkflowVersion struct {
ID string `json:"id"`
Status string `json:"status"`
Message string `json:"message"`
Language string `json:"language"`
LanguageVersion string `json:"languageVersion"`
MainWorkflowPath string `json:"mainWorkflowPath"`
Inputs []*WorkflowParam `json:"inputs"`
Outputs []*WorkflowParam `json:"outputs"`
Graph string `json:"graph"`
Metadata map[string]string `json:"metadata"`
Source string `json:"source"`
Files []*WorkflowFileInfo `json:"files"`
CreatedAt time.Time `json:"createdAt"`
UpdatedAt time.Time `json:"UpdatedAt"`
}
type WorkflowVersionBrief ¶
type WorkspaceItem ¶
type WorkspaceStorage ¶
type WorkspaceStorage struct {
NFS *NFSWorkspaceStorage `json:"nfs,omitempty"`
}
Click to show internal directories.
Click to hide internal directories.