plugin

Aug 4, 2026

Changes in this version

+ func LoadExternalPlugins(ctx context.Context, mgr *Manager, dir string, logger *slog.Logger) error

+ type AuthContext struct

+ ARN string

+ AccessKeyID string

+ AccountID string

+ Claims map[string]string

+ IsRoot bool

+ Roles []string

+ UserID string

+ type Descriptor struct

+ APIPaths []string

+ Actions []string

+ Metadata map[string]string

+ Name string

+ Protocol string

+ Version string

+ type ExternalPlugin struct

+ func (ep *ExternalPlugin) Describe(_ context.Context) (*Descriptor, error)

+ func (ep *ExternalPlugin) HandleRequest(_ context.Context, req *Request) (*Response, error)

+ func (ep *ExternalPlugin) HealthCheck(_ context.Context) (HealthStatus, string, error)

+ func (ep *ExternalPlugin) Init(_ context.Context, _ []byte, _ string, _ string) error

+ func (ep *ExternalPlugin) Shutdown(_ context.Context) error

+ type GRPCBridge struct

+ func NewGRPCBridge(cfg GRPCBridgeConfig) *GRPCBridge

+ func (b *GRPCBridge) Close() error

+ func (b *GRPCBridge) Conn() *grpc.ClientConn

+ func (b *GRPCBridge) Connect(ctx context.Context, addr string) error

+ type GRPCBridgeConfig struct

+ Addr string

+ Args []string

+ BinaryPath string

+ type HealthCheckResult struct

+ Message string

+ Name string

+ Status HealthStatus

+ type HealthStatus int

+ const HealthDegraded

+ const HealthHealthy

+ const HealthUnhealthy

+ const HealthUnknown

+ func (h HealthStatus) String() string

+ type Manager struct

+ func NewManager(logger *slog.Logger) *Manager

+ func (m *Manager) HealthCheckAll(ctx context.Context) map[string]HealthCheckResult

+ func (m *Manager) List() []PluginInfo

+ func (m *Manager) Lookup(name string) (Plugin, error)

+ func (m *Manager) LookupByPath(path string) (Plugin, error)

+ func (m *Manager) Names() []string

+ func (m *Manager) RegisterInProcess(ctx context.Context, p Plugin) error

+ func (m *Manager) RegisterServiceAdapter(ctx context.Context, adapter *ServiceAdapter) error

+ func (m *Manager) ShutdownAll(ctx context.Context)

+ type Plugin interface

+ Describe func(ctx context.Context) (*Descriptor, error)

+ HandleRequest func(ctx context.Context, req *Request) (*Response, error)

+ HealthCheck func(ctx context.Context) (HealthStatus, string, error)

+ Init func(ctx context.Context, config []byte, dataDir string, logLevel string) error

+ Shutdown func(ctx context.Context) error

+ type PluginInfo struct

+ APIPaths []string

+ Actions []string

+ Healthy bool

+ LastCheck time.Time

+ Metadata map[string]string

+ Mode string

+ Name string

+ Protocol string

+ Version string

+ type PluginMode int

+ const ModeExternalGRPC

+ const ModeInProcess

+ func (m PluginMode) String() string

+ type Request struct

+ Action string

+ Auth *AuthContext

+ Body []byte

+ Headers map[string]string

+ Method string

+ Path string

+ QueryParams map[string]string

+ type Response struct

+ Body []byte

+ Headers map[string]string

+ StatusCode int

+ type ServiceAdapter struct

+ func NewServiceAdapter(svc service.Service, region, accountID string) *ServiceAdapter

+ func (a *ServiceAdapter) Describe(_ context.Context) (*Descriptor, error)

+ func (a *ServiceAdapter) HandleRequest(ctx context.Context, req *Request) (*Response, error)

+ func (a *ServiceAdapter) HealthCheck(_ context.Context) (HealthStatus, string, error)

+ func (a *ServiceAdapter) Init(_ context.Context, _ []byte, _ string, _ string) error

+ func (a *ServiceAdapter) Shutdown(_ context.Context) error

+ func (a *ServiceAdapter) Unwrap() service.Service

+ type StreamingPlugin interface

+ StreamRequest func(ctx context.Context, req *Request, send func(*Response) error) error