gosnowflake

package module

Go to main page

Versions in this module

v1

v1.6.17

Jul 20, 2022

v1.6.16

Jul 20, 2022

v1.6.15

Jul 20, 2022

v1.6.14

Jul 20, 2022

Changes in this version

type AuthType

+ const AuthTypeKMSJwt

v1.6.13

Jul 20, 2022

Changes in this version

+ const DateType

+ const ErrAsync

+ const ErrBindSerialization

+ const ErrBindUpload

+ const ErrCodeRegionOverlap

+ const ErrCommandNotRecognized

+ const ErrCompressionNotSupported

+ const ErrFailedToConvertToS3Client

+ const ErrFailedToDownloadFromStage

+ const ErrFailedToUploadToStage

+ const ErrFileNotExists

+ const ErrInternalNotMatchEncryptMaterial

+ const ErrInvalidStageFs

+ const ErrInvalidStageLocation

+ const ErrLocalPathNotDirectory

+ const ErrNoResultIDs

+ const ErrNotImplemented

+ const ErrQueryIDFormat

+ const ErrQueryIsRunning

+ const ErrQueryReportedError

+ const ErrQueryStatus

+ const QueryFailed

+ const QueryStatusComplete

+ const QueryStatusInProgress

+ const SFQueryAborted

+ const SFQueryAborting

+ const SFQueryBlocked

+ const SFQueryDisconnected

+ const SFQueryFailedWithError

+ const SFQueryFailedWithIncident

+ const SFQueryNoData

+ const SFQueryQueueRepairingWarehouse

+ const SFQueryQueued

+ const SFQueryRestarted

+ const SFQueryResumingWarehouse

+ const SFQueryRunning

+ const SFQuerySuccess

+ const SFSessionIDKey

+ const SFSessionUserKey

+ const TimeType

+ const TimestampLTZType

+ const TimestampNTZType

+ const TimestampTZType

+ var ErrInvalidRegion = &SnowflakeError

+ var ErrUnknownError = &SnowflakeError

+ var LogKeys = [...]contextKey

+ func Array(a interface{}, typ ...timezoneType) interface

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

+ func SetLogger(inLogger *SFLogger)

+ func WithArrowBatches(ctx context.Context) context.Context

+ func WithAsyncMode(ctx context.Context) context.Context

+ func WithDescribeOnly(ctx context.Context) context.Context

+ func WithFetchResultByID(ctx context.Context, queryID string) context.Context

+ func WithFileStream(ctx context.Context, reader io.Reader) context.Context

+ func WithFileTransferOptions(ctx context.Context, options *SnowflakeFileTransferOptions) context.Context

+ func WithHigherPrecision(ctx context.Context) context.Context

+ func WithMultiStatement(ctx context.Context, num int) (context.Context, error)

+ func WithQueryIDChan(ctx context.Context, c chan<- string) context.Context

+ func WithRequestID(ctx context.Context, requestID UUID) context.Context

+ func WithStreamDownloader(ctx context.Context) context.Context

+ type ArrowBatch struct

+ func (rb *ArrowBatch) Fetch() (*[]array.Record, error)

type AuthType

+ const AuthTypeTokenAccessor

type Config

+ AWSKMSKeyARN string

+ ClientIP net.IP

+ ClientTimeout time.Duration

+ DisableTelemetry bool

+ KeepSessionAlive bool

+ TokenAccessor TokenAccessor

+ Transporter http.RoundTripper

+ type Connector struct

+ func NewConnector(driver InternalSnowflakeDriver, config Config) Connector

+ func (t Connector) Connect(ctx context.Context) (driver.Conn, error)

+ func (t Connector) Driver() driver.Driver

+ type InternalClient interface

+ Get func(context.Context, *url.URL, map[string]string, time.Duration) (*http.Response, error)

+ Post func(context.Context, *url.URL, map[string]string, []byte, time.Duration, bool) (*http.Response, error)

+ type InternalSnowflakeDriver interface

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

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

+ type SFLogger interface

+ SetLogLevel func(level string) error

+ SetOutput func(output io.Writer)

+ WithContext func(ctx context.Context) *rlog.Entry

+ func CreateDefaultLogger() SFLogger

+ func GetLogger() SFLogger

+ type SnowflakeConnection interface

+ GetQueryStatus func(ctx context.Context, queryID string) (*SnowflakeQueryStatus, error)

type SnowflakeDriver

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

+ type SnowflakeFileTransferOptions struct

+ DisablePutOverwrite bool

+ MultiPartThreshold int64

+ RaisePutGetError bool

type SnowflakeParameter

+ ActivateVersion string

+ ExpiresAt string

+ IsExpired string

+ PartialRollout string

+ SetByControllingParameter string

+ type SnowflakeQueryStatus struct

+ EndTime int64

+ ErrorCode string

+ ErrorMessage string

+ ProducedRows int64

+ SQLText string

+ ScanBytes int64

+ StartTime int64

+ type SnowflakeResult interface

+ GetArrowBatches func() ([]*ArrowBatch, error)

+ GetQueryID func() string

+ GetStatus func() queryStatus

+ type TokenAccessor interface

+ GetTokens func() (token string, masterToken string, sessionID int64)

+ Lock func() error

+ SetTokens func(token string, masterToken string, sessionID int64)

+ Unlock func()

+ type UUID [16]byte

+ func NewUUID() UUID

+ func ParseUUID(str string) UUID

+ func (u UUID) String() string

v1.3.4

Jan 6, 2020

v1.3.3

Dec 3, 2019

v1.3.2

Sep 30, 2019

v1.3.1

Sep 16, 2019

Changes in this version

+ const ErrOCSPInvalidValidity

+ const ErrOCSPNoOCSPResponderURL

+ const ErrOCSPStatusRevoked

+ const ErrOCSPStatusUnknown

v1.3.0

Aug 26, 2019

Changes in this version

+ const ErrObjectNotExistOrAuthorized

+ const ErrRoleNotExist

type Config

+ ValidateDefaultParameters ConfigBool

+ type ConfigBool uint8

+ const ConfigBoolFalse

+ const ConfigBoolTrue

v1.2.0

Jul 1, 2019

Changes in this version

type Config

+ OCSPFailOpen OCSPFailOpenMode

+ type OCSPFailOpenMode int

+ const OCSPFailOpenFalse

+ const OCSPFailOpenTrue

v1.1.19

Jun 17, 2019

Changes in this version

+ const ErrCodeFailedToParseAuthenticator

+ type AuthType int

+ const AuthTypeExternalBrowser

+ const AuthTypeJwt

+ const AuthTypeOAuth

+ const AuthTypeOkta

+ const AuthTypeSnowflake

+ func (authType AuthType) String() string

type Config

+ OktaURL *url.URL

v1.1.18

Jun 3, 2019

Changes in this version

+ const ErrSessionGone

v1.1.17

Mar 23, 2019

v1.1.16

Jan 18, 2019

v1.1.15

Nov 27, 2018

Changes in this version

type SnowflakeParameter

+ Type string

+ Unknown string

v1.1.14

Oct 23, 2018

v1.1.13

Oct 9, 2018

v1.1.12

Sep 25, 2018

v1.1.11

Sep 6, 2018

Changes in this version

+ const ErrCodePrivateKeyParseError

+ var CustomJSONDecoderEnabled = false

+ var MaxChunkDownloadWorkers = 10

type Config

+ JWTExpireTimeout time.Duration

+ PrivateKey *rsa.PrivateKey

v1.1.10

Aug 14, 2018

Changes in this version

+ type SnowflakeParameter struct

+ Default string

+ Description string

+ Key string

+ Level string

+ ParameterComment string

+ SetByClass string

+ SetByThreadID string

+ SetByThreadName string

+ SetByUser string

+ SetInJob string

+ SetOn string

+ Value string

+ func ScanSnowflakeParameter(rows *sql.Rows) (*SnowflakeParameter, error)

v1.1.9

Jul 22, 2018

v1.1.8

Jun 13, 2018

v1.1.7

May 23, 2018

Changes in this version

+ const ErrFailedToHeartbeat

v1.1.6

Mar 8, 2018

v1.1.5

Feb 7, 2018

Changes in this version

+ const ErrFailedToGetExternalBrowserResponse

+ const ErrFailedToParseResponse

type Config

+ Token string

v1.1.4

Jan 25, 2018

v1.1.3

Jan 8, 2018

v1.1.2

Dec 28, 2017

v1.1.1

Dec 12, 2017

v1.1.0

Dec 1, 2017

Changes in this version

+ const ErrCodeFailedToConnect

+ const ErrCodeObjectNotExists

+ const ErrCodeServiceUnavailable

v1.0.0

Oct 25, 2017

Changes in this version

+ const ErrCodeEmptyAccountCode

+ const ErrCodeEmptyPasswordCode

+ const ErrCodeEmptyUsernameCode

+ const ErrCodeFailedToParseHost

+ const ErrCodeFailedToParsePort

+ const ErrCodeIdpConnectionError

+ const ErrCodeSSOURLNotMatch

+ const ErrFailedToAuth

+ const ErrFailedToAuthOKTA

+ const ErrFailedToAuthSAML

+ const ErrFailedToCancelQuery

+ const ErrFailedToCloseSession

+ const ErrFailedToConnect

+ const ErrFailedToGetChunk

+ const ErrFailedToGetSSO

+ const ErrFailedToPostQuery

+ const ErrFailedToRenewSession

+ const ErrInvalidBinaryHexForm

+ const ErrInvalidOffsetStr

+ const ErrInvalidTimestampTz

+ const ErrNoDefaultTransactionIsolationLevel

+ const ErrNoReadOnlyTransaction

+ const ErrServiceUnavailable

+ const SQLStateConnectionFailure

+ const SQLStateConnectionRejected

+ const SQLStateConnectionWasNotEstablished

+ const SQLStateFeatureNotSupported

+ const SQLStateInvalidDataTimeFormat

+ const SQLStateNumericValueOutOfRange

+ const SnowflakeGoDriverVersion

+ var DataTypeArray = []byte

+ var DataTypeBinary = []byte

+ var DataTypeBoolean = []byte

+ var DataTypeDate = []byte

+ var DataTypeFixed = []byte

+ var DataTypeObject = []byte

+ var DataTypeReal = []byte

+ var DataTypeText = []byte

+ var DataTypeTime = []byte

+ var DataTypeTimestampLtz = []byte

+ var DataTypeTimestampNtz = []byte

+ var DataTypeTimestampTz = []byte

+ var DataTypeVariant = []byte

+ var ErrEmptyAccount = &SnowflakeError

+ var ErrEmptyPassword = &SnowflakeError

+ var ErrEmptyUsername = &SnowflakeError

+ var SnowflakeTransport = &http.Transport

+ var SnowflakeTransportSerial = &http.Transport

+ var SnowflakeTransportTest = SnowflakeTransport

+ func DSN(cfg *Config) (dsn string, err error)

+ func Location(offset int) *time.Location

+ func LocationWithOffsetString(offsets string) (loc *time.Location, err error)

+ type Config struct

+ Account string

+ Application string

+ Authenticator string

+ Database string

+ Host string

+ InsecureMode bool

+ LoginTimeout time.Duration

+ Params map[string]*string

+ Passcode string

+ PasscodeInPassword bool

+ Password string

+ Port int

+ Protocol string

+ Region string

+ RequestTimeout time.Duration

+ Role string

+ Schema string

+ User string

+ Warehouse string

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

+ type SnowflakeDriver struct

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

+ type SnowflakeError struct

+ IncludeQueryID bool

+ Message string

+ MessageArgs []interface{}

+ Number int

+ QueryID string

+ SQLState string

+ func (se *SnowflakeError) Error() string

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