Documentation
¶
Overview ¶
Package steps provides the action executor step.
Package steps provides the auto-closer logic for confirmed duplicate issues.
Package steps contains the modular "Lego block" pipeline steps. Each step implements the pipeline.Step interface.
Package steps provides the indexer step for adding issues to the vector database.
Package steps provides the response builder step.
Package steps provides the similarity search step.
Package steps provides the transfer check step.
Package steps provides the triage step.
Package steps provides the VectorDB preparation step.
Index ¶
- func RegisterAll(r *pipeline.Registry)
- type ActionExecutor
- type AutoCloseDetail
- type AutoCloseResult
- type AutoCloser
- type CommandHandler
- type DuplicateDetector
- type Gatekeeper
- type Indexer
- type LLMRouter
- type PendingAction
- type PendingActionScheduler
- type QualityChecker
- type ResponseBuilder
- type SimilaritySearch
- type TransferCheck
- type Triage
- type VectorDBPrep
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterAll ¶
RegisterAll registers all built-in steps with the registry.
Types ¶
type ActionExecutor ¶
type ActionExecutor struct {
// contains filtered or unexported fields
}
ActionExecutor executes the decided actions (posting comments, transferring, etc).
func NewActionExecutor ¶
func NewActionExecutor(deps *pipeline.Dependencies) *ActionExecutor
NewActionExecutor creates a new action executor step.
type AutoCloseDetail ¶ added in v0.1.7
type AutoCloseDetail struct {
Number int `json:"number"`
Action string `json:"action"` // "closed", "skipped_grace", "skipped_human", "error"
Reason string `json:"reason,omitempty"`
}
AutoCloseDetail records the outcome for a single issue.
type AutoCloseResult ¶ added in v0.1.7
type AutoCloseResult struct {
Processed int `json:"processed"`
Closed int `json:"closed"`
SkippedGrace int `json:"skipped_grace_period"`
SkippedHuman int `json:"skipped_human_activity"`
Errors []string `json:"errors,omitempty"`
Details []AutoCloseDetail `json:"details,omitempty"`
}
AutoCloseResult holds the summary of an auto-close run.
type AutoCloser ¶ added in v0.1.7
type AutoCloser struct {
// contains filtered or unexported fields
}
AutoCloser scans issues with the potential-duplicate label and closes those whose grace period has expired and have no human activity.
func NewAutoCloser ¶ added in v0.1.7
NewAutoCloser creates a new AutoCloser.
func (*AutoCloser) Run ¶ added in v0.1.7
func (ac *AutoCloser) Run(ctx context.Context, org, repo string) (*AutoCloseResult, error)
Run processes all open issues with the "potential-duplicate" label.
type CommandHandler ¶ added in v0.1.0
type CommandHandler struct {
// contains filtered or unexported fields
}
CommandHandler processes bot commands like /undo.
func NewCommandHandler ¶ added in v0.1.0
func NewCommandHandler(deps *pipeline.Dependencies) *CommandHandler
NewCommandHandler creates a new command handler step.
func (*CommandHandler) Name ¶ added in v0.1.0
func (s *CommandHandler) Name() string
Name returns the step name.
type DuplicateDetector ¶ added in v0.1.0
type DuplicateDetector struct {
// contains filtered or unexported fields
}
DuplicateDetector analyzes similarity results for duplicates using LLM.
func NewDuplicateDetector ¶ added in v0.1.0
func NewDuplicateDetector(deps *pipeline.Dependencies) *DuplicateDetector
NewDuplicateDetector creates a new duplicate detector step.
func (*DuplicateDetector) Name ¶ added in v0.1.0
func (s *DuplicateDetector) Name() string
Name returns the step name.
type Gatekeeper ¶
type Gatekeeper struct {
// contains filtered or unexported fields
}
Gatekeeper checks if the issue's repository is enabled and applies cooldown logic.
func NewGatekeeper ¶
func NewGatekeeper(deps *pipeline.Dependencies) *Gatekeeper
NewGatekeeper creates a new gatekeeper step.
type Indexer ¶
type Indexer struct {
// contains filtered or unexported fields
}
Indexer adds/updates the issue in the vector database.
func NewIndexer ¶
func NewIndexer(deps *pipeline.Dependencies) *Indexer
NewIndexer creates a new indexer step.
type LLMRouter ¶ added in v0.1.0
type LLMRouter struct {
// contains filtered or unexported fields
}
LLMRouter analyzes issue intent and routes to best repository using LLM.
func NewLLMRouter ¶ added in v0.1.0
func NewLLMRouter(deps *pipeline.Dependencies) *LLMRouter
NewLLMRouter creates a new LLM router step.
type PendingAction ¶
type PendingAction struct {
IssueNumber int `json:"issue_number"`
Org string `json:"org"`
Repo string `json:"repo"`
TransferTarget string `json:"transfer_target,omitempty"`
Reason string `json:"reason"`
CreatedAt time.Time `json:"created_at"`
ExpiresAt time.Time `json:"expires_at"`
}
PendingAction represents an action that needs to be executed later.
type PendingActionScheduler ¶
type PendingActionScheduler struct {
// contains filtered or unexported fields
}
PendingActionScheduler schedules actions that could not be executed immediately.
func NewPendingActionScheduler ¶
func NewPendingActionScheduler(deps *pipeline.Dependencies) *PendingActionScheduler
NewPendingActionScheduler creates a new PendingActionScheduler step.
func (*PendingActionScheduler) Name ¶
func (s *PendingActionScheduler) Name() string
Name returns the step name.
type QualityChecker ¶ added in v0.1.0
type QualityChecker struct {
// contains filtered or unexported fields
}
QualityChecker assesses issue quality using LLM.
func NewQualityChecker ¶ added in v0.1.0
func NewQualityChecker(deps *pipeline.Dependencies) *QualityChecker
NewQualityChecker creates a new quality checker step.
func (*QualityChecker) Name ¶ added in v0.1.0
func (s *QualityChecker) Name() string
Name returns the step name.
type ResponseBuilder ¶
type ResponseBuilder struct {
// contains filtered or unexported fields
}
ResponseBuilder constructs the comment to post on the issue.
func NewResponseBuilder ¶
func NewResponseBuilder(deps *pipeline.Dependencies) *ResponseBuilder
NewResponseBuilder creates a new response builder step.
type SimilaritySearch ¶
type SimilaritySearch struct {
// contains filtered or unexported fields
}
SimilaritySearch finds similar issues using the vector database.
func NewSimilaritySearch ¶
func NewSimilaritySearch(deps *pipeline.Dependencies) *SimilaritySearch
NewSimilaritySearch creates a new similarity search step.
func (*SimilaritySearch) Name ¶
func (s *SimilaritySearch) Name() string
Name returns the step name.
type TransferCheck ¶
type TransferCheck struct{}
TransferCheck evaluates if an issue should be transferred to another repository.
func NewTransferCheck ¶
func NewTransferCheck(deps *pipeline.Dependencies) *TransferCheck
NewTransferCheck creates a new transfer check step.
type Triage ¶
type Triage struct {
// contains filtered or unexported fields
}
Triage uses LLM to suggest labels for the issue.
func NewTriage ¶
func NewTriage(deps *pipeline.Dependencies) *Triage
NewTriage creates a new triage step.
type VectorDBPrep ¶
type VectorDBPrep struct {
// contains filtered or unexported fields
}
VectorDBPrep ensures the vector database collection exists and is ready.
func NewVectorDBPrep ¶
func NewVectorDBPrep(deps *pipeline.Dependencies) *VectorDBPrep
NewVectorDBPrep creates a new vector DB preparation step.
Source Files