plugin_manager

Documentation

Index

• func FindPluginFolder(remoteSchema string) (string, error)
• func GetPluginManager() (pluginshared.PluginManager, error)
• func GetPluginPath(plugin, pluginShortName string) (string, error)
• func NewPluginManagerState(reattach *plugin.ReattachConfig) *pluginManagerState
• func PluginFQNToSchemaName(pluginFQN string) string
• func Start() error
• func Stop() error
• type PluginManager
  • 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(req *pb.SetConnectionConfigMapRequest) (resp *pb.SetConnectionConfigMapResponse, err error)
  • func (m *PluginManager) Shutdown(req *pb.ShutdownRequest) (resp *pb.ShutdownResponse, err error)
• type PluginManagerClient
  • func NewPluginManagerClient(pluginManagerState *pluginManagerState) (*PluginManagerClient, error)
  • func (c *PluginManagerClient) Get(req *pb.GetRequest) (res *pb.GetResponse, err error)
  • func (c *PluginManagerClient) SetConnectionConfigMap(req *pb.SetConnectionConfigMapRequest) (res *pb.SetConnectionConfigMapResponse, err error)
  • func (c *PluginManagerClient) Shutdown(req *pb.ShutdownRequest) (res *pb.ShutdownResponse, err error)

Functions

func FindPluginFolder

func FindPluginFolder(remoteSchema string) (string, error)

search for a folder which when hashed would match the schema

func GetPluginManager

func GetPluginManager() (pluginshared.PluginManager, error)

GetPluginManager connects to a running plugin manager

func GetPluginPath

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

func NewPluginManagerState

func NewPluginManagerState(reattach *plugin.ReattachConfig) *pluginManagerState

func PluginFQNToSchemaName

func PluginFQNToSchemaName(pluginFQN string) string

schemas in postgres are limited to 63 chars - the name may be longer than this, in which case trim the length and add a hash to the end to make unique

func Start

func Start() error

Start loads the plugin manager state, stops any previous instance and instantiates a new the plugin manager

func Stop

func Stop() error

Stop loads the plugin manager state and if a running instance is found, stop it

Types

type PluginManager

type PluginManager struct {
	pb.UnimplementedPluginManagerServer

	Plugins map[string]runningPlugin
	// contains filtered or unexported fields
}

PluginManager is the real implementation of grpc.PluginManager

func NewPluginManager

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

func (*PluginManager) Get

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

func (*PluginManager) Serve

func (m *PluginManager) Serve()

func (*PluginManager) SetConnectionConfigMap

func (m *PluginManager) SetConnectionConfigMap(req *pb.SetConnectionConfigMapRequest) (resp *pb.SetConnectionConfigMapResponse, err error)

func (*PluginManager) Shutdown

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

type PluginManagerClient

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

PluginManagerClient is the client used by steampipe to access the plugin manager

func NewPluginManagerClient

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

func (*PluginManagerClient) Get

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

func (*PluginManagerClient) SetConnectionConfigMap

func (c *PluginManagerClient) SetConnectionConfigMap(req *pb.SetConnectionConfigMapRequest) (res *pb.SetConnectionConfigMapResponse, err error)

func (*PluginManagerClient) Shutdown

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