golake

package module

Go to main page

Versions in this module

v0

v0.9.3

May 31, 2026

Changes in this version

+ const LakeSessionIDHeader

+ const QueryResultFormatArrow

+ const QueryResultFormatJSON

type APIClientState

+ QuerySeq int64

type ColumnTypeOptions

+ func (opt *ColumnTypeOptions) SetBinaryOutputFormat(v string)

+ func (opt *ColumnTypeOptions) SetHTTPJSONResultMode(v string)

type Config

+ LoginEnabled bool

+ QueryResultFormat string

+ UserAgent string

+ type LoginRequest struct

+ Database string

+ Role string

+ Settings map[string]string

+ type LoginResponse struct

+ ServerMaxArrowResultVersion *int64

+ Version string

type QueryRequest

+ ArrowResultVersionMax *int64

type Settings

+ BinaryOutputFormat string

+ HTTPJSONResultMode string

v0.9.2

Apr 13, 2026

Changes in this version

+ const Authorization

+ const ContextKeyQueryID

+ const ContextUserAgentID

+ const DBSessionIDKey

+ const EMPTY_FIELD_AS

+ const LakeQueryIDHeader

+ const LakeQueryIDNode

+ const LakeQueryStickyNode

+ const LakeRouteHintHeader

+ const LakeTenantHeader

+ const LakeWarehouseHeader

+ const PURGE

+ const SFSessionUserKey

+ const SSL_MODE_DISABLE

+ const UserAgent

+ const WarehouseRoute

+ var ErrDoRequest = errors.New("DoRequestFailed")

+ var ErrNoLastInsertID = errors.New("no LastInsertId available")

+ var ErrNoRowsAffected = errors.New("no RowsAffected available")

+ var ErrPlaceholderCount = errors.New("lake: wrong placeholder count")

+ var ErrReadResponse = errors.New("ReadResponseFailed")

+ var LogKeys = [...]contextKey

+ var ProvisionWarehouseTimeout = "ProvisionWarehouseTimeout"

+ func Array(v interface{}) driver.Valuer

+ func DBCallerPrettyfier(frame *runtime.Frame) (string, string)

+ func Date(t time.Time) driver.Valuer

+ func Decimal128(v interface{}, s int32) driver.Valuer

+ func Decimal32(v interface{}, s int32) driver.Valuer

+ func Decimal64(v interface{}, s int32) driver.Valuer

+ func DeregisterTLSConfig(key string)

+ func IP(i net.IP) driver.Valuer

+ func Interval(t time.Duration) driver.Valuer

+ func IsAuthFailed(err error) bool

+ func IsNotFound(err error) bool

+ func IsProxyErr(err error) bool

+ func Map(v interface{}) driver.Valuer

+ func NewAPIError(hint string, status int, respBuf []byte) error

+ func NewAPIHttpClientFromConfig(cfg *Config) *http.Client

+ func RegisterTLSConfig(key string, config *tls.Config) error

+ func SetLogger(inLogger DBLogger)

+ func Tuple(v interface{}) driver.Valuer

+ func UInt64(u uint64) driver.Valuer

+ type APIClient struct

+ EmptyFieldAs string

+ MaxRowsInBuffer int64

+ MaxRowsPerPage int64

+ PresignedURLDisabled bool

+ QuerySeq int64

+ SessionID string

+ WaitTimeSeconds int64

+ func NewAPIClientFromConfig(cfg *Config) *APIClient

+ func (c *APIClient) CloseQuery(ctx context.Context, response *QueryResponse) error

+ func (c *APIClient) GetPresignedURL(ctx context.Context, stage *StageLocation) (*PresignedResponse, error)

+ func (c *APIClient) GetQueryID() string

+ func (c *APIClient) GetState() *APIClientState

+ func (c *APIClient) InsertWithStage(ctx context.Context, sql string, stage *StageLocation, ...) (*QueryResponse, error)

+ func (c *APIClient) KillQuery(ctx context.Context, response *QueryResponse) error

+ func (c *APIClient) Logout(ctx context.Context) error

+ func (c *APIClient) NeedKeepAlive() bool

+ func (c *APIClient) NeedSticky() bool

+ func (c *APIClient) NewDefaultCSVFormatOptions() map[string]string

+ func (c *APIClient) NewDefaultCopyOptions() map[string]string

+ func (c *APIClient) NextQuery()

+ func (c *APIClient) PollQuery(ctx context.Context, nextURI string) (*QueryResponse, error)

+ func (c *APIClient) PollUntilQueryEnd(ctx context.Context, resp *QueryResponse) (*QueryResponse, error)

+ func (c *APIClient) QuerySync(ctx context.Context, query string) (*QueryResponse, error)

+ func (c *APIClient) StartQuery(ctx context.Context, query string) (*QueryResponse, error)

+ func (c *APIClient) UploadToStage(ctx context.Context, stage *StageLocation, input *bufio.Reader, size int64) error

+ func (c *APIClient) UploadToStageByAPI(ctx context.Context, stage *StageLocation, input *bufio.Reader) error

+ func (c *APIClient) UploadToStageByPresignURL(ctx context.Context, stage *StageLocation, input *bufio.Reader, size int64) error

+ func (c *APIClient) Verify(ctx context.Context) error

+ func (c *APIClient) WithState(state *APIClientState) *APIClient

+ type APIClientState struct

+ Cookies map[string]*http.Cookie

+ NodeID string

+ RouteHint string

+ SessionID string

+ SessionState string

+ type APIError struct

+ Hint string

+ RespBody APIErrorResponseBody

+ RespText string

+ StatusCode int

+ func (e APIError) Error() string

+ type APIErrorResponseBody struct

+ Error string

+ Message string

+ func RespBody(err error) APIErrorResponseBody

+ type AccessTokenLoader interface

+ LoadAccessToken func(ctx context.Context, forceRotate bool) (string, error)

+ type AuthMethod string

+ const AuthMethodAccessToken

+ const AuthMethodUserPassword

+ type Batch interface

+ AppendToFile func(v []driver.Value) error

+ BatchInsert func() error

+ type BatchStmt struct

+ func PrepareBatch(query string) (stmt *BatchStmt, err error)

+ func (stmt *BatchStmt) ExecBatch(ctx context.Context, conn *sql.Conn, rows [][]driver.Value) (result driver.Result, err error)

+ type ColumnType interface

+ DatabaseTypeName func() string

+ Desc func() *TypeDesc

+ Length func() (int64, bool)

+ Nullable func() (bool, bool)

+ Parse func(s string) (driver.Value, error)

+ PrecisionScale func() (int64, int64, bool)

+ ScanType func() reflect.Type

+ func NewColumnType(dbType string, opts *ColumnTypeOptions) (ColumnType, error)

+ type ColumnTypeOptions struct

+ func (opt *ColumnTypeOptions) SetFormatNullAsStr(v bool)

+ func (opt *ColumnTypeOptions) SetTimezone(v *time.Location)

+ type Config struct

+ AccessToken string

+ AccessTokenFile string

+ AccessTokenLoader AccessTokenLoader

+ Database string

+ Debug bool

+ EmptyFieldAs string

+ EnableOpenTelemetry bool

+ GzipCompression bool

+ Host string

+ Location *time.Location

+ MaxRowsInBuffer int64

+ MaxRowsPerPage int64

+ Params map[string]string

+ Password string

+ PresignedURLDisabled bool

+ Role string

+ SSLMode string

+ StatsTracker QueryStatsTracker

+ TLSConfig string

+ Tenant string

+ Timeout time.Duration

+ User string

+ WaitTimeSecs int64

+ Warehouse string

+ func NewConfig() *Config

+ func ParseDSN(dsn string) (*Config, error)

+ func (cfg *Config) AddParams(params map[string]string) (err error)

+ func (cfg *Config) Connect(ctx context.Context) (driver.Conn, error)

+ func (cfg *Config) Driver() driver.Driver

+ func (cfg *Config) FormatDSN() string

+ type ContextKey string

+ type ContextLogger interface

+ Infoln func(args ...interface{})

+ type DBLogger interface

+ Debugf func(format string, args ...interface{})

+ Error func(args ...interface{})

+ Info func(args ...interface{})

+ SetLogLevel func(level string) error

+ SetOutput func(output io.Writer)

+ WithContext func(ctx context.Context) ContextLogger

+ func CreateDefaultLogger() DBLogger

+ func GetLogger() DBLogger

+ type DataField struct

+ Name string

+ Type string

+ type DataParser interface

+ Nullable func() bool

+ Parse func(io.RuneScanner) (driver.Value, error)

+ Type func() reflect.Type

+ func NewDataParser(t *TypeDesc, opt *DataParserOptions) (DataParser, error)

+ type DataParserOptions struct

+ Location *time.Location

+ UseDBLocation bool

+ type FileAccessTokenData struct

+ AccessToken string

+ type FileAccessTokenLoader struct

+ func NewFileAccessTokenLoader(path string) *FileAccessTokenLoader

+ func (l *FileAccessTokenLoader) LoadAccessToken(ctx context.Context, forceRotate bool) (string, error)

+ type IgnoreDomainCookieJar struct

+ func NewIgnoreDomainCookieJar() *IgnoreDomainCookieJar

+ func (jar *IgnoreDomainCookieJar) Cookies(u *url.URL) []*http.Cookie

+ func (jar *IgnoreDomainCookieJar) SetCookies(_u *url.URL, cookies []*http.Cookie)

+ type LakeConn struct

+ func (dc *LakeConn) Begin() (driver.Tx, error)

+ func (dc *LakeConn) BeginTx(ctx context.Context, _ driver.TxOptions) (driver.Tx, error)

+ func (dc *LakeConn) Close() error

+ func (dc *LakeConn) ExecBatch(ctx context.Context, query string, rows [][]driver.Value) (driver.Result, error)

+ func (dc *LakeConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (dc *LakeConn) Ping(ctx context.Context) error

+ func (dc *LakeConn) Prepare(query string) (driver.Stmt, error)

+ func (dc *LakeConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (dc *LakeConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

+ type LakeDriver struct

+ func (d LakeDriver) Open(dsn string) (driver.Conn, error)

+ func (d LakeDriver) OpenConnector(dsn string) (driver.Connector, error)

+ func (d LakeDriver) OpenWithConfig(ctx context.Context, config *Config) (driver.Conn, error)

+ type PaginationConfig struct

+ MaxRowsInBuffer int64

+ MaxRowsPerPage int64

+ WaitTime int64

+ type PresignedResponse struct

+ Headers map[string]string

+ Method string

+ URL string

+ type QueryError struct

+ Code int

+ Detail string

+ Kind string

+ Message string

+ func (e *QueryError) Error() string

+ type QueryIDGenerator func() string

+ type QueryProgress struct

+ Bytes uint64

+ Rows uint64

+ type QueryRequest struct

+ Pagination *PaginationConfig

+ SQL string

+ Session *json.RawMessage

+ StageAttachment *StageAttachmentConfig

+ type QueryResponse struct

+ Data [][]*string

+ Error *QueryError

+ FinalURI string

+ ID string

+ KillURI string

+ NextURI string

+ NodeID string

+ Schema *[]DataField

+ Session *json.RawMessage

+ Settings *Settings

+ State string

+ Stats *QueryStats

+ StatsURI string

+ func (r *QueryResponse) ReadFinished() bool

+ type QueryStats struct

+ ResultProgress QueryProgress

+ RunningTimeMS float64

+ ScanProgress QueryProgress

+ WriteProgress QueryProgress

+ type QueryStatsTracker func(queryID string, stats *QueryStats)

+ type RequestType int

+ const Final

+ const Kill

+ const Page

+ const Query

+ type ServerInfo struct

+ Id string

+ StartTime string

+ type SessionState struct

+ Database string

+ NeedKeepAlive bool

+ NeedSticky bool

+ Role string

+ SecondaryRoles *[]string

+ Settings map[string]string

+ TxnState TxnState

+ type Settings struct

+ GeometryOutputFormat string

+ TimeZone string

+ type StageAttachmentConfig struct

+ CopyOptions map[string]string

+ FileFormatOptions map[string]string

+ Location string

+ type StageLocation struct

+ Name string

+ Path string

+ func (sl *StageLocation) String() string

+ type StaticAccessTokenLoader struct

+ AccessToken string

+ func NewStaticAccessTokenLoader(accessToken string) *StaticAccessTokenLoader

+ func (l *StaticAccessTokenLoader) LoadAccessToken(ctx context.Context, forceRotate bool) (string, error)

+ type TxnState string

+ const TxnStateActive

+ const TxnStateAutoCommit

+ type TypeDesc struct

+ Args []*TypeDesc

+ Name string

+ Nullable bool

+ func ParseTypeDesc(s string) (*TypeDesc, error)

+ func (desc *TypeDesc) Normalize() *TypeDesc

+ type VerifyResponse struct

+ Roles []string

+ Tenant string

+ User string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL