plugin_manager

package
v1.26.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 20, 2026 License: MPL-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Manager

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

func New

func New(
	lc fx.Lifecycle,
	pluginWriter *plugin_writer.Writer,
	pluginQuerier *plugin_reader.Reader,
	runner plugin_runner.Host,
	bus *pubsub.Bus,
	logger *slog.Logger,
	cfg config.Config,
) *Manager

func (*Manager) AddExternal

func (m *Manager) AddExternal(ctx context.Context, manifest rpc.Manifest) (*plugin.Record, string, error)

func (*Manager) AddFromFile

func (m *Manager) AddFromFile(ctx context.Context, r io.Reader) (*plugin.Available, error)

func (*Manager) AddFromURL

func (m *Manager) AddFromURL(ctx context.Context, u url.URL) (*plugin.Available, error)

func (*Manager) CycleExternalToken

func (m *Manager) CycleExternalToken(ctx context.Context, id plugin.InstallationID) (string, error)

func (*Manager) Delete

func (m *Manager) Delete(ctx context.Context, id plugin.InstallationID) error

func (*Manager) Get

func (*Manager) GetConfiguration

func (m *Manager) GetConfiguration(
	ctx context.Context,
	id plugin.InstallationID,
) (map[string]any, error)

func (*Manager) GetConfigurationSchema

func (m *Manager) GetConfigurationSchema(
	ctx context.Context,
	id plugin.InstallationID,
) (rpc.ManifestConfigurationSchema, error)

func (*Manager) GetSession

func (*Manager) List

func (m *Manager) List(ctx context.Context) ([]*plugin.Record, error)

func (*Manager) SetActiveState

func (m *Manager) SetActiveState(ctx context.Context, id plugin.InstallationID, desiredState plugin.ActiveState) error

Handle state transitions for plugins Activate and deactivate via runner sessions.

func (*Manager) UpdateConfiguration

func (m *Manager) UpdateConfiguration(
	ctx context.Context,
	id plugin.InstallationID,
	config map[string]any,
) (map[string]any, error)

func (*Manager) UpdateManifest

func (m *Manager) UpdateManifest(
	ctx context.Context,
	id plugin.InstallationID,
	manifest rpc.Manifest,
) (*plugin.Record, error)

func (*Manager) UpdatePackage

func (m *Manager) UpdatePackage(
	ctx context.Context,
	id plugin.InstallationID,
	reader io.Reader,
) (*plugin.Record, error)

Jump to

Keyboard shortcuts

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