Documentation ¶
Index ¶
- func New(ctx context.Context, logger zerolog.Logger, specBytes []byte, ...) (plugin.Client, error)
- type Client
- func (c *Client) Close(ctx context.Context) error
- func (c *Client) DeleteRecordsBatch(ctx context.Context, messages message.WriteDeleteRecords) error
- func (c *Client) DeleteStaleBatch(ctx context.Context, messages message.WriteDeleteStales) error
- func (c *Client) InsertBatch(ctx context.Context, messages message.WriteInserts) error
- func (c *Client) MigrateTableBatch(ctx context.Context, messages message.WriteMigrateTables) error
- func (c *Client) PgToSchemaType(t string) arrow.DataType
- func (c *Client) Read(ctx context.Context, table *schema.Table, res chan<- arrow.Record) error
- func (c *Client) SchemaTypeToPg(t arrow.DataType) string
- func (c *Client) Write(ctx context.Context, res <-chan message.WriteMessage) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct { plugin.UnimplementedSource // contains filtered or unexported fields }
func (*Client) DeleteRecordsBatch ¶
func (*Client) DeleteStaleBatch ¶
DeleteStaleBatch deletes stale records from the destination table. It forms part of the writer.MixedBatchWriter interface.
func (*Client) InsertBatch ¶
InsertBatch inserts records into the destination table. It forms part of the writer.MixedBatchWriter interface.
func (*Client) MigrateTableBatch ¶
MigrateTableBatch migrates a table. It forms part of the writer.MixedBatchWriter interface.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.