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) 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
- type LogLevel
- type Spec
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) 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.
type Spec ¶
type Spec struct { ConnectionString string `json:"connection_string,omitempty"` PgxLogLevel LogLevel `json:"pgx_log_level,omitempty"` BatchSize int `json:"batch_size,omitempty"` BatchSizeBytes int `json:"batch_size_bytes,omitempty"` BatchTimeout configtype.Duration `json:"batch_timeout,omitempty"` CustomCQIDSalt string `json:"custom_cqid_salt,omitempty"` }
func (*Spec) SetDefaults ¶
func (s *Spec) SetDefaults()
Click to show internal directories.
Click to hide internal directories.