snowflake

Documentation

Index

• Constants
• func ColumnsWithDataTypes(columns model.TableSchema, prefix string) string
• func WithConfig(h *Snowflake, config *config.Config)
• type Credentials
• type Snowflake
  • func New() *Snowflake
  • func (sf *Snowflake) AddColumns(tableName string, columnsInfo []warehouseutils.ColumnInfo) (err error)
  • func (*Snowflake) AlterColumn(_, _, _ string) (model.AlterTableResponse, error)
  • func (sf *Snowflake) Cleanup()
  • func (sf *Snowflake) Connect(warehouse model.Warehouse) (client.Client, error)
  • func (*Snowflake) CrashRecover()
  • func (sf *Snowflake) CreateSchema() (err error)
  • func (sf *Snowflake) CreateTable(tableName string, columnMap model.TableSchema) (err error)
  • func (sf *Snowflake) DeleteBy(tableNames []string, params warehouseutils.DeleteByParams) (err error)
  • func (sf *Snowflake) DownloadIdentityRules(gzWriter *misc.GZipWriter) (err error)
  • func (sf *Snowflake) DropTable(tableName string) (err error)
  • func (*Snowflake) ErrorMappings() []model.JobError
  • func (sf *Snowflake) FetchSchema(model.Warehouse) (model.Schema, model.Schema, error)
  • func (sf *Snowflake) GetTotalCountInTable(ctx context.Context, tableName string) (int64, error)
  • func (sf *Snowflake) IsEmpty(warehouse model.Warehouse) (empty bool, err error)
  • func (sf *Snowflake) LoadIdentityMappingsTable() (err error)
  • func (sf *Snowflake) LoadIdentityMergeRulesTable() (err error)
  • func (sf *Snowflake) LoadTable(ctx context.Context, tableName string) error
  • func (sf *Snowflake) LoadTestTable(location, tableName string, _ map[string]interface{}, _ string) (err error)
  • func (sf *Snowflake) LoadUserTables(ctx context.Context) map[string]error
  • func (sf *Snowflake) SetConnectionTimeout(timeout time.Duration)
  • func (sf *Snowflake) Setup(warehouse model.Warehouse, uploader warehouseutils.Uploader) (err error)
  • func (sf *Snowflake) TestConnection(ctx context.Context, _ model.Warehouse) error

Constants

const (
	StorageIntegration = "storageIntegration"
	Account            = "account"
	Warehouse          = "warehouse"
	Database           = "database"
	User               = "user"
	Role               = "role"
	Password           = "password"
	Application        = "Rudderstack_Warehouse"
)

String constants for snowflake destination config

Functions

func ColumnsWithDataTypes

func ColumnsWithDataTypes(columns model.TableSchema, prefix string) string

func WithConfig

func WithConfig(h *Snowflake, config *config.Config)

Types

type Credentials

type Credentials struct {
	Account   string
	Warehouse string
	Database  string
	User      string
	Role      string
	Password  string
	// contains filtered or unexported fields
}

type Snowflake

type Snowflake struct {
	DB             *sqlmiddleware.DB
	Namespace      string
	CloudProvider  string
	ObjectStorage  string
	Warehouse      model.Warehouse
	Uploader       warehouseutils.Uploader
	ConnectTimeout time.Duration
	Logger         logger.Logger

	SlowQueryThreshold time.Duration

	EnableDeleteByJobs bool
	// contains filtered or unexported fields
}

func New

func New() *Snowflake

func (*Snowflake) AddColumns

func (sf *Snowflake) AddColumns(tableName string, columnsInfo []warehouseutils.ColumnInfo) (err error)

func (*Snowflake) AlterColumn

func (*Snowflake) AlterColumn(_, _, _ string) (model.AlterTableResponse, error)

func (*Snowflake) Cleanup

func (sf *Snowflake) Cleanup()

func (*Snowflake) Connect

func (sf *Snowflake) Connect(warehouse model.Warehouse) (client.Client, error)

func (*Snowflake) CrashRecover

func (*Snowflake) CrashRecover()

func (*Snowflake) CreateSchema

func (sf *Snowflake) CreateSchema() (err error)

func (*Snowflake) CreateTable

func (sf *Snowflake) CreateTable(tableName string, columnMap model.TableSchema) (err error)

func (*Snowflake) DeleteBy

func (sf *Snowflake) DeleteBy(tableNames []string, params warehouseutils.DeleteByParams) (err error)

func (*Snowflake) DownloadIdentityRules

func (sf *Snowflake) DownloadIdentityRules(gzWriter *misc.GZipWriter) (err error)

DownloadIdentityRules gets distinct combinations of anonymous_id, user_id from tables in warehouse

func (*Snowflake) DropTable

func (sf *Snowflake) DropTable(tableName string) (err error)

func (*Snowflake) ErrorMappings

func (*Snowflake) ErrorMappings() []model.JobError

func (*Snowflake) FetchSchema

func (sf *Snowflake) FetchSchema(model.Warehouse) (model.Schema, model.Schema, error)

FetchSchema queries the snowflake database and returns the schema

func (*Snowflake) GetTotalCountInTable

func (sf *Snowflake) GetTotalCountInTable(ctx context.Context, tableName string) (int64, error)

func (*Snowflake) IsEmpty

func (sf *Snowflake) IsEmpty(warehouse model.Warehouse) (empty bool, err error)

func (*Snowflake) LoadIdentityMappingsTable

func (sf *Snowflake) LoadIdentityMappingsTable() (err error)

func (*Snowflake) LoadIdentityMergeRulesTable

func (sf *Snowflake) LoadIdentityMergeRulesTable() (err error)

func (*Snowflake) LoadTable

func (sf *Snowflake) LoadTable(ctx context.Context, tableName string) error

func (*Snowflake) LoadTestTable

func (sf *Snowflake) LoadTestTable(location, tableName string, _ map[string]interface{}, _ string) (err error)

func (*Snowflake) LoadUserTables

func (sf *Snowflake) LoadUserTables(ctx context.Context) map[string]error

func (*Snowflake) SetConnectionTimeout

func (sf *Snowflake) SetConnectionTimeout(timeout time.Duration)

func (*Snowflake) Setup

func (sf *Snowflake) Setup(warehouse model.Warehouse, uploader warehouseutils.Uploader) (err error)

func (*Snowflake) TestConnection

func (sf *Snowflake) TestConnection(ctx context.Context, _ model.Warehouse) error