db

Documentation

Index

• func LoadData(dbConn *PostgresConnection, schema string, table string) ([]map[string]interface{}, error)
• type GCSUploader
  • func NewGCSUploader(cfg struct{ ... }) (*GCSUploader, error)
  • func (uploader *GCSUploader) Upload(data []map[string]interface{}) error
• type PostgresConnection
  • func NewPostgresConnection(cfg config.PostgresConfig) (*PostgresConnection, error)
  • func (pc *PostgresConnection) Close(ctx context.Context)

Functions

func LoadData

func LoadData(dbConn *PostgresConnection, schema string, table string) ([]map[string]interface{}, error)

Types

type GCSUploader

type GCSUploader struct {
	// contains filtered or unexported fields
}

func NewGCSUploader

func NewGCSUploader(cfg struct {
	ProjectID       string
	BucketName      string
	CredentialsFile string
}) (*GCSUploader, error)

func (*GCSUploader) Upload

func (uploader *GCSUploader) Upload(data []map[string]interface{}) error

type PostgresConnection

type PostgresConnection struct {
	Pool *pgxpool.Pool
}

func NewPostgresConnection

func NewPostgresConnection(cfg config.PostgresConfig) (*PostgresConnection, error)

func (*PostgresConnection) Close

func (pc *PostgresConnection) Close(ctx context.Context)