pluginmanager

Documentation

Index

• Constants
• func GetPluginManager() (pluginshared.PluginManager, error)
• func StartNewInstance(steampipeExecutablePath string) error
• func Stop() error
• type PluginManagerClient
  • func NewPluginManagerClient(pluginManagerState *PluginManagerState) (*PluginManagerClient, error)
  • func (c *PluginManagerClient) Get(req *pb.GetRequest) (*pb.GetResponse, error)
  • func (c *PluginManagerClient) RefreshConnections(req *pb.RefreshConnectionsRequest) (*pb.RefreshConnectionsResponse, error)
  • func (c *PluginManagerClient) Shutdown(req *pb.ShutdownRequest) (*pb.ShutdownResponse, error)
• type PluginManagerState
  • func LoadPluginManagerState() (*PluginManagerState, error)
  • func NewPluginManagerState(executable string, reattach *plugin.ReattachConfig) *PluginManagerState
  • func (s *PluginManagerState) Save() error

Constants

const PluginManagerStructVersion = 20220411

Functions

func GetPluginManager

func GetPluginManager() (pluginshared.PluginManager, error)

GetPluginManager connects to a running plugin manager

func StartNewInstance

func StartNewInstance(steampipeExecutablePath string) error

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

func Stop

func Stop() error

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

Types

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) (*pb.GetResponse, error)

func (*PluginManagerClient) RefreshConnections

func (c *PluginManagerClient) RefreshConnections(req *pb.RefreshConnectionsRequest) (*pb.RefreshConnectionsResponse, error)

func (*PluginManagerClient) Shutdown

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

type PluginManagerState

type PluginManagerState struct {
	Protocol        plugin.Protocol `json:"protocol"`
	ProtocolVersion int             `json:"protocol_version"`
	Addr            *pb.SimpleAddr  `json:"addr"`
	Pid             int             `json:"pid"`
	// path to the steampipe executable
	Executable string `json:"executable"`
	// is the plugin manager running
	Running       bool  `json:"-"`
	StructVersion int64 `json:"struct_version"`
}

func LoadPluginManagerState

func LoadPluginManagerState() (*PluginManagerState, error)

func NewPluginManagerState

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

func (*PluginManagerState) Save

func (s *PluginManagerState) Save() error