interfaces

package

Go to main page

Versions in this module

v0

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