Documentation
¶
Index ¶
- Constants
- Variables
- func NewFactorySessionsRegistry() *factorysessions.Registry
- func NewHostedWorkersConfig(cfg *FactoryServiceConfig, logger *zap.Logger, clock factory.Clock) hostedworkers.Config
- func NewRuntimeBuildService(cfg *FactoryServiceConfig, clock factory.Clock, baseLogger *zap.Logger, ...) *runtimebuild.Service
- func ProvideFactorySaveCollaborator(shell FactoryServiceShell, cfg *FactoryServiceConfig) factorySaveSaver
- func ServiceClockForCompose(cfg *FactoryServiceConfig, load FactoryConfigLoadResult) factory.Clock
- type APIServerStarter
- type ComposeCollaboratorSnapshot
- type FactoryConfigLoadResult
- type FactoryService
- func (fs *FactoryService) ActivateNamedFactory(ctx context.Context, name string) error
- func (fs *FactoryService) CloseFactorySession(_ context.Context, sessionID string) error
- func (fs *FactoryService) ComposeCollaboratorSnapshot() ComposeCollaboratorSnapshot
- func (fs *FactoryService) GetCurrentFactory(ctx context.Context) (factoryapi.Factory, error)
- func (fs *FactoryService) GetCurrentFactoryForSession(_ context.Context, sessionID string) (factoryapi.Factory, error)
- func (fs *FactoryService) GetCurrentNamedFactory(_ context.Context) (factoryapi.Factory, error)
- func (fs *FactoryService) GetEngineStateSnapshot(ctx context.Context) (*interfaces.EngineStateSnapshot[petri.MarkingSnapshot, *state.Net], error)
- func (fs *FactoryService) GetEngineStateSnapshotForSession(ctx context.Context, sessionID string) (*interfaces.EngineStateSnapshot[petri.MarkingSnapshot, *state.Net], error)
- func (fs *FactoryService) GetFactoryEvents(ctx context.Context) ([]factoryapi.FactoryEvent, error)
- func (fs *FactoryService) GetModel(ctx context.Context, modelName string) (factoryapi.ModelDetail, error)
- func (fs *FactoryService) InvokeModel(ctx context.Context, modelName string, ...) (apisurface.ModelInvocationResult, error)
- func (fs *FactoryService) ListFactorySessions(_ context.Context) (factoryapi.ListFactorySessionsResponse, error)
- func (fs *FactoryService) ListModels(ctx context.Context) (factoryapi.ListModelsResponse, error)
- func (fs *FactoryService) MoveWork(ctx context.Context, workID, stateName string, ...) (interfaces.OperatorMoveResult, error)
- func (fs *FactoryService) MoveWorkForSession(ctx context.Context, sessionID, workID, stateName, requestID string) (interfaces.OperatorMoveResult, error)
- func (fs *FactoryService) OpenFactorySession(ctx context.Context, request factoryapi.OpenFactorySessionRequest) (factoryapi.OpenFactorySessionResponse, error)
- func (fs *FactoryService) OpenFactorySessionFromFolder(ctx context.Context, folderPath string, target *FactorySessionTargetRef, ...) (*FactorySessionOpenResult, error)
- func (fs *FactoryService) Pause(ctx context.Context) error
- func (fs *FactoryService) PullModel(ctx context.Context, modelName string) (apisurface.ModelPullResult, error)
- func (fs *FactoryService) Run(ctx context.Context) error
- func (fs *FactoryService) RuntimeLogDiagnostics() RuntimeLogDiagnostics
- func (fs *FactoryService) SaveCurrentFactoryForSession(ctx context.Context, sessionID string, request factoryapi.Factory) (factoryapi.Factory, error)
- func (fs *FactoryService) SaveFactoryForSession(ctx context.Context, sessionID string, mode factoryapi.FactorySaveMode, ...) (factoryapi.Factory, error)
- func (fs *FactoryService) SubmitWorkRequest(ctx context.Context, request interfaces.WorkRequest) (interfaces.WorkRequestSubmitResult, error)
- func (fs *FactoryService) SubmitWorkRequestForSession(ctx context.Context, sessionID string, request interfaces.WorkRequest) (interfaces.WorkRequestSubmitResult, error)
- func (fs *FactoryService) SubscribeFactoryEvents(ctx context.Context) (*interfaces.FactoryEventStream, error)
- func (fs *FactoryService) SubscribeFactoryEventsForSession(ctx context.Context, sessionID string) (*interfaces.FactoryEventStream, error)
- func (fs *FactoryService) WaitToComplete() <-chan struct{}
- type FactoryServiceCollaborators
- type FactoryServiceConfig
- type FactoryServiceRoot
- type FactoryServiceShell
- type FactorySessionOpenResult
- type FactorySessionTarget
- type FactorySessionTargetKind
- type FactorySessionTargetRef
- type LocalModelDomain
- type RuntimeLogDiagnostics
- type SimpleDashboardRenderInput
- type SimpleDashboardRenderer
Constants ¶
const ( FactorySessionTargetKindDefault = factorysessions.TargetKindDefault FactorySessionTargetKindNamed = factorysessions.TargetKindNamed )
Variables ¶
var ErrCurrentFactoryNotFound = apisurface.ErrCurrentFactoryNotFound
ErrCurrentFactoryNotFound reports that no durable current-factory pointer could be resolved for canonical current-factory reads.
var ErrFactoryActivationRequiresIdle = apisurface.ErrFactoryActivationRequiresIdle
ErrFactoryActivationRequiresIdle reports that runtime replacement was attempted while the current runtime still had active work.
var ErrInvalidNamedFactory = apisurface.ErrInvalidNamedFactory
ErrInvalidNamedFactory reports that the submitted named-factory payload could not be persisted or validated as a runnable runtime config.
var ErrInvalidNamedFactoryName = apisurface.ErrInvalidNamedFactoryName
ErrInvalidNamedFactoryName reports that the requested named-factory name is not a safe canonical layout segment.
Functions ¶
func NewFactorySessionsRegistry ¶ added in v0.0.5
func NewFactorySessionsRegistry() *factorysessions.Registry
NewFactorySessionsRegistry constructs the live session registry collaborator.
func NewHostedWorkersConfig ¶ added in v0.0.5
func NewHostedWorkersConfig( cfg *FactoryServiceConfig, logger *zap.Logger, clock factory.Clock, ) hostedworkers.Config
NewHostedWorkersConfig builds the hosted-workers collaborator from service config.
func NewRuntimeBuildService ¶ added in v0.0.5
func NewRuntimeBuildService( cfg *FactoryServiceConfig, clock factory.Clock, baseLogger *zap.Logger, localModels *LocalModelDomain, ) *runtimebuild.Service
NewRuntimeBuildService constructs the runtimebuild collaborator for wire.
func ProvideFactorySaveCollaborator ¶ added in v0.0.5
func ProvideFactorySaveCollaborator( shell FactoryServiceShell, cfg *FactoryServiceConfig, ) factorySaveSaver
ProvideFactorySaveCollaborator constructs the factorysave collaborator for a built FactoryService shell.
func ServiceClockForCompose ¶ added in v0.0.5
func ServiceClockForCompose(cfg *FactoryServiceConfig, load FactoryConfigLoadResult) factory.Clock
ServiceClockForCompose selects the factory clock for the loaded replay artifact.
Types ¶
type APIServerStarter ¶
type APIServerStarter func(ctx context.Context, runtime apisurface.APISurface, port int, logger *zap.Logger) error
APIServerStarter is a callback that starts an API server for the factory. It receives the API surface, port, and logger, and should block until ctx is cancelled. Callers (e.g. CLI) provide their own implementation to avoid import cycles between service and api packages.
type ComposeCollaboratorSnapshot ¶ added in v0.0.5
type ComposeCollaboratorSnapshot struct {
SessionsInitialized bool
RuntimeBuildInitialized bool
ModelAssetsInitialized bool
FactorySaveInitialized bool
HostedWorkersLoggerReady bool
BundleModelResources bool
BundleLocalModels bool
}
ComposeCollaboratorSnapshot records whether S6 collaborators were initialized on a built FactoryService. Tests compare snapshots across wire and direct build paths.
type FactoryConfigLoadResult ¶ added in v0.0.5
type FactoryConfigLoadResult struct {
LoadedFactoryCfg *factoryconfig.LoadedFactoryConfig
ReplayArtifact *interfaces.ReplayArtifact
SessionLogger *zap.Logger
}
FactoryConfigLoadResult carries factory config load outputs needed before runtime bundle construction.
func LoadFactoryConfigForCompose ¶ added in v0.0.5
func LoadFactoryConfigForCompose( cfg *FactoryServiceConfig, root FactoryServiceRoot, ) (FactoryConfigLoadResult, error)
LoadFactoryConfigForCompose loads factory.json and replay metadata for wire composition after FactoryServiceRoot resolution.
type FactoryService ¶
type FactoryService struct {
// contains filtered or unexported fields
}
FactoryService is an instantiation of a factory along with its runtime concerns: file watcher, dashboard, API server. It owns the full lifecycle so that CLI and other entry points remain thin wrappers.
Extracted domains are composed explicitly: pkg/factorysessions owns the live session registry, pkg/localmodels owns managed model runtime wiring, and pkg/hostedworkers owns hosted poller supervision invoked from poller_watcher.
func AttachFactorySaveCollaborator ¶ added in v0.0.5
func AttachFactorySaveCollaborator( shell FactoryServiceShell, factorySave factorySaveSaver, ) *FactoryService
AttachFactorySaveCollaborator assigns the factorysave collaborator on the service shell and returns the assembled FactoryService.
func BuildFactoryService ¶
func BuildFactoryService(ctx context.Context, cfg *FactoryServiceConfig) (*FactoryService, error)
BuildFactoryService loads factory.json from the config directory, constructs the petri net, factory runtime, file watcher, and session metrics.
func (*FactoryService) ActivateNamedFactory ¶
func (fs *FactoryService) ActivateNamedFactory(ctx context.Context, name string) error
ActivateNamedFactory builds a replacement runtime from a persisted named factory directory and swaps it in only after the current runtime is idle.
func (*FactoryService) CloseFactorySession ¶ added in v0.0.5
func (fs *FactoryService) CloseFactorySession(_ context.Context, sessionID string) error
func (*FactoryService) ComposeCollaboratorSnapshot ¶ added in v0.0.5
func (fs *FactoryService) ComposeCollaboratorSnapshot() ComposeCollaboratorSnapshot
ComposeCollaboratorSnapshot reports initialized S6 collaborators for equivalence tests.
func (*FactoryService) GetCurrentFactory ¶ added in v0.0.5
func (fs *FactoryService) GetCurrentFactory(ctx context.Context) (factoryapi.Factory, error)
GetCurrentFactory returns the canonical current factory definition together with durable optimistic-concurrency metadata.
func (*FactoryService) GetCurrentFactoryForSession ¶ added in v0.0.5
func (fs *FactoryService) GetCurrentFactoryForSession(_ context.Context, sessionID string) (factoryapi.Factory, error)
func (*FactoryService) GetCurrentNamedFactory ¶
func (fs *FactoryService) GetCurrentNamedFactory(_ context.Context) (factoryapi.Factory, error)
GetCurrentNamedFactory returns the durable current named-factory read model resolved entirely from the persisted pointer and canonical on-disk layout.
func (*FactoryService) GetEngineStateSnapshot ¶
func (fs *FactoryService) GetEngineStateSnapshot(ctx context.Context) (*interfaces.EngineStateSnapshot[petri.MarkingSnapshot, *state.Net], error)
GetEngineStateSnapshot returns the factory boundary's aggregate observability snapshot.
func (*FactoryService) GetEngineStateSnapshotForSession ¶ added in v0.0.5
func (fs *FactoryService) GetEngineStateSnapshotForSession(ctx context.Context, sessionID string) (*interfaces.EngineStateSnapshot[petri.MarkingSnapshot, *state.Net], error)
func (*FactoryService) GetFactoryEvents ¶
func (fs *FactoryService) GetFactoryEvents(ctx context.Context) ([]factoryapi.FactoryEvent, error)
GetFactoryEvents returns the canonical factory event history.
func (*FactoryService) GetModel ¶ added in v0.0.5
func (fs *FactoryService) GetModel(ctx context.Context, modelName string) (factoryapi.ModelDetail, error)
func (*FactoryService) InvokeModel ¶ added in v0.0.5
func (fs *FactoryService) InvokeModel(ctx context.Context, modelName string, request factoryapi.ModelInvocationRequest) (apisurface.ModelInvocationResult, error)
func (*FactoryService) ListFactorySessions ¶ added in v0.0.5
func (fs *FactoryService) ListFactorySessions(_ context.Context) (factoryapi.ListFactorySessionsResponse, error)
func (*FactoryService) ListModels ¶ added in v0.0.5
func (fs *FactoryService) ListModels(ctx context.Context) (factoryapi.ListModelsResponse, error)
func (*FactoryService) MoveWork ¶ added in v0.0.5
func (fs *FactoryService) MoveWork(ctx context.Context, workID, stateName string, source interfaces.WorkStateChangeSource, requestID string) (interfaces.OperatorMoveResult, error)
MoveWork applies a synchronous operator relocation on the current service-owned runtime.
func (*FactoryService) MoveWorkForSession ¶ added in v0.0.5
func (fs *FactoryService) MoveWorkForSession(ctx context.Context, sessionID, workID, stateName, requestID string) (interfaces.OperatorMoveResult, error)
func (*FactoryService) OpenFactorySession ¶ added in v0.0.5
func (fs *FactoryService) OpenFactorySession(ctx context.Context, request factoryapi.OpenFactorySessionRequest) (factoryapi.OpenFactorySessionResponse, error)
func (*FactoryService) OpenFactorySessionFromFolder ¶ added in v0.0.5
func (fs *FactoryService) OpenFactorySessionFromFolder( ctx context.Context, folderPath string, target *FactorySessionTargetRef, validateOnly bool, initNewFactory bool, ) (*FactorySessionOpenResult, error)
func (*FactoryService) Pause ¶
func (fs *FactoryService) Pause(ctx context.Context) error
Pause pauses the current runtime instance.
func (*FactoryService) PullModel ¶ added in v0.0.5
func (fs *FactoryService) PullModel(ctx context.Context, modelName string) (apisurface.ModelPullResult, error)
func (*FactoryService) Run ¶
func (fs *FactoryService) Run(ctx context.Context) error
Run starts the file watcher, dashboard, API server, and factory engine. It blocks until ctx is cancelled or the factory reaches a terminal state. portos:func-length-exception owner=agent-factory reason=legacy-service-run-loop review=2026-07-18 removal=split-sidecar-startup-recording-and-engine-shutdown-before-next-service-run-change
func (*FactoryService) RuntimeLogDiagnostics ¶ added in v0.0.5
func (fs *FactoryService) RuntimeLogDiagnostics() RuntimeLogDiagnostics
RuntimeLogDiagnostics returns the selected runtime log metadata for startup diagnostics without exposing the sink writer.
func (*FactoryService) SaveCurrentFactoryForSession ¶ added in v0.0.5
func (fs *FactoryService) SaveCurrentFactoryForSession( ctx context.Context, sessionID string, request factoryapi.Factory, ) (factoryapi.Factory, error)
SaveCurrentFactoryForSession replaces the current factory definition for one live session using REPLACE_CURRENT semantics.
func (*FactoryService) SaveFactoryForSession ¶ added in v0.0.5
func (fs *FactoryService) SaveFactoryForSession( ctx context.Context, sessionID string, mode factoryapi.FactorySaveMode, request factoryapi.Factory, ) (factoryapi.Factory, error)
SaveFactoryForSession is the single orchestrated pipeline for session-scoped factory submission. It delegates to the factorysave collaborator.
func (*FactoryService) SubmitWorkRequest ¶
func (fs *FactoryService) SubmitWorkRequest(ctx context.Context, request interfaces.WorkRequest) (interfaces.WorkRequestSubmitResult, error)
SubmitWorkRequest submits a canonical work request batch to the factory.
func (*FactoryService) SubmitWorkRequestForSession ¶ added in v0.0.5
func (fs *FactoryService) SubmitWorkRequestForSession(ctx context.Context, sessionID string, request interfaces.WorkRequest) (interfaces.WorkRequestSubmitResult, error)
func (*FactoryService) SubscribeFactoryEvents ¶
func (fs *FactoryService) SubscribeFactoryEvents(ctx context.Context) (*interfaces.FactoryEventStream, error)
SubscribeFactoryEvents returns canonical factory event history followed by live events from the current service-owned runtime.
func (*FactoryService) SubscribeFactoryEventsForSession ¶ added in v0.0.5
func (fs *FactoryService) SubscribeFactoryEventsForSession(ctx context.Context, sessionID string) (*interfaces.FactoryEventStream, error)
func (*FactoryService) WaitToComplete ¶
func (fs *FactoryService) WaitToComplete() <-chan struct{}
WaitToComplete returns a channel that is closed when all tokens reach terminal or failed places and no dispatches are in flight. Delegates to the underlying factory's termination signal.
type FactoryServiceCollaborators ¶ added in v0.0.5
type FactoryServiceCollaborators struct {
Sessions *factorysessions.Registry
LocalModels LocalModelDomain
RuntimeBuild *runtimebuild.Service
}
FactoryServiceCollaborators groups explicit S6 composition collaborators.
func NewFactoryServiceCollaborators ¶ added in v0.0.5
func NewFactoryServiceCollaborators( cfg *FactoryServiceConfig, clock factory.Clock, baseLogger *zap.Logger, sessions *factorysessions.Registry, ) FactoryServiceCollaborators
NewFactoryServiceCollaborators builds S6 collaborators using the provided session registry and freshly constructed local-model dependencies.
func NewFactoryServiceCollaboratorsFromParts ¶ added in v0.0.5
func NewFactoryServiceCollaboratorsFromParts( sessions *factorysessions.Registry, localModels LocalModelDomain, runtimeBuild *runtimebuild.Service, ) FactoryServiceCollaborators
NewFactoryServiceCollaboratorsFromParts assembles collaborators from explicit wire-provided parts.
type FactoryServiceConfig ¶
type FactoryServiceConfig struct {
// Dir is the factory root directory containing factory.json and inputs/.
Dir string
// RunnerID sets the factory-level runner override used when a workstation
// does not declare its own runner selection.
RunnerID string
// ExecutionBaseDir overrides the base directory used to resolve relative
// runtime execution paths such as workstation workingDirectory values.
// Empty defaults to the loaded factory directory.
ExecutionBaseDir string
// RuntimeMode controls whether the runtime exits on idle completion or
// stays alive until its context is canceled. Empty defaults to batch mode.
RuntimeMode interfaces.RuntimeMode
// Port is the REST API server port. 0 disables the API server.
Port int
// Logger is the structured logger. Nil uses a production default.
Logger *zap.Logger
// Verbose enables additional runtime diagnostic records. The runtime file
// log remains enabled regardless of this setting.
Verbose bool
// RuntimeInstanceID identifies this runtime process for file-backed logs.
// Empty generates a UUID.
RuntimeInstanceID string
// RuntimeLogDir optionally overrides the default ~/.agent-factory/logs
// directory. Tests use this to keep file-backed logs isolated.
RuntimeLogDir string
// RuntimeLogConfig controls bounded runtime file logging behavior.
// Zero values use defaults that match the package rolling policy.
RuntimeLogConfig logging.RuntimeLogConfig
// WorkFile is an optional path to a FACTORY_REQUEST_BATCH JSON file
// containing initial work to submit when the factory starts.
WorkFile string
// RecordPath is an optional path where the service writes a replay artifact
// for the current run.
RecordPath string
// ReplayPath is an optional path to a replay artifact whose embedded config
// should be used instead of local factory files.
ReplayPath string
// WorkflowID is optional metadata recorded into replay artifacts when the
// caller selected a specific workflow.
WorkflowID string
// MockWorkersConfig is the normalized mock-worker run configuration loaded
// by the CLI when --with-mock-workers is enabled.
MockWorkersConfig *factoryconfig.MockWorkersConfig
// RecordFlushInterval controls how often dirty record-mode artifacts are
// flushed during execution. Empty uses replay.DefaultRecordFlushInterval.
RecordFlushInterval time.Duration
// Clock is an optional runtime time source. Replay mode defaults to a
// deterministic logical clock when no explicit clock is supplied.
Clock factory.Clock
// ExtraOptions are additional factory.FactoryOption values applied when
// constructing the factory (e.g. factory.WithWorkerExecutor for tests).
ExtraOptions []factory.FactoryOption
// SimpleDashboardRenderer is an optional callback for rendering dashboard
// output from the aggregate runtime snapshot and event-first world view.
// If nil, no dashboard output is produced.
SimpleDashboardRenderer SimpleDashboardRenderer
// APIServerStarter is an optional callback that starts an API server.
// If nil, no API server is started.
APIServerStarter APIServerStarter
// APIServerReady, when non-nil, is closed by the API starter once the
// service-mode HTTP surface is reachable. Service-mode startup work waits
// for this signal so external clients can observe the startup window before
// the initial WorkFile begins processing.
APIServerReady <-chan struct{}
// ProviderOverride, when non-nil, replaces the default
// ScriptWrapProvider for MODEL_WORKER executors. This allows tests
// to inject a mock Provider and exercise the full worker pipeline
// (prompt rendering, AgentExecutor, stop-token evaluation) without
// shelling out to a real CLI tool.
ProviderOverride workers.Provider
// ProviderCommandRunnerOverride, when non-nil, is injected into the
// ScriptWrapProvider used by MODEL_WORKER executors. This preserves the
// real provider request construction while letting tests fake the CLI
// subprocess boundary and assert command details, env, stdin, stdout,
// stderr, and exit failures.
ProviderCommandRunnerOverride workers.CommandRunner
// SkipBuiltInRunnerPrerequisiteValidation disables PATH-style built-in
// runner prerequisite checks during startup. Tests that replace execution
// with mocks or custom executors use this to exercise service wiring
// without requiring local AI runner binaries to exist.
SkipBuiltInRunnerPrerequisiteValidation bool
// WorkstationLoader, when non-nil, is consulted before falling back
// to disk when loading workstation AGENTS.md files. Returning
// (nil, nil) from Load signals "no config available" and the
// workstation is skipped. Tests use this to inject workstation
// definitions without requiring files on disk.
WorkstationLoader factoryconfig.WorkstationLoader
// CommandRunnerOverride, when non-nil, is injected into SCRIPT_WORKER
// executors instead of the default ExecCommandRunner. This allows
// tests to mock os/exec at the CommandRunner level while still
// exercising the full ScriptExecutor pipeline (arg templates, env
// merging, exit-code routing).
CommandRunnerOverride workers.CommandRunner
// HostedPollerHTTPClient, when non-nil, overrides the default HTTP client
// used by repository-owned hosted pollers such as the built-in Linear
// integration.
HostedPollerHTTPClient *http.Client
// HostedPollerSecretResolver, when non-nil, resolves hosted-worker
// auth.secretRef values at runtime instead of using the default env/file
// lookup behavior.
HostedPollerSecretResolver secretResolver
// HostedLinearEndpoint overrides the Linear GraphQL endpoint for tests.
// Empty uses the official default endpoint.
HostedLinearEndpoint string
// ModelCacheDir optionally overrides the default managed local-model cache
// directory under ~/.agent-factory/models.
ModelCacheDir string
// LocalModelRuntimeOverride injects a managed local-model runtime for
// supported LOCAL model workers. Package tests use this to exercise the
// load/invoke/reuse path without a live embedded backend.
LocalModelRuntimeOverride localModelRuntime
// FactorySave, when non-nil, replaces the default factorysave.Service
// collaborator. Tests use this to assert SaveFactoryForSession delegates
// without running the full save orchestration pipeline.
FactorySave factorySaveSaver
// ModelAssets, when non-nil, replaces the default localmodels.AssetPuller
// collaborator wired at service construction. Tests use this to assert
// PullModel delegates without running managed asset downloads.
ModelAssets modelAssetPuller
}
FactoryServiceConfig holds all parameters needed to build and run a factory.
type FactoryServiceRoot ¶ added in v0.0.5
FactoryServiceRoot holds the absolutized factory directory and base logger after FactoryServiceConfig normalization during service construction.
func ResolveFactoryServiceRoot ¶ added in v0.0.5
func ResolveFactoryServiceRoot(cfg *FactoryServiceConfig) (FactoryServiceRoot, error)
ResolveFactoryServiceRoot absolutizes cfg.Dir, assigns cfg.Logger, and mints cfg.RuntimeInstanceID when empty.
type FactoryServiceShell ¶ added in v0.0.5
type FactoryServiceShell struct {
Service *FactoryService
}
FactoryServiceShell is the pre-factorysave FactoryService assembly product for Wire composition.
func ComposeFactoryService ¶ added in v0.0.5
func ComposeFactoryService( ctx context.Context, cfg *FactoryServiceConfig, root FactoryServiceRoot, collaborators FactoryServiceCollaborators, load FactoryConfigLoadResult, clock factory.Clock, hostedWorkers hostedworkers.Config, ) (FactoryServiceShell, error)
ComposeFactoryService constructs *FactoryService using explicit S6 collaborators.
type FactorySessionOpenResult ¶ added in v0.0.5
type FactorySessionOpenResult = factorysessions.OpenResult
type FactorySessionTarget ¶ added in v0.0.5
type FactorySessionTarget = factorysessions.Target
type FactorySessionTargetKind ¶ added in v0.0.5
type FactorySessionTargetKind = factorysessions.TargetKind
type FactorySessionTargetRef ¶ added in v0.0.5
type FactorySessionTargetRef = factorysessions.TargetRef
type LocalModelDomain ¶ added in v0.0.5
type LocalModelDomain = localModelDomain
LocalModelDomain wires pkg/localmodels runtime dependencies constructed at service build time and copied onto each factoryRuntimeBundle.
func NewLocalModelDomain ¶ added in v0.0.5
func NewLocalModelDomain(cfg *FactoryServiceConfig) LocalModelDomain
NewLocalModelDomain constructs the local-model collaborator group for a build.
type RuntimeLogDiagnostics ¶ added in v0.0.5
RuntimeLogDiagnostics describes the active runtime log selected during service construction.
type SimpleDashboardRenderInput ¶
type SimpleDashboardRenderInput struct {
EngineState interfaces.EngineStateSnapshot[petri.MarkingSnapshot, *state.Net]
RenderData dashboardrender.SimpleDashboardRenderData
Now time.Time
}
SimpleDashboardRenderInput carries the low-level engine snapshot that powers runtime diagnostics together with the dedicated event-first render DTO used for dashboard session accounting.
type SimpleDashboardRenderer ¶
type SimpleDashboardRenderer func(input SimpleDashboardRenderInput)
SimpleDashboardRenderer is a callback that formats and prints dashboard output. Callers (e.g. CLI) provide their own rendering implementation.
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package ingest provides filesystem-backed external input ingestion for the factory runtime.
|
Package ingest provides filesystem-backed external input ingestion for the factory runtime. |