Versions in this module Expand all Collapse all v1 v1.11.0 Apr 21, 2026 Changes in this version + const OperationTypeCloseStatement + const OperationTypeCreateSession + const OperationTypeDeleteSession + const OperationTypeExecuteStatement + const OperationTypeUnspecified + const TagBytesDownloaded + const TagChunkCount + const TagChunkInitialLatencyMs + const TagChunkSlowestLatencyMs + const TagChunkSumLatencyMs + const TagChunkTotalPresent + const TagOperationType + func ReleaseForConnection(host string) + type ChunkDetails struct + InitialChunkLatencyMs int64 + SlowestChunkLatencyMs int64 + SumChunksDownloadTimeMs int64 + TotalChunksIterated int32 + TotalChunksPresent int32 + type DriverConnectionParameters struct + AuthFlow string + AuthMech string + AuthScope string + EnableArrow bool + EnableDirectResults bool + EnableMetricViewMeta bool + HTTPPath string + HostInfo *HostDetails + Mode string + QueryTags string + SocketTimeout int64 + UseCFProxy bool + UseProxy bool + UseSystemProxy bool + type DriverErrorInfo struct + ErrorName string + StackTrace string + type DriverSystemConfiguration struct + CharSetEncoding string + ClientAppName string + DriverName string + DriverVersion string + LocaleName string + OSArch string + OSName string + OSVersion string + ProcessName string + RuntimeName string + RuntimeVendor string + RuntimeVersion string + type FrontendLogContext struct + ClientContext *TelemetryClientContext + type FrontendLogEntry struct + SQLDriverLog *TelemetryEvent + type HostDetails struct + HostURL string + Port int32 + ProxyAuthType string + type Interceptor struct + func InitializeForConnection(ctx context.Context, opts TelemetryInitOptions) *Interceptor + func (i *Interceptor) AddTag(ctx context.Context, key string, value interface{}) + func (i *Interceptor) AfterExecute(ctx context.Context, err error) + func (i *Interceptor) BeforeExecute(ctx context.Context, sessionID string, statementID string) context.Context + func (i *Interceptor) BeforeExecuteWithTime(ctx context.Context, sessionID string, statementID string, startTime time.Time) context.Context + func (i *Interceptor) Close(ctx context.Context) error + func (i *Interceptor) CompleteStatement(ctx context.Context, statementID string, failed bool) + func (i *Interceptor) FinalizeLatency(ctx context.Context) + func (i *Interceptor) RecordOperation(ctx context.Context, sessionID string, statementID string, ...) + type OperationDetail struct + IsInternalCall bool + NOperationStatusCalls int32 + OperationStatusLatencyMs int64 + OperationType string + type ResultLatency struct + ResultSetConsumptionLatencyMs int64 + ResultSetReadyLatencyMs int64 + type SQLExecutionEvent struct + ChunkDetails *ChunkDetails + ChunkID int64 + ExecutionResult string + IsCompressed bool + JavaUsesPatchedArrow bool + OperationDetail *OperationDetail + ResultLatency *ResultLatency + RetryCount int64 + StatementType string + type TelemetryClientContext struct + ClientType string + ClientVersion string + type TelemetryEvent struct + AuthType string + DriverConnectionParameters *DriverConnectionParameters + ErrorInfo *DriverErrorInfo + OperationLatencyMs int64 + SQLOperation *SQLExecutionEvent + SQLStatementID string + SessionID string + SystemConfiguration *DriverSystemConfiguration + VolumeOperation *VolumeOperationEvent + type TelemetryFrontendLog struct + Context *FrontendLogContext + Entry *FrontendLogEntry + FrontendLogEventID string + WorkspaceID int64 + type TelemetryInitOptions struct + BatchSize int + DriverVersion string + EnableTelemetry config.ConfigValue[bool] + FlushInterval time.Duration + HTTPClient *http.Client + Host string + RetryCount int + RetryDelay time.Duration + type TelemetryRequest struct + Items []string + ProtoLogs []string + UploadTime int64 + type TelemetryResponse struct + Errors []string + NumProtoSuccess int + NumRealtimeSuccess int + NumSuccess int + type VolumeOperationEvent struct + LocalFile string + VolumeOperationType string + VolumePath string v1.10.0 Feb 19, 2026 Changes in this version + const TagCompressionEnabled + const TagDriverOS + const TagDriverRuntime + const TagDriverVersion + const TagErrorCode + const TagErrorType + const TagFeatureCloudFetch + const TagFeatureDirectResults + const TagFeatureLZ4 + const TagPollCount + const TagPollLatency + const TagResultBytesDownloaded + const TagResultChunkCount + const TagResultFormat + const TagServerAddress + const TagSessionID + const TagStatementID + const TagWorkspaceID + var ErrCircuitOpen = errors.New("circuit breaker is open") + type Config struct + BatchSize int + CircuitBreakerEnabled bool + CircuitBreakerThreshold int + CircuitBreakerTimeout time.Duration + EnableTelemetry config.ConfigValue[bool] + Enabled bool + FlushInterval time.Duration + MaxRetries int + RetryDelay time.Duration + func DefaultConfig() *Config + func ParseTelemetryConfig(params map[string]string) *Config
Go to main page