destination

Documentation

Index

• Constants
• type Config
  • func (Config) Parameters() map[string]config.Parameter
  • func (c Config) TableFunction() (f TableFn, err error)
• type TableFn

Constants

const (
	ConfigKey   = "key"
	ConfigTable = "table"
	ConfigUrl   = "url"
)

Types

type Config

type Config struct {
	// 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) Parameters

func (Config) Parameters() map[string]config.Parameter

func (Config) TableFunction

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.

type TableFn

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