Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2023 Changes in this version + func AssignFromHttpResponse(restyResp *resty.Response, resp interface{}) error + func AssignToHttpRequest(req interface{}, restyRequest *resty.Request) + type CancelRunRequest struct + ID string + SubmissionID string + WorkspaceID string + func (req *CancelRunRequest) ToGRPC() *submissionproto.CancelRunRequest + type CancelRunResponse struct + func (resp *CancelRunResponse) FromGRPC(protoResp *submissionproto.CancelRunResponse) + type CancelSubmissionRequest struct + ID string + WorkspaceID string + func (req *CancelSubmissionRequest) ToGRPC() *submissionproto.CancelSubmissionRequest + type CancelSubmissionResponse struct + func (resp *CancelSubmissionResponse) FromGRPC(protoResp *submissionproto.CancelSubmissionResponse) + type CheckSubmissionRequest struct + Name string + WorkspaceID string + func (req *CheckSubmissionRequest) ToGRPC() *submissionproto.CheckSubmissionRequest + type CheckSubmissionResponse struct + IsNameExist bool + func (resp *CheckSubmissionResponse) FromGRPC(protoResp *submissionproto.CheckSubmissionResponse) + type CreateSubmissionRequest struct + Description *string + Entity *Entity + ExposedOptions ExposedOptions + InOutMaterial *InOutMaterial + Name string + Type string + WorkflowID string + WorkspaceID string + func (req *CreateSubmissionRequest) ToGRPC() *submissionproto.CreateSubmissionRequest + type CreateSubmissionResponse struct + ID string + func (resp *CreateSubmissionResponse) FromGRPC(protoResp *submissionproto.CreateSubmissionResponse) + type CreateWorkflowRequest struct + Description string + ID string + Language string + MainWorkflowPath string + Name string + Source string + Tag string + Token string + Url string + WorkspaceID string + func (req *CreateWorkflowRequest) ToGRPC() *workspaceproto.CreateWorkflowRequest + type CreateWorkflowResponse struct + ID string + func (resp *CreateWorkflowResponse) FromGRPC(protoResp *workspaceproto.CreateWorkflowResponse) + type CreateWorkspaceRequest struct + Description string + Name string + Storage *WorkspaceStorage + func (req *CreateWorkspaceRequest) ToGRPC() *workspaceproto.CreateWorkspaceRequest + type CreateWorkspaceResponse struct + Id string + func (resp *CreateWorkspaceResponse) FromGRPC(protoResp *workspaceproto.CreateWorkspaceResponse) + type DataModel struct + ID string + Name string + RowCount int64 + Type string + type DeleteDataModelRequest struct + Headers []string + ID string + RowIDs []string + WorkspaceID string + func (req *DeleteDataModelRequest) ToGRPC() *workspaceproto.DeleteDataModelRequest + type DeleteDataModelResponse struct + func (resp *DeleteDataModelResponse) FromGRPC(protoResp *workspaceproto.DeleteDataModelResponse) + type DeleteSubmissionRequest struct + ID string + WorkspaceID string + func (req *DeleteSubmissionRequest) ToGRPC() *submissionproto.DeleteSubmissionRequest + type DeleteSubmissionResponse struct + func (resp *DeleteSubmissionResponse) FromGRPC(protoResp *submissionproto.DeleteSubmissionResponse) + type DeleteWorkflowRequest struct + ID string + WorkspaceID string + func (req *DeleteWorkflowRequest) ToGRPC() *workspaceproto.DeleteWorkflowRequest + type DeleteWorkflowResponse struct + func (resp *DeleteWorkflowResponse) FromGRPC(protoResp *workspaceproto.DeleteWorkflowResponse) + type DeleteWorkspaceRequest struct + Id string + func (req *DeleteWorkspaceRequest) ToGRPC() *workspaceproto.DeleteWorkspaceRequest + type DeleteWorkspaceResponse struct + func (resp *DeleteWorkspaceResponse) FromGRPC(protoResp *workspaceproto.DeleteWorkspaceResponse) + type Entity struct + DataModelID string + DataModelRowIDs []string + InputsTemplate string + OutputsTemplate string + type ExposedOptions struct + ReadFromCache bool + type GetDataModelRequest struct + ID string + WorkspaceID string + func (req *GetDataModelRequest) ToGRPC() *workspaceproto.GetDataModelRequest + type GetDataModelResponse struct + DataModel *DataModel + Headers []string + func (resp *GetDataModelResponse) FromGRPC(protoResp *workspaceproto.GetDataModelResponse) + type GetWorkflowFileRequest struct + ID string + WorkflowID string + WorkspaceID string + func (req *GetWorkflowFileRequest) ToGRPC() *workspaceproto.GetWorkflowFileRequest + type GetWorkflowFileResponse struct + File *WorkflowFile + func (resp *GetWorkflowFileResponse) FromGRPC(protoResp *workspaceproto.GetWorkflowFileResponse) + type GetWorkflowRequest struct + ID string + WorkspaceID string + func (req *GetWorkflowRequest) ToGRPC() *workspaceproto.GetWorkflowRequest + type GetWorkflowResponse struct + Workflow WorkflowItem + func (resp *GetWorkflowResponse) FromGRPC(protoResp *workspaceproto.GetWorkflowResponse) + type GetWorkflowVersionRequest struct + ID string + WorkflowID string + WorkspaceID string + func (req *GetWorkflowVersionRequest) ToGRPC() *workspaceproto.GetWorkflowVersionRequest + type GetWorkflowVersionResponse struct + Version WorkflowVersion + func (resp *GetWorkflowVersionResponse) FromGRPC(protoResp *workspaceproto.GetWorkflowVersionResponse) + type Grid struct + Type string + Value []byte + type ImportWorkspaceRequest struct + FilePath string + MountPath string + MountType string + type ImportWorkspaceResponse struct + Id string + func (resp *ImportWorkspaceResponse) FromGRPC(protoResp *workspaceproto.ImportWorkspaceResponse) + type InOutMaterial struct + InputsMaterial string + OutputsMaterial string + type ListAllDataModelRowIDsRequest struct + ID string + WorkspaceID string + func (req *ListAllDataModelRowIDsRequest) ToGRPC() *workspaceproto.ListAllDataModelRowIDsRequest + type ListAllDataModelRowIDsResponse struct + RowIDs []string + func (resp *ListAllDataModelRowIDsResponse) FromGRPC(protoResp *workspaceproto.ListAllDataModelRowIDsResponse) + type ListDataModelRowsRequest struct + ID string + InSetIDs []string + OrderBy string + Page int32 + RowIDs []string + SearchWord string + Size int32 + WorkspaceID string + func (req *ListDataModelRowsRequest) ToGRPC() *workspaceproto.ListDataModelRowsRequest + type ListDataModelRowsResponse struct + Headers []string + Page int32 + Rows [][]string + Size int32 + Total int64 + func (resp *ListDataModelRowsResponse) FromGRPC(protoResp *workspaceproto.ListDataModelRowsResponse) + type ListDataModelsRequest struct + IDs []string + SearchWord string + Types []string + WorkspaceID string + func (req *ListDataModelsRequest) ToGRPC() *workspaceproto.ListDataModelsRequest + type ListDataModelsResponse struct + Items []DataModel + func (resp *ListDataModelsResponse) BriefItems() interface{} + func (resp *ListDataModelsResponse) FromGRPC(protoResp *workspaceproto.ListDataModelsResponse) + type ListRunsRequest struct + IDs []string + OrderBy string + Page int + SearchWord string + Size int + Status []string + SubmissionID string + WorkspaceID string + func (req *ListRunsRequest) ToGRPC() *submissionproto.ListRunsRequest + type ListRunsResponse struct + Items []RunItem + Page int + Size int + Total int + func (resp *ListRunsResponse) FromGRPC(protoResp *submissionproto.ListRunsResponse) + type ListSubmissionsRequest struct + IDs []string + OrderBy string + Page int + SearchWord string + Size int + Status []string + WorkflowID string + WorkspaceID string + func (req *ListSubmissionsRequest) ToGRPC() *submissionproto.ListSubmissionsRequest + type ListSubmissionsResponse struct + Items []SubmissionItem + Page int + Size int + Total int + func (resp *ListSubmissionsResponse) BriefItems() reflect.Value + func (resp *ListSubmissionsResponse) FromGRPC(protoResp *submissionproto.ListSubmissionsResponse) + type ListTasksRequest struct + OrderBy string + Page int + RunID string + Size int + SubmissionID string + WorkspaceID string + func (req *ListTasksRequest) ToGRPC() *submissionproto.ListTasksRequest + type ListTasksResponse struct + Items []TaskItem + Page int + Size int + Total int + func (resp *ListTasksResponse) FromGRPC(protoResp *submissionproto.ListTasksResponse) + type ListWorkflowFilesRequest struct + IDs string + OrderBy string + Page int + Size int + WorkflowID string + WorkflowVersionID string + WorkspaceID string + func (req *ListWorkflowFilesRequest) ToGRPC() *workspaceproto.ListWorkflowFilesRequest + type ListWorkflowFilesResponse struct + Items []*WorkflowFile + Page int + Size int + Total int + WorkflowID string + WorkspaceID string + func (resp *ListWorkflowFilesResponse) FromGRPC(protoResp *workspaceproto.ListWorkflowFilesResponse) + type ListWorkflowVersionsRequest struct + IDs string + OrderBy string + Page int + Size int + WorkflowID string + WorkspaceID string + func (req *ListWorkflowVersionsRequest) ToGRPC() *workspaceproto.ListWorkflowVersionsRequest + type ListWorkflowVersionsResponse struct + Items []WorkflowVersion + Page int + Size int + Total int + WorkflowID string + WorkspaceID string + func (resp *ListWorkflowVersionsResponse) FromGRPC(protoResp *workspaceproto.ListWorkflowVersionsResponse) + type ListWorkflowsRequest struct + IDs string + OrderBy string + Page int + SearchWord string + Size int + WorkspaceID string + func (req *ListWorkflowsRequest) ToGRPC() *workspaceproto.ListWorkflowRequest + type ListWorkflowsResponse struct + Items []WorkflowItem + Page int + Size int + Total int + func (resp *ListWorkflowsResponse) BriefItems() reflect.Value + func (resp *ListWorkflowsResponse) FromGRPC(protoResp *workspaceproto.ListWorkflowResponse) + type ListWorkspacesRequest struct + IDs string + OrderBy string + Page int + SearchWord string + Size int + func (req *ListWorkspacesRequest) ToGRPC() *workspaceproto.ListWorkspaceRequest + type ListWorkspacesResponse struct + Items []WorkspaceItem + Page int + Size int + Total int + func (resp *ListWorkspacesResponse) BriefItems() reflect.Value + func (resp *ListWorkspacesResponse) FromGRPC(protoResp *workspaceproto.ListWorkspaceResponse) + type NFSWorkspaceStorage struct + MountPath string + type PatchDataModelRequest struct + Async bool + Headers []string + Name string + Rows [][]string + WorkspaceID string + func (req *PatchDataModelRequest) ToGRPC() *workspaceproto.PatchDataModelRequest + type PatchDataModelResponse struct + ID string + func (resp *PatchDataModelResponse) FromGRPC(protoResp *workspaceproto.PatchDataModelResponse) + type Row struct + Grid []Grid + type RunItem struct + Duration int64 + EngineRunID string + FinishTime *int64 + ID string + Inputs string + Log *string + Message *string + Name string + Outputs string + StartTime int64 + Status string + TaskStatus Status + type Status struct + Cancelled int64 + Cancelling int64 + Count int64 + Failed int64 + Initializing int64 + Pending int64 + Queued int64 + Running int64 + Succeeded int64 + type SubmissionItem struct + Description *string + Duration int64 + Entity *Entity + ExposedOptions ExposedOptions + FinishTime *int64 + ID string + InOutMaterial *InOutMaterial + Name string + RunStatus Status + StartTime int64 + Status string + WorkflowVersion WorkflowVersionBrief + type TaskItem struct + Duration int64 + FinishTime *int64 + Name string + RunID string + StartTime int64 + Status string + Stderr string + Stdout string + type UpdateWorkflowRequest struct + Description string + ID string + Name string + WorkspaceID string + func (req *UpdateWorkflowRequest) ToGRPC() *workspaceproto.UpdateWorkflowRequest + type UpdateWorkflowResponse struct + func (resp *UpdateWorkflowResponse) FromGRPC(protoResp *workspaceproto.UpdateWorkflowResponse) + type UpdateWorkspaceRequest struct + Description *string + ID string + Name *string + func (req *UpdateWorkspaceRequest) ToGRPC() *workspaceproto.UpdateWorkspaceRequest + type UpdateWorkspaceResponse struct + func (resp *UpdateWorkspaceResponse) FromGRPC(protoResp *workspaceproto.UpdateWorkspaceResponse) + type WorkflowFile struct + Content string + CreatedAt time.Time + ID string + Path string + UpdatedAt time.Time + WorkflowVersionID string + type WorkflowFileInfo struct + ID string + Path string + type WorkflowItem struct + CreatedAt time.Time + Description string + ID string + LatestVersion WorkflowVersion + Name string + UpdatedAt time.Time + type WorkflowParam struct + Default string + Name string + Optional bool + Type string + type WorkflowVersion struct + CreatedAt time.Time + Files []*WorkflowFileInfo + Graph string + ID string + Inputs []*WorkflowParam + Language string + LanguageVersion string + MainWorkflowPath string + Message string + Metadata map[string]string + Outputs []*WorkflowParam + Source string + Status string + UpdatedAt time.Time + type WorkflowVersionBrief struct + ID string + VersionID string + type WorkspaceItem struct + CreateTime int64 + Description string + Id string + Name string + Storage *WorkspaceStorage + UpdateTime int64 + type WorkspaceStorage struct + NFS *NFSWorkspaceStorage + func (s WorkspaceStorage) String() string