loop

package

Go to main page

Versions in this module

v0

v0.9.1

Apr 23, 2026

Changes in this version

+ func FallbackContent(ctx context.Context) string

+ func NotifyEnvelopesFromContext(ctx context.Context) []messages.Envelope

+ func ReportAgentRun(ctx context.Context, s AgentRunSummary) map[string]any

+ func ReportConversationID(ctx context.Context, conversationID string) map[string]any

+ type AgentRunSummary struct

+ ActiveTags []string

+ EffectiveTools []string

+ InputTokens int

+ LoadedCapabilities []toolcatalog.LoadedCapabilityEntry

+ Model string

+ OutputTokens int

+ RequestID string

+ type Completion string

+ const CompletionChannel

+ const CompletionConversation

+ const CompletionNone

+ const CompletionReturn

+ type CompletionChannelTarget struct

+ Channel string

+ ConversationID string

+ Recipient string

+ func CloneCompletionChannelTarget(t *CompletionChannelTarget) *CompletionChannelTarget

+ func (t *CompletionChannelTarget) Validate() error

+ type CompletionDelivery struct

+ Channel *CompletionChannelTarget

+ Content string

+ ConversationID string

+ LoopID string

+ LoopName string

+ Mode Completion

+ Response *Response

+ Status *Status

+ type CompletionSink func(ctx context.Context, delivery CompletionDelivery) error

+ type Conditions struct

+ Schedule *ScheduleCondition

+ func (c Conditions) Evaluate(now time.Time) DefinitionEligibilityStatus

+ func (c Conditions) Validate() error

type Config

+ Completion Completion

+ FallbackContent string

+ Operation Operation

+ type DefinitionEligibilityStatus struct

+ Eligible bool

+ NextTransitionAt time.Time

+ Reason string

+ type DefinitionPolicy struct

+ Reason string

+ State DefinitionPolicyState

+ UpdatedAt time.Time

+ type DefinitionPolicySource string

+ const DefinitionPolicySourceDefault

+ const DefinitionPolicySourceOverlay

+ type DefinitionPolicyState string

+ const DefinitionPolicyStateActive

+ const DefinitionPolicyStateInactive

+ const DefinitionPolicyStatePaused

+ func ParseDefinitionPolicyState(raw string) (DefinitionPolicyState, error)

+ type DefinitionRecord struct

+ Spec Spec

+ UpdatedAt time.Time

+ type DefinitionRegistry struct

+ func NewDefinitionRegistry(base []Spec) (*DefinitionRegistry, error)

+ func (r *DefinitionRegistry) ApplyPolicy(name string, policy DefinitionPolicy, updatedAt time.Time) error

+ func (r *DefinitionRegistry) ClearPolicy(name string, updatedAt time.Time) error

+ func (r *DefinitionRegistry) Delete(name string, updatedAt time.Time) error

+ func (r *DefinitionRegistry) Get(name string) (Spec, bool)

+ func (r *DefinitionRegistry) ReplaceOverlay(records map[string]DefinitionRecord) error

+ func (r *DefinitionRegistry) ReplacePolicies(policies map[string]DefinitionPolicy, updatedAt time.Time) error

+ func (r *DefinitionRegistry) Snapshot() *DefinitionRegistrySnapshot

+ func (r *DefinitionRegistry) Upsert(spec Spec, updatedAt time.Time) error

+ type DefinitionRegistrySnapshot struct

+ ConfigDefinitions int

+ Definitions []DefinitionSnapshot

+ Generation int64

+ OverlayDefinitions int

+ UpdatedAt time.Time

+ type DefinitionRegistryView struct

+ ByEligibilityState map[string]int

+ ByPolicyState map[string]int

+ ByRuntimeState map[string]int

+ ConfigDefinitions int

+ Definitions []DefinitionView

+ DefinitionsWithWarnings int

+ Generation int64

+ OverlayDefinitions int

+ RunningDefinitions int

+ UpdatedAt time.Time

+ WarningCount int

+ func BuildDefinitionRegistryView(snapshot *DefinitionRegistrySnapshot, ...) *DefinitionRegistryView

+ type DefinitionRuntimeStatus struct

+ Attempts int

+ Iterations int

+ LastError string

+ LastWakeAt time.Time

+ LoopID string

+ Running bool

+ StartedAt time.Time

+ State State

+ type DefinitionSnapshot struct

+ Name string

+ PolicyReason string

+ PolicySource DefinitionPolicySource

+ PolicyState DefinitionPolicyState

+ PolicyUpdatedAt time.Time

+ Source DefinitionSource

+ Spec Spec

+ UpdatedAt time.Time

+ type DefinitionSource string

+ const DefinitionSourceConfig

+ const DefinitionSourceOverlay

+ type DefinitionView struct

+ Eligibility DefinitionEligibilityStatus

+ Runtime DefinitionRuntimeStatus

+ Warnings []DefinitionWarning

+ type DefinitionWarning struct

+ Code string

+ Message string

+ func BuildDefinitionWarnings(spec Spec) []DefinitionWarning

type Deps

+ CompletionSink CompletionSink

+ type ImmutableDefinitionError struct

+ Name string

+ func (e *ImmutableDefinitionError) Error() string

+ type InactiveDefinitionError struct

+ Name string

+ func (e *InactiveDefinitionError) Error() string

+ type IneligibleDefinitionError struct

+ Name string

+ Reason string

+ func (e *IneligibleDefinitionError) Error() string

type IterationResult

+ ActiveTags []string

+ EffectiveTools []string

+ LoadedCapabilities []toolcatalog.LoadedCapabilityEntry

+ RequestID string

type IterationSnapshot

+ ActiveTags []string

+ EffectiveTools []string

+ RequestID string

+ Tooling ToolingState

+ type Launch struct

+ AllowedTools []string

+ ChannelBinding *memory.ChannelBinding

+ CompletionChannel *CompletionChannelTarget

+ CompletionConversationID string

+ ConversationID string

+ ExcludeTools []string

+ FallbackContent string

+ Hints map[string]string

+ InitialTags []string

+ MaxIterations int

+ MaxOutputTokens int

+ Metadata map[string]string

+ Model string

+ OnProgress func(kind string, data map[string]any)

+ ParentID string

+ RunTimeout time.Duration

+ SkipContext bool

+ SkipTagFilter bool

+ Spec Spec

+ SystemPrompt string

+ Task string

+ ToolTimeout time.Duration

+ UsageRole string

+ UsageTaskName string

+ func (l *Launch) UnmarshalJSON(data []byte) error

+ func (l *Launch) Validate() error

+ func (l Launch) MarshalJSON() ([]byte, error)

+ type LaunchResult struct

+ Detached bool

+ FinalStatus *Status

+ LoopID string

+ Operation Operation

+ Response *Response

type Loop

+ func NewFromLaunch(launch Launch, deps Deps) (*Loop, error)

+ func NewFromSpec(spec Spec, deps Deps) (*Loop, error)

+ func (l *Loop) SetActiveTagsFunc(fn func() []string)

+ type Message struct

+ Content string

+ Role string

+ type NotifyReceipt struct

+ ForceSupervisor bool

+ LoopID string

+ LoopName string

+ PendingNotifications int

+ QueuedForNextWake bool

+ State State

+ WokeImmediately bool

+ type Operation string

+ const OperationBackgroundTask

+ const OperationRequestReply

+ const OperationService

+ type PausedDefinitionError struct

+ Name string

+ func (e *PausedDefinitionError) Error() string

type Registry

+ func (r *Registry) FindByName(name string) []*Loop

+ func (r *Registry) Launch(ctx context.Context, launch Launch, deps Deps) (LaunchResult, error)

+ func (r *Registry) MaxLoops() int

+ func (r *Registry) NotifyLoop(ctx context.Context, id string, env messages.Envelope) (NotifyReceipt, error)

+ func (r *Registry) NotifyLoopByName(ctx context.Context, name string, env messages.Envelope) (NotifyReceipt, error)

+ func (r *Registry) SpawnSpec(ctx context.Context, spec Spec, deps Deps) (string, error)

+ func (r *Registry) StopLoopByName(name string) error

+ type Request struct

+ AllowedTools []string

+ ChannelBinding *memory.ChannelBinding

+ ConversationID string

+ ExcludeTools []string

+ FallbackContent string

+ Hints map[string]string

+ InitialTags []string

+ MaxIterations int

+ MaxOutputTokens int

+ Messages []Message

+ Model string

+ OnProgress func(kind string, data map[string]any)

+ SkipContext bool

+ SkipTagFilter bool

+ SystemPrompt string

+ ToolTimeout time.Duration

+ UsageRole string

+ UsageTaskName string

+ type Response struct

+ ActiveTags []string

+ CacheCreationInputTokens int

+ CacheReadInputTokens int

+ Content string

+ ContextWindow int

+ EffectiveTools []string

+ Exhausted bool

+ FinishReason string

+ InputTokens int

+ Iterations int

+ LoadedCapabilities []toolcatalog.LoadedCapabilityEntry

+ Model string

+ OutputTokens int

+ RequestID string

+ ToolsUsed map[string]int

type RetriggerMode

+ func ParseRetriggerMode(raw string) (RetriggerMode, error)

+ func (m *RetriggerMode) UnmarshalText(text []byte) error

+ func (m RetriggerMode) MarshalText() ([]byte, error)

+ func (m RetriggerMode) String() string

+ type ScheduleCondition struct

+ Timezone string

+ Windows []ScheduleWindow

+ func (s *ScheduleCondition) Evaluate(now time.Time) DefinitionEligibilityStatus

+ func (s *ScheduleCondition) Validate() error

+ type ScheduleWindow struct

+ Days []string

+ End string

+ Start string

+ func (w ScheduleWindow) Validate() error

+ type Spec struct

+ Completion Completion

+ Conditions Conditions

+ Enabled bool

+ ExcludeTools []string

+ FallbackContent string

+ Handler func(ctx context.Context, event any) error

+ Hints map[string]string

+ Jitter *float64

+ MaxDuration time.Duration

+ MaxIter int

+ Metadata map[string]string

+ Name string

+ OnRetrigger RetriggerMode

+ Operation Operation

+ ParentID string

+ PostIterate func(ctx context.Context, result IterationResult) error

+ Profile router.LoopProfile

+ QualityFloor int

+ Setup func(l *Loop)

+ SleepDefault time.Duration

+ SleepMax time.Duration

+ SleepMin time.Duration

+ Supervisor bool

+ SupervisorContext string

+ SupervisorProb float64

+ SupervisorQualityFloor int

+ Tags []string

+ Task string

+ TaskBuilder func(ctx context.Context, isSupervisor bool) (string, error)

+ WaitFunc func(ctx context.Context) (any, error)

+ func (s *Spec) EffectiveConfig() Config

+ func (s *Spec) ToConfig() Config

+ func (s *Spec) UnmarshalJSON(data []byte) error

+ func (s *Spec) Validate() error

+ func (s *Spec) ValidatePersistable() error

+ func (s Spec) MarshalJSON() ([]byte, error)

type Status

+ ActiveTags []string

+ Tooling ToolingState

+ type ToolingState struct

+ ConfiguredTags []string

+ EffectiveTools []string

+ ExcludedTools []string

+ LoadedCapabilities []toolcatalog.LoadedCapabilityEntry

+ LoadedTags []string

+ ToolsUsed map[string]int

+ func BuildToolingState(configuredTags, loadedTags, effectiveTools, excludedTools []string, ...) ToolingState

+ type UnknownDefinitionError struct

+ Name string

+ func (e *UnknownDefinitionError) Error() string

v0.9.1-rc.2

Apr 23, 2026

v0.9.1-rc.1

Apr 23, 2026

v0.9.0-rc

Apr 7, 2026

v0.8.4

Mar 12, 2026

Changes in this version

+ var ErrNoOp = errors.New("loop: no-op iteration")

+ func LoopIDFromContext(ctx context.Context) string

v0.8.3

Mar 12, 2026

Changes in this version

+ const DefaultJitter

+ const DefaultSleepDefault

+ const DefaultSleepMax

+ const DefaultSleepMin

+ const DefaultSupervisorProb

+ var ErrLoopStopped = errors.New("loop: cannot start a stopped loop")

+ var ErrNilRunner = errors.New("loop: Runner is required")

+ func Float64Ptr(v float64) *float64

+ func IterationSummary(ctx context.Context) map[string]any

+ func ProgressFunc(ctx context.Context) func(string, map[string]any)

+ func SpawnDemoLoops(ctx context.Context, registry *Registry, eventBus *events.Bus, ...) error

+ type Config struct

+ ExcludeTools []string

+ Handler func(ctx context.Context, event any) error

+ Hints map[string]string

+ Jitter *float64

+ MaxDuration time.Duration

+ MaxIter int

+ Metadata map[string]string

+ Name string

+ OnRetrigger RetriggerMode

+ ParentID string

+ PostIterate func(ctx context.Context, result IterationResult) error

+ QualityFloor int

+ Setup func(l *Loop)

+ SleepDefault time.Duration

+ SleepMax time.Duration

+ SleepMin time.Duration

+ Supervisor bool

+ SupervisorContext string

+ SupervisorProb float64

+ SupervisorQualityFloor int

+ Tags []string

+ Task string

+ TaskBuilder func(ctx context.Context, isSupervisor bool) (string, error)

+ WaitFunc func(ctx context.Context) (any, error)

+ type Deps struct

+ EventBus *events.Bus

+ Logger *slog.Logger

+ Rand RandSource

+ Runner Runner

+ type IterationResult struct

+ ContextWindow int

+ ConvID string

+ Elapsed time.Duration

+ InputTokens int

+ Model string

+ OutputTokens int

+ Sleep time.Duration

+ Supervisor bool

+ ToolsUsed map[string]int

+ type IterationSnapshot struct

+ CompletedAt time.Time

+ ContextWindow int

+ ConvID string

+ ElapsedMs int64

+ Error string

+ InputTokens int

+ Model string

+ Number int

+ OutputTokens int

+ SleepAfterMs int64

+ StartedAt time.Time

+ Summary map[string]any

+ Supervisor bool

+ ToolsUsed map[string]int

+ WaitAfter bool

+ type Loop struct

+ func New(cfg Config, deps Deps) (*Loop, error)

+ func (l *Loop) CurrentConvID() string

+ func (l *Loop) Done() <-chan struct{}

+ func (l *Loop) ID() string

+ func (l *Loop) Name() string

+ func (l *Loop) SetNextSleep(d time.Duration)

+ func (l *Loop) Start(ctx context.Context) error

+ func (l *Loop) Status() Status

+ func (l *Loop) Stop()

+ type RandSource interface

+ Float64 func() float64

+ type Registry struct

+ func NewRegistry(opts ...RegistryOption) *Registry

+ func (r *Registry) ActiveCount() int

+ func (r *Registry) Deregister(id string)

+ func (r *Registry) Get(id string) *Loop

+ func (r *Registry) GetByName(name string) *Loop

+ func (r *Registry) List() []*Loop

+ func (r *Registry) Register(l *Loop) error

+ func (r *Registry) ShutdownAll(ctx context.Context) int

+ func (r *Registry) SpawnLoop(ctx context.Context, cfg Config, deps Deps) (string, error)

+ func (r *Registry) Statuses() []Status

+ func (r *Registry) StopLoop(id string) error

+ type RegistryOption func(*Registry)

+ func WithMaxLoops(n int) RegistryOption

+ func WithRegistryLogger(l *slog.Logger) RegistryOption

+ type RetriggerMode int

+ const RetriggerQueue

+ const RetriggerRestart

+ const RetriggerSingle

+ const RetriggerSpawn

+ type RunMessage struct

+ Content string

+ Role string

+ type RunRequest struct

+ ConversationID string

+ ExcludeTools []string

+ Hints map[string]string

+ Messages []RunMessage

+ OnProgress func(kind string, data map[string]any)

+ SkipTagFilter bool

+ type RunResponse struct

+ Content string

+ ContextWindow int

+ InputTokens int

+ Model string

+ OutputTokens int

+ ToolsUsed map[string]int

+ type Runner interface

+ Run func(ctx context.Context, req RunRequest, stream StreamCallback) (*RunResponse, error)

+ type State string

+ const StateError

+ const StatePending

+ const StateProcessing

+ const StateSleeping

+ const StateStopped

+ const StateWaiting

+ type Status struct

+ Attempts int

+ Config Config

+ ConsecutiveErrors int

+ ContextWindow int

+ EventDriven bool

+ HandlerOnly bool

+ ID string

+ Iterations int

+ LLMContext map[string]any

+ LastError string

+ LastInputTokens int

+ LastOutputTokens int

+ LastSupervisorIter int

+ LastWakeAt time.Time

+ Name string

+ ParentID string

+ RecentConvIDs []string

+ RecentIterations []IterationSnapshot

+ StartedAt time.Time

+ State State

+ TotalInputTokens int

+ TotalOutputTokens int

+ type StreamCallback func(event any)

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