snowflake

package

v0.6.1 Latest Latest Go to latest Published: May 7, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

func GetClient(ctx context.Context) (*Client, error)

func NewClient(ctx context.Context) (*Client, error)

func (c *Client) DeleteFilesFromStage(ctx context.Context,
	roleName, databaseName, schemaName, stageName string, files []string) error

func (c *Client) ExecuteQueryWithRole(ctx context.Context, warehouse, query, role string) error

func (c *Client) GetRole() string

func (c *Client) ListFilesFromStage(ctx context.Context, roleName, databaseName,
	schemaName, stageName string, resources any) error

func (c *Client) Ping(ctx context.Context) error

func (c *Client) Put(ctx context.Context, roleName, filePath, databaseName,
	schemaName, stageName, subpath string, resources any) error

Put facilitates uploading files to the internal stage resource

func (c *Client) QueryTableUsingRole(ctx context.Context, query, warehouseName, role string, resources any) error

type ClientConfig struct {
	gosnowflake.Config
}

var (
	SfConfig *ClientConfig
)

type UploadedFileStatus struct {
	Source string `db:"source"`
	Target string `db:"target"`
	Status string `db:"status"`
}