telemetry

package

Go to main page

Versions in this module

v1

v1.13.0

Jun 4, 2026

v1.12.0

May 25, 2026

Changes in this version

type TelemetryInitOptions

+ UserAgent string

v1.11.1

May 20, 2026

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

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