interfaces

package

Go to main page

Versions in this module

v0

v0.2.4

Nov 12, 2026

v0.2.3

Nov 11, 2026

v0.2.2

Nov 10, 2026

v0.2.1

Nov 10, 2026

v0.2.0

Nov 9, 2026

Changes in this version

type ContainerRepository

+ ClearContainerTemplateDefinitionDefault func(ctx context.Context) error

+ GetDefaultContainerTemplateDefinition func(ctx context.Context) (*types.ContainerTemplateDefinition, error)

type ContainerService

+ CreateTerminalAppSession func(ctx context.Context, in types.TerminalAppSessionInput) (*types.AppSession, error)

+ ExportContainerTemplate func(ctx context.Context, definitionID int64) (*types.ContainerTemplateBundle, error)

+ GetDefaultContainerTemplate func(ctx context.Context) (*types.ContainerTemplate, error)

+ SetDefaultContainerTemplate func(ctx context.Context, definitionID int64) error

type DataRepository

+ ExistsFileByPathInDataset func(ctx context.Context, datasetID int64, path string) (bool, error)

+ GetProjectDatasetByDatasetID func(ctx context.Context, datasetID int64) (*types.ProjectDataset, error)

+ ListFileByDatasetID func(ctx context.Context, datasetID int64) ([]*types.FileWithDatasetInfo, error)

type DataService

+ ImportDatasetDirFiles func(ctx context.Context, datasetID int64, projectID int64, role string) (*types.ImportDatasetDirFilesResult, error)

+ ListDatasetDirFiles func(ctx context.Context, datasetID int64, projectID int64) (string, []*types.DatasetDirFile, error)

+ ListDatasetFiles func(ctx context.Context, datasetID int64) ([]*types.FileWithDatasetInfo, error)

type ProjectRepository

+ ExistsProjectReportItemOwner func(ctx context.Context, reportID int64, ...) (bool, error)

+ GetActiveUserProjectByUserID func(ctx context.Context, userID int64) (*types.UserProject, error)

+ GetLiteratureOwnerProjectID func(ctx context.Context, literatureID int64) (int64, error)

+ UpdateUserProjectMenuConfig func(ctx context.Context, userID int64, projectID int64, ...) error

type ProjectService

+ CommitProjectReport func(ctx context.Context, userID int64, reportID int64, message string) (*types.ProjectReportCommitResult, error)

+ GetActiveUserMenuConfig func(ctx context.Context, userID int64) (types.UserMenuConfig, error)

+ GetProjectReportFile func(ctx context.Context, userID int64, reportID int64) (string, error)

+ GetProjectReportGitDiff func(ctx context.Context, userID int64, reportID int64) (*types.ProjectReportGitDiff, error)

+ PackageProjectReportItems func(ctx context.Context, userID int64, reportID int64) (string, error)

+ RevertProjectReportFile func(ctx context.Context, userID int64, reportID int64, relPath string) error

+ UpdateActiveUserMenuConfig func(ctx context.Context, userID int64, config types.UserMenuConfig) error

+ UpdateProjectReportFile func(ctx context.Context, userID int64, reportID int64, content string) error

type WorkflowService

+ GetScriptFormJSONByScript func(ctx context.Context, script *types.Script) ([]any, map[string]any, error)

v0.1.5

Oct 14, 2026

Changes in this version

type AISummaryRepository

+ PageAISummariesByProjectID func(ctx context.Context, pagination *types.Pagination, projectID int64) ([]*types.AISummary, int64, error)

type AISummaryService

+ PageAISummariesByProjectID func(ctx context.Context, pagination *types.Pagination, projectID int64) ([]*types.AISummary, int64, error)

type DataRepository

+ CreateAssay func(ctx context.Context, assay *types.Assay) error

+ CreateDatasetAssay func(ctx context.Context, datasetAssay *types.DatasetAssay) error

+ DeleteAssay func(ctx context.Context, id int64) error

+ DeleteAssayWithRelations func(ctx context.Context, id int64) error

+ DeleteDatasetAssay func(ctx context.Context, id int64) error

+ ExistsAssayByID func(ctx context.Context, id int64) (bool, error)

+ ExistsAssayNameInDataset func(ctx context.Context, datasetID int64, sampleName, role string, ...) (bool, error)

+ GetAssayByID func(ctx context.Context, id int64) (*types.Assay, error)

+ GetAssayByNameAndDatasetID func(ctx context.Context, datasetID int64, sampleName, role string) (*types.Assay, error)

+ GetDatasetAssayByAssayID func(ctx context.Context, assayID int64) (*types.DatasetAssay, error)

+ GetDatasetAssayByID func(ctx context.Context, id int64) (*types.DatasetAssay, error)

+ GetFileByAnalysisNodeIDAndFileKey func(ctx context.Context, analysisNodeID int64, fileKey string) (*types.File, error)

+ GetFileByAssayIDAndFileKey func(ctx context.Context, assayID int64, fileKey string) (*types.File, error)

+ GetFileByPathAndAssayID func(ctx context.Context, path string, assayID int64) (*types.File, error)

+ ListAssay func(ctx context.Context) ([]*types.Assay, error)

+ ListAssayByProjectID func(ctx context.Context, projectID string, roles []string) ([]*types.AssayWithDatasetInfo, error)

+ ListDatasetAssay func(ctx context.Context) ([]*types.DatasetAssay, error)

+ ListDatasetByProjectID func(ctx context.Context, projectID string) ([]*types.Dataset, error)

+ ListFileByAnalysisNodeID func(ctx context.Context, analysisNodeID int64) ([]*types.File, error)

+ ListFileByAssayID func(ctx context.Context, assayID int64) ([]*types.File, error)

+ ListFileByAssayIDAndRole func(ctx context.Context, assayID int64, roles []string) ([]*types.File, error)

+ ListFileByProjectIDViaAnalysisNode func(ctx context.Context, projectID string) ([]*types.FileWithDatasetInfo, error)

+ PageAssayByProjectID func(ctx context.Context, pagination *types.Pagination, projectID string) ([]*types.AssayWithDatasetInfo, int64, error)

+ PageFileByProjectIDViaAnalysisNode func(ctx context.Context, pagination *types.Pagination, projectID string) ([]*types.FileWithDatasetInfo, int64, error)

+ UpdateAssay func(ctx context.Context, assay *types.Assay) error

+ UpdateDatasetAssay func(ctx context.Context, datasetAssay *types.DatasetAssay) error

type DataService

+ CreateAssay func(ctx context.Context, assay *types.Assay) error

+ CreateDatasetAssay func(ctx context.Context, datasetAssay *types.DatasetAssay) error

+ DeleteAssay func(ctx context.Context, id int64) error

+ DeleteDatasetAssay func(ctx context.Context, id int64) error

+ GetAssayByID func(ctx context.Context, id int64) (*types.Assay, error)

+ GetDatasetAssayByAssayID func(ctx context.Context, assayID int64) (*types.DatasetAssay, error)

+ GetDatasetAssayByID func(ctx context.Context, id int64) (*types.DatasetAssay, error)

+ ImportAssayTSV func(ctx context.Context, req *types.ImportAssayTSVRequest) (*types.ImportAssayTSVResult, error)

+ ListAssay func(ctx context.Context) ([]*types.Assay, error)

+ ListAssayByProjectID func(ctx context.Context, projectID string, roles []string) ([]*types.AssayWithDatasetInfo, error)

+ ListDatasetAssay func(ctx context.Context) ([]*types.DatasetAssay, error)

+ ListDatasetByProjectID func(ctx context.Context, projectID string) ([]*types.Dataset, error)

+ ListFileByAnalysisNodeID func(ctx context.Context, analysisNodeID int64) ([]*types.File, error)

+ ListFileByAssayID func(ctx context.Context, assayID int64) ([]*types.File, error)

+ ListFileByAssayIDAndRole func(ctx context.Context, assayID int64, roles []string) ([]*types.File, error)

+ ListFileByProjectIDViaAnalysisNode func(ctx context.Context, projectID string) ([]*types.FileWithDatasetInfo, error)

+ PageAssayByProjectID func(ctx context.Context, pagination *types.Pagination, projectID string) (*types.PageResult, error)

+ PageFileByProjectIDViaAnalysisNode func(ctx context.Context, pagination *types.Pagination, projectID string) (*types.PageResult, error)

+ UpdateAssay func(ctx context.Context, assay *types.Assay) error

+ UpdateDatasetAssay func(ctx context.Context, datasetAssay *types.DatasetAssay) error

+ UploadFileToDataset func(ctx context.Context, datasetID int64, projectID, role, fileName string, ...) (*types.AddFileToDatasetResponse, error)

type ProjectRepository

+ AddProjectReportItem func(ctx context.Context, item *types.ProjectReportItem) error

+ DeleteProjectReportItem func(ctx context.Context, itemID int64) error

+ DeleteProjectReportItemsByIDs func(ctx context.Context, itemIDs []int64) error

+ DeleteProjectReportItemsByReportID func(ctx context.Context, reportID int64) error

+ GetProjectReportItemByID func(ctx context.Context, itemID int64) (*types.ProjectReportItem, error)

+ ListProjectReportItemsByReportID func(ctx context.Context, reportID int64) ([]*types.ProjectReportItem, error)

+ ReorderProjectReportItems func(ctx context.Context, reportID int64, orders []types.ProjectReportItemOrder) error

+ UpdateProjectReportItem func(ctx context.Context, item *types.ProjectReportItem) error

type ProjectService

+ AddProjectReportItem func(ctx context.Context, userID string, item *types.ProjectReportItem) error

+ DeleteProjectReportItem func(ctx context.Context, userID string, itemID int64) error

+ GetProjectReportContent func(ctx context.Context, reportID int64) (string, error)

+ GetProjectReportItemContent func(ctx context.Context, itemID int64) (*types.ProjectReportItemContent, error)

+ GetProjectReportItemDetailByID func(ctx context.Context, userID string, itemID int64) (*types.ProjectReportItem, error)

+ ListProjectReportItemsByReportID func(ctx context.Context, userID string, reportID int64) ([]*types.ProjectReportItem, error)

+ ReorderProjectReportItems func(ctx context.Context, userID string, reportID int64, ...) error

+ UpdateProjectReportItem func(ctx context.Context, userID string, item *types.ProjectReportItem) error

type WorkbookReadResult

+ File *types.File

v0.1.4

Sep 19, 2026

Changes in this version

type AISummaryService

+ UpdateAISummary func(ctx context.Context, id int64, title, content *string) (*types.AISummary, error)

type ContainerRepository

+ CreateContainerTemplateDefinition func(ctx context.Context, item *types.ContainerTemplateDefinition) error

+ CreateContainerTemplateSpec func(ctx context.Context, item *types.ContainerTemplateSpec) error

+ DeleteContainerTemplateDefinition func(ctx context.Context, id int64) error

+ DeleteContainerTemplateSpec func(ctx context.Context, id int64) error

+ GetContainerTemplateDefinitionByID func(ctx context.Context, id int64) (*types.ContainerTemplateDefinition, error)

+ GetContainerTemplateSpecByID func(ctx context.Context, id int64) (*types.ContainerTemplateSpec, error)

+ ListContainerTemplateBySpecID func(ctx context.Context, specID int64) ([]*types.ContainerTemplate, error)

+ ListContainerTemplateDefinitionByImageIDs func(ctx context.Context, imageIDs []int64) ([]*types.ContainerTemplateDefinition, error)

+ ListContainerTemplateDefinitionBySpecID func(ctx context.Context, specID int64) ([]*types.ContainerTemplateDefinition, error)

+ ListContainerTemplateSpec func(ctx context.Context) ([]*types.ContainerTemplateSpec, error)

+ MarkOutboxEventFailed func(ctx context.Context, id int64) error

+ PageContainerTemplateSpec func(ctx context.Context, pagination *types.Pagination) ([]*types.ContainerTemplateSpec, int64, error)

+ UpdateContainerTemplateDefinition func(ctx context.Context, item *types.ContainerTemplateDefinition) error

+ UpdateContainerTemplateSpec func(ctx context.Context, item *types.ContainerTemplateSpec) error

type ContainerService

+ CreateContainerTemplateDefinition func(ctx context.Context, item *types.ContainerTemplateDefinition) error

+ CreateContainerTemplateSpec func(ctx context.Context, item *types.ContainerTemplateSpec) error

+ DeleteContainerTemplateSpec func(ctx context.Context, id int64) error

+ GetContainerImageUsage func(ctx context.Context, imageID int64) (*types.ContainerImageUsage, error)

+ GetContainerTemplateDefinitionByID func(ctx context.Context, id int64) (*types.ContainerTemplateDefinition, error)

+ GetContainerTemplateSpecByID func(ctx context.Context, id int64) (*types.ContainerTemplateSpec, error)

+ ImportContainerTemplate func(ctx context.Context, item *types.ContainerTemplateExport) (*types.ContainerTemplateExport, error)

+ ListContainerTemplateBySpecID func(ctx context.Context, specID int64) ([]*types.ContainerTemplate, error)

+ ListContainerTemplateSpec func(ctx context.Context) ([]*types.ContainerTemplateSpec, error)

+ PageContainerTemplateSpec func(ctx context.Context, pagination *types.Pagination) (*types.PageResult, error)

+ UpdateContainerTemplateDefinition func(ctx context.Context, item *types.ContainerTemplateDefinition) error

+ UpdateContainerTemplateSpec func(ctx context.Context, item *types.ContainerTemplateSpec) error

type DagOrchestrator

+ GetRunningInfo func(ctx context.Context, analysisID int64) (*DagRunningInfo, error)

+ Name func() string

+ PersistsGraphOnSave func() bool

+ type DagRunningInfo struct

+ AnalysisID int64

+ MaxConcurrency int

+ PollIntervalMs int64

+ QueueSize int

+ StartedAt time.Time

+ Status string

+ StopRequested bool

+ TaskName string

+ TimeoutSeconds int64

+ UpdatedAt time.Time

type DataService

+ EnsureDatasetDir func(ctx context.Context, datasetID int64, projectID string) (string, error)

type WorkflowRepository

+ UpdateWorkflowDagDefinition func(ctx context.Context, workflowID int64, dagDefinition string) error

type WorkflowService

+ GetWorkflowVisByWorkflow func(ctx context.Context, workflow *types.Workflow) (map[string]any, error)

+ ScriptToNode func(ctx context.Context, workflowID int64, scriptID int64) (map[string]any, error)

+ UpdateWorkflowDagDefinition func(ctx context.Context, workflowID int64, dagDefinition string) error

v0.1.3

Sep 1, 2026

v0.1.2

Aug 31, 2026

Changes in this version

+ type AISummaryRepository interface

+ CreateAISummary func(ctx context.Context, item *types.AISummary) error

+ DeleteAISummary func(ctx context.Context, id int64) error

+ GetAISummaryByID func(ctx context.Context, id int64) (*types.AISummary, error)

+ ListAISummariesByOwner func(ctx context.Context, ownerType types.SummaryOwnerType, ownerID int64) ([]*types.AISummary, error)

+ UpdateAISummary func(ctx context.Context, item *types.AISummary) error

+ type AISummaryService interface

+ CreateAISummary func(ctx context.Context, ownerType types.SummaryOwnerType, ownerID int64) (*types.AISummary, error)

+ DeleteAISummary func(ctx context.Context, id int64) error

+ GetAISummaryByID func(ctx context.Context, id int64) (*types.AISummary, error)

+ GetAISummaryInput func(ctx context.Context, ownerType types.SummaryOwnerType, ownerID int64) (*types.AISummaryInput, error)

+ ListAISummariesByOwner func(ctx context.Context, ownerType types.SummaryOwnerType, ownerID int64) ([]*types.AISummary, error)

+ RegenerateAISummary func(ctx context.Context, id int64) (*types.AISummary, error)

type AnalysisRepository

+ ListAnalysisNodesByProjectIDAndStatus func(ctx context.Context, projectID int64, status string) ([]*types.AnalysisNode, error)

type ProjectRepository

+ AddProjectLiterature func(ctx context.Context, pl *types.ProjectLiterature) error

+ CreateLiterature func(ctx context.Context, literature *types.Literature) error

+ DeleteLiterature func(ctx context.Context, literatureID int64) error

+ DeleteProjectLiterature func(ctx context.Context, projectID string, literatureID int64) error

+ DeleteProjectLiteratureByLiteratureID func(ctx context.Context, literatureID int64) error

+ ExistsProjectLiterature func(ctx context.Context, projectID string, literatureID int64) (bool, error)

+ GetLiteratureByID func(ctx context.Context, literatureID int64) (*types.Literature, error)

+ ListLiteratureByProjectID func(ctx context.Context, projectID string) ([]*types.Literature, error)

+ PageLiteratureByProjectID func(ctx context.Context, pagination *types.Pagination, projectID string) ([]*types.Literature, int64, error)

+ PageLiteraturePool func(ctx context.Context, pagination *types.Pagination, projectID string) ([]*types.LiteraturePoolItem, int64, error)

+ UpdateLiterature func(ctx context.Context, literature *types.Literature) error

type ProjectService

+ AddLiterature func(ctx context.Context, userID string, literature *types.Literature) (*types.Literature, error)

+ BindLiteratureToProject func(ctx context.Context, userID string, literatureID int64) error

+ DeleteLiterature func(ctx context.Context, userID string, literatureID int64) error

+ GetLiteratureDetailByID func(ctx context.Context, userID string, literatureID int64) (*types.Literature, error)

+ GetProjectReportByID func(ctx context.Context, reportID int64) (*types.ProjectReport, error)

+ ListLiteratureByProjectID func(ctx context.Context, userID string) ([]*types.Literature, error)

+ PageLiteratureByProjectID func(ctx context.Context, userID string, pagination *types.Pagination) ([]*types.Literature, int64, error)

+ PageLiteraturePool func(ctx context.Context, userID string, pagination *types.Pagination) ([]*types.LiteraturePoolItem, int64, error)

+ UnbindLiteratureFromProject func(ctx context.Context, userID string, literatureID int64) error

+ UpdateLiterature func(ctx context.Context, userID string, literature *types.Literature) error

v0.1.1

Aug 27, 2026

Changes in this version

+ var ErrInvalidDagDefinitionJSON = stderrs.New("dag_definition is not valid JSON format")

+ type AnalysisRepository interface

+ ClaimNextReadyNode func(ctx context.Context, analysisID int64, fromStatus string, toStatus string) (*types.AnalysisNode, error)

+ CreateAnalysis func(ctx context.Context, item *types.Analysis) error

+ CreateAnalysisEdges func(ctx context.Context, items []*types.AnalysisEdge) error

+ CreateAnalysisNodes func(ctx context.Context, items []*types.AnalysisNode) error

+ DeleteAnalysisByID func(ctx context.Context, id int64) error

+ DeleteAnalysisEdgesByAnalysisID func(ctx context.Context, analysisID int64) error

+ DeleteAnalysisNodeByID func(ctx context.Context, id int64) error

+ DeleteAnalysisNodesByAnalysisID func(ctx context.Context, analysisID int64) error

+ GetAnalysisByAnalysisID func(ctx context.Context, analysisID string) (*types.Analysis, error)

+ GetAnalysisByID func(ctx context.Context, analysisID int64) (*types.Analysis, error)

+ GetAnalysisNodeByAnalysisNodeID func(ctx context.Context, analysisNodeID string) (*types.AnalysisNode, error)

+ GetAnalysisNodeByID func(ctx context.Context, id int64) (*types.AnalysisNode, error)

+ GetAnalysisNodeByNodeID func(ctx context.Context, analysisID int64, nodeID string) (*types.AnalysisNode, error)

+ ListAnalysisByJobStatus func(ctx context.Context, jobStatus string) ([]*types.Analysis, error)

+ ListAnalysisByProjectID func(ctx context.Context, projectID int64, query *types.AnalysisQuey) ([]*types.Analysis, error)

+ ListAnalysisByWorkflowID func(ctx context.Context, workflowID string) ([]*types.Analysis, error)

+ ListAnalysisEdgesByAnalysisID func(ctx context.Context, analysisID int64) ([]*types.AnalysisEdge, error)

+ ListAnalysisNodesByAnalysisID func(ctx context.Context, analysisID int64) ([]*types.AnalysisNode, error)

+ ListAnalysisNodesByProjectIDAndScriptID func(ctx context.Context, projectID, scriptID int64) ([]*types.AnalysisNode, error)

+ PageAnalysisByProjectID func(ctx context.Context, pagination *types.Pagination, projectID int64, ...) ([]*types.Analysis, int64, error)

+ PageAnalysisNodesByProjectID func(ctx context.Context, pagination *types.Pagination, projectID, scriptID int64) ([]*types.AnalysisNode, int64, error)

+ TryMarkAnalysisRunning func(ctx context.Context, analysisID int64, now time.Time, staleBefore time.Time) (bool, error)

+ UpdateAnalysisByAnalysisID func(ctx context.Context, analysisID string, values map[string]any) error

+ UpdateAnalysisByID func(ctx context.Context, analysisID int64, values map[string]any) error

+ UpdateAnalysisNodeByAnalysisNodeID func(ctx context.Context, analysisNodeID string, values map[string]any) error

+ UpdateAnalysisNodeByID func(ctx context.Context, id int64, values map[string]any) error

+ WithTransaction func(ctx context.Context, fn func(AnalysisRepository) error) error

+ type AnalysisService interface

+ DeleteAnalysis func(ctx context.Context, id int64) error

+ DeleteAnalysisNode func(ctx context.Context, id int64) error

+ GetAnalysisByAnalysisID func(ctx context.Context, analysisID string) (*types.Analysis, error)

+ GetAnalysisByID func(ctx context.Context, analysisID int64) (*types.Analysis, error)

+ GetAnalysisNodeByAnalysisNodeID func(ctx context.Context, analysisNodeID string) (*types.AnalysisNode, error)

+ GetAnalysisNodeByID func(ctx context.Context, id int64) (*types.AnalysisNode, error)

+ ListAnalysisByProjectID func(ctx context.Context, projectID int64, query *types.AnalysisQuey) ([]*types.Analysis, error)

+ ListAnalysisByWorkflowID func(ctx context.Context, workflowID string) ([]*types.Analysis, error)

+ ListAnalysisNodesByAnalysisID func(ctx context.Context, analysisID int64) ([]*types.AnalysisNode, error)

+ ListAnalysisNodesByProjectIDAndScriptID func(ctx context.Context, projectID, scriptID int64) ([]*types.AnalysisNode, error)

+ PageAnalysisByProjectID func(ctx context.Context, pagination *types.Pagination, projectID int64, ...) ([]*types.Analysis, int64, error)

+ SaveAnalysisController func(ctx context.Context, input *types.AnalysisControllerSaveInput) (*types.Analysis, error)

+ UpdateAnalysisByID func(ctx context.Context, analysisID int64, values map[string]any) error

+ UpdateAnalysisNodeByID func(ctx context.Context, analysisNodeID int64, values map[string]any) error

+ type AuthTokenRepository interface

+ CreateToken func(ctx context.Context, token *types.AuthToken) error

+ DeleteExpiredTokens func(ctx context.Context) error

+ DeleteToken func(ctx context.Context, id string) error

+ GetTokenByValue func(ctx context.Context, tokenValue string) (*types.AuthToken, error)

+ GetTokensByUserID func(ctx context.Context, userID string) ([]*types.AuthToken, error)

+ RevokeTokensByUserID func(ctx context.Context, userID string) error

+ UpdateToken func(ctx context.Context, token *types.AuthToken) error

+ type ContainerRepository interface

+ CountContainerInstanceByStatuses func(ctx context.Context, statuses []types.ContainerStatus) (int64, error)

+ CountPendingOutboxEvents func(ctx context.Context, eventTypes ...string) (int64, error)

+ CountPendingOutboxEventsByType func(ctx context.Context, eventType string) (int64, error)

+ CreateAppSession func(ctx context.Context, item *types.AppSession) error

+ CreateContainerImage func(ctx context.Context, item *types.ContainerImage) error

+ CreateContainerInstance func(ctx context.Context, item *types.ContainerInstance) error

+ CreateContainerTemplate func(ctx context.Context, item *types.ContainerTemplate) error

+ CreateOutboxEvent func(ctx context.Context, item *types.OutboxEvent) error

+ DeleteAppSession func(ctx context.Context, id int64) error

+ DeleteContainerImage func(ctx context.Context, id int64) error

+ DeleteContainerInstance func(ctx context.Context, id int64) error

+ DeleteContainerTemplate func(ctx context.Context, id int64) error

+ GetAppSessionByID func(ctx context.Context, id int64) (*types.AppSession, error)

+ GetContainerImageByID func(ctx context.Context, id int64) (*types.ContainerImage, error)

+ GetContainerInstanceByID func(ctx context.Context, id int64) (*types.ContainerInstance, error)

+ GetContainerInstanceByOwner func(ctx context.Context, ownerType types.ContainerOwnerType, ownerID int64) (*types.ContainerInstance, error)

+ GetContainerInstanceByRuntimeID func(ctx context.Context, runtimeID string) (*types.ContainerInstance, error)

+ GetContainerTemplateByID func(ctx context.Context, id int64) (*types.ContainerTemplate, error)

+ GetProjectByProjectID func(ctx context.Context, projectID string) (*types.Project, error)

+ ListAppSession func(ctx context.Context) ([]*types.AppSession, error)

+ ListContainerImage func(ctx context.Context) ([]*types.ContainerImage, error)

+ ListContainerInstance func(ctx context.Context) ([]*types.ContainerInstance, error)

+ ListContainerInstanceByOwnerTypeAndOwnerIDs func(ctx context.Context, ownerType types.ContainerOwnerType, ownerIDs []int64) ([]*types.ContainerInstance, error)

+ ListContainerTemplate func(ctx context.Context) ([]*types.ContainerTemplate, error)

+ ListPendingOutboxEvent func(ctx context.Context, limit int) ([]*types.OutboxEvent, error)

+ ListPendingOutboxEventsByType func(ctx context.Context, eventType string, limit int) ([]*types.OutboxEvent, error)

+ MarkOutboxEventPending func(ctx context.Context, id int64) error

+ MarkOutboxEventProcessing func(ctx context.Context, id int64) error

+ MarkOutboxEventSent func(ctx context.Context, id int64) error

+ PageAppSessionByUserID func(ctx context.Context, userID string, pagination *types.Pagination, ...) ([]*types.AppSession, int64, error)

+ PageContainerImage func(ctx context.Context, pagination *types.Pagination) ([]*types.ContainerImage, int64, error)

+ PageContainerInstance func(ctx context.Context, pagination *types.Pagination) ([]*types.ContainerInstance, int64, error)

+ PageContainerTemplate func(ctx context.Context, pagination *types.Pagination) ([]*types.ContainerTemplate, int64, error)

+ PageOutboxEvent func(ctx context.Context, pagination *types.Pagination) ([]*types.OutboxEvent, int64, error)

+ UpdateAppSession func(ctx context.Context, item *types.AppSession) error

+ UpdateContainerImage func(ctx context.Context, item *types.ContainerImage) error

+ UpdateContainerInstance func(ctx context.Context, item *types.ContainerInstance) error

+ UpdateContainerTemplate func(ctx context.Context, item *types.ContainerTemplate) error

+ WithTransaction func(ctx context.Context, fn func(ContainerRepository) error) error

+ type ContainerService interface

+ CreateAppSessionByTemplate func(ctx context.Context, userID string, projectID int64, containerTemplateID int64, ...) (*types.AppSession, error)

+ CreateAppSessionByTemplateForAnalysisNode func(ctx context.Context, userID string, projectID int64, containerTemplateID int64, ...) (*types.AppSession, error)

+ CreateContainerImage func(ctx context.Context, item *types.ContainerImage) error

+ CreateContainerTemplate func(ctx context.Context, item *types.ContainerTemplate) error

+ DeleteAppSession func(ctx context.Context, userID string, appSessionID int64) error

+ DeleteContainerImage func(ctx context.Context, id int64) error

+ DeleteContainerInstancesByOwnerTypeAndOwnerIDs func(ctx context.Context, ownerType types.ContainerOwnerType, ownerIDs []int64) error

+ DeleteContainerTemplate func(ctx context.Context, id int64) error

+ GetAppSessionByID func(ctx context.Context, userID string, appSessionID int64) (*types.AppSession, error)

+ GetContainerImageByID func(ctx context.Context, id int64) (*types.ContainerImage, error)

+ GetContainerTemplateByID func(ctx context.Context, id int64) (*types.ContainerTemplate, error)

+ ListAppSessionByUserID func(ctx context.Context, userID string) ([]*types.AppSession, error)

+ ListContainerImage func(ctx context.Context) ([]*types.ContainerImage, error)

+ ListContainerInstanceByOwnerTypeAndOwnerIDs func(ctx context.Context, ownerType types.ContainerOwnerType, ownerIDs []int64) ([]*types.ContainerInstance, error)

+ ListContainerTemplate func(ctx context.Context) ([]*types.ContainerTemplate, error)

+ PageAppSessionByUserID func(ctx context.Context, userID string, pagination *types.Pagination, ...) (*types.PageResult, error)

+ PageContainerImage func(ctx context.Context, pagination *types.Pagination) (*types.PageResult, error)

+ PageContainerInstance func(ctx context.Context, pagination *types.Pagination) (*types.PageResult, error)

+ PageContainerTemplate func(ctx context.Context, pagination *types.Pagination) (*types.PageResult, error)

+ PageOutboxEvent func(ctx context.Context, pagination *types.Pagination) (*types.PageResult, error)

+ RecreateAppSessionContainer func(ctx context.Context, userID string, appSessionID int64) error

+ StartAppSession func(ctx context.Context, userID string, appSessionID int64) error

+ StopAppSession func(ctx context.Context, userID string, appSessionID int64) error

+ UpdateContainerImage func(ctx context.Context, item *types.ContainerImage) error

+ UpdateContainerTemplate func(ctx context.Context, item *types.ContainerTemplate) error

+ type DagOrchestrator interface

+ RecoverRunningAnalyses func(ctx context.Context) (int, error)

+ StartAsync func(ctx context.Context, analysisID int64) error

+ StopAsync func(ctx context.Context, analysisID int64) error

+ type DataRepository interface

+ CreateDataset func(ctx context.Context, dataset *types.Dataset) error

+ CreateDatasetFile func(ctx context.Context, datasetFile *types.DatasetFile) error

+ CreateDatasetSample func(ctx context.Context, datasetSample *types.DatasetSample) error

+ CreateFile func(ctx context.Context, file *types.File) error

+ CreateProjectDataset func(ctx context.Context, projectDataset *types.ProjectDataset) error

+ CreateSample func(ctx context.Context, sample *types.Sample) error

+ CreateSampleFile func(ctx context.Context, sampleFile *types.SampleFile) error

+ DeleteDataset func(ctx context.Context, id int64) error

+ DeleteDatasetFile func(ctx context.Context, id int64) error

+ DeleteDatasetSample func(ctx context.Context, id int64) error

+ DeleteDatasetWithRelations func(ctx context.Context, id int64) error

+ DeleteFile func(ctx context.Context, id int64) error

+ DeleteFileWithRelations func(ctx context.Context, id int64) error

+ DeleteProjectDataset func(ctx context.Context, id int64) error

+ DeleteSample func(ctx context.Context, id int64) error

+ DeleteSampleFile func(ctx context.Context, id int64) error

+ DeleteSampleWithRelations func(ctx context.Context, id int64) error

+ ExistsDatasetByID func(ctx context.Context, id int64) (bool, error)

+ ExistsDatasetFile func(ctx context.Context, datasetID, fileID int64) (bool, error)

+ ExistsFileByID func(ctx context.Context, id int64) (bool, error)

+ ExistsProjectByID func(ctx context.Context, id string) (bool, error)

+ ExistsSampleByID func(ctx context.Context, id int64) (bool, error)

+ GetDatasetByID func(ctx context.Context, id int64) (*types.Dataset, error)

+ GetDatasetFileByID func(ctx context.Context, id int64) (*types.DatasetFile, error)

+ GetDatasetSampleByID func(ctx context.Context, id int64) (*types.DatasetSample, error)

+ GetFileByFileID func(ctx context.Context, fileID string) (*types.File, error)

+ GetFileByID func(ctx context.Context, id int64) (*types.File, error)

+ GetFileByPath func(ctx context.Context, path string) (*types.File, error)

+ GetProjectDatasetByID func(ctx context.Context, id int64) (*types.ProjectDataset, error)

+ GetSampleByID func(ctx context.Context, id int64) (*types.Sample, error)

+ GetSampleFileByID func(ctx context.Context, id int64) (*types.SampleFile, error)

+ ListDataset func(ctx context.Context) ([]*types.Dataset, error)

+ ListDatasetFile func(ctx context.Context) ([]*types.DatasetFile, error)

+ ListDatasetSample func(ctx context.Context) ([]*types.DatasetSample, error)

+ ListFile func(ctx context.Context) ([]*types.File, error)

+ ListFileByProjectID func(ctx context.Context, projectID string, roles []string) ([]*types.FileWithDatasetInfo, error)

+ ListProjectDataset func(ctx context.Context) ([]*types.ProjectDataset, error)

+ ListSample func(ctx context.Context) ([]*types.Sample, error)

+ ListSampleByProjectID func(ctx context.Context, projectID string) ([]*types.SampleWithDatasetInfo, error)

+ ListSampleFile func(ctx context.Context) ([]*types.SampleFile, error)

+ PageDatasetByProjectID func(ctx context.Context, pagination *types.Pagination, query *types.QueryDataset, ...) ([]*types.Dataset, int64, error)

+ PageFileByProjectID func(ctx context.Context, pagination *types.Pagination, projectID string, ...) ([]*types.FileWithDatasetInfo, int64, error)

+ PageSampleByProjectID func(ctx context.Context, pagination *types.Pagination, projectID string) ([]*types.SampleWithDatasetInfo, int64, error)

+ UpdateDataset func(ctx context.Context, dataset *types.Dataset) error

+ UpdateDatasetFile func(ctx context.Context, datasetFile *types.DatasetFile) error

+ UpdateDatasetSample func(ctx context.Context, datasetSample *types.DatasetSample) error

+ UpdateFile func(ctx context.Context, file *types.File) error

+ UpdateProjectDataset func(ctx context.Context, projectDataset *types.ProjectDataset) error

+ UpdateSample func(ctx context.Context, sample *types.Sample) error

+ UpdateSampleFile func(ctx context.Context, sampleFile *types.SampleFile) error

+ WithTransaction func(ctx context.Context, fn func(DataRepository) error) error

+ type DataService interface

+ AddFileToDataset func(ctx context.Context, req *types.AddFileToDatasetRequest) (*types.AddFileToDatasetResponse, error)

+ CreateDataset func(ctx context.Context, dataset *types.Dataset) error

+ CreateDatasetFile func(ctx context.Context, datasetFile *types.DatasetFile) error

+ CreateDatasetSample func(ctx context.Context, datasetSample *types.DatasetSample) error

+ CreateFile func(ctx context.Context, file *types.File) error

+ CreateProjectDataset func(ctx context.Context, projectDataset *types.ProjectDataset) error

+ CreateSample func(ctx context.Context, sample *types.Sample) error

+ CreateSampleFile func(ctx context.Context, sampleFile *types.SampleFile) error

+ DeleteDataset func(ctx context.Context, id int64) error

+ DeleteDatasetFile func(ctx context.Context, id int64) error

+ DeleteDatasetSample func(ctx context.Context, id int64) error

+ DeleteFile func(ctx context.Context, id int64) error

+ DeleteProjectDataset func(ctx context.Context, id int64) error

+ DeleteSample func(ctx context.Context, id int64) error

+ DeleteSampleFile func(ctx context.Context, id int64) error

+ GetDatasetByID func(ctx context.Context, id int64) (*types.Dataset, error)

+ GetDatasetFileByID func(ctx context.Context, id int64) (*types.DatasetFile, error)

+ GetDatasetSampleByID func(ctx context.Context, id int64) (*types.DatasetSample, error)

+ GetFileByFileID func(ctx context.Context, fileID string) (*types.File, error)

+ GetFileByID func(ctx context.Context, id int64) (*types.File, error)

+ GetProjectDatasetByID func(ctx context.Context, id int64) (*types.ProjectDataset, error)

+ GetSampleByID func(ctx context.Context, id int64) (*types.Sample, error)

+ GetSampleFileByID func(ctx context.Context, id int64) (*types.SampleFile, error)

+ ListDataset func(ctx context.Context) ([]*types.Dataset, error)

+ ListDatasetFile func(ctx context.Context) ([]*types.DatasetFile, error)

+ ListDatasetSample func(ctx context.Context) ([]*types.DatasetSample, error)

+ ListFile func(ctx context.Context) ([]*types.File, error)

+ ListFileByProjectID func(ctx context.Context, projectID string, roles []string) ([]*types.FileWithDatasetInfo, error)

+ ListFileByProjectIDGroupByRole func(ctx context.Context, projectID string) ([]*types.FileByProjectRoleGroup, error)

+ ListProjectDataset func(ctx context.Context) ([]*types.ProjectDataset, error)

+ ListSample func(ctx context.Context) ([]*types.Sample, error)

+ ListSampleByProjectID func(ctx context.Context, projectID string) ([]*types.SampleWithDatasetInfo, error)

+ ListSampleFile func(ctx context.Context) ([]*types.SampleFile, error)

+ PageDatasetByProjectID func(ctx context.Context, pagination *types.Pagination, query *types.QueryDataset, ...) (*types.PageResult, error)

+ PageFileByProjectID func(ctx context.Context, pagination *types.Pagination, projectID string, ...) (*types.PageResult, error)

+ PageSampleByProjectID func(ctx context.Context, pagination *types.Pagination, projectID string) (*types.PageResult, error)

+ UpdateDataset func(ctx context.Context, dataset *types.Dataset) error

+ UpdateDatasetFile func(ctx context.Context, datasetFile *types.DatasetFile) error

+ UpdateDatasetSample func(ctx context.Context, datasetSample *types.DatasetSample) error

+ UpdateFile func(ctx context.Context, file *types.File) error

+ UpdateProjectDataset func(ctx context.Context, projectDataset *types.ProjectDataset) error

+ UpdateSample func(ctx context.Context, sample *types.Sample) error

+ UpdateSampleFile func(ctx context.Context, sampleFile *types.SampleFile) error

+ type DataflowDagOrchestrator interface

+ StartAsyncV3 func(ctx context.Context, projectID int64, analysisID int64, ...) error

+ type DynamicDagOrchestrator interface

+ StartAsyncV2 func(ctx context.Context, analysisID int64, parseAnalysisResult map[string]any, ...) error

+ type LLMRepository interface

+ CreateLLMConversation func(ctx context.Context, conversation *types.LLMConversation) error

+ CreateLLMSession func(ctx context.Context, session *types.LLMSession) error

+ DeleteLLMConversation func(ctx context.Context, id int64) error

+ DeleteLLMSession func(ctx context.Context, id int64) error

+ DeleteLLMSessionWithRelations func(ctx context.Context, id int64) error

+ GetLLMConversationByID func(ctx context.Context, id int64) (*types.LLMConversation, error)

+ GetLLMConversationByIDAndProjectID func(ctx context.Context, id int64, projectID int64) (*types.LLMConversation, error)

+ GetLLMSessionByID func(ctx context.Context, id int64) (*types.LLMSession, error)

+ GetLLMSessionByIDAndProjectID func(ctx context.Context, id int64, projectID int64) (*types.LLMSession, error)

+ ListLLMConversationBySessionID func(ctx context.Context, llmSessionID int64) ([]*types.LLMConversation, error)

+ ListLLMSessionByProjectID func(ctx context.Context, projectID int64) ([]*types.LLMSession, error)

+ UpdateLLMConversation func(ctx context.Context, conversation *types.LLMConversation) error

+ UpdateLLMSession func(ctx context.Context, session *types.LLMSession) error

+ type LLMService interface

+ CreateLLMConversation func(ctx context.Context, userID string, conversation *types.LLMConversation) error

+ CreateLLMSession func(ctx context.Context, userID string, session *types.LLMSession) error

+ DeleteLLMConversation func(ctx context.Context, userID string, id int64) error

+ DeleteLLMSession func(ctx context.Context, userID string, id int64) error

+ GetLLMConversationByID func(ctx context.Context, userID string, id int64) (*types.LLMConversation, error)

+ GetLLMSessionByID func(ctx context.Context, userID string, id int64) (*types.LLMSession, error)

+ ListLLMConversationBySessionID func(ctx context.Context, userID string, llmSessionID int64) ([]*types.LLMConversation, error)

+ ListLLMSession func(ctx context.Context, userID string) ([]*types.LLMSession, error)

+ UpdateLLMConversation func(ctx context.Context, userID string, conversation *types.LLMConversation) error

+ UpdateLLMSession func(ctx context.Context, userID string, session *types.LLMSession) error

+ type NodeOrchestrator interface

+ StartAsync func(ctx context.Context, analysisNodeID int64) error

+ StopAsync func(ctx context.Context, analysisNodeID int64) error

+ type ProjectRepository interface

+ ActivateUserProject func(ctx context.Context, userID, projectID string) error

+ AddProjectReport func(ctx context.Context, report *types.ProjectReport) error

+ AddUserProject func(ctx context.Context, up *types.UserProject) error

+ CreateProject func(ctx context.Context, project *types.Project) error

+ DeleteProjectReport func(ctx context.Context, projectID string, reportID int64) error

+ DeleteUserProject func(ctx context.Context, userID, projectID string) error

+ ExistsUserProject func(ctx context.Context, userID, projectID string) (bool, error)

+ GetActiveProjectByUserID func(ctx context.Context, userID string) (*types.Project, error)

+ GetProjectByID func(ctx context.Context, id int64) (*types.Project, error)

+ GetProjectReportByID func(ctx context.Context, reportID int64) (*types.ProjectReport, error)

+ GetUserProject func(ctx context.Context, userID, projectID string) (*types.UserProject, error)

+ GetUserProjectByShareCode func(ctx context.Context, shareCode string) (*types.UserProject, error)

+ ListProjectByUserID func(ctx context.Context, userID string) ([]*types.ProjectListItem, error)

+ ListProjectReportByProjectID func(ctx context.Context, projectID string) ([]*types.ProjectReport, error)

+ PageProjectReportByProjectID func(ctx context.Context, pagination *types.Pagination, projectID string) ([]*types.ProjectReport, int64, error)

+ UpdateProjectReport func(ctx context.Context, report *types.ProjectReport) error

+ UpdateProjectSharing func(ctx context.Context, userID, projectID string, enabled bool, shareCode string) error

+ type ProjectService interface

+ ActivateUserProject func(ctx context.Context, userID, projectID string) error

+ AddProjectReport func(ctx context.Context, userID string, report *types.ProjectReport) error

+ AddUserProject func(ctx context.Context, userID, projectID string) error

+ AddUserProjectByShareCode func(ctx context.Context, userID, shareCode string) error

+ CreateDefaultProjectForUser func(ctx context.Context, userID, username string) error

+ CreateProjectForUser func(ctx context.Context, userID string, project *types.Project) (*types.Project, error)

+ DeleteProjectReport func(ctx context.Context, userID string, reportID int64) error

+ DeleteUserProject func(ctx context.Context, userID, projectID string) error

+ GetActiveProjectByUserID func(ctx context.Context, userID string) (*types.Project, error)

+ GetActiveProjectDirByUserID func(ctx context.Context, userID, baseDir string) (*types.Project, string, error)

+ GetProjectByID func(ctx context.Context, id int64) (*types.Project, error)

+ GetProjectReportDetailByID func(ctx context.Context, userID string, reportID int64) (*types.ProjectReport, error)

+ ListProjectByUserID func(ctx context.Context, userID string) ([]*types.ProjectListItem, error)

+ ListProjectReportByProjectID func(ctx context.Context, userID, projectID string) ([]*types.ProjectReport, error)

+ PageProjectReportByProjectID func(ctx context.Context, userID, projectID string, pagination *types.Pagination) ([]*types.ProjectReport, int64, error)

+ UpdateProjectReport func(ctx context.Context, userID string, report *types.ProjectReport) error

+ UpdateProjectSharing func(ctx context.Context, userID, projectID string, enabled bool) (string, error)

+ type SheetFileService interface

+ ReadWorkbook func(ctx context.Context, filePath, format string) (*WorkbookReadResult, error)

+ WriteWorkbook func(ctx context.Context, filePath, format string, workbookData map[string]any) (*WorkbookWriteResult, error)

+ type StoreRepository interface

+ CreateStore func(ctx context.Context, item *types.Store) error

+ DeleteStore func(ctx context.Context, id int64) error

+ GetStoreByID func(ctx context.Context, id int64) (*types.Store, error)

+ GetStoreByStoreID func(ctx context.Context, storeID string) (*types.Store, error)

+ GetStoreByURL func(ctx context.Context, rawURL string) (*types.Store, error)

+ ListInstalledScriptMap func(ctx context.Context, activeProjectID int64, storeIDs []int64) (map[int64]int64, error)

+ ListInstalledWorkflowMap func(ctx context.Context, activeProjectID int64, storeIDs []int64) (map[int64]uint, error)

+ ListStore func(ctx context.Context) ([]*types.Store, error)

+ PageStore func(ctx context.Context, pagination *types.Pagination, query *types.StorePageQuery) ([]*types.Store, int64, error)

+ UpdateStore func(ctx context.Context, item *types.Store) error

+ type StoreService interface

+ CreateStore func(ctx context.Context, item *types.Store) error

+ DeleteStore func(ctx context.Context, id int64) error

+ GetStoreByID func(ctx context.Context, id int64) (*types.Store, error)

+ GetStoreByStoreID func(ctx context.Context, storeID string) (*types.Store, error)

+ GetStoreByURL func(ctx context.Context, rawURL string) (*types.Store, error)

+ ListStore func(ctx context.Context) ([]*types.Store, error)

+ PageStore func(ctx context.Context, userID string, pagination *types.Pagination, ...) (*types.PageResult, error)

+ UpdateStore func(ctx context.Context, item *types.Store) error

+ type TaskEnqueuer interface

+ Enqueue func(task *asynq.Task, opts ...asynq.Option) (*asynq.TaskInfo, error)

+ type UserRepository interface

+ CreateUser func(ctx context.Context, user *types.User) error

+ DeleteUser func(ctx context.Context, id string) error

+ GetUserByEmail func(ctx context.Context, email string) (*types.User, error)

+ GetUserByID func(ctx context.Context, id string) (*types.User, error)

+ GetUserByTenantID func(ctx context.Context, tenantID uint64) (*types.User, error)

+ GetUserByUsername func(ctx context.Context, username string) (*types.User, error)

+ ListUsers func(ctx context.Context, offset, limit int) ([]*types.User, error)

+ SearchUsers func(ctx context.Context, query string, limit int) ([]*types.User, error)

+ UpdateUser func(ctx context.Context, user *types.User) error

+ type UserService interface

+ ChangePassword func(ctx context.Context, userID string, oldPassword, newPassword string) error

+ DeleteUser func(ctx context.Context, id string) error

+ GenerateTokens func(ctx context.Context, user *types.User) (accessToken, refreshToken string, err error)

+ GetCurrentUser func(ctx context.Context) (*types.User, error)

+ GetUserByEmail func(ctx context.Context, email string) (*types.User, error)

+ GetUserByID func(ctx context.Context, id string) (*types.User, error)

+ GetUserByTenantID func(ctx context.Context, tenantID uint64) (*types.User, error)

+ GetUserByUsername func(ctx context.Context, username string) (*types.User, error)

+ Login func(ctx context.Context, req *types.LoginRequest) (*types.LoginResponse, error)

+ RefreshToken func(ctx context.Context, refreshToken string) (accessToken, newRefreshToken string, err error)

+ Register func(ctx context.Context, req *types.RegisterRequest) (*types.User, error)

+ RevokeToken func(ctx context.Context, token string) error

+ SearchUsers func(ctx context.Context, query string, limit int) ([]*types.User, error)

+ UpdateUser func(ctx context.Context, user *types.User) error

+ ValidatePassword func(ctx context.Context, userID string, password string) error

+ ValidateToken func(ctx context.Context, token string) (*types.User, error)

+ type WorkbookReadResult struct

+ FilePath string

+ Format string

+ WorkbookData map[string]any

+ type WorkbookWriteResult struct

+ FilePath string

+ Format string

+ type WorkflowRepository interface

+ CreateScript func(ctx context.Context, script *types.Script) error

+ CreateWorkflow func(ctx context.Context, workflow *types.Workflow) error

+ DeleteScriptByID func(ctx context.Context, id int64) error

+ DeleteWorkflowByID func(ctx context.Context, id int64) error

+ ExistsScriptInProjectByScriptID func(ctx context.Context, projectID int64, scriptID string) (*types.Script, error)

+ ExistsWorkflowInProjectByWorkflowID func(ctx context.Context, projectID int64, workflowID string) (*types.Workflow, error)

+ FindScriptsByScriptIDs func(ctx context.Context, scriptIDs []string) ([]*types.Script, error)

+ GetScriptByID func(ctx context.Context, id int64) (*types.Script, error)

+ GetScriptByScriptID func(ctx context.Context, projectID int64, scriptID string) (*types.Script, error)

+ GetScriptContainerSnapshotByScriptID func(ctx context.Context, scriptID int64) (*types.ScriptContainerSnapshot, error)

+ GetWorkflowByID func(ctx context.Context, id int64) (*types.Workflow, error)

+ GetWorkflowByWorkflowID func(ctx context.Context, workflowID string) (*types.Workflow, error)

+ ListWorkflowsByProjectID func(ctx context.Context, projectID int64) ([]*types.Workflow, error)

+ PageScript func(ctx context.Context, pagination *types.Pagination, ...) ([]*types.Script, int64, error)

+ PageWorkflow func(ctx context.Context, pagination *types.Pagination, ...) ([]*types.Workflow, int64, error)

+ UpdateScript func(ctx context.Context, script *types.Script) error

+ UpdateWorkflow func(ctx context.Context, workflow *types.Workflow) error

+ type WorkflowService interface

+ CreateScript func(ctx context.Context, script *types.Script) error

+ CreateWorkflow func(ctx context.Context, workflow *types.Workflow) error

+ DeleteScript func(ctx context.Context, id int64) error

+ DeleteWorkflow func(ctx context.Context, id int64) error

+ ExistsScriptInProjectByScriptID func(ctx context.Context, projectID int64, scriptID string) (*types.Script, error)

+ ExistsWorkflowInProjectByWorkflowID func(ctx context.Context, projectID int64, workflowID string) (*types.Workflow, error)

+ GenerateScriptJSONByScriptID func(ctx context.Context, scriptID int64) (*types.ScriptJSONExportResponse, error)

+ GenerateWorkflowJSONByWorkflowID func(ctx context.Context, workflowID int64, storageBaseDir string) (*types.WorkflowJSONExportResponse, error)

+ GetFormJSONByWorkflowID func(ctx context.Context, workflowID string) ([]any, error)

+ GetScriptByID func(ctx context.Context, id int64) (*types.Script, error)

+ GetScriptByScriptID func(ctx context.Context, projectID int64, scriptID string) (*types.Script, error)

+ GetScriptContainerSnapshotByScriptID func(ctx context.Context, scriptID int64) (*types.ScriptContainerSnapshot, error)

+ GetScriptFileByScriptID func(ctx context.Context, scriptID int64) (string, string, error)

+ GetScriptFormJSONByID func(ctx context.Context, scriptID int64) ([]any, error)

+ GetWorkflowByID func(ctx context.Context, id int64) (*types.Workflow, error)

+ GetWorkflowByWorkflowID func(ctx context.Context, workflowID string) (*types.Workflow, error)

+ GetWorkflowVisByWorkflowID func(ctx context.Context, workflowID string) (map[string]any, error)

+ PageScript func(ctx context.Context, pagination *types.Pagination, ...) ([]*types.Script, int64, error)

+ PageWorkflow func(ctx context.Context, pagination *types.Pagination, ...) ([]*types.Workflow, int64, error)

+ UpdateScript func(ctx context.Context, script *types.Script) error

+ UpdateWorkflow func(ctx context.Context, workflow *types.Workflow) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL