redshift

Documentation

Index

• Constants
• type HandleT
  • func (rs *HandleT) CrashRecover(config warehouseutils.ConfigT) (err error)
  • func (rs *HandleT) Export() (err error)
  • func (rs *HandleT) MigrateSchema() (err error)
  • func (rs *HandleT) Process(config warehouseutils.ConfigT) (err error)
• type RedshiftCredentialsT
• type S3ManifestEntryT
• type S3ManifestT

Constants

const (
	AWSAccessKey        = "accessKey"
	AWSAccessSecret     = "accessKeyID"
	AWSBucketNameConfig = "bucketName"
	RSHost              = "host"
	RSPort              = "port"
	RSDbName            = "database"
	RSUserName          = "user"
	RSPassword          = "password"
)

String constants for redshift destination config

Types

type HandleT

type HandleT struct {
	DbHandle      *sql.DB
	Db            *sql.DB
	Namespace     string
	CurrentSchema map[string]map[string]string
	Warehouse     warehouseutils.WarehouseT
	Upload        warehouseutils.UploadT
}

func (*HandleT) CrashRecover

func (rs *HandleT) CrashRecover(config warehouseutils.ConfigT) (err error)

func (*HandleT) Export

func (rs *HandleT) Export() (err error)

func (*HandleT) MigrateSchema

func (rs *HandleT) MigrateSchema() (err error)

func (*HandleT) Process

func (rs *HandleT) Process(config warehouseutils.ConfigT) (err error)

type RedshiftCredentialsT

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

RedshiftCredentialsT ...

type S3ManifestEntryT

type S3ManifestEntryT struct {
	Url       string `json:"url"`
	Mandatory bool   `json:"mandatory"`
}

type S3ManifestT

type S3ManifestT struct {
	Entries []S3ManifestEntryT `json:"entries"`
}