agent

package

Go to main page

Versions in this module

v0

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