agent

package

Go to main page

Versions in this module

v0

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