grpc

package
v0.2.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 18, 2021 License: MPL-2.0 Imports: 6 Imported by: 3

Documentation

Index

Constants

View Source
const (
	IPv4 = "IPv4"
	IPv6 = "IPv6"
)

Variables

This section is empty.

Functions

func QualEquals added in v0.2.4

func QualEquals(left *proto.Qual, right *proto.Qual) bool

func QualMapToString

func QualMapToString(qualMap map[string]*proto.Quals) interface{}

func QualToString added in v0.2.4

func QualToString(q *proto.Qual) string

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, getSchemaFunc GetSchemaFunc, executeFunc ExecuteFunc, setConnectionConfigFunc SetConnectionConfigFunc) *PluginServer

func (PluginServer) Execute

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

type SetConnectionConfigFunc func(string, string) error

Directories

Path Synopsis
Package shared contains shared data between the host and plugins.
Package shared contains shared data between the host and plugins.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL