sourcerer

package
v0.0.26 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 23, 2024 License: GPL-3.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PutColumnsOnTables added in v0.0.16 

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 added in v0.0.16 

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 added in v0.0.16 

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 added in v0.0.24 

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 added in v0.0.24 

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

func (*DbxConn) GetColumns added in v0.0.24 

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

func (*DbxConn) GetSourceTables added in v0.0.24 

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

type DuckConn added in v0.0.5 

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

func (*DuckConn) ConnectToDb added in v0.0.16 

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

func (*DuckConn) GetColumns added in v0.0.5 

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

func (*DuckConn) GetSourceTables added in v0.0.16 

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

type PgConn added in v0.0.22 

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 added in v0.0.22 

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

func (*PgConn) GetColumns added in v0.0.22 

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

func (*PgConn) GetSourceTables added in v0.0.22 

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 added in v0.0.16 

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 added in v0.0.16 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.