Documentation
¶
Index ¶
- Constants
- func AgentRunWorkflow(ctx workflow.Context, input AgentRunWorkflowInput) error
- func QueueForRuntime(runtimeKind, invocationMode string) string
- func RegisterAgentRunWorker(w tworker.Worker, activities *AgentRunActivities)
- func TaskQueueName(baseName string) string
- func WorkflowIDForRun(runID string) string
- type AgentRunActivities
- func (a *AgentRunActivities) ExecuteRunActivity(ctx context.Context, appID, runID string) (ExecuteRunResult, error)
- func (a *AgentRunActivities) MarkRunFailedActivity(ctx context.Context, appID, runID, message string) error
- func (a *AgentRunActivities) PrepareRunActivity(ctx context.Context, appID, runID string) error
- type AgentRunWorkflowInput
- type ExecuteRunResult
- type QueueConfig
- type RunEngine
- func (e *RunEngine) CancelRun(ctx context.Context, run *agentcore.AgentRun) error
- func (e *RunEngine) CheckCodingAdmission(ctx context.Context) error
- func (e *RunEngine) DescribeRun(ctx context.Context, run *agentcore.AgentRun) (*engine.RunExecutionInfo, error)
- func (e *RunEngine) InspectRun(ctx context.Context, run *agentcore.AgentRun) (string, error)
- func (e *RunEngine) ResumeRun(ctx context.Context, run *agentcore.AgentRun, payload engine.ResumePayload) error
- func (e *RunEngine) StartRun(ctx context.Context, run *agentcore.AgentRun) error
- type RunMessageSignal
- type RunResumeSignal
Constants ¶
View Source
const ( QueueAgentNativeInteractive = "agent-native-interactive" QueueAgentNativeAutonomous = "agent-native-autonomous" QueueAgentNativeCoding = "agent-native-coding" QueueAutomation = "automation-default" WorkflowSignalResume = "ResumeRun" WorkflowSignalApprove = "ApproveRun" WorkflowSignalHandoff = "HandoffRun" WorkflowSignalMessage = "RunMessage" )
Variables ¶
This section is empty.
Functions ¶
func AgentRunWorkflow ¶
func AgentRunWorkflow(ctx workflow.Context, input AgentRunWorkflowInput) error
func QueueForRuntime ¶
func RegisterAgentRunWorker ¶
func RegisterAgentRunWorker(w tworker.Worker, activities *AgentRunActivities)
func TaskQueueName ¶
func WorkflowIDForRun ¶
Types ¶
type AgentRunActivities ¶
type AgentRunActivities struct {
// contains filtered or unexported fields
}
func NewAgentRunActivities ¶
func NewAgentRunActivities(store agentcore.Store, runner *engine.Engine) *AgentRunActivities
func (*AgentRunActivities) ExecuteRunActivity ¶
func (a *AgentRunActivities) ExecuteRunActivity(ctx context.Context, appID, runID string) (ExecuteRunResult, error)
func (*AgentRunActivities) MarkRunFailedActivity ¶
func (a *AgentRunActivities) MarkRunFailedActivity(ctx context.Context, appID, runID, message string) error
func (*AgentRunActivities) PrepareRunActivity ¶
func (a *AgentRunActivities) PrepareRunActivity(ctx context.Context, appID, runID string) error
type AgentRunWorkflowInput ¶
type ExecuteRunResult ¶
type QueueConfig ¶
func SharedQueues ¶
func SharedQueues() []QueueConfig
func WorkerQueues ¶
func WorkerQueues(coding bool) []QueueConfig
WorkerQueues keeps coding workers separate from the default shared workloads.
type RunEngine ¶
type RunEngine struct {
// contains filtered or unexported fields
}
func NewRunEngine ¶
func (*RunEngine) CheckCodingAdmission ¶
CheckCodingAdmission requires a live coding workflow poller in this namespace.
func (*RunEngine) DescribeRun ¶
func (*RunEngine) InspectRun ¶
type RunMessageSignal ¶
type RunMessageSignal struct {
Content string `json:"content"`
}
type RunResumeSignal ¶
type RunResumeSignal struct {
Intent string `json:"intent"`
Content string `json:"content,omitempty"`
ResponsePayload json.RawMessage `json:"response_payload,omitempty"`
ExternalActorID string `json:"external_actor_id,omitempty"`
ResumeID string `json:"resume_id,omitempty"`
InteractionID string `json:"interaction_id,omitempty"`
}
Click to show internal directories.
Click to hide internal directories.