Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2023 Changes in this version + const FileOrderByPath + const FileOrderByVersion + const OrderByCreateTime + const OrderByName + const VersionOrderByLanguage + const VersionOrderBySource + const VersionOrderByStatus + type GetFileHandler interface + Handle func(context.Context, *GetFileQuery) (*WorkflowFile, error) + func NewGetFileHandler(readModel ReadModel, workspaceReadModel workspace.WorkspaceReadModel) GetFileHandler + type GetFileQuery struct + ID string + WorkflowID string + WorkspaceID string + type GetHandler interface + Handle func(context.Context, *GetQuery) (*Workflow, error) + func NewGetHandler(readModel ReadModel, workspaceReadModel workspace.WorkspaceReadModel) GetHandler + type GetQuery struct + ID string + WorkspaceID string + type GetVersionHandler interface + Handle func(context.Context, *GetVersionQuery) (*WorkflowVersion, error) + func NewGetVersionHandler(readModel ReadModel, workspaceReadModel workspace.WorkspaceReadModel) GetVersionHandler + type GetVersionQuery struct + ID string + WorkflowID string + WorkspaceID string + type ListFilesHandler interface + Handle func(context.Context, *ListFilesQuery) ([]*WorkflowFile, int, error) + func NewListFilesHandler(readModel ReadModel, workspaceReadModel workspace.WorkspaceReadModel) ListFilesHandler + type ListFilesQuery struct + Filter *ListWorkflowFilesFilter + Pg *utils.Pagination + WorkflowID string + WorkflowVersionID string + WorkspaceID string + type ListHandler interface + Handle func(context.Context, *ListQuery) ([]*Workflow, int, error) + func NewListHandler(readModel ReadModel, workspaceReadModel workspace.WorkspaceReadModel) ListHandler + type ListQuery struct + Filter *ListWorkflowsFilter + Pg *utils.Pagination + WorkspaceID string + type ListVersionsHandler interface + Handle func(context.Context, *ListVersionsQuery) ([]*WorkflowVersion, int, error) + func NewListVersionsHandler(readModel ReadModel, workspaceReadModel workspace.WorkspaceReadModel) ListVersionsHandler + type ListVersionsQuery struct + Filter *ListWorkflowVersionsFilter + Pg *utils.Pagination + WorkflowID string + WorkspaceID string + type ListWorkflowFilesFilter struct + IDs []string + type ListWorkflowVersionsFilter struct + IDs []string + type ListWorkflowsFilter struct + Exact bool + IDs []string + SearchWord string + type Queries struct + GetByID GetHandler + GetFile GetFileHandler + GetVersion GetVersionHandler + ListFiles ListFilesHandler + ListVersions ListVersionsHandler + ListWorkflows ListHandler + func NewQueries(readModel ReadModel, workspaceReadModel workspace.WorkspaceReadModel) *Queries + type ReadModel interface + GetById func(ctx context.Context, workspaceID, id string) (*Workflow, error) + GetByName func(ctx context.Context, workspaceID, name string) (*Workflow, error) + GetFile func(ctx context.Context, id string) (*WorkflowFile, error) + GetVersion func(ctx context.Context, id string) (*WorkflowVersion, error) + List func(ctx context.Context, workspaceID string, pg *utils.Pagination, ...) ([]*Workflow, int, error) + ListFiles func(ctx context.Context, workflowVersionID string, pg *utils.Pagination, ...) ([]*WorkflowFile, int, error) + ListVersions func(ctx context.Context, workflowID string, pg *utils.Pagination, ...) ([]*WorkflowVersion, int, error) + type Workflow struct + CreatedAt time.Time + Description string + ID string + LatestVersion *WorkflowVersion + Name string + UpdatedAt time.Time + WorkspaceID string + type WorkflowFile struct + Content string + CreatedAt time.Time + ID string + Path string + UpdatedAt time.Time + WorkflowVersionID string + func (f *WorkflowFile) ToWorkflowFileInfo() *WorkflowFileInfo + type WorkflowFileInfo struct + ID string + Path string + type WorkflowParam struct + Default string + Name string + Optional bool + Type string + type WorkflowVersion struct + CreatedAt time.Time + Files []*WorkflowFileInfo + Graph string + ID string + Inputs []WorkflowParam + Language string + LanguageVersion string + MainWorkflowPath string + Message string + Metadata map[string]string + Outputs []WorkflowParam + Source string + Status string + UpdatedAt time.Time