grpc

type Enricher ¶

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

Enricher wraps a gRPC EnricherClient to implement the application Enricher interface. This allows external plugins (go-plugin processes) to be used as enrichers.

Since the Enricher interface now uses proto types directly, this wrapper is minimal - it just stores capabilities and delegates calls to the gRPC client.

func NewEnricher(pluginID string, client pluginv1.EnricherClient, logger *slog.Logger) (*Enricher, error)

func (e *Enricher) Capabilities() enrichment.EnricherCapabilities

func (e *Enricher) Enrich(ctx context.Context, req *pluginv1.EnrichRequest) (*pluginv1.EnrichResponse, error)

func (e *Enricher) Stage() string

type EnricherPlugin ¶

type EnricherPlugin struct {
	plugin.Plugin
	// Impl is only used when serving (plugin side)
	Impl pluginv1.EnricherServer
}

EnricherPlugin is the go-plugin implementation for the Enricher service.

func (p *EnricherPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *EnricherPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type Factory ¶

type Factory struct{}

Factory implements the manager.PluginFactory interface. It creates go-plugin Plugin instances for the plugin manager.

func NewFactory() *Factory

func (f *Factory) GetBrokerID(brokerInfo interface{}) uint32

func (f *Factory) NewEnricherGRPCPlugin() plugin.Plugin

func (f *Factory) NewHostDataGRPCPlugin(impl manager.HostDataServer, logger *slog.Logger) plugin.Plugin

func (f *Factory) NewHostPluginsGRPCPlugin(impl manager.HostPluginsServer, logger *slog.Logger) plugin.Plugin

func (f *Factory) NewHostProgressGRPCPlugin(impl manager.HostProgressServer, logger *slog.Logger) plugin.Plugin

func (f *Factory) NewHostRatingsGRPCPlugin(impl manager.HostRatingsServer, logger *slog.Logger) plugin.Plugin

func (f *Factory) NewHostStorageGRPCPlugin(impl manager.HostStorageServer, pluginID string, logger *slog.Logger) plugin.Plugin

func (f *Factory) NewHostWeatherGRPCPlugin(impl manager.HostWeatherServer, logger *slog.Logger) plugin.Plugin

func (f *Factory) NewPluginCoreGRPCPlugin() plugin.Plugin

func (f *Factory) NewPluginProviderGRPCPlugin() plugin.Plugin

func (f *Factory) NewTrendingProviderGRPCPlugin() plugin.Plugin

func (f *Factory) NewVectorSearchGRPCPlugin() plugin.Plugin

type HostDataBrokerInfo ¶

type HostDataBrokerInfo struct {
	BrokerID uint32
}

HostDataBrokerInfo contains the broker ID for connecting to the host data service.

type HostDataPlugin ¶

type HostDataPlugin struct {
	plugin.Plugin
	Impl   pluginv1.HostDataServer
	Logger *slog.Logger
}

HostDataPlugin is the go-plugin implementation for the HostData service. On the host side, this starts a gRPC server on a broker ID that the plugin can connect to.

func (p *HostDataPlugin) GRPCClient(
	ctx context.Context,
	broker *plugin.GRPCBroker,
	c *grpc.ClientConn,
) (interface{}, error)

func (p *HostDataPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type HostPluginsBrokerInfo ¶

type HostPluginsBrokerInfo struct {
	BrokerID uint32
}

HostPluginsBrokerInfo contains the broker ID for connecting to the host plugins service.

type HostPluginsPlugin ¶

type HostPluginsPlugin struct {
	plugin.Plugin
	Impl   pluginv1.HostPluginsServer
	Logger *slog.Logger
}

HostPluginsPlugin is the go-plugin implementation for the HostPlugins service. On the host side, this starts a gRPC server on a broker ID that the plugin can connect to. This provides capability-based plugin discovery for inter-plugin communication.

func (p *HostPluginsPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *HostPluginsPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type HostProgressBrokerInfo ¶

type HostProgressBrokerInfo struct {
	BrokerID uint32
}

HostProgressBrokerInfo contains the broker ID for connecting to the host progress service.

type HostProgressPlugin ¶

type HostProgressPlugin struct {
	plugin.Plugin
	Impl   pluginv1.HostProgressServer
	Logger *slog.Logger
}

HostProgressPlugin is the go-plugin implementation for the HostProgress service. On the host side, this starts a gRPC server on a broker ID that the plugin can connect to. This provides read-only access to user watch progress for recommendations.

func (p *HostProgressPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *HostProgressPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type HostRatingsBrokerInfo ¶

type HostRatingsBrokerInfo struct {
	BrokerID uint32
}

HostRatingsBrokerInfo contains the broker ID for connecting to the host ratings service.

type HostRatingsPlugin ¶

type HostRatingsPlugin struct {
	plugin.Plugin
	Impl   pluginv1.HostRatingsServer
	Logger *slog.Logger
}

HostRatingsPlugin is the go-plugin implementation for the HostRatings service. On the host side, this starts a gRPC server on a broker ID that the plugin can connect to. This provides read-only access to user ratings for recommendations.

func (p *HostRatingsPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *HostRatingsPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type HostStorageBrokerInfo ¶

type HostStorageBrokerInfo struct {
	BrokerID uint32
}

HostStorageBrokerInfo contains the broker ID for connecting to the host storage service.

type HostStoragePlugin ¶

type HostStoragePlugin struct {
	plugin.Plugin
	Impl     pluginv1.HostStorageServer
	PluginID string // The ID of the plugin that this storage is for
	Logger   *slog.Logger
}

HostStoragePlugin is the go-plugin implementation for the HostStorage service. On the host side, this starts a gRPC server on a broker ID that the plugin can connect to.

func (p *HostStoragePlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *HostStoragePlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type HostWeatherBrokerInfo ¶

type HostWeatherBrokerInfo struct {
	BrokerID uint32
}

HostWeatherBrokerInfo contains the broker ID for connecting to the host weather service.

type HostWeatherPlugin ¶

type HostWeatherPlugin struct {
	plugin.Plugin
	Impl   pluginv1.HostWeatherServer
	Logger *slog.Logger
}

HostWeatherPlugin is the go-plugin implementation for the HostWeather service. On the host side, this starts a gRPC server on a broker ID that the plugin can connect to. This provides weather context for search query enrichment.

func (p *HostWeatherPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *HostWeatherPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type PluginCorePlugin ¶

type PluginCorePlugin struct {
	plugin.Plugin
	// Impl is only used when serving (plugin side)
	Impl pluginv1.PluginCoreServer
}

PluginCorePlugin is the go-plugin implementation for the PluginCore service. This is used by the host to communicate with plugins.

func (p *PluginCorePlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *PluginCorePlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type PluginProviderPlugin ¶

type PluginProviderPlugin struct {
	plugin.Plugin
}

PluginProviderPlugin is the go-plugin implementation for the PluginProvider service. This allows the host to call the plugin's provider methods (chat, embeddings, etc.). Provider plugins implement this service.

func (p *PluginProviderPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *PluginProviderPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type TrendingProviderPlugin ¶

type TrendingProviderPlugin struct {
	plugin.Plugin
}

TrendingProviderPlugin is the go-plugin implementation for the TrendingProviderService. On the host side, this is used to dispense a client for calling the plugin's trending methods. The plugin serves this service; the host is a client only.

func (p *TrendingProviderPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *TrendingProviderPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type VectorSearchPlugin ¶

type VectorSearchPlugin struct {
	plugin.Plugin
}

VectorSearchPlugin is the go-plugin implementation for the VectorSearch service. On the host side, this is used to dispense a client for calling the plugin's VectorSearch methods. The plugin serves this service; the host is a client only.

func (p *VectorSearchPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *VectorSearchPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error