Versions in this module Expand all Collapse all v0 v0.0.1 Oct 9, 2023 Changes in this version + func New(ctx context.Context, logger zerolog.Logger, specBytes []byte, ...) (plugin.Client, error) + type Client struct + 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 int + const LogLevelDebug + const LogLevelError + const LogLevelInfo + const LogLevelTrace + const LogLevelWarn + func (r *LogLevel) MarshalJSON() ([]byte, error) + func (r *LogLevel) String() string + func (r *LogLevel) UnmarshalJSON(data []byte) (err error) + type Spec struct + BatchSize int + BatchSizeBytes int + BatchTimeout configtype.Duration + ConnectionString string + CustomCQIDSalt string + PgxLogLevel LogLevel + func (s *Spec) SetDefaults()