snowflake

package

v0.1.21 Latest Latest Go to latest Published: Nov 5, 2025 License: MIT Imports: 10 Imported by: 0

Details

View Source

const TableName string = "EXECUTE_DOCUMENTS"

This section is empty.

This section is empty.

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

func NewSnowflake(dsn string, chunkSize int) (*Snowflake, error)

func (s *Snowflake) CreateViews(data execute.RootSchema) error

func (s *Snowflake) Prune() error

func (s *Snowflake) Upload(batch_date string, nextRecord func() (map[string]interface{}, error)) (int, error)