db

Documentation

Index

• func ConnectPool(ctx context.Context, host, port, user, password, dbname string, ...) (*pgxpool.Pool, error)
• func DataConsumer(ctx context.Context, pool *pgxpool.Pool, tableName string, columns []string, ...)
• func DataProducer(ctx context.Context, pool *pgxpool.Pool, tableName string, ...)
• func FetchColumns(ctx context.Context, pool *pgxpool.Pool, tableName string) ([]string, error)

Functions

func ConnectPool

func ConnectPool(ctx context.Context, host, port, user, password, dbname string, isUnixSocket bool) (*pgxpool.Pool, error)

func DataConsumer

func DataConsumer(ctx context.Context, pool *pgxpool.Pool, tableName string, columns []string, dataChan <-chan []interface{}, wg *sync.WaitGroup)

DataConsumer receives data from a channel and writes it to the target database.

func DataProducer

func DataProducer(ctx context.Context, pool *pgxpool.Pool, tableName string, dataChan chan<- []interface{}, wg *sync.WaitGroup)

DataProducer fetches data from the specified table and sends it to a channel.

func FetchColumns

func FetchColumns(ctx context.Context, pool *pgxpool.Pool, tableName string) ([]string, error)

FetchColumns function fetches column names for the given table from the source database.