Documentation ¶
Index ¶
- func New(ctx context.Context, logger zerolog.Logger, s []byte, ...) (plugin.Client, error)
- type Client
- func (c *Client) Close(ctx context.Context) error
- func (c *Client) Read(ctx context.Context, table *schema.Table, res chan<- arrow.Record) error
- func (c *Client) Write(ctx context.Context, msgs <-chan message.WriteMessage) error
- func (c *Client) WriteTable(ctx context.Context, msgs <-chan *message.WriteInsert) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct { plugin.UnimplementedSource streamingbatchwriter.IgnoreMigrateTable streamingbatchwriter.UnimplementedDeleteStale streamingbatchwriter.UnimplementedDeleteRecords *filetypes.Client // contains filtered or unexported fields }
func (*Client) WriteTable ¶
Click to show internal directories.
Click to hide internal directories.