external

package

Go to main page

Versions in this module

v0

v0.1.5

Feb 22, 2026

Changes in this version

type CallbackServer

+ func (s *CallbackServer) PublishMessage(_ context.Context, req *pb.PublishMessageRequest) (*pb.PublishMessageResponse, error)

+ func (s *CallbackServer) SetMessagePublishFunc(fn MessagePublishFunc)

+ func (s *CallbackServer) SetMessageSubscribeFunc(fn MessageSubscribeFunc)

+ func (s *CallbackServer) Subscribe(_ context.Context, req *pb.SubscribeRequest) (*pb.ErrorResponse, error)

+ func (s *CallbackServer) Unsubscribe(_ context.Context, req *pb.UnsubscribeRequest) (*pb.ErrorResponse, error)

+ type MessagePublishFunc func(brokerName, topic string, payload []byte, metadata map[string]string) (messageID string, err error)

+ type MessageSubscribeFunc func(brokerName, topic string, handler func([]byte, map[string]string) error) (cancel func(), err error)

+ type RemoteTrigger struct

+ func NewRemoteTrigger(typeName, name, handleID string, client pb.PluginServiceClient, ...) *RemoteTrigger

+ func (t *RemoteTrigger) Configure(_ modular.Application, _ any) error

+ func (t *RemoteTrigger) Destroy() error

+ func (t *RemoteTrigger) Init(_ modular.Application) error

+ func (t *RemoteTrigger) Name() string

+ func (t *RemoteTrigger) Start(ctx context.Context) error

+ func (t *RemoteTrigger) Stop(ctx context.Context) error

v0.1.1

Feb 22, 2026

Changes in this version

+ type UIManifest struct

+ AssetDir string

+ Description string

+ Name string

+ NavItems []UINavItem

+ Version string

+ type UINavItem struct

+ Category string

+ ID string

+ Icon string

+ Label string

+ Order int

+ RequiredPermission string

+ RequiredRole string

+ type UIPluginEntry struct

+ AssetsDir string

+ Manifest UIManifest

+ type UIPluginHandler struct

+ func NewUIPluginHandler(manager *UIPluginManager) *UIPluginHandler

+ func (h *UIPluginHandler) RegisterRoutes(mux *http.ServeMux)

+ type UIPluginInfo struct

+ Description string

+ Loaded bool

+ Name string

+ NavItems []UINavItem

+ Version string

+ type UIPluginManager struct

+ func NewUIPluginManager(pluginsDir string, logger *log.Logger) *UIPluginManager

+ func (m *UIPluginManager) AllUIPluginInfos() []UIPluginInfo

+ func (m *UIPluginManager) AsNativePlugin(name string) plugin.NativePlugin

+ func (m *UIPluginManager) DiscoverPlugins() ([]string, error)

+ func (m *UIPluginManager) GetPlugin(name string) (*UIPluginEntry, bool)

+ func (m *UIPluginManager) IsLoaded(name string) bool

+ func (m *UIPluginManager) LoadPlugin(name string) error

+ func (m *UIPluginManager) LoadedPlugins() []string

+ func (m *UIPluginManager) ReloadPlugin(name string) error

+ func (m *UIPluginManager) ServeAssets(name string) http.Handler

+ func (m *UIPluginManager) UIPages(name string) []plugin.UIPageDef

+ func (m *UIPluginManager) UnloadPlugin(name string) error

+ type UIPluginNativePlugin struct

+ func (p *UIPluginNativePlugin) Dependencies() []plugin.PluginDependency

+ func (p *UIPluginNativePlugin) Description() string

+ func (p *UIPluginNativePlugin) Name() string

+ func (p *UIPluginNativePlugin) OnDisable(_ plugin.PluginContext) error

+ func (p *UIPluginNativePlugin) OnEnable(_ plugin.PluginContext) error

+ func (p *UIPluginNativePlugin) RegisterRoutes(_ *http.ServeMux)

+ func (p *UIPluginNativePlugin) UIPages() []plugin.UIPageDef

+ func (p *UIPluginNativePlugin) Version() string

v0.1.0

Feb 22, 2026

Changes in this version

+ const MagicCookieKey

+ const MagicCookieValue

+ const ProtocolVersion

+ var Handshake = goplugin.HandshakeConfig

+ type CallbackServer struct

+ func NewCallbackServer(onTrigger TriggerFunc, lookup ServiceLookupFunc, logger *log.Logger) *CallbackServer

+ func (s *CallbackServer) GetService(_ context.Context, req *pb.GetServiceRequest) (*pb.GetServiceResponse, error)

+ func (s *CallbackServer) Log(_ context.Context, req *pb.LogRequest) (*emptypb.Empty, error)

+ func (s *CallbackServer) TriggerWorkflow(_ context.Context, req *pb.TriggerWorkflowRequest) (*pb.ErrorResponse, error)

+ type ExternalPluginAdapter struct

+ func NewExternalPluginAdapter(name string, client *PluginClient) (*ExternalPluginAdapter, error)

+ func (a *ExternalPluginAdapter) Capabilities() []capability.Contract

+ func (a *ExternalPluginAdapter) Dependencies() []plugin.PluginDependency

+ func (a *ExternalPluginAdapter) Description() string

+ func (a *ExternalPluginAdapter) EngineManifest() *plugin.PluginManifest

+ func (a *ExternalPluginAdapter) ModuleFactories() map[string]plugin.ModuleFactory

+ func (a *ExternalPluginAdapter) ModuleSchemas() []*schema.ModuleSchema

+ func (a *ExternalPluginAdapter) Name() string

+ func (a *ExternalPluginAdapter) OnDisable(_ plugin.PluginContext) error

+ func (a *ExternalPluginAdapter) OnEnable(_ plugin.PluginContext) error

+ func (a *ExternalPluginAdapter) RegisterRoutes(_ *http.ServeMux)

+ func (a *ExternalPluginAdapter) StepFactories() map[string]plugin.StepFactory

+ func (a *ExternalPluginAdapter) TriggerFactories() map[string]plugin.TriggerFactory

+ func (a *ExternalPluginAdapter) UIPages() []plugin.UIPageDef

+ func (a *ExternalPluginAdapter) Version() string

+ func (a *ExternalPluginAdapter) WiringHooks() []plugin.WiringHook

+ func (a *ExternalPluginAdapter) WorkflowHandlers() map[string]plugin.WorkflowHandlerFactory

+ type ExternalPluginManager struct

+ func NewExternalPluginManager(pluginsDir string, logger *log.Logger) *ExternalPluginManager

+ func (m *ExternalPluginManager) DiscoverPlugins() ([]string, error)

+ func (m *ExternalPluginManager) IsLoaded(name string) bool

+ func (m *ExternalPluginManager) LoadPlugin(name string) (*ExternalPluginAdapter, error)

+ func (m *ExternalPluginManager) LoadedPlugins() []string

+ func (m *ExternalPluginManager) ReloadPlugin(name string) (*ExternalPluginAdapter, error)

+ func (m *ExternalPluginManager) Shutdown()

+ func (m *ExternalPluginManager) UnloadPlugin(name string) error

+ type GRPCPlugin struct

+ CallbackServer *CallbackServer

+ func (p *GRPCPlugin) GRPCClient(_ context.Context, broker *goplugin.GRPCBroker, c *grpc.ClientConn) (any, error)

+ func (p *GRPCPlugin) GRPCServer(broker *goplugin.GRPCBroker, s *grpc.Server) error

+ type PluginClient struct

+ type PluginHandler struct

+ func NewPluginHandler(manager *ExternalPluginManager) *PluginHandler

+ func (h *PluginHandler) RegisterRoutes(mux *http.ServeMux)

+ type RemoteModule struct

+ func NewRemoteModule(name, handleID string, client pb.PluginServiceClient) *RemoteModule

+ func (m *RemoteModule) Dependencies() []string

+ func (m *RemoteModule) Destroy() error

+ func (m *RemoteModule) Init(app modular.Application) error

+ func (m *RemoteModule) InvokeService(method string, args map[string]any) (map[string]any, error)

+ func (m *RemoteModule) Name() string

+ func (m *RemoteModule) ProvidesServices() []string

+ func (m *RemoteModule) RegisterConfig(app modular.Application) error

+ func (m *RemoteModule) RequiresServices() []string

+ func (m *RemoteModule) Start(ctx context.Context) error

+ func (m *RemoteModule) Stop(ctx context.Context) error

+ type RemoteStep struct

+ func NewRemoteStep(name, handleID string, client pb.PluginServiceClient) *RemoteStep

+ func (s *RemoteStep) Destroy() error

+ func (s *RemoteStep) Execute(ctx context.Context, pc *module.PipelineContext) (*module.StepResult, error)

+ func (s *RemoteStep) Name() string

+ type ServiceLookupFunc func(name string) bool

+ type TriggerFunc func(triggerType, action string, data map[string]any) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL