plugin_host

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

type LookupPluginHost interface {
	// Directive indicates LookupPluginHost is a directive.
	directive.Directive

	// LookupPluginHostPlatformIDs filters the platform IDs to match.
	// If unset (empty), matches all platform IDs.
	LookupPluginHostPlatformIDs() []string
}

type LookupPluginHostValue = PluginHost

type PluginHost interface {
	// GetPlatformId returns the platform ID for this host.
	// The plugin host must be capable of executing plugin manifests with this platform id.
	// Must return a value.
	GetPlatformId() string

	// Execute executes the plugin host.
	// If an error is returned, the plugin host execution will be retried.
	// If nil is returned, this indicates PluginHost does not need the Execute goroutin.
	// Return context.Canceled if context was canceled.
	Execute(ctx context.Context) error

	// ListPlugins lists the set of loaded plugins in the host.
	ListPlugins(ctx context.Context) ([]string, error)

	// ExecutePlugin executes the plugin with the given ID.
	// If the plugin was already initialized, existing state can be reused.
	// The plugin should be stopped if/when the function exits.
	// Return ErrPluginUninitialized if the plugin was not ready.
	// Should expect to be called only once (at a time) for a plugin ID.
	// pluginDist contains the plugin distribution files (binaries and assets).
	// rpcInit is called when the RPC client is ready, should return a mux for the server.
	// instanceKey is the logical instance key passed to the plugin in its start
	// info (empty for shared plugins).
	// executionKey distinguishes concurrent executions of one instance, such
	// as a replacement starting before its predecessor stops. Hosts derive
	// worker and controller identities from it.
	// manifestRoot identifies the exact files used by this execution.
	ExecutePlugin(
		ctx context.Context,
		pluginID,
		instanceKey,
		executionKey,
		manifestRoot,
		entrypoint string,
		pluginDist *unixfs.FSHandle,
		pluginAssets *unixfs.FSHandle,
		hostRpcMux srpc.Mux,
		rpcInit PluginRpcInitCb,
	) error

	// DeletePlugin clears cached plugin data for the given plugin ID.
	DeletePlugin(ctx context.Context, pluginID string) error
}

type PluginHostScheduler interface {
	// AddPluginReference adds a reference to the plugin, returning the RunningPlugin
	// handle and a release function.
	// instanceKey may be empty for shared (non-instanced) plugins.
	AddPluginReference(pluginID, instanceKey string) (bldr_plugin.RunningPluginRef, func())

	// AddPinnedPluginReference retains an exact executable without following replacement.
	AddPinnedPluginReference(pluginID, instanceKey, manifestRoot string) (bldr_plugin.RunningPluginRef, func())

	// AddSelectedPluginReference selects an installed artifact for a logical binding.
	AddSelectedPluginReference(pluginID, instanceKey string, refs ...*manifest.ManifestRef) (bldr_plugin.RunningPluginRef, func())
}

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

type PluginRpcInitCb func(client srpc.Client) error