Documentation
¶
Index ¶
- Constants
- func ColumnsWithDataTypes(columns map[string]string, prefix string) string
- func Connect(cred SnowflakeCredentialsT) (*sql.DB, error)
- func Init()
- type HandleT
- func (sf *HandleT) AddColumn(tableName, columnName, columnType string) (err error)
- func (sf *HandleT) AlterColumn(_, _, _ string) (err error)
- func (sf *HandleT) Cleanup()
- func (sf *HandleT) Connect(warehouse warehouseutils.WarehouseT) (client.Client, error)
- func (sf *HandleT) CrashRecover(_ warehouseutils.WarehouseT) (err error)
- func (sf *HandleT) CreateSchema() (err error)
- func (sf *HandleT) CreateTable(tableName string, columnMap map[string]string) (err error)
- func (sf *HandleT) DownloadIdentityRules(gzWriter *misc.GZipWriter) (err error)
- func (sf *HandleT) DropTable(tableName string) (err error)
- func (sf *HandleT) FetchSchema(warehouse warehouseutils.WarehouseT) (schema warehouseutils.SchemaT, err error)
- func (sf *HandleT) GetTotalCountInTable(tableName string) (total int64, err error)
- func (sf *HandleT) IsEmpty(warehouse warehouseutils.WarehouseT) (empty bool, err error)
- func (sf *HandleT) LoadIdentityMappingsTable() (err error)
- func (sf *HandleT) LoadIdentityMergeRulesTable() (err error)
- func (sf *HandleT) LoadTable(tableName string) error
- func (sf *HandleT) LoadTestTable(location, tableName string, _ map[string]interface{}, _ string) (err error)
- func (sf *HandleT) LoadUserTables() map[string]error
- func (sf *HandleT) SetConnectionTimeout(timeout time.Duration)
- func (sf *HandleT) Setup(warehouse warehouseutils.WarehouseT, uploader warehouseutils.UploaderI) (err error)
- func (sf *HandleT) TestConnection(warehouse warehouseutils.WarehouseT) (err error)
- type OptionalCredsT
- type SnowflakeCredentialsT
Constants ¶
View Source
const ( AWSAccessKey = "accessKey" AWSAccessSecret = "accessKeyID" StorageIntegration = "storageIntegration" SFAccount = "account" SFWarehouse = "warehouse" SFDbName = "database" SFUserName = "user" SFPassword = "password" )
String constants for snowflake destination config
Variables ¶
This section is empty.
Functions ¶
func ColumnsWithDataTypes ¶ added in v0.1.10
Types ¶
type HandleT ¶
type HandleT struct { Db *sql.DB Namespace string CloudProvider string ObjectStorage string Warehouse warehouseutils.WarehouseT Uploader warehouseutils.UploaderI ConnectTimeout time.Duration }
func (*HandleT) AlterColumn ¶ added in v0.1.10
func (*HandleT) Connect ¶ added in v0.1.10
func (sf *HandleT) Connect(warehouse warehouseutils.WarehouseT) (client.Client, error)
func (*HandleT) CrashRecover ¶
func (sf *HandleT) CrashRecover(_ warehouseutils.WarehouseT) (err error)
func (*HandleT) CreateSchema ¶ added in v0.1.10
func (*HandleT) CreateTable ¶ added in v0.1.10
func (*HandleT) DownloadIdentityRules ¶ added in v0.1.10
func (sf *HandleT) DownloadIdentityRules(gzWriter *misc.GZipWriter) (err error)
DownloadIdentityRules gets distinct combinations of anonymous_id, user_id from tables in warehouse
func (*HandleT) FetchSchema ¶ added in v0.1.10
func (sf *HandleT) FetchSchema(warehouse warehouseutils.WarehouseT) (schema warehouseutils.SchemaT, err error)
FetchSchema queries snowflake and returns the schema assoiciated with provided namespace
func (*HandleT) GetTotalCountInTable ¶ added in v0.1.10
func (*HandleT) IsEmpty ¶ added in v0.1.10
func (sf *HandleT) IsEmpty(warehouse warehouseutils.WarehouseT) (empty bool, err error)
func (*HandleT) LoadIdentityMappingsTable ¶ added in v0.1.10
func (*HandleT) LoadIdentityMergeRulesTable ¶ added in v0.1.10
func (*HandleT) LoadTestTable ¶ added in v0.1.10
func (*HandleT) LoadUserTables ¶ added in v0.1.10
func (*HandleT) SetConnectionTimeout ¶ added in v0.1.10
func (*HandleT) Setup ¶ added in v0.1.10
func (sf *HandleT) Setup(warehouse warehouseutils.WarehouseT, uploader warehouseutils.UploaderI) (err error)
func (*HandleT) TestConnection ¶ added in v0.1.10
func (sf *HandleT) TestConnection(warehouse warehouseutils.WarehouseT) (err error)
type OptionalCredsT ¶
type OptionalCredsT struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.