coordinator

type API struct {
	// contains filtered or unexported fields
}

type AgentInfo struct {
	Name         string
	State        AgentState
	FailCount    int
	LastCheck    time.Time
	LastResponse time.Time
	Tasks        []int // Issue numbers assigned to this agent
}

type AgentState string

type AssignRequest struct {
	TargetAgent string `json:"target_agent"`
}

type AssignResponse struct {
	Success     bool   `json:"success"`
	IssueNumber int    `json:"issue_number"`
	AssignedTo  string `json:"assigned_to"`
}

type Config struct {
	HealthCheckInterval time.Duration // Interval between health checks
	ResponseTimeout     time.Duration // Timeout for agent responses
	MaxRetries          int           // Maximum retry attempts
	BackoffBase         time.Duration // Base duration for exponential backoff
	BackoffMax          time.Duration // Maximum backoff duration
}

type Coordinator struct {
	// contains filtered or unexported fields
}

type ErrorResponse struct {
	Error string `json:"error"`
}

type GetTasksFunc func(agentName string) []int

type HandoverResponse struct {
	IssueNumber   int                       `json:"issue_number"`
	Status        string                    `json:"status"`
	OriginalAgent string                    `json:"original_agent"`
	AssignedAgent string                    `json:"assigned_agent,omitempty"`
	History       []taskqueue.HandoverEvent `json:"history"`
	Context       string                    `json:"context,omitempty"`
}

type NotifyFunc func(ctx context.Context, target, message string) error

type PendingTaskItem struct {
	IssueNumber    int    `json:"issue_number"`
	OriginalAgent  string `json:"original_agent"`
	Priority       int    `json:"priority"`
	CreatedAt      string `json:"created_at"`
	ContextSummary string `json:"context_summary,omitempty"`
}

type PendingTasksResponse struct {
	Tasks []PendingTaskItem `json:"tasks"`
	Total int               `json:"total"`
}

type RecoverFunc func(ctx context.Context, agentName string) error