Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

venat

package module

Go to main page

Versions in this module

v0

v0.13.0

Aug 1, 2026

Changes in this version

type Runner

+ func (r *Runner) AppendTaskExecutionEvent(ctx context.Context, cmd api.AppendTaskExecutionEventCommand) error

+ func (r *Runner) ListActionAttempts(ctx context.Context, selector api.ActionAttemptSelector) ([]api.ActionAttempt, error)

+ func (r *Runner) ResolveActionAttempt(ctx context.Context, cmd api.ResolveActionAttemptCommand) (api.ActionAttempt, error)

v0.12.1

Jul 31, 2026

v0.12.0

Jul 31, 2026

Changes in this version

+ var ErrActionReconcileRequired = api.ErrActionReconcileRequired

+ var ErrActionTaskRequired = api.ErrActionTaskRequired

+ var ErrCompletionCriteriaUnmet = api.ErrCompletionCriteriaUnmet

+ var ErrDependencyFailed = api.ErrDependencyFailed

+ var ErrDependencyUnmet = api.ErrDependencyUnmet

+ var ErrHandoffCycle = api.ErrHandoffCycle

+ var ErrHandoffDepthExceeded = api.ErrHandoffDepthExceeded

+ var ErrIdempotencyConflict = api.ErrIdempotencyConflict

+ var ErrInvalidAddress = api.ErrInvalidAddress

+ var ErrInvalidCommand = api.ErrInvalidCommand

+ var ErrInvalidConfiguration = api.ErrInvalidConfiguration

+ var ErrInvalidTransition = api.ErrInvalidTransition

+ var ErrLeaseHolderMismatch = api.ErrLeaseHolderMismatch

+ var ErrLeaseNotActive = api.ErrLeaseNotActive

+ var ErrNoRecipients = api.ErrNoRecipients

+ var ErrNotFound = api.ErrNotFound

+ var ErrOwnerMismatch = api.ErrOwnerMismatch

+ var ErrPolicyDenied = api.ErrPolicyDenied

+ var ErrPolicyObligationFailed = api.ErrPolicyObligationFailed

+ var ErrResponseTaskRequired = api.ErrResponseTaskRequired

+ var ErrStaleTaskVersion = api.ErrStaleTaskVersion

+ var ErrSubscriptionClosed = api.ErrSubscriptionClosed

+ var ErrTerminalState = api.ErrTerminalState

+ var ErrWaitTimeout = api.ErrWaitTimeout

+ func DefaultConfig() api.Config

+ type Runner struct

+ func New(configs ...api.Config) *Runner

+ func NewDevelopment(configs ...api.Config) *Runner

+ func NewProduction(cfg api.Config) (*Runner, error)

+ func (r *Runner) AckEnvelope(ctx context.Context, cmd api.AckEnvelopeCommand) error

+ func (r *Runner) AcquireTaskExecution(ctx context.Context, cmd api.AcquireTaskExecutionCommand) (api.TaskExecutionLease, bool, error)

+ func (r *Runner) ActiveLeaseCount(runID, taskID string) int

+ func (r *Runner) ActiveLeaseCountContext(ctx context.Context, runID, taskID string) int

+ func (r *Runner) AdvanceRun(ctx context.Context, cmd api.AdvanceRunCommand) (api.Run, error)

+ func (r *Runner) Agents() []api.AgentProfile

+ func (r *Runner) AppendEvent(ctx context.Context, event api.Event) error

+ func (r *Runner) AppendUsage(ctx context.Context, record api.UsageRecord) error

+ func (r *Runner) Begin(ctx context.Context) (api.UnitOfWork, error)

+ func (r *Runner) Close(ctx context.Context) error

+ func (r *Runner) CompleteActionAttempt(ctx context.Context, cmd api.CompleteActionAttemptCommand) (api.ActionAttempt, error)

+ func (r *Runner) CreateTask(ctx context.Context, cmd api.CreateTaskCommand) (api.Task, error)

+ func (r *Runner) DeadLetter(ctx context.Context, cmd api.DeadLetterCommand) error

+ func (r *Runner) DecideApproval(ctx context.Context, cmd api.DecideApprovalCommand) error

+ func (r *Runner) DispatchTask(ctx context.Context, cmd api.DispatchTaskCommand) (api.TaskEnvelope, error)

+ func (r *Runner) DispatchTaskFanOut(ctx context.Context, cmd api.FanOutDispatchTaskCommand) ([]api.TaskEnvelope, error)

+ func (r *Runner) DrainResponseOutbox(ctx context.Context) (int, error)

+ func (r *Runner) EndTraceSpan(ctx context.Context, cmd api.EndTraceSpanCommand) error

+ func (r *Runner) Events(runID string) []api.Event

+ func (r *Runner) ExecuteCommand(ctx context.Context, command api.Command) (any, error)

+ func (r *Runner) HeartbeatTaskExecution(ctx context.Context, cmd api.HeartbeatTaskExecutionCommand) error

+ func (r *Runner) InvokeTool(ctx context.Context, cmd api.ToolInvocation) (api.ToolInvocationResult, error)

+ func (r *Runner) ListEnvelopes(ctx context.Context, runID string) ([]api.TaskEnvelope, error)

+ func (r *Runner) ListEvents(ctx context.Context, runID string) ([]api.Event, error)

+ func (r *Runner) ListMessages(ctx context.Context, runID string) ([]api.UserMessage, error)

+ func (r *Runner) ListQueuedMessages(ctx context.Context) ([]api.UserMessage, error)

+ func (r *Runner) ListTasks(ctx context.Context, runID string) ([]api.Task, error)

+ func (r *Runner) ListTraceSpans(ctx context.Context, runID string) ([]api.TraceSpan, error)

+ func (r *Runner) LoadEnvelope(ctx context.Context, envelopeID string) (api.TaskEnvelope, error)

+ func (r *Runner) LoadMessage(ctx context.Context, runID, messageID string) (api.UserMessage, error)

+ func (r *Runner) LoadRun(ctx context.Context, runID string) (api.Run, error)

+ func (r *Runner) LoadTask(ctx context.Context, runID, taskID string) (api.Task, error)

+ func (r *Runner) Mode() api.RuntimeMode

+ func (r *Runner) PendingResumeTokens(ctx context.Context, selector api.ResumeTokenSelector) ([]api.ResumeToken, error)

+ func (r *Runner) PublishResponse(ctx context.Context, cmd api.PublishResponseCommand) error

+ func (r *Runner) QueryUsage(ctx context.Context, selector api.UsageSelector) ([]api.UsageRecord, error)

+ func (r *Runner) QueueEnvelope(ctx context.Context, env api.TaskEnvelope) error

+ func (r *Runner) QueueMessage(ctx context.Context, message api.UserMessage) error

+ func (r *Runner) QueueRun(ctx context.Context, cmd api.StartRunCommand) (api.Run, error)

+ func (r *Runner) ReadyTasks(runID string) []api.Task

+ func (r *Runner) ReadyTasksContext(ctx context.Context, runID string) []api.Task

+ func (r *Runner) Recover(ctx context.Context, runID string) (api.Projection, error)

+ func (r *Runner) RecoverResumeToken(ctx context.Context, cmd api.RecoverResumeTokenCommand) (api.ResumeToken, error)

+ func (r *Runner) RegisterAgent(profile api.AgentProfile)

+ func (r *Runner) RegisterFlow(flow api.Flow) error

+ func (r *Runner) RegisterTool(tool api.Tool)

+ func (r *Runner) ReleaseTaskExecution(ctx context.Context, cmd api.ReleaseTaskExecutionCommand) error

+ func (r *Runner) Replay(runID string, mode api.ReplayMode) (api.Projection, error)

+ func (r *Runner) ReplayContext(ctx context.Context, runID string, mode api.ReplayMode) (api.Projection, error)

+ func (r *Runner) ReplayRunState(runID string) (api.Projection, error)

+ func (r *Runner) ReplayRunStateContext(ctx context.Context, runID string) (api.Projection, error)

+ func (r *Runner) RequestApproval(ctx context.Context, cmd api.RequestApprovalCommand) (api.ApprovalRequest, api.ResumeToken, error)

+ func (r *Runner) RequestHandoff(ctx context.Context, cmd api.HandoffCommand) error

+ func (r *Runner) ResponseOutbox(runID string) []api.UserMessage

+ func (r *Runner) ResponseOutboxContext(ctx context.Context, runID string) []api.UserMessage

+ func (r *Runner) ResumeTokens() map[string]api.ResumeToken

+ func (r *Runner) Run(ctx context.Context, runID string) (api.Run, error)

+ func (r *Runner) RunEvents(ctx context.Context, runID string) ([]api.Event, error)

+ func (r *Runner) RunTimeline(ctx context.Context, runID string) ([]api.RunTimelineItem, error)

+ func (r *Runner) SaveRun(ctx context.Context, run api.Run) error

+ func (r *Runner) SaveTask(ctx context.Context, task api.Task) error

+ func (r *Runner) SaveTraceSpan(ctx context.Context, span api.TraceSpan) error

+ func (r *Runner) SelectItems(ctx context.Context, runID string, selector api.BlackboardSelector) ([]api.BlackboardItem, error)

+ func (r *Runner) SetMessagePolicy(policy api.MessagePolicyChecker)

+ func (r *Runner) SetOutputGateway(gateway api.OutputGateway)

+ func (r *Runner) SetPipeline(components api.PipelineComponents)

+ func (r *Runner) SetPolicyEngine(policy api.PolicyEngine)

+ func (r *Runner) StartActionAttempt(ctx context.Context, cmd api.StartActionAttemptCommand) (api.ActionAttempt, error)

+ func (r *Runner) StartRun(ctx context.Context, cmd api.StartRunCommand) (api.Run, api.Task, error)

+ func (r *Runner) StartTraceSpan(ctx context.Context, cmd api.StartTraceSpanCommand) (api.TraceSpan, error)

+ func (r *Runner) StoreCapabilities(ctx context.Context) (api.StoreCapabilities, error)

+ func (r *Runner) StoreProvider() api.StoreProvider

+ func (r *Runner) SubmitResponseOutput(ctx context.Context, cmd api.SubmitResponseOutputCommand) error

+ func (r *Runner) SubmitTypedReport(ctx context.Context, cmd api.SubmitTypedReportCommand) error

+ func (r *Runner) SubmitUserInput(ctx context.Context, cmd api.SubmitUserInputCommand) error

+ func (r *Runner) Subscribe(ctx context.Context, runID string, filter api.BlackboardFilter) (<-chan api.BlackboardItem, func() error, error)

+ func (r *Runner) SumUsageCredits(ctx context.Context, selector api.UsageSelector) (int64, error)

+ func (r *Runner) Task(ctx context.Context, runID, taskID string) (api.Task, error)

+ func (r *Runner) TraceSpans(runID string) []api.TraceSpan

+ func (r *Runner) TransitionRun(ctx context.Context, cmd api.TransitionRunCommand) error

+ func (r *Runner) TransitionTask(ctx context.Context, cmd api.TransitionTaskCommand) error

+ func (r *Runner) UpdateEnvelope(ctx context.Context, env api.TaskEnvelope) error

+ func (r *Runner) UpdateMessage(ctx context.Context, message api.UserMessage) error

+ func (r *Runner) WaitForBlackboard(ctx context.Context, runID string, filter api.BlackboardFilter, ...) ([]api.BlackboardItem, error)

+ func (r *Runner) WriteItem(ctx context.Context, item api.BlackboardItem) error