handlers

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 31, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateNotebook 

func CreateNotebook(ctx context.Context, c *app.RequestContext, handler command.CreateHandler)

CreateNotebook create or update notebook 

@Summary		use to create or update notebook
@Description	create notebook, update if name exist, set ipynb content in http body
@Tags			notebook
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/notebook/{name} [put]
@Security		basicAuth
@Param			request	body		notebook.IPythonNotebook	true	"ipynb content"
@Failure		400		{object}	apperrors.AppError			"invalid param"
@Failure		401		{object}	apperrors.AppError			"unauthorized"
@Failure		403		{object}	apperrors.AppError			"forbidden"
@Failure		500		{object}	apperrors.AppError			"internal system error"

func CreateWorkflow 

func CreateWorkflow(ctx context.Context, c *app.RequestContext, handler command.CreateHandler)

CreateWorkflow create or update workflow 

@Summary		use to create or update workflow
@Description	create workflow, add workflow version if id is given
@Tags			workflow
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/workflow [post]
@Security		basicAuth
@Param			workspace-id	path		string					true	"workspace id"
@Param			request			body		createWorkflowRequest	true	"create workflow request"
@Success		200				{object}	createWorkflowResponse
@Failure		400				{object}	apperrors.AppError	"invalid param"
@Failure		401				{object}	apperrors.AppError	"unauthorized"
@Failure		403				{object}	apperrors.AppError	"forbidden"
@Failure		500				{object}	apperrors.AppError	"internal system error"

func CreateWorkspace 

func CreateWorkspace(ctx context.Context, c *app.RequestContext, handler command.CreateWorkspaceHandler)

CreateWorkspace create workspace 

@Summary		use to create workspace
@Description	create workspace
@Tags			workspace
@Accept			application/json
@Produce		application/json
@Router			/workspace [post]
@Security		basicAuth
@Param			request	body		CreateWorkspaceRequest	true	"create workspace request"
@Success		201		{object}	CreateWorkspaceResponse
@Failure		400		{object}	apperrors.AppError	"invalid param"
@Failure		401		{object}	apperrors.AppError	"unauthorized"
@Failure		403		{object}	apperrors.AppError	"forbidden"
@Failure		500		{object}	apperrors.AppError	"internal system error"

func DeleteDataModel 

func DeleteDataModel(ctx context.Context, c *app.RequestContext, handler datamodelcommand.DeleteDataModelHandler)

DeleteDataModel delete data model 

@Summary		use to delete data model,support delete with data model name/row ids/headers
@Description	delete data model
@Tags			datamodel
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace_id}/data_model/{id} [delete]
@Security		basicAuth
@Param			workspace_id	path	string		true	"get workspace id"
@Param			id				path	string		true	"get data model id"
@Param			headers			query	[]string	false	"the data model headers should delete"
@Param			rowIDs			query	[]string	false	"the data model row ids should delete"
@Success		202
@Failure		400	{object}	apperrors.AppError	"invalid param"
@Failure		401	{object}	apperrors.AppError	"unauthorized"
@Failure		403	{object}	apperrors.AppError	"forbidden"
@Failure		500	{object}	apperrors.AppError	"internal system error"

func DeleteNotebook 

func DeleteNotebook(ctx context.Context, c *app.RequestContext, handler command.DeleteHandler)

DeleteNotebook delete notebook 

@Summary		use to delete notebook
@Description	delete notebook
@Tags			notebook
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/notebook/{name} [delete]
@Security		basicAuth
@Success		200
@Failure		400	{object}	apperrors.AppError	"invalid param"
@Failure		401	{object}	apperrors.AppError	"unauthorized"
@Failure		403	{object}	apperrors.AppError	"forbidden"
@Failure		500	{object}	apperrors.AppError	"internal system error"

func DeleteWorkflow 

func DeleteWorkflow(ctx context.Context, c *app.RequestContext, handler command.DeleteHandler)

DeleteWorkflow delete workflow 

@Summary		use to delete workflow
@Description	delete workflow
@Tags			workflow
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/workflow/{id} [delete]
@Security		basicAuth
@Param			workspace-id	path	string	true	"delete workspace id"
@Param			id				path	string	true	"delete workflow id"
@Success		202
@Failure		400	{object}	apperrors.AppError	"invalid param"
@Failure		401	{object}	apperrors.AppError	"unauthorized"
@Failure		403	{object}	apperrors.AppError	"forbidden"
@Failure		404	{object}	apperrors.AppError	"not found"
@Failure		500	{object}	apperrors.AppError	"internal system error"

func DeleteWorkspace 

func DeleteWorkspace(ctx context.Context, c *app.RequestContext, handler command.DeleteWorkspaceHandler)

DeleteWorkspace delete workspace 

@Summary		use to delete workspace
@Description	delete workspace
@Tags			workspace
@Accept			application/json
@Produce		application/json
@Router			/workspace/{id} [delete]
@Security		basicAuth
@Param			id	path	string	true	"delete workspace id"
@Success		202
@Failure		400	{object}	apperrors.AppError	"invalid param"
@Failure		401	{object}	apperrors.AppError	"unauthorized"
@Failure		403	{object}	apperrors.AppError	"forbidden"
@Failure		404	{object}	apperrors.AppError	"not found"
@Failure		500	{object}	apperrors.AppError	"internal system error"

func GetDataModel 

func GetDataModel(ctx context.Context, c *app.RequestContext, handler datamodelquery.GetDataModelHandler)

GetDataModel get data model 

@Summary		use to get data model
@Description	get data model
@Tags			datamodel
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace_id}/data_model/{id} [get]
@Security		basicAuth
@Param			workspace_id	path		string	true	"get workspace id"
@Param			id				path		string	true	"get data model id"
@Success		200				{object}	GetDataModelResponse
@Failure		400				{object}	apperrors.AppError	"invalid param"
@Failure		401				{object}	apperrors.AppError	"unauthorized"
@Failure		403				{object}	apperrors.AppError	"forbidden"
@Failure		500				{object}	apperrors.AppError	"internal system error"

func GetNotebook 

func GetNotebook(ctx context.Context, c *app.RequestContext, handler query.GetHandler)

GetNotebook get notebook content 

@Summary		get notebook content
@Description	get notebook content
@Tags			notebook
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/notebook/{name} [get]
@Security		basicAuth
@Failure		400	{object}	apperrors.AppError	"invalid param"
@Failure		401	{object}	apperrors.AppError	"unauthorized"
@Failure		403	{object}	apperrors.AppError	"forbidden"
@Failure		500	{object}	apperrors.AppError	"internal system error"

func GetWorkflow 

func GetWorkflow(ctx context.Context, c *app.RequestContext, handler query.GetHandler)

GetWorkflow get workflow by id 

@Summary		get workflow
@Description	get workflow
@Tags			workflow
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/workflow/{id} [get]
@Security		basicAuth
@Param			id				path		string	true	"workflow id"
@Param			workspace-id	path		string	true	"workspace id"
@Success		200				{object}	getWorkflowResponse
@Failure		400				{object}	apperrors.AppError	"invalid param"
@Failure		401				{object}	apperrors.AppError	"unauthorized"
@Failure		403				{object}	apperrors.AppError	"forbidden"
@Failure		500				{object}	apperrors.AppError	"internal system error"

func GetWorkflowFile 

func GetWorkflowFile(ctx context.Context, c *app.RequestContext, handler query.GetFileHandler)

GetWorkflowFile get workflow file by id 

@Summary		get workflow file
@Description	get workflow file
@Tags			workflow
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/workflow/{workflow-id}/file/{id} [get]
@Security		basicAuth
@Param			id				path		string	true	"workflow file id"
@Param			workspace-id	path		string	true	"workspace id"
@Param			workflow-id		path		string	true	"workflow id"
@Success		200				{object}	getWorkflowFileResponse
@Failure		400				{object}	apperrors.AppError	"invalid param"
@Failure		401				{object}	apperrors.AppError	"unauthorized"
@Failure		403				{object}	apperrors.AppError	"forbidden"
@Failure		500				{object}	apperrors.AppError	"internal system error"

func GetWorkflowVersion 

func GetWorkflowVersion(ctx context.Context, c *app.RequestContext, handler query.GetVersionHandler)

GetWorkflowVersion get workflow version by id 

@Summary		get workflow version
@Description	get workflow version
@Tags			workflow
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/workflow/{workflow-id}/version/{id} [get]
@Security		basicAuth
@Param			id				path		string	true	"workflow version id"
@Param			workspace-id	path		string	true	"workspace id"
@Param			workflow-id		path		string	true	"workflow id"
@Success		200				{object}	getWorkflowVersionResponse
@Failure		400				{object}	apperrors.AppError	"invalid param"
@Failure		401				{object}	apperrors.AppError	"unauthorized"
@Failure		403				{object}	apperrors.AppError	"forbidden"
@Failure		500				{object}	apperrors.AppError	"internal system error"

func GetWorkspaceById 

func GetWorkspaceById(ctx context.Context, c *app.RequestContext, handler query.GetWorkspaceByIDQueryHandler)

GetWorkspaceById get workspace 

@Summary		use to get workspace by id
@Description	get workspace
@Tags			workspace
@Accept			application/json
@Produce		application/json
@Router			/workspace/{id} [get]
@Security		basicAuth
@Param			id	path		string	true	"get workspace id"
@Success		200	{object}	GetWorkspaceByIdResponse
@Failure		400	{object}	apperrors.AppError	"invalid param"
@Failure		401	{object}	apperrors.AppError	"unauthorized"
@Failure		403	{object}	apperrors.AppError	"forbidden"
@Failure		404	{object}	apperrors.AppError	"not found"
@Failure		500	{object}	apperrors.AppError	"internal system error"

func ImportWorkspace 

func ImportWorkspace(ctx context.Context, c *app.RequestContext, handler command.ImportWorkspaceHandler)

ImportWorkspace import workspace 

@Summary		use to import workspace
@Description	import workspace
@Tags			workspace
@Accept			multipart/form-data
@Produce		application/json
@Router			/workspace [put]
@Security		basicAuth
@Param			file		formData	file	true	"file"
@Param			mountType	query		string	true	"workspace mount path"
@Param			mountPath	query		string	true	"workspace mount type, only support nfs"
@Success		200			{object}	ImportWorkspaceResponse
@Failure		400			{object}	apperrors.AppError	"invalid param"
@Failure		401			{object}	apperrors.AppError	"unauthorized"
@Failure		403			{object}	apperrors.AppError	"forbidden"
@Failure		500			{object}	apperrors.AppError	"internal system error"

func ListAllDataModelRowIDs 

func ListAllDataModelRowIDs(ctx context.Context, c *app.RequestContext, handler datamodelquery.ListAllDataModelRowIDsHandler)

ListAllDataModelRowIDs list all data model row ids 

@Summary		use to list all data model row ids
@Description	list all data model row ids
@Tags			datamodel
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace_id}/data_model/{id}/rows/ids [get]
@Security		basicAuth
@Param			workspace_id	path		string	true	"get workspace id"
@Param			id				path		string	true	"get data model id"
@Success		200				{object}	ListAllDataModelRowIDsResponse
@Failure		400				{object}	apperrors.AppError	"invalid param"
@Failure		401				{object}	apperrors.AppError	"unauthorized"
@Failure		403				{object}	apperrors.AppError	"forbidden"
@Failure		500				{object}	apperrors.AppError	"internal system error"

func ListDataModelRows 

func ListDataModelRows(ctx context.Context, c *app.RequestContext, handler datamodelquery.ListDataModelRowsHandler)

ListDataModelRows list data model rows 

@Summary		use to list data model rows
@Description	list data model rows
@Tags			datamodel
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace_id}/data_model/{id}/rows [get]
@Security		basicAuth
@Param			workspace_id	path		string		true	"get workspace id"
@Param			id				path		string		true	"get data model id"
@Param			page			query		int			false	"query page"
@Param			size			query		int			false	"query size"
@Param			orderBy			query		string		false	"query order, just like field1,field2:desc"
@Param			inSetIDs		query		[]string	false	"data model entity set reffed entity row ids"
@Param			searchWord		query		string		false	"query searchWord"
@Param			rowIDs			query		[]string	false	"data model row ids"
@Success		200				{object}	ListDataModelRowsResponse
@Failure		400				{object}	apperrors.AppError	"invalid param"
@Failure		401				{object}	apperrors.AppError	"unauthorized"
@Failure		403				{object}	apperrors.AppError	"forbidden"
@Failure		500				{object}	apperrors.AppError	"internal system error"

func ListDataModels 

func ListDataModels(ctx context.Context, c *app.RequestContext, handler datamodelquery.ListDataModelsHandler)

ListDataModels list data models 

@Summary		use to list data models
@Description	list data models
@Tags			datamodel
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace_id}/data_model [get]
@Security		basicAuth
@Param			workspace_id	path		string		true	"get workspace id"
@Param			types			query		[]string	false	"data model types"
@Param			searchWord		query		string		false	"query searchWord"
@Param			ids				query		[]string	false	"data model ids"
@Success		200				{object}	ListDataModelsResponse
@Failure		400				{object}	apperrors.AppError	"invalid param"
@Failure		401				{object}	apperrors.AppError	"unauthorized"
@Failure		403				{object}	apperrors.AppError	"forbidden"
@Failure		500				{object}	apperrors.AppError	"internal system error"

func ListNotebooks 

func ListNotebooks(ctx context.Context, c *app.RequestContext, handler query.ListHandler)

ListNotebooks list notebook 

@Summary		use to list notebook of workspace
@Description	list notebook of workspace
@Tags			notebook
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/notebook [get]
@Security		basicAuth
@Success		200	{object}	listNotebooksResponse
@Failure		400	{object}	apperrors.AppError	"invalid param"
@Failure		401	{object}	apperrors.AppError	"unauthorized"
@Failure		403	{object}	apperrors.AppError	"forbidden"
@Failure		500	{object}	apperrors.AppError	"internal system error"

func ListWorkflowFiles 

func ListWorkflowFiles(ctx context.Context, c *app.RequestContext, handler query.ListFilesHandler)

ListWorkflowFiles list workflow files 

@Summary		use to list workflow files
@Description	list workflow of workspace
@Tags			workflow
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/workflow/{workflow-id}/file [get]
@Security		basicAuth
@Param			workspace-id		path		string						true	"workspace id"
@Param			workflow-id			path		string						true	"workflow id"
@Param			request				body		listWorkflowFilesRequest	true	"list workflow files"
@Param			page				query		int							false	"page number"
@Param			size				query		int							false	"page size"
@Param			orderBy				query		string						false	"support order field: version/path, support order: asc/desc, seperated by comma, eg: version:desc,path:asc"
@Param			searchWord			query		string						false	"workflow name"
@Param			ids					query		string						false	"workspace file ids seperated by comma"
@Param			workflowVersionID	query		string						false	"workspace version id"
@Success		200					{object}	listWorkflowFilesResponse
@Failure		400					{object}	apperrors.AppError	"invalid param"
@Failure		401					{object}	apperrors.AppError	"unauthorized"
@Failure		403					{object}	apperrors.AppError	"forbidden"
@Failure		500					{object}	apperrors.AppError	"internal system error"

func ListWorkflowVersions 

func ListWorkflowVersions(ctx context.Context, c *app.RequestContext, handler query.ListVersionsHandler)

ListWorkflowVersions list workflow version 

@Summary		use to list workflow versions
@Description	list workflow verions of workspace
@Tags			workflow
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/workflow/{workflow-id}/versions [get]
@Security		basicAuth
@Param			workspace-id	path		string	true	"workspace id"
@Param			workflow-id		path		string	true	"workflow id"
@Param			page			query		int		false	"page number"
@Param			size			query		int		false	"page size"
@Param			orderBy			query		string	false	"support order field: source/language/status, support order: asc/desc, seperated by comma, eg: status:desc,language:asc"
@Param			ids				query		string	false	"workspace version ids seperated by comma"
@Success		200				{object}	listWorkflowVersionsResponse
@Failure		400				{object}	apperrors.AppError	"invalid param"
@Failure		401				{object}	apperrors.AppError	"unauthorized"
@Failure		403				{object}	apperrors.AppError	"forbidden"
@Failure		500				{object}	apperrors.AppError	"internal system error"

func ListWorkflows 

func ListWorkflows(ctx context.Context, c *app.RequestContext, handler query.ListHandler)

ListWorkflows list workflows 

@Summary		use to list workflows of workspace
@Description	list workflow of workspace
@Tags			workflow
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/workflow [get]
@Security		basicAuth
@Param			workspace-id	path		string	true	"workspace id"
@Param			page			query		int		false	"page number"
@Param			size			query		int		false	"page size"
@Param			orderBy			query		string	false	"support order field: name/createdAt, support order: asc/desc, seperated by comma, eg: createdAt:desc,name:asc"
@Param			searchWord		query		string	false	"workflow name"
@Param			exact			query		bool	false	"exact"
@Param			ids				query		string	false	"workspace ids seperated by comma"
@Success		200				{object}	listWorkflowsResponse
@Failure		400				{object}	apperrors.AppError	"invalid param"
@Failure		401				{object}	apperrors.AppError	"unauthorized"
@Failure		403				{object}	apperrors.AppError	"forbidden"
@Failure		500				{object}	apperrors.AppError	"internal system error"

func ListWorkspaces 

func ListWorkspaces(ctx context.Context, c *app.RequestContext, handler query.ListWorkspacesHandler)

ListWorkspaces list workspaces 

@Summary		use to list workspaces
@Description	list workspaces
@Tags			workspace
@Accept			application/json
@Produce		application/json
@Router			/workspace [get]
@Security		basicAuth
@Param			page		query		int		false	"query page"
@Param			size		query		int		false	"query size"
@Param			orderBy		query		string	false	"query order, just like field1,field2:desc"
@Param			searchWord	query		string	false	"query searchWord"
@Param			exact		query		bool	false	"query exact"
@Param			ids			query		string	false	"query ids, split by comma"
@Success		200			{object}	ListWorkspacesResponse
@Failure		400			{object}	apperrors.AppError	"invalid param"
@Failure		401			{object}	apperrors.AppError	"unauthorized"
@Failure		403			{object}	apperrors.AppError	"forbidden"
@Failure		500			{object}	apperrors.AppError	"internal system error"

func PatchDataModel 

func PatchDataModel(ctx context.Context, c *app.RequestContext, handler datamodelcommand.PatchDataModelHandler)

PatchDataModel patch data model 

@Summary		use to patch data model
@Description	patch data model
@Tags			datamodel
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace_id}/data_model  [patch]
@Security		basicAuth
@Param			request	body		PatchDataModelRequest	true	"patch data model request"
@Success		201		{object}	PatchDataModelResponse
@Failure		400		{object}	apperrors.AppError	"invalid param"
@Failure		401		{object}	apperrors.AppError	"unauthorized"
@Failure		403		{object}	apperrors.AppError	"forbidden"
@Failure		500		{object}	apperrors.AppError	"internal system error"

func UpdateWorkflow 

func UpdateWorkflow(ctx context.Context, c *app.RequestContext, handler command.UpdateHandler)

UpdateWorkflow update workflow 

@Summary		use to update workflow
@Description	update workspace
@Tags			workflow
@Accept			application/json
@Produce		application/json
@Router			/workspace/{workspace-id}/workflow/{id} [patch]
@Security		basicAuth
@Param			workspace-id	path	string					true	"update workspace id"
@Param			id				path	string					true	"update workflow id"
@Param			request			body	updateWorkflowRequest	true	"update workflow request"
@Success		200
@Failure		400	{object}	apperrors.AppError	"invalid param"
@Failure		401	{object}	apperrors.AppError	"unauthorized"
@Failure		403	{object}	apperrors.AppError	"forbidden"
@Failure		404	{object}	apperrors.AppError	"not found"
@Failure		500	{object}	apperrors.AppError	"internal system error"

func UpdateWorkspace 

func UpdateWorkspace(ctx context.Context, c *app.RequestContext, handler command.UpdateWorkspaceHandler)

UpdateWorkspace update workspace 

@Summary		use to update workspace
@Description	update workspace
@Tags			workspace
@Accept			application/json
@Produce		application/json
@Router			/workspace/{id} [patch]
@Security		basicAuth
@Param			id		path	string					true	"update workspace id"
@Param			request	body	UpdateWorkspaceRequest	true	"update workspace request"
@Success		200
@Failure		400	{object}	apperrors.AppError	"invalid param"
@Failure		401	{object}	apperrors.AppError	"unauthorized"
@Failure		403	{object}	apperrors.AppError	"forbidden"
@Failure		404	{object}	apperrors.AppError	"not found"
@Failure		500	{object}	apperrors.AppError	"internal system error"

Types

type CreateWorkspaceRequest 

type CreateWorkspaceRequest struct {
	Name        string           `json:"name"`
	Description string           `json:"description"`
	Storage     WorkspaceStorage `json:"storage"`
}

type CreateWorkspaceResponse 

type CreateWorkspaceResponse struct {
	Id string `json:"id"`
}

type DataModel 

type DataModel struct {
	ID       string `json:"id"`
	Name     string `json:"name"`
	RowCount int64  `json:"rowCount"`
	Type     string `json:"type"`
}

type DeleteDataModelRequest 

type DeleteDataModelRequest struct {
	ID          string   `path:"id"`
	WorkspaceID string   `path:"workspace_id"`
	Headers     []string `query:"headers"`
	RowIDs      []string `query:"rowIDs"`
}

type DeleteWorkspaceRequest 

type DeleteWorkspaceRequest struct {
	Id string `path:"id"`
}

type GetDataModelRequest 

type GetDataModelRequest struct {
	WorkspaceID string `path:"workspace_id"`
	ID          string `path:"id"`
}

type GetDataModelResponse 

type GetDataModelResponse struct {
	DataModel *DataModel `json:"dataModel,omitempty"`
	Headers   []string   `json:"headers"`
}

type GetWorkspaceByIdRequest 

type GetWorkspaceByIdRequest struct {
	Id string `path:"id"`
}

type GetWorkspaceByIdResponse 

type GetWorkspaceByIdResponse struct {
	WorkspaceItem `json:",inline"`
}

type Grid 

type Grid struct {
	Value []byte `json:"value"`
	Type  string `json:"type"`
}

type ImportWorkspaceRequest 

type ImportWorkspaceRequest struct {
	FileName  string
	MountPath string `query:"mountPath"`
	MountType string `query:"mountType"`
}

type ImportWorkspaceResponse 

type ImportWorkspaceResponse struct {
	Id string `json:"id"`
}

type ListAllDataModelRowIDsRequest 

type ListAllDataModelRowIDsRequest struct {
	WorkspaceID string `path:"workspace_id"`
	ID          string `path:"id"`
}

type ListAllDataModelRowIDsResponse 

type ListAllDataModelRowIDsResponse struct {
	RowIDs []string `json:"rowIDs"`
}

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"`
}

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"`
}

type ListDataModelsRequest 

type ListDataModelsRequest struct {
	WorkspaceID string   `path:"workspace_id"`
	Types       []string `query:"types"`
	SearchWord  string   `query:"searchWord"`
	IDs         []string `query:"ids"`
}

type ListDataModelsResponse 

type ListDataModelsResponse struct {
	Items []*DataModel `json:"Items"`
}

type ListWorkspacesRequest 

type ListWorkspacesRequest struct {
	Page       int    `query:"page"`
	Size       int    `query:"size"`
	OrderBy    string `query:"orderBy"`
	SearchWord string `query:"searchWord"`
	Exact      bool   `query:"exact"`
	IDs        string `query:"ids"`
}

type ListWorkspacesResponse 

type ListWorkspacesResponse struct {
	Page  int             `json:"page"`
	Size  int             `json:"size"`
	Total int             `json:"total"`
	Items []WorkspaceItem `json:"items"`
}

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"`
}

type PatchDataModelResponse 

type PatchDataModelResponse struct {
	ID string `json:"id"`
}

type Row 

type Row struct {
	Grid []*Grid `json:"grid"`
}

type UpdateWorkspaceRequest 

type UpdateWorkspaceRequest struct {
	ID          string  `path:"id"`
	Name        *string `json:"name,omitempty"`
	Description *string `json:"description,omitempty"`
}

type WorkflowFile 

type WorkflowFile struct {
	ID                string    `json:"id"`
	WorkflowVersionID string    `json:"workflowVersionID"`
	Path              string    `json:"path"`
	Content           string    `json:"content"`
	CreatedAt         time.Time `json:"createdAt"`
	UpdatedAt         time.Time `json:"updatedAt"`
}

func WorkflowFileDTOtoWorkflowFileVO 

func WorkflowFileDTOtoWorkflowFileVO(workflowFileDTO *query.WorkflowFile) *WorkflowFile

type WorkflowFileInfo 

type WorkflowFileInfo struct {
	ID   string `json:"id"`
	Path string `json:"path"`
}

type WorkflowItem 

type WorkflowItem struct {
	ID            string           `json:"id"`
	Name          string           `json:"name"`
	Description   string           `json:"description"`
	LatestVersion *WorkflowVersion `json:"latestVersion"`
	CreatedAt     time.Time        `json:"createdAt"`
	UpdatedAt     time.Time        `json:"updatedAt"`
}

func WorkflowDTOtoWorkflowItemVO 

func WorkflowDTOtoWorkflowItemVO(workflowDTO *query.Workflow) *WorkflowItem

type WorkflowParam 

type WorkflowParam struct {
	Name     string `json:"name"`
	Type     string `json:"type"`
	Optional bool   `json:"optional"`
	Default  string `json:"default"`
}

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"`
}

func WorkflowVersionDTOtoVO 

func WorkflowVersionDTOtoVO(workflowVersion *query.WorkflowVersion) *WorkflowVersion

type WorkspaceItem 

type WorkspaceItem struct {
	Id          string           `json:"id"`
	Name        string           `json:"name"`
	Description string           `json:"description"`
	Storage     WorkspaceStorage `json:"storage"`
	CreateTime  int64            `json:"createTime"`
	UpdateTime  int64            `json:"updateTime"`
}

type WorkspaceStorage 

type WorkspaceStorage struct {
	NFS *NFSWorkspaceStorage `json:"nfs,omitempty"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.