Documentation ¶
Index ¶
- type PluginManager
- func (m *PluginManager) Get(req *proto.GetRequest) (*proto.GetResponse, error)
- func (m *PluginManager) Serve()
- func (m *PluginManager) SetConnectionConfigMap(configMap connectionwatcher.ConnectionConfigMap)
- func (m *PluginManager) Shutdown(req *proto.ShutdownRequest) (resp *proto.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 { 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 connectionwatcher.ConnectionConfigMap)
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
Click to show internal directories.
Click to hide internal directories.