agent/

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

v0.1.5

Oct 14, 2026

Changes in this version

+ const AskUserToolName

+ const BuiltinDefaultProfileName

+ const QuestionTypeMultipleChoice

+ const QuestionTypeSingleChoice

+ const QuestionTypeText

+ var ErrInvalidQuestionTransition = errors.New("agent: invalid question state transition")

+ var ErrNoUserInputResolver = errors.New("agent: no user input resolver in runtime")

+ var ErrQuestionCanceled = errors.New("agent: question request canceled")

+ var ErrQuestionExpired = errors.New("agent: question request expired")

+ var ErrQuestionNotFound = errors.New("agent: question request not found")

+ var ErrQuestionNotPending = errors.New("agent: question request is not pending")

+ func AskUserToolDefinition() tool.Definition

+ func RenderSystemPromptTemplate(template string, vars map[string]any) (string, error)

type AgentEventType

+ const EventQuestionCreated

+ const EventQuestionResolved

type AgentService

+ func (s *AgentService) AnswerQuestion(ctx context.Context, id int64, answer AskUserAnswer, by string) error

+ func (s *AgentService) GetPendingQuestions(ctx context.Context, taskID int64) ([]*QuestionRequest, error)

+ func (s *AgentService) GetSystemSpromptByProfile(ctx context.Context, profile *Profile, vars map[string]any, userID string, ...) string

+ func (s *AgentService) PageQuestions(ctx context.Context, offset, limit int, taskID int64, ...) ([]*QuestionRequest, int64, error)

+ func (s *AgentService) RenderSystemPrompt(ctx context.Context, userID string, profileID int64, vars map[string]any) (*Profile, string, error)

+ func (s *AgentService) ResolveProfile(ctx context.Context, id int64) (*Profile, error)

+ type AskUserAnswer struct

+ Answers []QuestionAnswer

+ RequestID string

+ type AskUserInput struct

+ Description string

+ Questions []Question

+ RequestID string

+ Title string

+ type Question struct

+ AllowCustom bool

+ Description string

+ ID string

+ Options []QuestionOption

+ Placeholder string

+ Required bool

+ Title string

+ Type string

+ type QuestionAnswer struct

+ Custom string

+ ID string

+ Value string

+ Values []string

+ type QuestionManager struct

+ func NewQuestionManager(repo QuestionRepository) *QuestionManager

+ func (m *QuestionManager) Answer(ctx context.Context, id int64, answer AskUserAnswer, by string) (*QuestionRequest, error)

+ func (m *QuestionManager) Cancel(ctx context.Context, id int64) (*QuestionRequest, error)

+ func (m *QuestionManager) Create(ctx context.Context, taskID int64, sessionID string, input AskUserInput) (*QuestionRequest, error)

+ func (m *QuestionManager) Get(ctx context.Context, id int64) (*QuestionRequest, error)

+ func (m *QuestionManager) GetPending(ctx context.Context, taskID int64) ([]*QuestionRequest, error)

+ func (m *QuestionManager) Page(ctx context.Context, offset, limit int, taskID int64, ...) ([]*QuestionRequest, int64, error)

+ func (m *QuestionManager) Wait(ctx context.Context, id int64) (AskUserAnswer, error)

+ type QuestionOption struct

+ Description string

+ Label string

+ Value string

+ type QuestionRepository interface

+ Create func(ctx context.Context, question *QuestionRequest) error

+ Get func(ctx context.Context, id int64) (*QuestionRequest, error)

+ ListPendingByTask func(ctx context.Context, taskID int64) ([]*QuestionRequest, error)

+ Page func(ctx context.Context, offset, limit int, taskID int64, ...) ([]*QuestionRequest, int64, error)

+ Update func(ctx context.Context, question *QuestionRequest) error

+ type QuestionRequest struct

+ Answer *AskUserAnswer

+ CreatedAt time.Time

+ Description string

+ ID int64

+ Questions []Question

+ RequestID string

+ ResolvedAt *time.Time

+ ResolvedBy *string

+ SessionID string

+ Status QuestionStatus

+ TaskID int64

+ Title string

+ UpdatedAt time.Time

+ func NewQuestionRequest(taskID int64, sessionID string, input AskUserInput) *QuestionRequest

+ func (QuestionRequest) TableName() string

+ func (q *QuestionRequest) BeforeCreate(_ *gorm.DB) error

+ func (q *QuestionRequest) TransitionTo(next QuestionStatus) bool

+ type QuestionStatus string

+ const QuestionAnswered

+ const QuestionCanceled

+ const QuestionExpired

+ const QuestionPending

type Request

+ ProfileID int64

+ SystemPromptVars map[string]any

type Runtime

+ AskUser func(ctx context.Context, userID string, input AskUserInput) (AskUserAnswer, error)

type ServiceConfig

+ Questions *QuestionManager

+ Skills *skill.Registry

type TurnInput

+ ProfileID int64

+ SystemPromptVars map[string]any

type UserAgentConfig

+ ProfileID int64

v0.1.4

Sep 19, 2026

Changes in this version

+ const BuiltinSummaryProfileID

+ const MessageKindAssistant

+ const MessageKindAssistantFinal

+ const MessageKindReasoning

+ const MessageKindSkillCall

+ const MessageKindSkillResult

+ const MessageKindToolCall

+ const MessageKindToolResult

+ const MessageKindUser

+ const ProfileSummary

+ func EnsureBuiltinProfiles(ctx context.Context, repo ProfileRepository) error

+ func IsBuiltinProfileID(id int64) bool

type AgentService

+ func (s *AgentService) RunTaskSyncByID(ctx context.Context, taskID int64) (*Result, error)

type ConversationMessage

+ Data any

+ Kind string

+ TaskID int64

type Message

+ Data any

+ Kind string

+ TaskID int64

+ type ModelProviderConfig struct

+ APIKey string

+ BaseURL string

+ BearerToken string

+ Extra map[string]string

+ Model string

+ WorkingDir string

type Options

+ Providers map[string]ModelProviderConfig

type PermissionPolicy

+ func NewUserPermissionPolicy(provider UserAgentConfigProvider) PermissionPolicy

type Profile

+ Model string

+ Provider string

type ProfileRepository

+ ListBuiltin func(ctx context.Context) ([]*Profile, error)

type Result

+ TaskID int64

type Runtime

+ func NewTaskRuntime(svc *AgentService, taskID int64, handler StreamHandler) Runtime

type SkillRunner

+ func (r *SkillRunner) SetUserID(userID string) *SkillRunner

type ToolRunner

+ func (r *ToolRunner) SetUserID(userID string) *ToolRunner

+ type UserAgentConfig struct

+ Permissions map[OperationType]PermissionDecision

+ Profile string

+ func DefaultUserAgentConfig() UserAgentConfig

+ type UserAgentConfigProvider interface

+ GetAgentConfig func(ctx context.Context, userID string) (UserAgentConfig, error)

v0.1.3

Sep 1, 2026

Changes in this version

+ const BuiltinAnalysisCoderID

+ const BuiltinArticleWriterID

+ const BuiltinDefaultProfileID

type AgentEvent

+ func (e *AgentEvent) BeforeCreate(_ *gorm.DB) error

type AgentService

+ func (s *AgentService) GetTaskRequest(ctx context.Context, taskID int64) (*Request, error)

type Conversation

+ func (c *Conversation) BeforeCreate(_ *gorm.DB) error

type ConversationMessage

+ func (m *ConversationMessage) BeforeCreate(_ *gorm.DB) error

type PermissionRequest

+ func (p *PermissionRequest) BeforeCreate(_ *gorm.DB) error

type Profile

+ func (p *Profile) BeforeCreate(_ *gorm.DB) error

type Task

+ func (t *Task) BeforeCreate(_ *gorm.DB) error

v0.1.2

Aug 31, 2026

Changes in this version

+ const DefaultProfileName

+ const DefaultProvider

+ const ProfileAnalysisCoder

+ const ProfileArticleWriter

+ const ProviderClaudeCode

+ const ProviderCodex

+ const ProviderCopilot

+ const ProviderCustom

+ const ProviderMock

+ const RoleAssistant

+ const RoleSystem

+ const RoleTool

+ const RoleUser

+ var ErrConversationNotFound = errors.New("agent: conversation not found")

+ var ErrInvalidPermissionTransition = errors.New("agent: invalid permission state transition")

+ var ErrInvalidTaskTransition = errors.New("agent: invalid task state transition")

+ var ErrMemoryNotConfigured = errors.New("agent: memory manager not configured")

+ var ErrMemoryNotFound = errors.New("agent: memory not found")

+ var ErrNoPermissionResolver = errors.New("agent: no permission resolver in runtime")

+ var ErrNotImplemented = errors.New("agent: provider not implemented yet")

+ var ErrPermissionCanceled = errors.New("agent: permission request canceled")

+ var ErrPermissionDenied = errors.New("agent: permission denied")

+ var ErrPermissionExpired = errors.New("agent: permission request expired")

+ var ErrPermissionNotFound = errors.New("agent: permission request not found")

+ var ErrPermissionNotPending = errors.New("agent: permission request is not pending")

+ var ErrProfileNameRequired = errors.New("agent: profile name is required")

+ var ErrProfileNotFound = errors.New("agent: profile not found")

+ var ErrTaskAlreadyRunning = errors.New("agent: task already running")

+ var ErrTaskNotFound = errors.New("agent: task not found")

+ func BuildMemoryContext(memories []*Memory) string

+ type Agent interface

+ Invoke func(ctx context.Context, req Request, rt Runtime) (*Result, error)

+ Name func() string

+ Stream func(ctx context.Context, req Request, rt Runtime) (*Result, error)

+ type AgentEvent struct

+ CreatedAt time.Time

+ ID string

+ Payload any

+ Sequence int64

+ TaskID string

+ Type AgentEventType

+ func (AgentEvent) TableName() string

+ type AgentEventType string

+ const EventMemoryDeleted

+ const EventMemorySaved

+ const EventPermissionCreated

+ const EventPermissionResolved

+ const EventStream

+ const EventTaskCanceled

+ const EventTaskCompleted

+ const EventTaskCreated

+ const EventTaskFailed

+ const EventTaskStarted

+ const EventTaskWaiting

+ type AgentService struct

+ func NewService(cfg ServiceConfig) *AgentService

+ func (s *AgentService) ApprovePermission(ctx context.Context, id, by string) error

+ func (s *AgentService) CancelTask(ctx context.Context, taskID string) error

+ func (s *AgentService) CreateTask(ctx context.Context, req Request) (*Task, error)

+ func (s *AgentService) DeleteMemory(ctx context.Context, id string) error

+ func (s *AgentService) DeleteProfile(ctx context.Context, userID, id string) error

+ func (s *AgentService) DenyPermission(ctx context.Context, id, by string) error

+ func (s *AgentService) GetEvents(ctx context.Context, taskID string, after int64) ([]*AgentEvent, error)

+ func (s *AgentService) GetMemory(ctx context.Context, id string) (*Memory, error)

+ func (s *AgentService) GetPendingPermissions(ctx context.Context, taskID string) ([]*PermissionRequest, error)

+ func (s *AgentService) GetProfile(ctx context.Context, userID, id string) (*Profile, error)

+ func (s *AgentService) GetTask(ctx context.Context, id string) (*Task, error)

+ func (s *AgentService) ListMemory(ctx context.Context, userID string, offset, limit int, kinds ...MemoryKind) ([]*Memory, int64, error)

+ func (s *AgentService) ListProfiles(ctx context.Context, userID string) ([]*Profile, error)

+ func (s *AgentService) PageEvents(ctx context.Context, offset, limit int, taskID string) ([]*AgentEvent, int64, error)

+ func (s *AgentService) PagePermissions(ctx context.Context, offset, limit int, taskID string, ...) ([]*PermissionRequest, int64, error)

+ func (s *AgentService) PageTasks(ctx context.Context, offset, limit int, statuses ...TaskStatus) ([]*Task, int64, error)

+ func (s *AgentService) ProjectContext(ctx context.Context, userID string) (string, error)

+ func (s *AgentService) Recover(ctx context.Context) error

+ func (s *AgentService) RetrieveMemory(ctx context.Context, userID, query string, limit int) ([]*Memory, error)

+ func (s *AgentService) RunTask(ctx context.Context, req Request, handler StreamHandler) (*Task, error)

+ func (s *AgentService) RunTaskSync(ctx context.Context, req Request) (*Result, error)

+ func (s *AgentService) SaveMemory(ctx context.Context, memory *Memory) error

+ func (s *AgentService) SaveProfile(ctx context.Context, profile *Profile) error

+ func (s *AgentService) StartTask(ctx context.Context, taskID string, handler StreamHandler) error

+ func (s *AgentService) Subscribe(taskID string, handler EventHandler) func()

+ type Client struct

+ func NewClient(registry *Registry, defaultProvider string, opts Options) *Client

+ func (c *Client) InvokeRuntime(ctx context.Context, req Request, rt Runtime) (*Result, error)

+ func (c *Client) SetDefault(provider string, opts Options)

+ func (c *Client) Stream(ctx context.Context, req Request, handler StreamHandler) (*Result, error)

+ func (c *Client) StreamRuntime(ctx context.Context, req Request, rt Runtime) (*Result, error)

+ type ContextConfig struct

+ InjectMemory bool

+ InjectProject bool

+ type Conversation struct

+ CreatedAt time.Time

+ CurrentTaskID string

+ ID string

+ Messages []Message

+ Model string

+ Provider string

+ UpdatedAt time.Time

+ UserID string

+ func NewConversation(userID, provider, model string) *Conversation

+ func (Conversation) TableName() string

+ type ConversationMessage struct

+ Content string

+ ConversationID string

+ CreatedAt time.Time

+ ID string

+ Role string

+ Seq int

+ func (ConversationMessage) TableName() string

+ type ConversationRepository interface

+ Create func(ctx context.Context, conv *Conversation) error

+ Get func(ctx context.Context, id string) (*Conversation, error)

+ Page func(ctx context.Context, userID string, offset, limit int) ([]*Conversation, int64, error)

+ Update func(ctx context.Context, conv *Conversation) error

+ func NewGormConversationRepository(db *gorm.DB) ConversationRepository

+ func NewMemoryConversationRepository() ConversationRepository

+ type ConversationService struct

+ func NewConversationService(agent *AgentService, repo ConversationRepository) *ConversationService

+ func (s *ConversationService) CreateTurn(ctx context.Context, in TurnInput) (*Task, *Conversation, error)

+ func (s *ConversationService) GetConversation(ctx context.Context, id string) (*Conversation, error)

+ func (s *ConversationService) PageConversations(ctx context.Context, userID string, offset, limit int) ([]*Conversation, int64, error)

+ func (s *ConversationService) StartTurn(ctx context.Context, taskID string) error

+ type EventBus interface

+ Publish func(ctx context.Context, event AgentEvent)

+ Subscribe func(taskID string, handler EventHandler) (unsubscribe func())

+ func NewEventBus() EventBus

+ type EventHandler func(ctx context.Context, event AgentEvent) error

+ type EventRepository interface

+ Append func(ctx context.Context, event *AgentEvent) error

+ ListByTask func(ctx context.Context, taskID string, after int64) ([]*AgentEvent, error)

+ Page func(ctx context.Context, taskID string, offset, limit int) ([]*AgentEvent, int64, error)

+ func NewGormEventRepository(db *gorm.DB) EventRepository

+ func NewMemoryEventRepository() EventRepository

+ type Memory struct

+ Content string

+ CreatedAt time.Time

+ ID string

+ Importance int

+ Kind MemoryKind

+ LastAccessedAt *time.Time

+ Metadata map[string]any

+ SessionID string

+ UpdatedAt time.Time

+ UserID string

+ func NewMemory(userID, sessionID string, kind MemoryKind, content string) *Memory

+ func (Memory) TableName() string

+ type MemoryConfig struct

+ Extractor MemoryExtractor

+ Repo MemoryRepository

+ Retriever MemoryRetriever

+ type MemoryExtractor interface

+ Extract func(ctx context.Context, turn MemoryTurn) ([]*Memory, error)

+ func MockMemoryExtractor() MemoryExtractor

+ type MemoryExtractorFunc func(ctx context.Context, turn MemoryTurn) ([]*Memory, error)

+ func (f MemoryExtractorFunc) Extract(ctx context.Context, turn MemoryTurn) ([]*Memory, error)

+ type MemoryKind string

+ const MemoryKindEvent

+ const MemoryKindFact

+ const MemoryKindNote

+ const MemoryKindSummary

+ type MemoryManager struct

+ func NewMemoryManager(cfg MemoryConfig) *MemoryManager

+ func (m *MemoryManager) Delete(ctx context.Context, id string) error

+ func (m *MemoryManager) Extract(ctx context.Context, turn MemoryTurn) ([]*Memory, error)

+ func (m *MemoryManager) Get(ctx context.Context, id string) (*Memory, error)

+ func (m *MemoryManager) List(ctx context.Context, userID string, offset, limit int, kinds ...MemoryKind) ([]*Memory, int64, error)

+ func (m *MemoryManager) Retrieve(ctx context.Context, userID, query string, limit int) ([]*Memory, error)

+ func (m *MemoryManager) Save(ctx context.Context, memory *Memory) error

+ func (m *MemoryManager) Touch(ctx context.Context, id string) error

+ type MemoryRepository interface

+ Create func(ctx context.Context, memory *Memory) error

+ Delete func(ctx context.Context, id string) error

+ Get func(ctx context.Context, id string) (*Memory, error)

+ ListByUser func(ctx context.Context, userID string, offset, limit int, kinds ...MemoryKind) ([]*Memory, int64, error)

+ Search func(ctx context.Context, userID, query string, limit int) ([]*Memory, error)

+ Update func(ctx context.Context, memory *Memory) error

+ func NewGormMemoryRepository(db *gorm.DB) MemoryRepository

+ func NewMemoryRepository() MemoryRepository

+ type MemoryRetriever interface

+ Retrieve func(ctx context.Context, userID, query string, limit int) ([]*Memory, error)

+ type MemoryTurn struct

+ Request Request

+ Result *Result

+ SessionID string

+ UserID string

+ type Message struct

+ Content string

+ Role string

+ type MessageBlock struct

+ Content string

+ ID string

+ ToolCalls []ToolCall

+ TurnID string

+ type Operation struct

+ Command string

+ Content string

+ ID string

+ Metadata map[string]any

+ Path string

+ Type OperationType

+ type OperationType string

+ const OperationDelete

+ const OperationExecute

+ const OperationMove

+ const OperationNetwork

+ const OperationRead

+ const OperationWrite

+ type Options struct

+ APIKey string

+ BaseURL string

+ BearerToken string

+ Extra map[string]string

+ Model string

+ Skills *skill.Registry

+ Tools *tool.Registry

+ WorkingDir string

+ type PermissionDecision string

+ const DecisionAllow

+ const DecisionAsk

+ const DecisionDeny

+ type PermissionManager struct

+ func NewPermissionManager(repo PermissionRepository) *PermissionManager

+ func (m *PermissionManager) Approve(ctx context.Context, id, by string) (*PermissionRequest, error)

+ func (m *PermissionManager) Create(ctx context.Context, taskID, sessionID string, operation Operation) (*PermissionRequest, error)

+ func (m *PermissionManager) Deny(ctx context.Context, id, by string) (*PermissionRequest, error)

+ func (m *PermissionManager) Get(ctx context.Context, id string) (*PermissionRequest, error)

+ func (m *PermissionManager) GetPending(ctx context.Context, taskID string) ([]*PermissionRequest, error)

+ func (m *PermissionManager) Page(ctx context.Context, offset, limit int, taskID string, ...) ([]*PermissionRequest, int64, error)

+ func (m *PermissionManager) Wait(ctx context.Context, id string) (PermissionDecision, error)

+ type PermissionPolicy interface

+ Check func(ctx context.Context, operation Operation) PermissionDecision

+ func AllowAllPermissionPolicy() PermissionPolicy

+ func DefaultPermissionPolicy() PermissionPolicy

+ type PermissionRepository interface

+ Create func(ctx context.Context, permission *PermissionRequest) error

+ Get func(ctx context.Context, id string) (*PermissionRequest, error)

+ ListPendingByTask func(ctx context.Context, taskID string) ([]*PermissionRequest, error)

+ Page func(ctx context.Context, offset, limit int, taskID string, ...) ([]*PermissionRequest, int64, error)

+ Update func(ctx context.Context, permission *PermissionRequest) error

+ func NewGormPermissionRepository(db *gorm.DB) PermissionRepository

+ func NewMemoryPermissionRepository() PermissionRepository

+ type PermissionRequest struct

+ CreatedAt time.Time

+ ID string

+ Operation Operation

+ ResolvedAt *time.Time

+ ResolvedBy *string

+ SessionID string

+ Status PermissionStatus

+ TaskID string

+ UpdatedAt time.Time

+ func NewPermissionRequest(taskID, sessionID string, operation Operation) *PermissionRequest

+ func (PermissionRequest) TableName() string

+ func (p *PermissionRequest) Decision() PermissionDecision

+ func (p *PermissionRequest) TransitionTo(next PermissionStatus) bool

+ type PermissionStatus string

+ const PermissionApproved

+ const PermissionCanceled

+ const PermissionConsumed

+ const PermissionDenied

+ const PermissionExpired

+ const PermissionPending

+ type Profile struct

+ Context ContextConfig

+ CreatedAt time.Time

+ Description string

+ DisplayName string

+ ID string

+ IsBuiltin bool

+ IsDefault bool

+ Name string

+ Skills []string

+ SystemPrompt string

+ UpdatedAt time.Time

+ UserID string

+ func BuiltinProfiles() []*Profile

+ func DefaultBuiltinProfile() *Profile

+ func (Profile) TableName() string

+ type ProfileManager struct

+ func NewProfileManager(repo ProfileRepository) *ProfileManager

+ func (m *ProfileManager) Delete(ctx context.Context, userID, id string) error

+ func (m *ProfileManager) Get(ctx context.Context, userID, id string) (*Profile, error)

+ func (m *ProfileManager) List(ctx context.Context, userID string) ([]*Profile, error)

+ func (m *ProfileManager) Resolve(ctx context.Context, userID, name string) (*Profile, error)

+ func (m *ProfileManager) Save(ctx context.Context, p *Profile) error

+ type ProfileRepository interface

+ ClearDefault func(ctx context.Context, userID, exceptID string) error

+ Create func(ctx context.Context, profile *Profile) error

+ Delete func(ctx context.Context, id string) error

+ Get func(ctx context.Context, id string) (*Profile, error)

+ GetByName func(ctx context.Context, userID, name string) (*Profile, error)

+ GetDefault func(ctx context.Context, userID string) (*Profile, error)

+ ListByUser func(ctx context.Context, userID string) ([]*Profile, error)

+ Update func(ctx context.Context, profile *Profile) error

+ func NewGormProfileRepository(db *gorm.DB) ProfileRepository

+ func NewMemoryProfileRepository() ProfileRepository

+ type ProjectContextProvider interface

+ ProjectContext func(ctx context.Context, userID string) (string, error)

+ type Provider interface

+ Name func() string

+ New func(opts Options) (Agent, error)

+ type ReasoningBlock struct

+ Content string

+ ID string

+ type Registry struct

+ func NewRegistry(providers ...Provider) *Registry

+ func (r *Registry) Has(name string) bool

+ func (r *Registry) Names() []string

+ func (r *Registry) Register(p Provider)

+ func (r *Registry) Resolve(name string, opts Options) (Agent, error)

+ type Request struct

+ Env map[string]string

+ MaxTokens int

+ Messages []Message

+ Model string

+ Profile string

+ Provider string

+ SessionID string

+ Skills []string

+ Stream bool

+ SystemPrompt string

+ Timeout time.Duration

+ UserID string

+ WorkingDir string

+ type Result struct

+ Content string

+ Raw json.RawMessage

+ Usage Usage

+ type Runtime interface

+ Emit func(ctx context.Context, event StreamEvent) error

+ RequestPermission func(ctx context.Context, operation Operation) (PermissionDecision, error)

+ WaitPermission func(ctx context.Context, permissionID string) (PermissionDecision, error)

+ func NewStandaloneRuntime(handler StreamHandler) Runtime

+ type ServiceConfig struct

+ Bus EventBus

+ Client *Client

+ Events EventRepository

+ Memory *MemoryManager

+ Perms *PermissionManager

+ Policy PermissionPolicy

+ Profiles *ProfileManager

+ Project ProjectContextProvider

+ Tasks TaskRepository

+ type SkillCall struct

+ Arguments any

+ ID string

+ Name string

+ type SkillCallProvider func(ctx context.Context, results []skill.Result) ([]SkillCall, error)

+ type SkillLoop struct

+ func NewSkillLoop(runner *SkillRunner) *SkillLoop

+ func (l *SkillLoop) Run(ctx context.Context, next SkillCallProvider) ([]skill.Result, error)

+ type SkillPermissionResolver func(ctx context.Context, call SkillCall) (Operation, bool)

+ type SkillResultEvent struct

+ CallID string

+ Content string

+ IsError bool

+ Name string

+ type SkillRunner struct

+ func NewSkillRunner(inv *skill.Invoker, rt Runtime) *SkillRunner

+ func (r *SkillRunner) Run(ctx context.Context, call SkillCall) skill.Result

+ func (r *SkillRunner) RunAll(ctx context.Context, calls []SkillCall) []skill.Result

+ func (r *SkillRunner) SetPermissionResolver(resolver SkillPermissionResolver) *SkillRunner

+ type StreamEvent struct

+ Content string

+ Data any

+ Err error

+ Type StreamEventType

+ type StreamEventType string

+ const StreamEventDone

+ const StreamEventError

+ const StreamEventMessage

+ const StreamEventPermission

+ const StreamEventPermissionResult

+ const StreamEventReasoning

+ const StreamEventReasoningDelta

+ const StreamEventSkillCall

+ const StreamEventSkillResult

+ const StreamEventText

+ const StreamEventToolCall

+ const StreamEventToolResult

+ const StreamEventTurnEnd

+ const StreamEventTurnStart

+ type StreamHandler func(ctx context.Context, event StreamEvent) error

+ type Task struct

+ CreatedAt time.Time

+ Error string

+ FinishedAt *time.Time

+ ID string

+ Model string

+ Provider string

+ Request Request

+ SessionID string

+ StartedAt *time.Time

+ Status TaskStatus

+ UpdatedAt time.Time

+ WorkingDir string

+ func NewTask(req Request) *Task

+ func (Task) TableName() string

+ func (t *Task) TransitionTo(next TaskStatus) bool

+ type TaskRepository interface

+ Create func(ctx context.Context, task *Task) error

+ Get func(ctx context.Context, id string) (*Task, error)

+ ListByStatus func(ctx context.Context, statuses ...TaskStatus) ([]*Task, error)

+ Page func(ctx context.Context, offset, limit int, statuses ...TaskStatus) ([]*Task, int64, error)

+ Update func(ctx context.Context, task *Task) error

+ func NewGormTaskRepository(db *gorm.DB) TaskRepository

+ func NewMemoryTaskRepository() TaskRepository

+ type TaskStatus string

+ const TaskCanceled

+ const TaskCompleted

+ const TaskCreated

+ const TaskFailed

+ const TaskRunning

+ const TaskWaitingPermission

+ type ToolCall struct

+ Arguments any

+ ID string

+ Name string

+ type ToolCallProvider func(ctx context.Context, results []tool.Result) ([]ToolCall, error)

+ type ToolLoop struct

+ func NewToolLoop(runner *ToolRunner) *ToolLoop

+ func (l *ToolLoop) Run(ctx context.Context, next ToolCallProvider) ([]tool.Result, error)

+ type ToolPermissionResolver func(ctx context.Context, call ToolCall) (Operation, bool)

+ type ToolResultEvent struct

+ CallID string

+ Content string

+ IsError bool

+ Name string

+ type ToolRunner struct

+ func NewToolRunner(exec *tool.Executor, rt Runtime) *ToolRunner

+ func (r *ToolRunner) Run(ctx context.Context, call ToolCall) tool.Result

+ func (r *ToolRunner) RunAll(ctx context.Context, calls []ToolCall) []tool.Result

+ func (r *ToolRunner) SetPermissionResolver(resolver ToolPermissionResolver) *ToolRunner

+ type TurnBlock struct

+ Model string

+ TurnID string

+ type TurnInput struct

+ ConversationID string

+ Message string

+ Model string

+ Profile string

+ Provider string

+ SystemPrompt string

+ UserID string

+ WorkingDir string

+ type Usage struct

+ InputTokens int64

+ OutputTokens int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL