querylogs

Nov 30, 2025

Changes in this version

+ func BoolPtrValue(v *bool) *structpb.Value

+ func BoolValue(v bool) *structpb.Value

+ func DurationValue(v time.Duration) *structpb.Value

+ func FloatPtrValue(v *float64) *structpb.Value

+ func FloatValue(v float64) *structpb.Value

+ func IPPtrValue(v *net.IP) *structpb.Value

+ func IPValue(v net.IP) *structpb.Value

+ func Int32PtrValue(v *int32) *structpb.Value

+ func Int32Value(v int32) *structpb.Value

+ func IntPtrValue(v *int64) *structpb.Value

+ func IntValue(v int64) *structpb.Value

+ func NewMetadataStruct(fields map[string]*structpb.Value) *structpb.Struct

+ func StringListValue(v []string) *structpb.Value

+ func StringPtrValue(v *string) *structpb.Value

+ func StringValue(v string) *structpb.Value

+ func StructValue(fields map[string]*structpb.Value) *structpb.Value

+ func TimePtrValue(v *time.Time) *structpb.Value

+ func TimeValue(v time.Time) *structpb.Value

+ func TrimmedStringPtrValue(v *string) *structpb.Value

+ func UInt16Value(v uint16) *structpb.Value

+ func Uint32Value(v uint32) *structpb.Value

+ func Uint8Value(v uint8) *structpb.Value

+ func UintValue(v uint64) *structpb.Value

Nov 27, 2025

Changes in this version

+ const NumberPlaceholder

+ const StringPlaceholder

+ func SanitizeMetadataValue(v interface{}) interface

+ type DwhContext struct

+ Cluster string

+ Database string

+ Instance string

+ Role string

+ Schema string

+ User string

+ Warehouse string

+ type Metadata map[string]interface

+ func NewMetadata(pairs ...interface{}) Metadata

+ func SanitizeMetadata(m map[string]interface{}) Metadata

+ type NativeLineage struct

+ InputTables []scrapper.DwhFqn

+ OutputTables []scrapper.DwhFqn

+ func (nl *NativeLineage) GetInputTables() []scrapper.DwhFqn

+ func (nl *NativeLineage) GetOutputTables() []scrapper.DwhFqn

+ type ObfuscationMode int

+ const ObfuscationNone

+ const ObfuscationRedactLiterals

+ const ObfuscationRemoveQuery

+ type ObfuscatorOption func(*obfuscatorConfig)

+ func WithKeepJsonPath(keep bool) ObfuscatorOption

+ func WithPreserveLiteralsMatching(patterns []string) ObfuscatorOption

+ func WithPreserveNumbers(preserve bool) ObfuscatorOption

+ type QueryLog struct

+ CreatedAt time.Time

+ DwhContext *DwhContext

+ FinishedAt *time.Time

+ HasCompleteNativeLineage bool

+ IsTruncated bool

+ Metadata map[string]interface{}

+ NativeLineage *NativeLineage

+ NormalizedQueryHash *string

+ QueryID string

+ QueryType string

+ SQL string

+ SqlDialect string

+ SqlObfuscationMode ObfuscationMode

+ StartedAt *time.Time

+ Status string

+ type QueryLogIterator interface

+ Close func() error

+ Next func(ctx context.Context) (*QueryLog, error)

+ func NewSqlxRowsIterator[T any](rows *sqlx.Rows, obfuscator QueryObfuscator, sqlDialect string, ...) QueryLogIterator

+ type QueryLogsProvider interface

+ FetchQueryLogs func(ctx context.Context, from, to time.Time, obfuscator QueryObfuscator) (QueryLogIterator, error)

+ type QueryObfuscator interface

+ Mode func() ObfuscationMode

+ Obfuscate func(sql string) string

+ func NewQueryObfuscator(mode ObfuscationMode, opts ...ObfuscatorOption) (QueryObfuscator, error)

+ type SqlxRowsIterator struct

+ func (it *SqlxRowsIterator[T]) Close() error

+ func (it *SqlxRowsIterator[T]) Next(ctx context.Context) (*QueryLog, error)