agenttask

type ClaimOptions struct {
	AgentID   string        // ox internal agent id of the claimer
	AgentType string        // claimer's agent type (for target matching)
	PID       int           // claimer's process id (host-local liveness)
	Lease     time.Duration // how long to hold the claim; defaults to DefaultLease
}

type Status string

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

type Task struct {
	ID          string `json:"id"`                     // UUIDv7 (time-sortable)
	Title       string `json:"title"`                  // short summary shown to the agent
	Body        string `json:"body,omitempty"`         // fuller instruction for the executor
	Kind        string `json:"kind,omitempty"`         // category: doctor, session-finalize, anti-entropy, custom
	Priority    int    `json:"priority"`               // lower = higher priority (matches agentwork.WorkItem)
	Status      Status `json:"status"`                 // ready | in_progress | completed | canceled
	Source      string `json:"source,omitempty"`       // producer: daemon, doctor, cli
	TargetAgent string `json:"target_agent,omitempty"` // restrict to an agent type; "" = any
	DedupKey    string `json:"dedup_key,omitempty"`    // at most one active (non-terminal) task per key

	Payload map[string]string `json:"payload,omitempty"` // optional structured data for the executor

	CreatedAt time.Time `json:"created_at"`
	ExpiresAt time.Time `json:"expires_at,omitempty"` // zero = never; dropped once past

	// Lease fields — populated only while Status == in_progress.
	ClaimedByAgentID string    `json:"claimed_by_agent_id,omitempty"` // ox internal agent id (e.g. Oxa7b3)
	ClaimedByPID     int       `json:"claimed_by_pid,omitempty"`      // PID of claiming process (host-local liveness)
	ClaimedHost      string    `json:"claimed_host,omitempty"`        // hostname; PID only meaningful on the same host
	ClaimedAt        time.Time `json:"claimed_at,omitempty"`
	LeaseExpiresAt   time.Time `json:"lease_expires_at,omitempty"` // reverts to ready if not completed by this time
	Attempts         int       `json:"attempts,omitempty"`         // incremented each time the task is (re)claimed

	// Terminal fields.
	CompletedAt time.Time `json:"completed_at,omitempty"` // when it reached a terminal state
	Result      string    `json:"result,omitempty"`       // optional note on completion/cancellation
}