Documentation ¶
Index ¶
- func New(ctx context.Context, logger zerolog.Logger, spec specs.Destination) (destination.Client, error)
- type Client
- func (c *Client) Close(ctx context.Context) error
- func (*Client) DeleteStale(ctx context.Context, tables schema.Tables, sourceName string, ...) error
- func (c *Client) Metrics() destination.Metrics
- func (c *Client) Migrate(ctx context.Context, tables schema.Tables) error
- func (c *Client) Read(tx context.Context, table *schema.Table, sourceName string, res chan<- []any) error
- func (*Client) TransformBool(v *schema.Bool) any
- func (*Client) TransformBytea(v *schema.Bytea) any
- func (*Client) TransformCIDR(v *schema.CIDR) any
- func (*Client) TransformCIDRArray(v *schema.CIDRArray) any
- func (*Client) TransformFloat8(v *schema.Float8) any
- func (*Client) TransformInet(v *schema.Inet) any
- func (*Client) TransformInetArray(v *schema.InetArray) any
- func (*Client) TransformInt8(v *schema.Int8) any
- func (*Client) TransformInt8Array(v *schema.Int8Array) any
- func (*Client) TransformJSON(v *schema.JSON) any
- func (*Client) TransformMacaddr(v *schema.Macaddr) any
- func (*Client) TransformMacaddrArray(v *schema.MacaddrArray) any
- func (*Client) TransformText(v *schema.Text) any
- func (*Client) TransformTextArray(v *schema.TextArray) any
- func (*Client) TransformTimestamptz(v *schema.Timestamptz) any
- func (*Client) TransformUUID(v *schema.UUID) any
- func (*Client) TransformUUIDArray(v *schema.UUIDArray) any
- func (c *Client) Write(ctx context.Context, tables schema.Tables, ...) error
- type Spec
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct { destination.UnimplementedManagedWriter destination.DefaultReverseTransformer // contains filtered or unexported fields }
func (*Client) DeleteStale ¶
func (*Client) Metrics ¶
func (c *Client) Metrics() destination.Metrics
func (*Client) TransformMacaddrArray ¶
func (*Client) TransformMacaddrArray(v *schema.MacaddrArray) any
func (*Client) TransformTimestamptz ¶
func (*Client) TransformTimestamptz(v *schema.Timestamptz) any
func (*Client) Write ¶
func (c *Client) Write(ctx context.Context, tables schema.Tables, res <-chan *destination.ClientResource) error
Click to show internal directories.
Click to hide internal directories.