Documentation
¶
Index ¶
- type CopilotResult
- type FixSuggestion
- type PerformanceRecommendation
- type SchemaImpact
- type SelfHealingService
- func (s *SelfHealingService) AnalyzeError(ctx context.Context, workflowID string, nodeID string, errStr string, ...) (*FixSuggestion, error)
- func (s *SelfHealingService) AnalyzeSchemaChange(ctx context.Context, oldSchema, newSchema map[string]any, workflowID string) (*SchemaImpact, error)
- func (s *SelfHealingService) AnalyzeWorkflow(ctx context.Context, wf storage.Workflow) (*PerformanceRecommendation, error)
- func (s *SelfHealingService) GenerateLogic(ctx context.Context, prompt string) (*CopilotResult, error)
- func (s *SelfHealingService) GenerateWorkflow(ctx context.Context, prompt string) (any, error)
- func (s *SelfHealingService) SuggestMapping(ctx context.Context, sourceData map[string]any, targetSchema map[string]any) (string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CopilotResult ¶
type FixSuggestion ¶
type FixSuggestion struct {
Explanation string `json:"explanation"`
Description string `json:"description,omitempty"`
FixAction string `json:"fix_action"` // "update_mapping", "add_node", "change_config"
ConfigPatch any `json:"config_patch,omitempty"`
Confidence float64 `json:"confidence"`
AutoFixable bool `json:"auto_fixable"`
}
type SchemaImpact ¶
type SelfHealingService ¶
type SelfHealingService struct {
// contains filtered or unexported fields
}
func NewSelfHealingService ¶
func NewSelfHealingService(logger hermod.Logger) *SelfHealingService
func (*SelfHealingService) AnalyzeError ¶
func (s *SelfHealingService) AnalyzeError(ctx context.Context, workflowID string, nodeID string, errStr string, sampleData any) (*FixSuggestion, error)
func (*SelfHealingService) AnalyzeSchemaChange ¶
func (s *SelfHealingService) AnalyzeSchemaChange(ctx context.Context, oldSchema, newSchema map[string]any, workflowID string) (*SchemaImpact, error)
func (*SelfHealingService) AnalyzeWorkflow ¶
func (s *SelfHealingService) AnalyzeWorkflow(ctx context.Context, wf storage.Workflow) (*PerformanceRecommendation, error)
AnalyzeWorkflow provides holistic performance and configuration recommendations for a workflow.
func (*SelfHealingService) GenerateLogic ¶
func (s *SelfHealingService) GenerateLogic(ctx context.Context, prompt string) (*CopilotResult, error)
func (*SelfHealingService) GenerateWorkflow ¶
Click to show internal directories.
Click to hide internal directories.