destination

package

v0.13.0 Latest Latest Go to latest Published: Jun 3, 2025 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation ¶

Index ¶

type Config
- func (c *Config) TableFunction() (f TableFn, err error)
- func (c *Config) Validate(ctx context.Context) error
type TableFn

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶ added in v0.6.0

type Config struct {
	sdk.DefaultDestinationMiddleware

	// URL is the connection string for the Postgres database.
	URL string `json:"url" validate:"required"`
	// Table is used as the target table into which records are inserted.
	Table string `json:"table" default:"{{ index .Metadata \"opencdc.collection\" }}"`
	// Key represents the column name for the key used to identify and update existing rows.
	Key string `json:"key"`
}

func (*Config) TableFunction ¶ added in v0.7.0

func (c *Config) TableFunction() (f TableFn, err error)

TableFunction returns a function that determines the table for each record individually. The function might be returning a static table name. If the table is neither static nor a template, an error is returned.

func (*Config) Validate ¶ added in v0.11.0

func (c *Config) Validate(ctx context.Context) error

type TableFn ¶ added in v0.7.0

type TableFn func(opencdc.Record) (string, error)

Source Files ¶

View all Source files

config.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL