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) Serve()
  • func (m *PluginManager) SetConnectionConfigMap(configMap map[string]*sdkproto.ConnectionConfig)
  • func (m *PluginManager) Shutdown(req *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) Serve

func (m *PluginManager) Serve()

func (*PluginManager) SetConnectionConfigMap

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

func (*PluginManager) Shutdown

func (m *PluginManager) Shutdown(req *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