Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

service

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

+ const BuiltinContainerTemplateDir

+ func EnsureDefaultContainerTemplate(ctx context.Context, containerRepo interfaces.ContainerRepository) error

+ func InstallBuiltinContainerTemplates(ctx context.Context, svc interfaces.ContainerService) error

+ func SetBuiltinContainerTemplateDir(dir string)

v0.1.5

Oct 14, 2026

v0.1.4

Sep 19, 2026

v0.1.3

Sep 1, 2026

v0.1.2

Aug 31, 2026

Changes in this version

+ func NewAISummaryService(summaryRepo interfaces.AISummaryRepository, ...) interfaces.AISummaryService

v0.1.1

Aug 27, 2026

Changes in this version

+ var ErrDatasetFileAlreadyAdded = stderrs.New("dataset file already added")

+ var ErrInvalidWorkbookData = errors.New("invalid workbook data")

+ var ErrUnsupportedSheetFormat = errors.New("unsupported sheet format")

+ var ErrUserProjectActive = errors.New("user project is active")

+ func NewAnalysisService(analysisRepo interfaces.AnalysisRepository, ...) interfaces.AnalysisService

+ func NewContainerService(containerRepo interfaces.ContainerRepository, ...) interfaces.ContainerService

+ func NewDagOrchestrator(repo interfaces.AnalysisRepository, workflowRepo interfaces.WorkflowRepository, ...) interfaces.DagOrchestrator

+ func NewDataService(cfg *config.Config, dataRepo interfaces.DataRepository) interfaces.DataService

+ func NewDataflowDagOrchestratorV3(repo interfaces.AnalysisRepository, workflowRepo interfaces.WorkflowRepository, ...) interfaces.DataflowDagOrchestrator

+ func NewDynamicDagOrchestratorV2(repo interfaces.AnalysisRepository, workflowRepo interfaces.WorkflowRepository, ...) interfaces.DynamicDagOrchestrator

+ func NewLLMService(llmRepo interfaces.LLMRepository, projectSvc interfaces.ProjectService) interfaces.LLMService

+ func NewNodeOrchestrator(repo interfaces.AnalysisRepository, workflowRepo interfaces.WorkflowRepository, ...) interfaces.NodeOrchestrator

+ func NewProjectService(projectRepo interfaces.ProjectRepository) interfaces.ProjectService

+ func NewSheetFileService(cfg *config.Config) interfaces.SheetFileService

+ func NewStoreService(storeRepo interfaces.StoreRepository, projectService interfaces.ProjectService) interfaces.StoreService

+ func NewUserService(configInfo *config.Config, userRepo interfaces.UserRepository, ...) interfaces.UserService

+ func NewWorkflowService(workflowRepo interfaces.WorkflowRepository, ...) interfaces.WorkflowService

+ type BaseOperator struct

+ func (o *BaseOperator) IsFinished() bool

+ func (o *BaseOperator) Notify(ctx context.Context, signal DataflowSignal) error

+ type DataflowAnalysisNodePersistParams struct

+ AnalysisID int64

+ CommandPath string

+ DownstreamIDs []string

+ Executor string

+ InputHash string

+ InputsPatterns map[string]any

+ LogPath string

+ MaxRetry int

+ NodeID string

+ NodeName string

+ OutputDir string

+ OutputPatterns map[string]any

+ Params map[string]any

+ ParamsPath string

+ RerunReason string

+ ResolvedInputs map[string]any

+ ResolvedOutputs map[string]any

+ Retry int

+ SampleID string

+ ScriptID string

+ Status string

+ SubmitReason string

+ UpstreamIDs []string

+ WorkspaceDir string

+ type DataflowChannel struct

+ func (ch *DataflowChannel) Close(ctx context.Context) error

+ func (ch *DataflowChannel) Emit(ctx context.Context, value any) error

+ func (ch *DataflowChannel) ID() string

+ func (ch *DataflowChannel) IsClosed() bool

+ func (ch *DataflowChannel) Subscribe(op DataflowOperator)

+ type DataflowChannelSpec struct

+ ChannelID string

+ FromNodeID string

+ FromPort string

+ ToNodeID string

+ ToPort string

+ type DataflowGraphSpec struct

+ AnalysisID int64

+ Channels []DataflowChannelSpec

+ Processes []DataflowProcessSpec

+ type DataflowOperator interface

+ Notify func(ctx context.Context, signal DataflowSignal) error

+ type DataflowProcessRunRequest struct

+ AnalysisID int64

+ Inputs map[string]any

+ NodeID string

+ Reason string

+ type DataflowProcessRuntime interface

+ SubmitProcessInstance func(ctx context.Context, req DataflowProcessRunRequest) error

+ type DataflowProcessSpec struct

+ Downstream []string

+ Executor string

+ GatherField string

+ GatherMode string

+ InputKeys []string

+ Inputs map[string]any

+ MaxRetry int

+ NodeID string

+ NodeName string

+ OperatorType string

+ Outputs map[string]any

+ Params map[string]any

+ RerunReason string

+ ResolvedIn map[string]any

+ ResolvedOut map[string]any

+ Retry int

+ SampleID string

+ ScatterField string

+ ScatterMode string

+ ScriptID string

+ UpstreamIDs []string

+ type DataflowSignal struct

+ ChannelID string

+ Closed bool

+ Value any

+ type GatherOperator struct

+ type InputOperator struct

+ type ScatterOperator struct