Documentation
¶
Overview ¶
Package worker answers connector questions for the control services. Local serves them from in-process registries; the same contract is served over the wire by a persistent worker.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Handler ¶
Handler serves a Worker over ConnectRPC. The persistent worker mounts it so the control services reach the drivers it carries. It returns the mount pattern and the handler, as the generated constructor does.
func Local ¶
func Local(sources filament.SourceRegistry, sinks filament.SinkRegistry) filament.Worker
Local answers from the given registries in process.
func Remote ¶
func Remote(baseURL string, opts ...connect.ClientOption) filament.Worker
Remote returns a Worker that forwards to the persistent worker at baseURL, so the caller links no driver. Specs are served from a cached snapshot that refreshes in the background; every other call is one RPC under the caller's deadline. A bare host:port, as some platforms inject, is taken as plain HTTP.
Types ¶
This section is empty.
Source Files