Documentation
¶
Index ¶
- Constants
- func GetQualValue(v *proto.QualValue) interface{}
- func QualEquals(left *proto.Qual, right *proto.Qual) bool
- func QualMapToString(qualMap map[string]*proto.Quals) interface{}
- func QualToString(q *proto.Qual) string
- type ExecuteFunc
- type GetSchemaFunc
- type PluginClient
- type PluginServer
- func (s PluginServer) Execute(req *proto.ExecuteRequest, stream proto.WrapperPlugin_ExecuteServer) (err error)
- func (s PluginServer) GetSchema(_ *proto.GetSchemaRequest) (res *proto.GetSchemaResponse, err error)
- func (s PluginServer) Serve()
- func (s PluginServer) SetConnectionConfig(req *proto.SetConnectionConfigRequest) (res *proto.SetConnectionConfigResponse, err error)
- type SetConnectionConfigFunc
Constants ¶
View Source
const ( IPv4 = "IPv4" IPv6 = "IPv6" )
Variables ¶
This section is empty.
Functions ¶
func GetQualValue ¶ added in v0.2.9
func QualMapToString ¶
func QualToString ¶ added in v0.2.4
Types ¶
type ExecuteFunc ¶
type ExecuteFunc func(req *proto.ExecuteRequest, stream proto.WrapperPlugin_ExecuteServer) error
type GetSchemaFunc ¶
type GetSchemaFunc func() (map[string]*proto.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 {
proto.UnimplementedWrapperPluginServer
// contains filtered or unexported fields
}
PluginServer :: server for a single plugin
func NewPluginServer ¶
func NewPluginServer(pluginName string, setConnectionConfigFunc SetConnectionConfigFunc, getSchemaFunc GetSchemaFunc, executeFunc ExecuteFunc) *PluginServer
func (PluginServer) Execute ¶
func (s PluginServer) Execute(req *proto.ExecuteRequest, stream proto.WrapperPlugin_ExecuteServer) (err error)
func (PluginServer) GetSchema ¶
func (s PluginServer) GetSchema(_ *proto.GetSchemaRequest) (res *proto.GetSchemaResponse, err error)
func (PluginServer) Serve ¶
func (s PluginServer) Serve()
func (PluginServer) SetConnectionConfig ¶ added in v0.2.0
func (s PluginServer) SetConnectionConfig(req *proto.SetConnectionConfigRequest) (res *proto.SetConnectionConfigResponse, err error)
type SetConnectionConfigFunc ¶ added in v0.2.0
Click to show internal directories.
Click to hide internal directories.