Documentation
¶
Index ¶
Constants ¶
View Source
const ( IPv4 = "IPv4" IPv6 = "IPv6" )
Variables ¶
This section is empty.
Functions ¶
func QualMapToString ¶
Types ¶
type ExecuteFunc ¶
type ExecuteFunc func(req *pb.ExecuteRequest, stream pb.WrapperPlugin_ExecuteServer) error
type GetSchemaFunc ¶
type GetSchemaFunc func() (map[string]*pb.TableSchema, error)
type PluginClient ¶
type PluginClient struct {
Name string
Path string
Client *plugin.Client
Stub pluginshared.WrapperPluginClient
}
PluginClient:: the client object used by clients of the plugin
type PluginServer ¶
type PluginServer struct {
pb.UnimplementedWrapperPluginServer
// contains filtered or unexported fields
}
PluginServer :: server for a single plugin
func NewPluginServer ¶
func NewPluginServer(pluginName string, getSchemaFunc GetSchemaFunc, executeFunc ExecuteFunc) *PluginServer
func (PluginServer) Execute ¶
func (s PluginServer) Execute(req *pb.ExecuteRequest, stream pb.WrapperPlugin_ExecuteServer) error
func (PluginServer) GetSchema ¶
func (s PluginServer) GetSchema(_ *pb.GetSchemaRequest) (*pb.GetSchemaResponse, error)
func (PluginServer) Serve ¶
func (s PluginServer) Serve()
Click to show internal directories.
Click to hide internal directories.