agent

package

Go to main page

Versions in this module

v0

v0.1.7

Apr 30, 2026

Changes in this version

+ const AgentToolExecutionModeParallel

+ const AgentToolExecutionModeSequential

+ type AgentToolExecutionMode = types.AgentToolExecutionMode

type Option

+ func WithAgentToolExecutionMode(mode AgentToolExecutionMode) Option

v0.1.6

Apr 28, 2026

Changes in this version

+ const ApprovalRequestNameSubAgent

+ const ApprovalRequestNameTool

+ type AgentCustomEvent = events.AgentCustomEvent

+ type AgentCustomEventApprovalValue = events.AgentCustomEventApprovalValue

+ func ParseCustomEventApproval(ev *AgentCustomEvent) (AgentCustomEventApprovalValue, error)

+ type AgentCustomEventDelegationValue = events.AgentCustomEventDelegationValue

+ func ParseCustomEventDelegation(ev *AgentCustomEvent) (AgentCustomEventDelegationValue, error)

+ type AgentCustomEventName = events.AgentCustomEventName

+ const AgentCustomEventNameSubAgentDelegation

+ const AgentCustomEventNameToolApproval

type AgentEventType

+ const AgentEventTypeCustom

+ const AgentEventTypeRaw

+ const AgentEventTypeReasoningEnd

+ const AgentEventTypeReasoningMessageContent

+ const AgentEventTypeReasoningMessageEnd

+ const AgentEventTypeReasoningMessageStart

+ const AgentEventTypeReasoningStart

+ const AgentEventTypeRunError

+ const AgentEventTypeRunFinished

+ const AgentEventTypeRunStarted

+ const AgentEventTypeStepFinished

+ const AgentEventTypeStepStarted

+ const AgentEventTypeTextMessageContent

+ const AgentEventTypeTextMessageEnd

+ const AgentEventTypeTextMessageStart

+ const AgentEventTypeToolCallArgs

+ const AgentEventTypeToolCallEnd

+ const AgentEventTypeToolCallResult

+ const AgentEventTypeToolCallStart

+ type AgentRawEvent = events.AgentRawEvent

+ type AgentReasoningEndEvent = events.AgentReasoningEndEvent

+ type AgentReasoningMessageContentEvent = events.AgentReasoningMessageContentEvent

+ type AgentReasoningMessageEndEvent = events.AgentReasoningMessageEndEvent

+ type AgentReasoningMessageStartEvent = events.AgentReasoningMessageStartEvent

+ type AgentReasoningStartEvent = events.AgentReasoningStartEvent

+ type AgentRunAsyncResult = types.AgentRunAsyncResult

+ type AgentRunErrorEvent = events.AgentRunErrorEvent

+ type AgentRunFinishedEvent = events.AgentRunFinishedEvent

+ type AgentRunResult = types.AgentRunResult

+ type AgentRunStartedEvent = events.AgentRunStartedEvent

+ type AgentStepFinishedEvent = events.AgentStepFinishedEvent

+ type AgentStepStartedEvent = events.AgentStepStartedEvent

+ type AgentTextMessageContentEvent = events.AgentTextMessageContentEvent

+ type AgentTextMessageEndEvent = events.AgentTextMessageEndEvent

+ type AgentTextMessageStartEvent = events.AgentTextMessageStartEvent

+ type AgentToolCallArgsEvent = events.AgentToolCallArgsEvent

+ type AgentToolCallEndEvent = events.AgentToolCallEndEvent

+ type AgentToolCallResultEvent = events.AgentToolCallResultEvent

+ type AgentToolCallStartEvent = events.AgentToolCallStartEvent

+ type ApprovalRequestName = types.ApprovalRequestName

+ type BaseEvent = events.BaseEvent

type Option

+ func WithDisableFingerprintCheck(disable bool) Option

+ type SubAgentDelegationApprovalRequestValue = types.SubAgentDelegationApprovalRequestValue

+ func ParseDelegationApproval(req *ApprovalRequest) (SubAgentDelegationApprovalRequestValue, error)

+ type ToolApprovalRequestValue = types.ToolApprovalRequestValue

+ func ParseToolApproval(req *ApprovalRequest) (ToolApprovalRequestValue, error)

v0.1.4

Apr 25, 2026

Changes in this version

type MCPTool

+ func (m *MCPTool) DisplayName() string

v0.1.3

Apr 19, 2026

Changes in this version

+ const AgentModeAutonomous

+ const AgentModeInteractive

+ type AgentMode = types.AgentMode

type Option

+ func WithAgentMode(mode AgentMode) Option

type ToolCallStatus

+ const ToolCallStatusDenied

v0.1.2

Apr 13, 2026

Changes in this version

+ var ErrSubAgentNameInvalid = errors.New("sub-agent name invalid for delegation tool")

+ type AllowlistToolApprovalConfig struct

+ MCPTools map[string][]string

+ SubAgentNames []string

+ ToolNames []string

+ type MCPConfig struct

+ RetryAttempts int

+ Timeout time.Duration

+ ToolFilter types.MCPToolFilter

+ Transport types.MCPTransportConfig

+ type MCPServers map[string]MCPConfig

+ type MCPTool struct

+ Client interfaces.MCPClient

+ ServerName string

+ Spec interfaces.ToolSpec

+ func NewMCPTool(serverName string, spec interfaces.ToolSpec, client interfaces.MCPClient) *MCPTool

+ func (m *MCPTool) Description() string

+ func (m *MCPTool) Execute(ctx context.Context, args map[string]any) (any, error)

+ func (m *MCPTool) Name() string

+ func (m *MCPTool) Parameters() interfaces.JSONSchema

type Option

+ func WithMCPClients(clients ...interfaces.MCPClient) Option

+ func WithMCPConfig(servers MCPServers) Option

v0.1.1

Apr 8, 2026

Changes in this version

type ApprovalStatus

+ const ApprovalStatusUnavailable

v0.1.0

Apr 6, 2026

v0.0.10

Apr 5, 2026

Changes in this version

+ func NoopLogger() logger.Logger

type Agent

+ func (a *Agent) Stream(ctx context.Context, input string, conversationID string) (chan *AgentEvent, error)

type AgentWorker

+ func (aw *AgentWorker) Stop()

type Option

+ func DisableLocalWorker() Option

+ func EnableRemoteWorkers() Option

v0.0.9

Mar 31, 2026

Changes in this version

+ var ErrAgentAlreadyRunning = errors.New("agent already has an active run")

+ var ErrSubAgentToolNotExecutable = errors.New("sub-agent tool must be executed via workflow, not Execute()")

+ func AllowlistToolApprovalPolicy(toolNames ...string) interfaces.AgentToolApprovalPolicy

+ func AutoToolApprovalPolicy() interfaces.AgentToolApprovalPolicy

+ func NewSubAgentTool(sub *Agent) interfaces.Tool

+ func SubAgentToolName(a *Agent) string

+ type Agent struct

+ func NewAgent(opts ...Option) (*Agent, error)

+ func (a *Agent) AgentEventWorkflow(ctx workflow.Context) error

+ func (a *Agent) Close()

+ func (a *Agent) EventPublishActivity(ctx context.Context, channel string, event *AgentEvent) error

+ func (a *Agent) OnApproval(ctx context.Context, approvalToken string, status ApprovalStatus) error

+ func (a *Agent) Run(ctx context.Context, input string, conversationID string) (*AgentResponse, error)

+ func (a *Agent) RunAsync(ctx context.Context, input string, conversationID string) (resultCh <-chan RunAsyncResult, approvalCh <-chan *ApprovalRequest, err error)

+ func (a *Agent) RunStream(ctx context.Context, input string, conversationID string) (chan *AgentEvent, error)

+ type AgentEvent struct

+ AgentName string

+ Approval *ApprovalEvent

+ Content string

+ Error error

+ Metadata map[string]interface{}

+ Timestamp time.Time

+ ToolCall *ToolCallEvent

+ Type AgentEventType

+ WorkflowID string

+ type AgentEventType string

+ const AgentEventApproval

+ const AgentEventComplete

+ const AgentEventContent

+ const AgentEventContentDelta

+ const AgentEventError

+ const AgentEventThinking

+ const AgentEventThinkingDelta

+ const AgentEventToolCall

+ const AgentEventToolResult

+ type AgentEventUpdate struct

+ AgentName string

+ Event *AgentEvent

+ LocalChannelName string

+ type AgentLLMInput struct

+ ConversationID string

+ Messages []interfaces.Message

+ SkipTools bool

+ type AgentLLMResult struct

+ Content string

+ ToolCalls []ToolCallRequest

+ type AgentLLMStreamInput struct

+ ConversationID string

+ EventWorkflowID string

+ LocalChannelName string

+ Messages []interfaces.Message

+ SkipTools bool

+ type AgentResponse struct

+ AgentName string

+ Content string

+ Metadata map[string]any

+ Model string

+ type AgentTool interface

+ SubAgent func() *Agent

+ type AgentToolApprovalInput struct

+ Args map[string]any

+ EventWorkflowID string

+ LocalChannelName string

+ ToolCallID string

+ ToolName string

+ type AgentToolExecuteInput struct

+ Args map[string]any

+ ConversationID string

+ Messages []interfaces.Message

+ ToolCallID string

+ ToolName string

+ type AgentWorker struct

+ func NewAgentWorker(opts ...Option) (*AgentWorker, error)

+ func NewAgentWorkerDefault() *AgentWorker

+ func (aw *AgentWorker) AddConversationMessagesActivity(ctx context.Context, conversationID string, messages []interfaces.Message) error

+ func (aw *AgentWorker) AgentLLMActivity(ctx context.Context, input AgentLLMInput) (*AgentLLMResult, error)

+ func (aw *AgentWorker) AgentLLMStreamActivity(ctx context.Context, input AgentLLMStreamInput) (*AgentLLMResult, error)

+ func (aw *AgentWorker) AgentToolApprovalActivity(ctx context.Context, input AgentToolApprovalInput) (ApprovalStatus, error)

+ func (aw *AgentWorker) AgentToolExecuteActivity(ctx context.Context, input AgentToolExecuteInput) (string, error)

+ func (aw *AgentWorker) AgentWorkflow(ctx workflow.Context, input AgentWorkflowInput) (*AgentResponse, error)

+ func (aw *AgentWorker) Close()

+ func (aw *AgentWorker) SendAgentEventUpdateActivity(ctx context.Context, eventWorkflowID string, upd *AgentEventUpdate) error

+ func (aw *AgentWorker) Start() error

+ type AgentWorkflowInput struct

+ ConversationID string

+ EventTypes []AgentEventType

+ EventWorkflowID string

+ LocalChannelName string

+ StreamingEnabled bool

+ SubAgentDepth int

+ SubAgentRoutes map[string]SubAgentRoute

+ UserPrompt string

+ type ApprovalEvent struct

+ ApprovalToken string

+ Args map[string]any

+ DelegateToName string

+ Kind ToolApprovalKind

+ ToolCallID string

+ ToolName string

+ type ApprovalHandler func(ctx context.Context, req *ApprovalRequest)

+ type ApprovalRequest struct

+ AgentName string

+ Args map[string]any

+ DelegateToName string

+ Kind ToolApprovalKind

+ Respond ApprovalSender

+ ToolName string

+ type ApprovalSender func(status ApprovalStatus) error

+ type ApprovalStatus string

+ const ApprovalStatusApproved

+ const ApprovalStatusNone

+ const ApprovalStatusPending

+ const ApprovalStatusRejected

+ type LLMSampling struct

+ MaxTokens int

+ Temperature *float64

+ TopK *int

+ TopP *float64

+ type Option func(*agentConfig)

+ func DisableWorker() Option

+ func WithApprovalHandler(fn ApprovalHandler) Option

+ func WithApprovalTimeout(d time.Duration) Option

+ func WithConversation(conv interfaces.Conversation) Option

+ func WithConversationSize(size int) Option

+ func WithDescription(desc string) Option

+ func WithEnableRemoteWorkers(enable bool) Option

+ func WithInstanceId(id string) Option

+ func WithLLMClient(client interfaces.LLMClient) Option

+ func WithLLMSampling(s *LLMSampling) Option

+ func WithLogLevel(level string) Option

+ func WithLogger(l log.Logger) Option

+ func WithMaxIterations(n int) Option

+ func WithMaxSubAgentDepth(depth int) Option

+ func WithName(name string) Option

+ func WithResponseFormat(rf *interfaces.ResponseFormat) Option

+ func WithStream(enable bool) Option

+ func WithSubAgents(subAgents ...*Agent) Option

+ func WithSystemPrompt(prompt string) Option

+ func WithTaskQueue(queue string) Option

+ func WithTemporalClient(tc client.Client) Option

+ func WithTemporalConfig(cfg *TemporalConfig) Option

+ func WithTimeout(d time.Duration) Option

+ func WithToolApprovalPolicy(policy interfaces.AgentToolApprovalPolicy) Option

+ func WithToolRegistry(reg interfaces.ToolRegistry) Option

+ func WithTools(tools ...interfaces.Tool) Option

+ type RequireAllToolApprovalPolicy struct

+ func (RequireAllToolApprovalPolicy) RequiresApproval(interfaces.Tool) bool

+ type RunAsyncResult struct

+ Err error

+ Response *AgentResponse

+ type SubAgentRoute struct

+ ChildRoutes map[string]SubAgentRoute

+ TaskQueue string

+ type TemporalConfig struct

+ Host string

+ Namespace string

+ Port int

+ TaskQueue string

+ type ToolApprovalKind string

+ const ToolApprovalKindDelegation

+ const ToolApprovalKindTool

+ type ToolCallEvent struct

+ Args map[string]any

+ Result any

+ Status ToolCallStatus

+ ToolCallID string

+ ToolName string

+ type ToolCallRequest struct

+ Args map[string]any

+ NeedsApproval bool

+ ToolCallID string

+ ToolName string

+ type ToolCallStatus string

+ const ToolCallStatusCompleted

+ const ToolCallStatusFailed

+ const ToolCallStatusPending

+ const ToolCallStatusRunning

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