control

package
v1.0.5 Latest Latest
Warning

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

 Go to latest Published: Aug 22, 2026 License: MIT Imports: 30 Imported by: 0

Documentation

Overview

Package control provides the adapters that plug Fort's deterministic components into the control-plane ports (ui.Dispatcher, ui.FlowRunner).

This is the composition seam for "control plane, optionally with execution":

  • EngineDispatcher / FlowExecutor wrap the real router + DAG engine (full mode).
  • QueueDispatcher boards tasks with no execution plane at all (control-only mode).

cmd/fort picks which adapters to wire; the ui module only ever sees the ports.

Index

Constants

View Source 
const (
	PrimaryAgentReady         = "ready"
	PrimaryAgentNotConfigured = "not_configured"
	PrimaryAgentUnready       = "unready"
	PrimaryAgentDrifted       = "drifted"
	PrimaryAgentIneligible    = "ineligible"

	PrimaryAgentReasonNotEligible = "not_eligible_for_text_only_chat"

	ErrorPrimaryAgentNotConfigured = "primary_agent_not_configured"
	ErrorPrimaryAgentUnready       = "primary_agent_unready"
	ErrorPrimaryAgentDrift         = "primary_agent_drift"
	ErrorChatPolicyUnavailable     = "chat_policy_unavailable"
	ErrorChatAuthorityViolation    = "chat_authority_violation"
	ErrorPrimaryChannelInvariant   = "primary_channel_invariant"
	ErrorProviderResultUnknown     = "provider_result_unknown"
	ErrorProviderIncomplete        = "provider_incomplete"
	ErrorProviderRefusal           = "provider_refusal"
	ErrorProviderFailed            = "provider_failed"
	ErrorAgentChannelState         = "agent_channel_state"
	ErrorAgentRecoveryUnavailable  = "agent_recovery_unavailable"
)
View Source 
const (
	MaxScheduleDefinitions        = 1000
	ScheduleDetailOccurrenceLimit = 10
	MaxOccurrencePageLimit        = 50
)

Variables

View Source 
var (
	ErrInvalidScheduleFilter       = errors.New("invalid schedule filter")
	ErrInvalidOccurrencePage       = errors.New("invalid schedule occurrence page")
	ErrScheduleInventoryUnaccepted = errors.New("schedule_inventory_unaccepted")
	ErrScheduleInventoryDrift      = errors.New("schedule_inventory_drift")
)

Functions

func ErrorCode added in v1.0.4 

func ErrorCode(err error) string

ErrorCode returns only Phase 1's bounded service code. Storage and context errors remain available through errors.Is/As and are mapped by the caller.

func FlowDefinitionDigest added in v1.0.4 

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

FlowDefinitionDigest hashes the canonical JSON representation of one loaded, validated flow. Slice order is retained because it is execution-significant.

func FlowDefinitionDigests added in v1.0.4 

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

Types

type AgentChannelService added in v1.0.4 

type AgentChannelService struct {
	// contains filtered or unexported fields
}

AgentChannelService owns the agent-first hierarchy and delegates execution for compatible conversations to the existing Primary Channel lifecycle. It never consults the singleton Primary Agent setting.

func NewAgentChannelService added in v1.0.4 

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

func (*AgentChannelService) AgentNeedsYou added in v1.0.4 

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

func (*AgentChannelService) AgentOptions added in v1.0.4 

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

func (*AgentChannelService) CancelAgentTarget added in v1.0.4 

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

func (*AgentChannelService) CreateAgentChannel added in v1.0.4 

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

func (*AgentChannelService) CreateAgentConversation added in v1.0.4 

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

func (*AgentChannelService) GetAgentChannel added in v1.0.4 

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

func (*AgentChannelService) GetAgentConversation added in v1.0.4 

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

func (*AgentChannelService) ListAgentChannels added in v1.0.4 

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

func (*AgentChannelService) ListAgentConversations added in v1.0.4 

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

func (*AgentChannelService) PostAgentTurn added in v1.0.4 

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

func (*AgentChannelService) PostFirstAgentTurn added in v1.0.4 

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

func (*AgentChannelService) RecheckAgentOptions added in v1.0.4 

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

func (*AgentChannelService) RenameAgentChannel added in v1.0.4 

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

func (*AgentChannelService) RenameAgentConversation added in v1.0.4 

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

func (*AgentChannelService) RetryAgentTarget added in v1.0.4 

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

func (*AgentChannelService) SetAgentChannelState added in v1.0.4 

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

func (*AgentChannelService) SetAgentConversationPinned added in v1.0.4 

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

func (*AgentChannelService) SetAgentConversationState added in v1.0.4 

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

type AgentOptionSource added in v1.0.4 

type AgentOptionSource interface {
	AgentOptions(context.Context) ([]ui.AgentOption, error)
	RecheckAgentOptions(context.Context) ([]ui.AgentOption, error)
}

AgentOptionSource is the bounded inventory seam for the agent-first product. Production projects the already accepted Primary option contract; tests and future approved adapters can supply provider-neutral bindings without weakening that production eligibility boundary.

type CapabilityCoordinator added in v0.13.0 

type CapabilityCoordinator struct {
	// contains filtered or unexported fields
}

CapabilityCoordinator refreshes local and peer inventories concurrently, binds every peer payload to registry-owned identity/rank, and publishes one normalized snapshot generation atomically.

func NewCapabilityCoordinator added in v0.13.0 

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

func (*CapabilityCoordinator) Capabilities added in v0.13.0 

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

Capabilities implements ui.CapabilityLister without exposing refresh or private probe controls to the presentation layer.

func (*CapabilityCoordinator) Current added in v0.13.0 

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

func (*CapabilityCoordinator) RecheckConversationSeats added in v1.0.4 

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

RecheckConversationSeats explicitly reprobes every execution-profile adapter and publishes one fresh snapshot generation. It is the bounded user action behind the shared-conversation seat picker; it performs no setup, placement, or runtime dispatch.

func (*CapabilityCoordinator) Refresh added in v0.13.0 

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

func (*CapabilityCoordinator) RefreshMachine added in v0.13.0 

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

RefreshMachine refreshes only the already-selected target. Dispatch uses this path so an unrelated slow or unavailable peer cannot delay provider startup or influence deterministic placement.

type CapabilityCoordinatorOptions added in v0.13.0 

type CapabilityCoordinatorOptions struct {
	Live      *machines.Live
	LocalName string
	Local     LocalCapabilityRegistry
	Peers     PeerCapabilityClient
	Now       func() time.Time
}

type CapabilitySnapshotSource added in v0.13.0 

type CapabilitySnapshotSource interface {
	Capabilities() (corecap.Snapshot, uint64)
}

type ConversationActivity added in v0.13.0 

type ConversationActivity interface {
	ConversationTargetActive(string) bool
}

type ConversationSeatSource added in v0.13.0 

type ConversationSeatSource interface {
	ConversationSeats() []conversation.Seat
}

func FakeConversationSeats added in v0.13.0 

func FakeConversationSeats(machine string) ConversationSeatSource

FakeConversationSeats is test/demo plumbing for FORT_FAKE only. Production composition must use SnapshotConversationSeats so static claims never become ready seats.

type ConversationService added in v0.13.0 

type ConversationService struct {
	// contains filtered or unexported fields
}

ConversationService is the durable coordinator for projects, shared conversations, target fan-out, attribution, retry, and cancellation.

func NewConversationService added in v0.13.0 

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

func (*ConversationService) AddConversationParticipant added in v0.13.0 

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

func (*ConversationService) CancelTarget added in v0.13.0 

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

func (*ConversationService) Close added in v0.13.0 

func (s *ConversationService) Close()

Close stops active providers and joins their persistence loops.

func (*ConversationService) ConversationSeats added in v0.13.0 

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

func (*ConversationService) ConversationTargetActive added in v0.13.0 

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

func (*ConversationService) CreateConversation added in v0.13.0 

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

func (*ConversationService) CreateProject added in v0.13.0 

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

func (*ConversationService) DeleteConversation added in v0.13.0 

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

func (*ConversationService) DeleteProject added in v0.13.0 

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

func (*ConversationService) GetConversation added in v0.13.0 

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

func (*ConversationService) ListConversations added in v0.13.0 

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

func (*ConversationService) ListProjects added in v0.13.0 

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

func (*ConversationService) MoveConversation added in v0.13.0 

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

func (*ConversationService) PostTurn added in v0.13.0 

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

func (*ConversationService) RemoveConversationParticipant added in v0.13.0 

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

func (*ConversationService) RenameConversation added in v0.13.0 

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

func (*ConversationService) RenameProject added in v0.13.0 

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

func (*ConversationService) RetryTarget added in v0.13.0 

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

func (*ConversationService) SetConversationState added in v0.13.0 

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

func (*ConversationService) Wait added in v0.13.0 

func (s *ConversationService) Wait()

Wait joins every target accepted before the call. Shutdown and tests use it before closing the durable store that target completions persist to.

type CreateConversationRequest added in v0.13.0 

type CreateConversationRequest struct {
	ProjectID string   `json:"project_id,omitempty"`
	Title     string   `json:"title"`
	SeatIDs   []string `json:"seat_ids"`
}

type EngineDispatcher 

type EngineDispatcher struct {
	// contains filtered or unexported fields
}

EngineDispatcher routes + dispatches via the deterministic engine.

func NewEngineDispatcher 

func NewEngineDispatcher(e *engine.Engine) EngineDispatcher

NewEngineDispatcher adapts an engine to ui.Dispatcher.

func (EngineDispatcher) Accept added in v0.13.0 

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

Accept persists the routed run, then starts native execution in the background so an HTTP acceptance response is independent of provider startup.

func (EngineDispatcher) Submit 

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

Submit routes the task and starts native execution.

type FlowExecutor 

type FlowExecutor struct {
	// contains filtered or unexported fields
}

FlowExecutor adapts the DAG executor to ui.FlowRunner (id-based).

func NewFlowExecutor 

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

NewFlowExecutor adapts a graph executor + flow set to ui.FlowRunner.

func (FlowExecutor) Approve 

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

Approve records a gate approval.

func (FlowExecutor) Plan added in v0.11.0 

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

Plan exposes a flow's node list to the control plane (spec 033).

func (FlowExecutor) Reject 

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

Reject records a gate rejection with an optional redirect note.

func (FlowExecutor) ResumeFlow 

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

ResumeFlow resumes the named flow.

func (FlowExecutor) ResumeFlowAsync added in v0.13.0 

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

ResumeFlowAsync validates the immutable flow before scheduling one detached continuation of the durable run.

func (FlowExecutor) StartFlow 

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

StartFlow starts the named flow.

func (FlowExecutor) StartFlowAsync added in v0.13.0 

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

StartFlowAsync persists the run, then walks the flow once in the background.

func (FlowExecutor) StartPlaybook added in v0.12.0 

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

StartPlaybook compiles and starts an immutable route preview. The canonical flow id carries every field needed to reconstruct the exact flow after a process restart, while its delivery suffix lets operational views exclude answer-only history.

func (FlowExecutor) StartPlaybookAsync added in v0.13.0 

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

StartPlaybookAsync persists the exact canonical playbook flow, then executes it once in the background. Quick-answer output is delivered later through the existing run detail and event stream rather than holding the HTTP response.

func (FlowExecutor) WithPlaybooks added in v0.12.0 

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

WithPlaybooks enables immutable dynamic playbook flows on the same executor value used for static ui.FlowRunner operations.

type LocalCapabilityRegistry added in v0.13.0 

type LocalCapabilityRegistry interface {
	Current() corecap.NodeInventory
	Refresh(context.Context, corecap.RecheckRequest) (corecap.NodeInventory, error)
}

type OccurrencePage added in v1.0.4 

type OccurrencePage struct {
	Limit    int
	Before   time.Time
	BeforeID string
}

type PeerCapabilityClient added in v0.13.0 

type PeerCapabilityClient interface {
	Refresh(context.Context, string, string, corecap.RecheckRequest) (corecap.NodeInventory, error)
}

type Planner added in v0.8.0 

type Planner struct {
	// contains filtered or unexported fields
}

Planner implements ui.Planner: it runs a planner agent to decompose a goal into backlog sub-tasks (spec 026). The planner is a normal, visible run; Breakdown returns its id immediately and the sub-tasks are created when the run completes.

func NewPlanner added in v0.8.0 

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

NewPlanner adapts the engine + store to ui.Planner. defaultAgent is the planner agent used when a breakdown request doesn't specify one (FORT_PLANNER; falls back to "claude").

func (Planner) Breakdown added in v0.8.0 

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

Breakdown dispatches the planner run and returns its id; a goroutine ingests its output into the backlog once it completes. NOTE (spec 026 crash window): if the process stops between the run finishing and ingest writing items, the sub-tasks are not written — re-run the breakdown.

type PlaybookCatalog added in v0.12.0 

type PlaybookCatalog struct {
	// contains filtered or unexported fields
}

PlaybookCatalog adapts immutable store revisions to the UI playbook port. Definitions remain encoded as their UI wire form so display-only fields such as stage descriptions survive validation and round trips unchanged.

func NewPlaybookCatalog added in v0.12.0 

func NewPlaybookCatalog(st *store.Store) *PlaybookCatalog

NewPlaybookCatalog builds the durable playbook catalog and atomically seeds it before any route preview can be served. Routing remains read-only.

func (*PlaybookCatalog) Duplicate added in v0.12.0 

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

Duplicate appends a disabled, non-default copy with a fresh deterministic slug. A duplicate cannot change automatic routing until explicitly enabled.

func (*PlaybookCatalog) List added in v0.12.0 

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

List returns the latest immutable revision for every playbook.

func (*PlaybookCatalog) Route added in v0.12.0 

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

Route resolves a pure deterministic preview. An explicit revision loads that exact immutable row; the optional plan gate override only changes the returned execution snapshot and never persists a definition.

func (*PlaybookCatalog) Save added in v0.12.0 

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

Save validates the prospective latest catalog before appending a revision.

type PostConversationTurnRequest added in v0.13.0 

type PostConversationTurnRequest struct {
	Text                 string   `json:"text"`
	TargetParticipantIDs []string `json:"target_participant_ids"`
}

type PrimaryAgentOption added in v1.0.4 

type PrimaryAgentOption = ui.PrimaryAgentOption

type PrimaryAgentView added in v1.0.4 

type PrimaryAgentView = ui.PrimaryAgentView

type PrimaryChannelError added in v1.0.4 

type PrimaryChannelError struct {
	Code string
	Err  error
}

PrimaryChannelError keeps the Phase 1 closed recovery code independent of HTTP while retaining the underlying diagnostic for logs and tests.

func (*PrimaryChannelError) Error added in v1.0.4 

func (e *PrimaryChannelError) Error() string

func (*PrimaryChannelError) PrimaryChannelCode added in v1.0.4 

func (e *PrimaryChannelError) PrimaryChannelCode() string

func (*PrimaryChannelError) Unwrap added in v1.0.4 

func (e *PrimaryChannelError) Unwrap() error

type PrimaryChannelService added in v1.0.4 

type PrimaryChannelService struct {
	// contains filtered or unexported fields
}

PrimaryChannelService coordinates the canonical Channel rows and the one isolated subscription runtime. It has no generic target-selection method.

func NewPrimaryChannelService added in v1.0.4 

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

func (*PrimaryChannelService) CancelTarget added in v1.0.4 

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

func (*PrimaryChannelService) ClearPrimaryAgent added in v1.0.4 

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

func (*PrimaryChannelService) Close added in v1.0.4 

func (s *PrimaryChannelService) Close()

func (*PrimaryChannelService) CreateChannel added in v1.0.4 

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

func (*PrimaryChannelService) GetChannel added in v1.0.4 

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

func (*PrimaryChannelService) ListChannels added in v1.0.4 

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

func (*PrimaryChannelService) NeedsYou added in v1.0.4 

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

func (*PrimaryChannelService) PostTurn added in v1.0.4 

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

func (*PrimaryChannelService) PrimaryAgent added in v1.0.4 

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

func (*PrimaryChannelService) RecheckAndRetryTarget added in v1.0.4 

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

func (*PrimaryChannelService) RecheckPrimaryAgent added in v1.0.4 

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

func (*PrimaryChannelService) RenameChannel added in v1.0.4 

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

func (*PrimaryChannelService) RetryTarget added in v1.0.4 

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

func (*PrimaryChannelService) SetChannelPinned added in v1.0.4 

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

func (*PrimaryChannelService) SetChannelState added in v1.0.4 

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

func (*PrimaryChannelService) SetPrimaryAgent added in v1.0.4 

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

func (*PrimaryChannelService) Wait added in v1.0.4 

func (s *PrimaryChannelService) Wait()

type PrimaryNeedsYouItem added in v1.0.4 

type PrimaryNeedsYouItem = ui.PrimaryNeedsYouItem

type PrimaryOptionCapabilities added in v1.0.4 

type PrimaryOptionCapabilities interface {
	Capabilities() (corecap.Snapshot, uint64)
	Refresh(context.Context, corecap.RefreshMode, []string) (corecap.Snapshot, uint64, error)
	RefreshMachine(context.Context, string, corecap.RefreshMode, []string) (corecap.MachineInventory, error)
}

PrimaryOptionCapabilities is the only capability mutation surface exposed to Channels. Recheck and per-target preflight can invalidate only the three catalog rows that constitute the closed subscription binding.

type QueueDispatcher 

type QueueDispatcher struct {
	// contains filtered or unexported fields
}

QueueDispatcher boards a task as a "queued" run with no execution plane.

func NewQueueDispatcher 

func NewQueueDispatcher(s *store.Store) QueueDispatcher

NewQueueDispatcher adapts a store to ui.Dispatcher for control-only mode.

func (QueueDispatcher) Accept added in v0.13.0 

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

Accept is identical to Submit in control-only mode because boarding is the complete durable action and no provider execution follows.

func (QueueDispatcher) Submit 

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

Submit records the task on the board as queued; it is never dispatched.

type RelatedChannel added in v1.0.4 

type RelatedChannel struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type Roster 

type Roster struct {
	// contains filtered or unexported fields
}

Roster adapts a live machine registry pointer to ui.MachineLister and tracks peer reachability by polling each machine's /health (spec 022). It reads the Live pointer on every call, so a registry installed after construction (e.g. a mesh enrollment) is visible without a restart (spec 024). The local machine is reachable by definition; peers start unreachable until first probed.

func NewRoster 

func NewRoster(live *machines.Live) *Roster

NewRoster builds a roster over live.

func (*Roster) Machines 

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

Machines implements ui.MachineLister.

func (*Roster) Poll 

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

Poll refreshes peer reachability every interval until ctx is done. Run it in a goroutine from the composition root.

type ScheduleCreator added in v0.13.0 

type ScheduleCreator interface {
	Create(context.Context, scheduler.Definition) (scheduler.Definition, error)
}

type ScheduleDetail added in v1.0.4 

type ScheduleDetail struct {
	Item     ScheduleItem           `json:"item"`
	Upcoming []scheduler.Occurrence `json:"upcoming"`
	Recent   []scheduler.Occurrence `json:"recent"`
}

type ScheduleFilter added in v1.0.4 

type ScheduleFilter string
const (
	ScheduleFilterAll    ScheduleFilter = "all"
	ScheduleFilterActive ScheduleFilter = "active"
	ScheduleFilterPaused ScheduleFilter = "paused"
)

type ScheduleInventory added in v1.0.4 

type ScheduleInventory struct {
	CurrentDigest  string                  `json:"current_digest"`
	AcceptedDigest string                  `json:"accepted_digest,omitempty"`
	State          ScheduleInventoryState  `json:"state"`
	Items          []ScheduleInventoryItem `json:"items"`
}

type ScheduleInventoryItem added in v1.0.4 

type ScheduleInventoryItem struct {
	ID         string         `json:"id"`
	Kind       scheduler.Kind `json:"kind"`
	Expression string         `json:"expression"`
	Timezone   string         `json:"timezone"`
	FlowID     string         `json:"flow_id"`
	FlowDigest string         `json:"flow_digest"`
}

type ScheduleInventoryState added in v1.0.4 

type ScheduleInventoryState string
const (
	ScheduleInventoryAccepted   ScheduleInventoryState = "accepted"
	ScheduleInventoryUnaccepted ScheduleInventoryState = "unaccepted"
	ScheduleInventoryDrift      ScheduleInventoryState = "drift"
)

type ScheduleItem added in v1.0.4 

type ScheduleItem struct {
	ID                 string                `json:"id"`
	Title              string                `json:"title"`
	Enabled            bool                  `json:"enabled"`
	Kind               scheduler.Kind        `json:"kind"`
	Expression         string                `json:"expression"`
	Recurrence         string                `json:"recurrence"`
	Timezone           string                `json:"timezone"`
	NextFireAt         *time.Time            `json:"next_fire_at"`
	LastFireAt         *time.Time            `json:"last_fire_at"`
	TargetKind         string                `json:"target_kind"`
	TargetID           string                `json:"target_id"`
	RelatedChannel     *RelatedChannel       `json:"related_channel,omitempty"`
	LatestOccurrence   *scheduler.Occurrence `json:"latest_occurrence,omitempty"`
	SchedulerOwnership SchedulerOwnership    `json:"scheduler_ownership"`
	ObservedAt         time.Time             `json:"observed_at"`
	// contains filtered or unexported fields
}

type ScheduleList added in v1.0.4 

type ScheduleList struct {
	SnapshotID string         `json:"snapshot_id"`
	ObservedAt time.Time      `json:"observed_at"`
	Items      []ScheduleItem `json:"items"`
}

type ScheduleReadAdapter added in v1.0.4 

type ScheduleReadAdapter struct {
	// contains filtered or unexported fields
}

ScheduleReadAdapter is the control-plane port adapter for the deterministic schedule service. ui owns the HTTP wire types; the service retains its control-owned normalized representation and promotion errors.

func NewScheduleReadAdapter added in v1.0.4 

func NewScheduleReadAdapter(service *ScheduleReadService) *ScheduleReadAdapter

func (*ScheduleReadAdapter) Get added in v1.0.4 

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

func (*ScheduleReadAdapter) Inventory added in v1.0.4 

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

func (*ScheduleReadAdapter) List added in v1.0.4 

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

func (*ScheduleReadAdapter) Occurrences added in v1.0.4 

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

type ScheduleReadRepository added in v1.0.4 

type ScheduleReadRepository interface {
	ReadScheduleCatalog(context.Context, *bool, int) ([]store.ScheduleReadRow, error)
	ReadScheduleDetail(context.Context, string, time.Time, int) (store.ScheduleReadDetail, error)
	ReadScheduleOccurrences(context.Context, string, int, time.Time, string) ([]scheduler.Occurrence, error)
}

type ScheduleReadService added in v1.0.4 

type ScheduleReadService struct {
	// contains filtered or unexported fields
}

func NewScheduleReadService added in v1.0.4 

func NewScheduleReadService(repository ScheduleReadRepository, ownership SchedulerOwnership, flowDigests map[string]string) *ScheduleReadService

func (*ScheduleReadService) Get added in v1.0.4 

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

func (*ScheduleReadService) Inventory added in v1.0.4 

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

Inventory computes the review boundary over enabled durable definitions. Missing or malformed loaded-flow digests fail closed as drift; they can never be made acceptable by copying an invalid current value.

func (*ScheduleReadService) List added in v1.0.4 

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

func (*ScheduleReadService) Occurrences added in v1.0.4 

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

type ScheduleService added in v0.13.0 

type ScheduleService struct {
	// contains filtered or unexported fields
}

func NewScheduleService added in v0.13.0 

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

func (*ScheduleService) Create added in v0.13.0 

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

type SchedulerOwnership added in v1.0.4 

type SchedulerOwnership string
const (
	SchedulerOwnershipActive   SchedulerOwnership = "active"
	SchedulerOwnershipInactive SchedulerOwnership = "inactive"
	SchedulerOwnershipUnknown  SchedulerOwnership = "unknown"
)

type SnapshotConversationSeats added in v0.13.0 

type SnapshotConversationSeats struct {
	Source CapabilitySnapshotSource
}

SnapshotConversationSeats projects the verified capability inventory into exact profile + provider/model + machine seats.

func (SnapshotConversationSeats) ConversationSeats added in v0.13.0 

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

type TodayService added in v0.13.0 

type TodayService struct {
	// contains filtered or unexported fields
}

func NewTodayService added in v0.13.0 

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

func (*TodayService) Today added in v0.13.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.