-
Notifications
You must be signed in to change notification settings - Fork 0
/
etcd_keysapi_logger.go
55 lines (44 loc) · 1.72 KB
/
etcd_keysapi_logger.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
package kontrol
import (
"context"
etcd "github.com/coreos/etcd/client"
"github.com/koding/kite"
)
type KeysAPILogger struct {
kapi etcd.KeysAPI
log kite.Logger
}
func NewKeysAPILogger(kapi etcd.KeysAPI, log kite.Logger) KeysAPILogger {
return KeysAPILogger{
kapi: kapi,
log: log,
}
}
func (k KeysAPILogger) Get(ctx context.Context, key string, opts *etcd.GetOptions) (*etcd.Response, error) {
k.log.Debug("Get: key: %v opts: %v", key, opts)
return k.kapi.Get(ctx, key, opts)
}
func (k KeysAPILogger) Set(ctx context.Context, key, value string, opts *etcd.SetOptions) (*etcd.Response, error) {
k.log.Debug("Set: key: %v value: %v opts: %v", key, value, opts)
return k.kapi.Set(ctx, key, value, opts)
}
func (k KeysAPILogger) Delete(ctx context.Context, key string, opts *etcd.DeleteOptions) (*etcd.Response, error) {
k.log.Debug("Delete: key: %v opts: %v", key, opts)
return k.kapi.Delete(ctx, key, opts)
}
func (k KeysAPILogger) Create(ctx context.Context, key, value string) (*etcd.Response, error) {
k.log.Debug("Create: key: %v value: %v", key, value)
return k.kapi.Create(ctx, key, value)
}
func (k KeysAPILogger) CreateInOrder(ctx context.Context, dir, value string, opts *etcd.CreateInOrderOptions) (*etcd.Response, error) {
k.log.Debug("CreateInOrder: dir: %v value: %v opts: %v", dir, value, opts)
return k.kapi.CreateInOrder(ctx, dir, value, opts)
}
func (k KeysAPILogger) Update(ctx context.Context, key, value string) (*etcd.Response, error) {
k.log.Debug("Update: key: %v value: %v", key, value)
return k.kapi.Update(ctx, key, value)
}
func (k KeysAPILogger) Watcher(key string, opts *etcd.WatcherOptions) etcd.Watcher {
k.log.Debug("Watcher: key: %v opts: %v", key, opts)
return k.kapi.Watcher(key, opts)
}