Documentation
¶
Index ¶
- type Client
- type GRPCPlugin
- func (p *GRPCPlugin) Client(_ *plugin.MuxBroker, _ *rpc.Client) (any, error)
- func (p *GRPCPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (any, error)
- func (p *GRPCPlugin) GRPCServer(_ *plugin.GRPCBroker, s *grpc.Server) error
- func (p *GRPCPlugin) Server(_ *plugin.MuxBroker) (any, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client represents a plugin client
func NewClient ¶
func NewClient(ctx context.Context, pluginName, pluginPath string, config map[string]*structpb.Value) (*Client, error)
NewClient creates a new plugin client
func (*Client) Plugin ¶
func (c *Client) Plugin() pb.PluginClient
type GRPCPlugin ¶
type GRPCPlugin struct {
plugin.GRPCPlugin
}
GRPCPlugin is the plugin implementation for go-plugin
func (*GRPCPlugin) GRPCClient ¶
func (p *GRPCPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (any, error)
GRPCClient is required by the go-plugin interface
func (*GRPCPlugin) GRPCServer ¶
func (p *GRPCPlugin) GRPCServer(_ *plugin.GRPCBroker, s *grpc.Server) error
GRPCServer is required by the go-plugin interface
Click to show internal directories.
Click to hide internal directories.