pluginmanager_service

Documentation

Index

• type PluginManager
  • func NewPluginManager(connectionConfig map[string]*sdkproto.ConnectionConfig, logger hclog.Logger) (*PluginManager, error)
  • func (m *PluginManager) Get(req *proto.GetRequest) (*proto.GetResponse, error)
  • func (m *PluginManager) OnConnectionConfigChanged(configMap connectionwatcher.ConnectionConfigMap)
  • func (m *PluginManager) OnConnectionsChanged(refreshResult *steampipeconfig.RefreshConnectionResult, ...)
  • func (m *PluginManager) Serve()
  • func (m *PluginManager) Shutdown(*proto.ShutdownRequest) (resp *proto.ShutdownResponse, err error)
• type PluginMessageServer
  • func NewPluginMessageServer(pluginManager *PluginManager) (*PluginMessageServer, error)
  • func (m *PluginMessageServer) AddConnection(pluginClient *sdkgrpc.PluginClient, pluginName string, ...) error

Types

type PluginManager

type PluginManager struct {
	proto.UnimplementedPluginManagerServer
	// contains filtered or unexported fields
}

PluginManager is the implementation of grpc.PluginManager

func NewPluginManager

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

func (*PluginManager) Get

func (m *PluginManager) Get(req *proto.GetRequest) (*proto.GetResponse, error)

func (*PluginManager) OnConnectionConfigChanged

func (m *PluginManager) OnConnectionConfigChanged(configMap connectionwatcher.ConnectionConfigMap)

OnConnectionConfigChanged is the callback function invoked by the connection watcher when the config changed

func (*PluginManager) OnConnectionsChanged

func (m *PluginManager) OnConnectionsChanged(refreshResult *steampipeconfig.RefreshConnectionResult, client *db_local.LocalDbClient)

OnConnectionsChanged is the callback function invoked by the connection watcher when connections are added or removed

func (*PluginManager) Serve

func (m *PluginManager) Serve()

func (*PluginManager) Shutdown

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

type PluginMessageServer

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

func NewPluginMessageServer

func NewPluginMessageServer(pluginManager *PluginManager) (*PluginMessageServer, error)

func (*PluginMessageServer) AddConnection

func (m *PluginMessageServer) AddConnection(pluginClient *sdkgrpc.PluginClient, pluginName string, connectionNames ...string) error