sourcerer

Documentation

Index

• func PutColumnsOnTables(ctx context.Context, ts shared.SourceTables, dbc DbConn) error
• type BqConn
  • func (bqc *BqConn) ConnectToDb(ctx context.Context) (err error)
  • func (bqc *BqConn) GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)
  • func (bqc *BqConn) GetSourceTables(ctx context.Context) (shared.SourceTables, error)
• type DbConn
  • func GetConn(cd shared.ConnectionDetails) (DbConn, error)
• type DbxConn
  • func (dbxc *DbxConn) ConnectToDb(ctx context.Context) (err error)
  • func (dbxc *DbxConn) GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)
  • func (dbxc *DbxConn) GetSourceTables(ctx context.Context) (shared.SourceTables, error)
• type DuckConn
  • func (dc *DuckConn) ConnectToDb(ctx context.Context) (err error)
  • func (dc *DuckConn) GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)
  • func (dc *DuckConn) GetSourceTables(ctx context.Context) (shared.SourceTables, error)
• type PgConn
  • func (pgc *PgConn) ConnectToDb(ctx context.Context) (err error)
  • func (pgc *PgConn) GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)
  • func (pgc *PgConn) GetSourceTables(ctx context.Context) (shared.SourceTables, error)
• type SfConn
  • func (sfc *SfConn) ConnectToDb(ctx context.Context) (err error)
  • func (sfc *SfConn) GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)
  • func (sfc *SfConn) GetSourceTables(ctx context.Context) (shared.SourceTables, error)

Functions

func PutColumnsOnTables

func PutColumnsOnTables(ctx context.Context, ts shared.SourceTables, dbc DbConn) error

Types

type BqConn

type BqConn struct {
	Bq      *bigquery.Client
	Cancel  context.CancelFunc
	Project string
	Dataset string
}

func (*BqConn) ConnectToDb

func (bqc *BqConn) ConnectToDb(ctx context.Context) (err error)

func (*BqConn) GetColumns

func (bqc *BqConn) GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)

func (*BqConn) GetSourceTables

func (bqc *BqConn) GetSourceTables(ctx context.Context) (shared.SourceTables, error)

type DbConn

type DbConn interface {
	ConnectToDb(ctx context.Context) error
	GetSourceTables(ctx context.Context) (shared.SourceTables, error)
	GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)
}

func GetConn

func GetConn(cd shared.ConnectionDetails) (DbConn, error)

type DbxConn

type DbxConn struct {
	Db       *sql.DB
	Cancel   context.CancelFunc
	Username string
	Token    string
	HttpPath string
	Host     string
	Port     int
	Catalog  string
	Schema   string
}

func (*DbxConn) ConnectToDb

func (dbxc *DbxConn) ConnectToDb(ctx context.Context) (err error)

func (*DbxConn) GetColumns

func (dbxc *DbxConn) GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)

func (*DbxConn) GetSourceTables

func (dbxc *DbxConn) GetSourceTables(ctx context.Context) (shared.SourceTables, error)

type DuckConn

type DuckConn struct {
	Db       *sql.DB
	Cancel   context.CancelFunc
	Path     string
	Database string
	Schema   string
}

func (*DuckConn) ConnectToDb

func (dc *DuckConn) ConnectToDb(ctx context.Context) (err error)

func (*DuckConn) GetColumns

func (dc *DuckConn) GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)

func (*DuckConn) GetSourceTables

func (dc *DuckConn) GetSourceTables(ctx context.Context) (shared.SourceTables, error)

type PgConn

type PgConn struct {
	Db       *sql.DB
	Cancel   context.CancelFunc
	Host     string
	Username string
	Password string
	Database string
	Schema   string
	SslMode  string
	Port     int
}

func (*PgConn) ConnectToDb

func (pgc *PgConn) ConnectToDb(ctx context.Context) (err error)

func (*PgConn) GetColumns

func (pgc *PgConn) GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)

func (*PgConn) GetSourceTables

func (pgc *PgConn) GetSourceTables(ctx context.Context) (shared.SourceTables, error)

type SfConn

type SfConn struct {
	Db       *sql.DB
	Cancel   context.CancelFunc
	Account  string
	Username string
	Database string
	Schema   string
}

func (*SfConn) ConnectToDb

func (sfc *SfConn) ConnectToDb(ctx context.Context) (err error)

func (*SfConn) GetColumns

func (sfc *SfConn) GetColumns(ctx context.Context, t shared.SourceTable) ([]shared.Column, error)

func (*SfConn) GetSourceTables

func (sfc *SfConn) GetSourceTables(ctx context.Context) (shared.SourceTables, error)