snowflake

package

v0.1.0 Latest Latest Go to latest Published: Mar 5, 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
}

var (
	Sfclient *Client
)

func GetClient() (*Client, error)

func NewClient(_ context.Context, config *ClientConfig) (*Client, error)

func (c *Client) DeleteFilesFromStage(ctx context.Context,
	roleName, databaseName, schemaName, stageName string, files []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

type ClientConfig struct {
	gosnowflake.Config
}

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