control

package

Go to main page

Versions in this module

v1

v1.0.5

Aug 22, 2026

v1.0.4

Aug 22, 2026

Changes in this version

+ const ErrorAgentChannelState

+ const ErrorAgentRecoveryUnavailable

+ const ErrorChatAuthorityViolation

+ const ErrorChatPolicyUnavailable

+ const ErrorPrimaryAgentDrift

+ const ErrorPrimaryAgentNotConfigured

+ const ErrorPrimaryAgentUnready

+ const ErrorPrimaryChannelInvariant

+ const ErrorProviderFailed

+ const ErrorProviderIncomplete

+ const ErrorProviderRefusal

+ const ErrorProviderResultUnknown

+ const MaxOccurrencePageLimit

+ const MaxScheduleDefinitions

+ const PrimaryAgentDrifted

+ const PrimaryAgentIneligible

+ const PrimaryAgentNotConfigured

+ const PrimaryAgentReady

+ const PrimaryAgentReasonNotEligible

+ const PrimaryAgentUnready

+ const ScheduleDetailOccurrenceLimit

+ var ErrInvalidOccurrencePage = errors.New("invalid schedule occurrence page")

+ var ErrInvalidScheduleFilter = errors.New("invalid schedule filter")

+ var ErrScheduleInventoryDrift = errors.New("schedule_inventory_drift")

+ var ErrScheduleInventoryUnaccepted = errors.New("schedule_inventory_unaccepted")

+ func ErrorCode(err error) string

+ func FlowDefinitionDigest(definition graph.Flow) (string, error)

+ func FlowDefinitionDigests(definitions []graph.Flow) (map[string]string, error)

+ type AgentChannelService struct

+ func NewAgentChannelService(st *store.Store, primary *PrimaryChannelService, options AgentOptionSource) *AgentChannelService

+ func (s *AgentChannelService) AgentNeedsYou(ctx context.Context) ([]ui.AgentNeedsYouItem, error)

+ func (s *AgentChannelService) AgentOptions(ctx context.Context) ([]ui.AgentOption, error)

+ func (s *AgentChannelService) CancelAgentTarget(ctx context.Context, channelID, conversationID, targetID string) error

+ func (s *AgentChannelService) CreateAgentChannel(ctx context.Context, optionID, name string) (ui.AgentChannelDetail, error)

+ func (s *AgentChannelService) CreateAgentConversation(ctx context.Context, channelID, name string) (ui.AgentConversationDetail, error)

+ func (s *AgentChannelService) GetAgentChannel(ctx context.Context, id string) (ui.AgentChannelDetail, error)

+ func (s *AgentChannelService) GetAgentConversation(ctx context.Context, channelID, conversationID string) (ui.AgentConversationDetail, error)

+ func (s *AgentChannelService) ListAgentChannels(ctx context.Context, state string) ([]ui.AgentChannelSummary, error)

+ func (s *AgentChannelService) ListAgentConversations(ctx context.Context, channelID, state string) ([]conversation.AgentConversationSummary, error)

+ func (s *AgentChannelService) PostAgentTurn(ctx context.Context, channelID, conversationID, clientTurnID, text string) (conversation.TurnResult, error)

+ func (s *AgentChannelService) PostFirstAgentTurn(ctx context.Context, channelID, name, clientTurnID, text string) (ui.AgentFirstTurnResult, error)

+ func (s *AgentChannelService) RecheckAgentOptions(ctx context.Context) ([]ui.AgentOption, error)

+ func (s *AgentChannelService) RenameAgentChannel(ctx context.Context, id, name string) error

+ func (s *AgentChannelService) RenameAgentConversation(ctx context.Context, channelID, conversationID, name string) error

+ func (s *AgentChannelService) RetryAgentTarget(ctx context.Context, channelID, conversationID, targetID string) (conversation.Target, error)

+ func (s *AgentChannelService) SetAgentChannelState(ctx context.Context, id string, state conversation.AgentChannelState) error

+ func (s *AgentChannelService) SetAgentConversationPinned(ctx context.Context, channelID, conversationID string, pinned bool) error

+ func (s *AgentChannelService) SetAgentConversationState(ctx context.Context, channelID, conversationID string, ...) error

+ type AgentOptionSource interface

+ AgentOptions func(context.Context) ([]ui.AgentOption, error)

+ RecheckAgentOptions func(context.Context) ([]ui.AgentOption, error)

type CapabilityCoordinator

+ func (c *CapabilityCoordinator) RecheckConversationSeats(ctx context.Context) error

+ type OccurrencePage struct

+ Before time.Time

+ BeforeID string

+ Limit int

+ type PrimaryAgentOption = ui.PrimaryAgentOption

+ type PrimaryAgentView = ui.PrimaryAgentView

+ type PrimaryChannelError struct

+ Code string

+ Err error

+ func (e *PrimaryChannelError) Error() string

+ func (e *PrimaryChannelError) PrimaryChannelCode() string

+ func (e *PrimaryChannelError) Unwrap() error

+ type PrimaryChannelService struct

+ func NewPrimaryChannelService(st *store.Store, rt coreruntime.Runtime, ...) *PrimaryChannelService

+ func (s *PrimaryChannelService) CancelTarget(ctx context.Context, channelID, targetID string) error

+ func (s *PrimaryChannelService) ClearPrimaryAgent(context.Context) error

+ func (s *PrimaryChannelService) Close()

+ func (s *PrimaryChannelService) CreateChannel(ctx context.Context, name string) (ui.PrimaryChannelDetail, error)

+ func (s *PrimaryChannelService) GetChannel(_ context.Context, id string) (ui.PrimaryChannelDetail, error)

+ func (s *PrimaryChannelService) ListChannels(_ context.Context, state string) ([]conversation.PrimaryChannelSummary, error)

+ func (s *PrimaryChannelService) NeedsYou(ctx context.Context) ([]PrimaryNeedsYouItem, error)

+ func (s *PrimaryChannelService) PostTurn(ctx context.Context, channelID, clientTurnID, text string) (conversation.TurnResult, error)

+ func (s *PrimaryChannelService) PrimaryAgent(context.Context) (PrimaryAgentView, error)

+ func (s *PrimaryChannelService) RecheckAndRetryTarget(ctx context.Context, channelID, targetID string) (conversation.Target, error)

+ func (s *PrimaryChannelService) RecheckPrimaryAgent(ctx context.Context) (PrimaryAgentView, error)

+ func (s *PrimaryChannelService) RenameChannel(ctx context.Context, id, name string) error

+ func (s *PrimaryChannelService) RetryTarget(ctx context.Context, channelID, targetID string) (conversation.Target, error)

+ func (s *PrimaryChannelService) SetChannelPinned(ctx context.Context, id string, pinned bool) error

+ func (s *PrimaryChannelService) SetChannelState(ctx context.Context, id string, state conversation.ConversationState) error

+ func (s *PrimaryChannelService) SetPrimaryAgent(_ context.Context, optionID string) (PrimaryAgentView, error)

+ func (s *PrimaryChannelService) Wait()

+ type PrimaryNeedsYouItem = ui.PrimaryNeedsYouItem

+ type PrimaryOptionCapabilities interface

+ Capabilities func() (corecap.Snapshot, uint64)

+ Refresh func(context.Context, corecap.RefreshMode, []string) (corecap.Snapshot, uint64, error)

+ RefreshMachine func(context.Context, string, corecap.RefreshMode, []string) (corecap.MachineInventory, error)

+ type RelatedChannel struct

+ ID string

+ Name string

+ type ScheduleDetail struct

+ Item ScheduleItem

+ Recent []scheduler.Occurrence

+ Upcoming []scheduler.Occurrence

+ type ScheduleFilter string

+ const ScheduleFilterActive

+ const ScheduleFilterAll

+ const ScheduleFilterPaused

+ type ScheduleInventory struct

+ AcceptedDigest string

+ CurrentDigest string

+ Items []ScheduleInventoryItem

+ State ScheduleInventoryState

+ type ScheduleInventoryItem struct

+ Expression string

+ FlowDigest string

+ FlowID string

+ ID string

+ Kind scheduler.Kind

+ Timezone string

+ type ScheduleInventoryState string

+ const ScheduleInventoryAccepted

+ const ScheduleInventoryDrift

+ const ScheduleInventoryUnaccepted

+ type ScheduleItem struct

+ Enabled bool

+ Expression string

+ ID string

+ Kind scheduler.Kind

+ LastFireAt *time.Time

+ LatestOccurrence *scheduler.Occurrence

+ NextFireAt *time.Time

+ ObservedAt time.Time

+ Recurrence string

+ RelatedChannel *RelatedChannel

+ SchedulerOwnership SchedulerOwnership

+ TargetID string

+ TargetKind string

+ Timezone string

+ Title string

+ type ScheduleList struct

+ Items []ScheduleItem

+ ObservedAt time.Time

+ SnapshotID string

+ type ScheduleReadAdapter struct

+ func NewScheduleReadAdapter(service *ScheduleReadService) *ScheduleReadAdapter

+ func (a *ScheduleReadAdapter) Get(ctx context.Context, id string) (ui.ScheduleDetail, error)

+ func (a *ScheduleReadAdapter) Inventory(ctx context.Context, acceptedDigest string) (ui.ScheduleInventory, error)

+ func (a *ScheduleReadAdapter) List(ctx context.Context, filter ui.ScheduleFilter) (ui.ScheduleList, error)

+ func (a *ScheduleReadAdapter) Occurrences(ctx context.Context, id string, page ui.OccurrencePage) ([]scheduler.Occurrence, error)

+ type ScheduleReadRepository interface

+ ReadScheduleCatalog func(context.Context, *bool, int) ([]store.ScheduleReadRow, error)

+ ReadScheduleDetail func(context.Context, string, time.Time, int) (store.ScheduleReadDetail, error)

+ ReadScheduleOccurrences func(context.Context, string, int, time.Time, string) ([]scheduler.Occurrence, error)

+ type ScheduleReadService struct

+ func NewScheduleReadService(repository ScheduleReadRepository, ownership SchedulerOwnership, ...) *ScheduleReadService

+ func (s *ScheduleReadService) Get(ctx context.Context, id string) (ScheduleDetail, error)

+ func (s *ScheduleReadService) Inventory(ctx context.Context, acceptedDigest string) (ScheduleInventory, error)

+ func (s *ScheduleReadService) List(ctx context.Context, filter ScheduleFilter) (ScheduleList, error)

+ func (s *ScheduleReadService) Occurrences(ctx context.Context, id string, page OccurrencePage) ([]scheduler.Occurrence, error)

+ type SchedulerOwnership string

+ const SchedulerOwnershipActive

+ const SchedulerOwnershipInactive

+ const SchedulerOwnershipUnknown

v0

v0.13.0

Aug 1, 2026

Changes in this version

+ type CapabilityCoordinator struct

+ func NewCapabilityCoordinator(options CapabilityCoordinatorOptions) (*CapabilityCoordinator, error)

+ func (c *CapabilityCoordinator) Capabilities() (corecap.Snapshot, uint64)

+ func (c *CapabilityCoordinator) Current() (corecap.Snapshot, uint64)

+ func (c *CapabilityCoordinator) Refresh(ctx context.Context, mode corecap.RefreshMode, adapters []string) (corecap.Snapshot, uint64, error)

+ func (c *CapabilityCoordinator) RefreshMachine(ctx context.Context, target string, mode corecap.RefreshMode, ...) (corecap.MachineInventory, error)

+ type CapabilityCoordinatorOptions struct

+ Live *machines.Live

+ Local LocalCapabilityRegistry

+ LocalName string

+ Now func() time.Time

+ Peers PeerCapabilityClient

+ type CapabilitySnapshotSource interface

+ Capabilities func() (corecap.Snapshot, uint64)

+ type ConversationActivity interface

+ ConversationTargetActive func(string) bool

+ type ConversationSeatSource interface

+ ConversationSeats func() []conversation.Seat

+ func FakeConversationSeats(machine string) ConversationSeatSource

+ type ConversationService struct

+ func NewConversationService(st *store.Store, rt runtime.Runtime, seats ConversationSeatSource, ...) *ConversationService

+ func (s *ConversationService) AddConversationParticipant(_ context.Context, conversationID, seatID string) (conversation.Participant, error)

+ func (s *ConversationService) CancelTarget(_ context.Context, targetID string) error

+ func (s *ConversationService) Close()

+ func (s *ConversationService) ConversationSeats(context.Context) ([]conversation.Seat, error)

+ func (s *ConversationService) ConversationTargetActive(id string) bool

+ func (s *ConversationService) CreateConversation(_ context.Context, projectID, title string, seatIDs []string) (store.ConversationDetail, error)

+ func (s *ConversationService) CreateProject(_ context.Context, name string) (conversation.Project, error)

+ func (s *ConversationService) DeleteConversation(_ context.Context, id string) error

+ func (s *ConversationService) DeleteProject(_ context.Context, id string) error

+ func (s *ConversationService) GetConversation(_ context.Context, id string) (store.ConversationDetail, error)

+ func (s *ConversationService) ListConversations(_ context.Context, scope string) ([]conversation.Conversation, error)

+ func (s *ConversationService) ListProjects(context.Context) ([]conversation.Project, error)

+ func (s *ConversationService) MoveConversation(_ context.Context, id, projectID string) error

+ func (s *ConversationService) PostTurn(_ context.Context, conversationID, clientTurnID, text string, ...) (conversation.TurnResult, error)

+ func (s *ConversationService) RemoveConversationParticipant(_ context.Context, conversationID, participantID string) error

+ func (s *ConversationService) RenameConversation(_ context.Context, id, title string) error

+ func (s *ConversationService) RenameProject(_ context.Context, id, name string) error

+ func (s *ConversationService) RetryTarget(_ context.Context, targetID string) (conversation.Target, error)

+ func (s *ConversationService) SetConversationState(_ context.Context, id string, state conversation.ConversationState) error

+ func (s *ConversationService) Wait()

+ type CreateConversationRequest struct

+ ProjectID string

+ SeatIDs []string

+ Title string

type EngineDispatcher

+ func (d EngineDispatcher) Accept(ctx context.Context, t task.Task) (ui.RunRef, error)

type FlowExecutor

+ func (f FlowExecutor) ResumeFlowAsync(ctx context.Context, flowID, runID string) error

+ func (f FlowExecutor) StartFlowAsync(ctx context.Context, flowID, runID, payload string) (ui.RunResult, error)

+ func (f FlowExecutor) StartPlaybookAsync(ctx context.Context, route ui.RoutePreview, runID, direction string) (ui.PlaybookRunResult, error)

+ type LocalCapabilityRegistry interface

+ Current func() corecap.NodeInventory

+ Refresh func(context.Context, corecap.RecheckRequest) (corecap.NodeInventory, error)

+ type PeerCapabilityClient interface

+ Refresh func(context.Context, string, string, corecap.RecheckRequest) (corecap.NodeInventory, error)

+ type PostConversationTurnRequest struct

+ TargetParticipantIDs []string

+ Text string

type QueueDispatcher

+ func (d QueueDispatcher) Accept(ctx context.Context, t task.Task) (ui.RunRef, error)

+ type ScheduleCreator interface

+ Create func(context.Context, scheduler.Definition) error

+ type ScheduleService struct

+ func NewScheduleService(next ScheduleCreator, flowIDs []string) *ScheduleService

+ func (s *ScheduleService) Create(ctx context.Context, definition scheduler.Definition) error

+ type SnapshotConversationSeats struct

+ Source CapabilitySnapshotSource

+ func (s SnapshotConversationSeats) ConversationSeats() []conversation.Seat

+ type TodayScheduleSource interface

+ MaterializeDay func(context.Context, time.Time, *time.Location) error

+ type TodayService struct

+ func NewTodayService(st *store.Store, schedules TodayScheduleSource, activity ConversationActivity) *TodayService

+ func (s *TodayService) Today(ctx context.Context, now time.Time, location *time.Location) (coretoday.View, error)

v0.12.0

Jul 22, 2026

Changes in this version

type FlowExecutor

+ func (f FlowExecutor) StartPlaybook(ctx context.Context, route ui.RoutePreview, runID, direction string) (ui.PlaybookRunResult, error)

+ func (f FlowExecutor) WithPlaybooks(catalog *PlaybookCatalog) FlowExecutor

+ type PlaybookCatalog struct

+ func NewPlaybookCatalog(st *store.Store) *PlaybookCatalog

+ func (c *PlaybookCatalog) Duplicate(ctx context.Context, id string) (ui.Playbook, error)

+ func (c *PlaybookCatalog) List(ctx context.Context) ([]ui.Playbook, error)

+ func (c *PlaybookCatalog) Route(ctx context.Context, request ui.RouteRequest) (ui.RoutePreview, error)

+ func (c *PlaybookCatalog) Save(ctx context.Context, definition ui.Playbook) (ui.Playbook, error)

v0.11.0

Jul 19, 2026

Changes in this version

type FlowExecutor

+ func (f FlowExecutor) Plan(flowID string) []ui.FlowNode

v0.10.4

Jul 10, 2026

v0.10.3

Jul 9, 2026

v0.10.2

Jul 9, 2026

v0.10.1

Jul 9, 2026

v0.10.0

Jul 9, 2026

v0.9.0

Jul 7, 2026

v0.8.0

Jul 7, 2026

Changes in this version

+ type Planner struct

+ func NewPlanner(e *engine.Engine, s *store.Store, defaultAgent string) Planner

+ func (p Planner) Breakdown(ctx context.Context, goal, agent, machine string) (string, error)

v0.7.0

Jul 6, 2026

v0.6.1

Jul 6, 2026

v0.6.0

Jul 5, 2026

v0.5.1

Jul 1, 2026

v0.5.0

Jul 1, 2026

Changes in this version

+ type EngineDispatcher struct

+ func NewEngineDispatcher(e *engine.Engine) EngineDispatcher

+ func (d EngineDispatcher) Submit(ctx context.Context, t task.Task) (ui.RunRef, error)

+ type FlowExecutor struct

+ func NewFlowExecutor(x *graph.Executor, flows []graph.Flow) FlowExecutor

+ func (f FlowExecutor) Approve(runID, nodeID, edit string) error

+ func (f FlowExecutor) Reject(runID, nodeID string) error

+ func (f FlowExecutor) ResumeFlow(ctx context.Context, flowID, runID string) (ui.RunResult, error)

+ func (f FlowExecutor) StartFlow(ctx context.Context, flowID, runID, payload string) (ui.RunResult, error)

+ type QueueDispatcher struct

+ func NewQueueDispatcher(s *store.Store) QueueDispatcher

+ func (d QueueDispatcher) Submit(_ context.Context, t task.Task) (ui.RunRef, error)

+ type Roster struct

+ func NewRoster(reg *machines.Registry) *Roster

+ func (r *Roster) Machines() []ui.MachineStatus

+ func (r *Roster) Poll(ctx context.Context, interval time.Duration)

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