snowflake

type DbDesc struct {
	Name    string `db:"name" json:"name"`
	Origin  string `db:"origin" json:"origin"`
	Owner   string `db:"owner" json:"owner"`
	Comment string `db:"comment" json:"comment"`
	Kind    string `db:"kind" json:"kind"`
}

type ShareDesc struct {
	Name              string         `db:"name" json:"name"`
	Kind              string         `db:"kind" json:"kind"`
	OwnerAccount      string         `db:"owner_account" json:"owner_account"`
	DatabaseName      string         `db:"database_name" json:"database_name"`
	To                string         `db:"to" json:"to"`
	Owner             string         `db:"owner" json:"owner"`
	Comment           string         `db:"comment" json:"comment"`
	ListingGlobalName string         `db:"listing_global_name" json:"listing_global_name"`
	Objects           []*ShareObject `json:"objects"`
}

type ShareObject struct {
	Kind     string    `db:"kind" json:"kind"`
	Name     string    `db:"name" json:"name"`
	SharedOn time.Time `db:"shared_on" json:"shared_on"`
}

type ShowStreamsRow struct {
	// CreatedOn is the timestamp when the stream was created
	CreatedOn string `db:"created_on"`
	// Name is the name of the stream
	Name string `db:"name"`
	// DatabaseName is the database containing the stream
	DatabaseName string `db:"database_name"`
	// SchemaName is the schema containing the stream
	SchemaName string `db:"schema_name"`
	// Owner is the owner of the stream
	Owner string `db:"owner"`
	// Comment is the comment/description for the stream
	Comment string `db:"comment"`
	// TableName is the name of the source table the stream tracks
	TableName string `db:"table_name"`
	// SourceType is the type of source object (Table, View, etc.)
	SourceType string `db:"source_type"`
	// BaseTables lists the base tables the stream tracks
	BaseTables string `db:"base_tables"`
	// Type is the stream type (DELTA, etc.)
	Type string `db:"type"`
	// Stale indicates whether the stream is stale (true/false)
	Stale string `db:"stale"`
	// Mode is the stream mode: DEFAULT (standard/delta), APPEND_ONLY, or INSERT_ONLY
	Mode string `db:"mode"`
	// StaleAfter is the timestamp when the stream becomes stale
	StaleAfter string `db:"stale_after"`
	// InvalidReason provides the reason if the stream is invalid
	InvalidReason string `db:"invalid_reason"`
	// OwnerRoleType is the type of owner role
	OwnerRoleType string `db:"owner_role_type"`
}

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

type SnowflakeScrapperConf struct {
	dwhexecsnowflake.SnowflakeConf
	NoGetDll       bool
	AccountUsageDb *string
}