plugin_manager

Nov 24, 2021

Changes in this version

+ func FindPluginFolder(remoteSchema string) (string, error)

+ func GetPluginManager() (pluginshared.PluginManager, error)

+ func GetPluginPath(plugin, pluginShortName string) (string, error)

+ func PluginFQNToSchemaName(pluginFQN string) string

+ func StartNewInstance(steampipeExecutablePath string) error

+ func Stop() error

+ type PluginManager struct

+ Plugins map[string]runningPlugin

+ func NewPluginManager(connectionConfig map[string]*pb.ConnectionConfig, logger hclog.Logger) *PluginManager

+ func (m *PluginManager) Get(req *pb.GetRequest) (resp *pb.GetResponse, err error)

+ func (m *PluginManager) Serve()

+ func (m *PluginManager) SetConnectionConfigMap(configMap map[string]*pb.ConnectionConfig)

+ func (m *PluginManager) Shutdown(req *pb.ShutdownRequest) (resp *pb.ShutdownResponse, err error)

+ type PluginManagerClient struct

+ func NewPluginManagerClient(pluginManagerState *PluginManagerState) (*PluginManagerClient, error)

+ func (c *PluginManagerClient) Get(req *pb.GetRequest) (res *pb.GetResponse, err error)

+ func (c *PluginManagerClient) Shutdown(req *pb.ShutdownRequest) (res *pb.ShutdownResponse, err error)

+ type PluginManagerState struct

+ Addr *pb.SimpleAddr

+ Executable string

+ Pid int

+ Protocol plugin.Protocol

+ ProtocolVersion int

+ Running bool

+ func LoadPluginManagerState() (*PluginManagerState, error)

+ func NewPluginManagerState(executable string, reattach *plugin.ReattachConfig) *PluginManagerState

+ func (s *PluginManagerState) Save() error