Help us shape the future of Go! Take the 2026 Go Developer Survey

durable

package
v0.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 17, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

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 QueueForRuntime(runtimeKind, invocationMode string) string

func RegisterAgentRunWorker

func RegisterAgentRunWorker(w tworker.Worker, activities *AgentRunActivities)

func TaskQueueName

func TaskQueueName(baseName string) string

func WorkflowIDForRun

func WorkflowIDForRun(runID string) string

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 AgentRunWorkflowInput struct {
	AppID string `json:"app_id"`
	RunID string `json:"run_id"`
}

type ExecuteRunResult

type ExecuteRunResult struct {
	WaitForApproval   bool `json:"wait_for_approval"`
	AwaitingInput     bool `json:"awaiting_input"`
	AwaitingAuth      bool `json:"awaiting_auth"`
	ContinueExecution bool `json:"continue_execution"`
}

type QueueConfig

type QueueConfig struct {
	Name        string
	Concurrency int
}

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 NewRunEngine(client tclient.Client) *RunEngine

func (*RunEngine) CancelRun

func (e *RunEngine) CancelRun(ctx context.Context, run *agentcore.AgentRun) error

func (*RunEngine) CheckCodingAdmission

func (e *RunEngine) CheckCodingAdmission(ctx context.Context) error

CheckCodingAdmission requires a live coding workflow poller in this namespace.

func (*RunEngine) DescribeRun

func (e *RunEngine) DescribeRun(ctx context.Context, run *agentcore.AgentRun) (*engine.RunExecutionInfo, error)

func (*RunEngine) InspectRun

func (e *RunEngine) InspectRun(ctx context.Context, run *agentcore.AgentRun) (string, error)

func (*RunEngine) ResumeRun

func (e *RunEngine) ResumeRun(ctx context.Context, run *agentcore.AgentRun, payload engine.ResumePayload) error

func (*RunEngine) StartRun

func (e *RunEngine) StartRun(ctx context.Context, run *agentcore.AgentRun) error

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"`
}

Jump to

Keyboard shortcuts

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