Versions in this module Expand all Collapse all v0 v0.0.2 Sep 9, 2026 Changes in this version + const LocalTaskMetaKey + func ExcludeLocal(_ protocol.MessageAddress, message protocol.ChatMessage) bool + func IsLocal(message protocol.ChatMessage) bool + func IsManagedTask(ctx context.Context) bool + func MarkLocal(message protocol.ChatMessage) protocol.ChatMessage + func WithManagedTask(ctx context.Context) context.Context + func Wrap(inner runtime.TurnExecutor, tasks TaskOps) runtime.TurnExecutor + func WrapWhen(inner runtime.TurnExecutor, tasks TaskOps, predicate Predicate) runtime.TurnExecutor + type Executor struct + func (e Executor) Run(ctx context.Context, addr protocol.MessageAddress, user protocol.ChatMessage) (protocol.ChatMessage, error) + type Predicate func(addr protocol.MessageAddress, user protocol.ChatMessage) bool + type TaskOps interface + ClaimTask func(ctx context.Context, taskID string) error + CompleteTask func(ctx context.Context, taskID string) error + FailTask func(ctx context.Context, taskID, reason string) error + type TerminalAcknowledger interface + AcknowledgeTaskTerminal func(ctx context.Context, workspaceID, taskID string) error
Go to main page