warehouse

Documentation

Index

• type Client
• type Record
• type Records
• type SnowflakeClient
  • func NewSnowflake() *SnowflakeClient
  • func (sc *SnowflakeClient) Connect(sfc SnowflakeCredentials) error
  • func (sc *SnowflakeClient) Run(query string) (Records, error)
• type SnowflakeCredentials
  • func (sfc SnowflakeCredentials) ConnString() (string, error)

Types

type Client

type Client interface {
	// TODO this is a convenient but not ideal interface. It pulls all the
	// results back into memory and it's better to stream!
	Run(string) (Records, error)
}

type Record

type Record map[string]interface{}

type Records

type Records []Record

type SnowflakeClient

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

func NewSnowflake

func NewSnowflake() *SnowflakeClient

func (*SnowflakeClient) Connect

func (sc *SnowflakeClient) Connect(sfc SnowflakeCredentials) error

func (*SnowflakeClient) Run

func (sc *SnowflakeClient) Run(query string) (Records, error)

type SnowflakeCredentials

type SnowflakeCredentials struct {
	AccountId string `json:"account_id"`
	User      string `json:"user"`
	Password  string `json:"password"`
	Database  string `json:"database"`
	Schema    string `json:"schema"`
	Warehouse string `json:"warehouse"`
}

func (SnowflakeCredentials) ConnString

func (sfc SnowflakeCredentials) ConnString() (string, error)