config

Documentation

Index

• func Columns(ctx context.Context, session *sink.Session, db *sql.DB, table string, ...) ([]sink.Column, error)
• func Dialect(ctx context.Context, db *sql.DB, opts ...option.Option) (*info.Dialect, error)
• func LoadSession(dialect *info.Dialect) io.Session
• func Session(ctx context.Context, db *sql.DB, options ...option.Option) (*sink.Session, error)
• type Config
  • func New(tableName string) *Config
  • func (c *Config) ApplyOption(ctx context.Context, db *sql.DB, options ...option.Option) error

Functions

func Columns

func Columns(ctx context.Context, session *sink.Session, db *sql.DB, table string, options ...option.Option) ([]sink.Column, error)

Columns returns table columns

func Dialect

func Dialect(ctx context.Context, db *sql.DB, opts ...option.Option) (*info.Dialect, error)

Dialect returns a dialect

func LoadSession

func LoadSession(dialect *info.Dialect) io.Session

LoadSession Returns new session for specified Dialect

func Session

func Session(ctx context.Context, db *sql.DB, options ...option.Option) (*sink.Session, error)

Session retrieve basic data from the database connection

Types

type Config

type Config struct {
	TableName string
	TagName   string
	Identity  string
	Columns   io.Columns
	Dialect   *info.Dialect
	Mapper    io.ColumnMapper
	Builder   io.Builder
}

Config represents general config

func New

func New(tableName string) *Config

New creates a config

func (*Config) ApplyOption

func (c *Config) ApplyOption(ctx context.Context, db *sql.DB, options ...option.Option) error

ApplyOption applied config option