-
Notifications
You must be signed in to change notification settings - Fork 1
/
traces.go
63 lines (51 loc) · 2.17 KB
/
traces.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package zerolog
import (
"github.com/rs/zerolog"
"github.com/ydb-platform/ydb-go-sdk/v3"
"github.com/ydb-platform/ydb-go-sdk/v3/log"
"github.com/ydb-platform/ydb-go-sdk/v3/trace"
)
func WithTraces(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) ydb.Option {
a := adapter{l: l}
return ydb.MergeOptions(
ydb.WithTraceDriver(log.Driver(a, d, opts...)),
ydb.WithTraceTable(log.Table(a, d, opts...)),
ydb.WithTraceScripting(log.Scripting(a, d, opts...)),
ydb.WithTraceScheme(log.Scheme(a, d, opts...)),
ydb.WithTraceCoordination(log.Coordination(a, d, opts...)),
ydb.WithTraceRatelimiter(log.Ratelimiter(a, d, opts...)),
ydb.WithTraceDiscovery(log.Discovery(a, d, opts...)),
ydb.WithTraceTopic(log.Topic(a, d, opts...)),
ydb.WithTraceDatabaseSQL(log.DatabaseSQL(a, d, opts...)),
)
}
func WithLogger(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) ydb.Option {
return ydb.WithLogger(adapter{l: l}, d, opts...)
}
func Table(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) trace.Table {
return log.Table(&adapter{l: l}, d, opts...)
}
func Topic(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) trace.Topic {
return log.Topic(&adapter{l: l}, d, opts...)
}
func Driver(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) trace.Driver {
return log.Driver(&adapter{l: l}, d, opts...)
}
func Coordination(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) trace.Coordination {
return log.Coordination(&adapter{l: l}, d, opts...)
}
func Discovery(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) trace.Discovery {
return log.Discovery(&adapter{l: l}, d, opts...)
}
func Ratelimiter(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) trace.Ratelimiter {
return log.Ratelimiter(&adapter{l: l}, d, opts...)
}
func Scheme(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) trace.Scheme {
return log.Scheme(&adapter{l: l}, d, opts...)
}
func Scripting(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) trace.Scripting {
return log.Scripting(&adapter{l: l}, d, opts...)
}
func DatabaseSQL(l *zerolog.Logger, d trace.Detailer, opts ...log.Option) trace.DatabaseSQL {
return log.DatabaseSQL(&adapter{l: l}, d, opts...)
}