Documentation ¶
Index ¶
- type PluginManager
- func (m *PluginManager) Get(req *pb.GetRequest) (*pb.GetResponse, error)
- func (m *PluginManager) OnConnectionConfigChanged(configMap connectionwatcher.ConnectionConfigMap)
- func (m *PluginManager) OnConnectionsChanged(ctx context.Context, refreshResult *steampipeconfig.RefreshConnectionResult)
- func (m *PluginManager) RefreshConnections(*pb.RefreshConnectionsRequest) (*pb.RefreshConnectionsResponse, error)
- func (m *PluginManager) Serve()
- func (m *PluginManager) Shutdown(*pb.ShutdownRequest) (resp *pb.ShutdownResponse, err error)
- type PluginMessageServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PluginManager ¶
type PluginManager struct { pb.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 *pb.GetRequest) (*pb.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(ctx context.Context, refreshResult *steampipeconfig.RefreshConnectionResult)
OnConnectionsChanged is the callback function invoked by the connection watcher when connections are added or removed
func (*PluginManager) RefreshConnections ¶
func (m *PluginManager) RefreshConnections(*pb.RefreshConnectionsRequest) (*pb.RefreshConnectionsResponse, error)
func (*PluginManager) Serve ¶
func (m *PluginManager) Serve()
func (*PluginManager) Shutdown ¶
func (m *PluginManager) Shutdown(*pb.ShutdownRequest) (resp *pb.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
Click to show internal directories.
Click to hide internal directories.