Documentation
¶
Overview ¶
Package flightwrap implements driver.PluginWrap: it turns a .so's raw registered source/sink factories into factories that serve the real driver over an in-process Arrow Flight server (internal/plugin/ flightserver) and hand back a Flight client adapter (internal/plugin) — the SAME contract a subprocess plugin speaks. A .so author's RegisterSource/RegisterSink code never changes; this package is only wired in by cmd/* right after driver.LoadPlugin's Init call.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Wrap ¶
type Wrap struct{}
Wrap is the driver.PluginWrap implementation. The zero value is ready to use.
func (Wrap) WrapSink ¶
func (Wrap) WrapSink(path string, real driver.SinkFactory) driver.SinkFactory
WrapSink returns a SinkFactory that builds the plugin's real sink, serves it over an in-process Flight server, and returns a Flight client adapter in its place.
func (Wrap) WrapSource ¶
func (Wrap) WrapSource(path string, real driver.SourceFactory) driver.SourceFactory
WrapSource returns a SourceFactory that builds the plugin's real source, serves it over an in-process Flight server, and returns a Flight client adapter in its place.
Source Files