Documentation
¶
Index ¶
- Variables
- func Configure(_ context.Context, logger zerolog.Logger, spec []byte, ...) (plugin.Client, error)
- func Plugin() *plugin.Plugin
- func TestConnection(_ context.Context, _ zerolog.Logger, spec []byte) error
- type Client
- func (*Client) Close(_ context.Context) error
- func (c *Client) Logger() *zerolog.Logger
- func (*Client) Read(context.Context, *schema.Table, chan<- arrow.Record) error
- func (c *Client) Sync(ctx context.Context, options plugin.SyncOptions, ...) error
- func (c *Client) Tables(_ context.Context, options plugin.TableOptions) (schema.Tables, error)
- func (*Client) Write(context.Context, <-chan message.WriteMessage) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( Team = "example-team" Kind = "source" Name = "example" Version = "development" )
These variables are used by the `package` command and for checking usage limits.
Functions ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.