Skip to content

Commit 8665aee

Browse files
committed
fix: added Debugf
1 parent f336167 commit 8665aee

File tree

4 files changed

+18
-0
lines changed

4 files changed

+18
-0
lines changed

memcache4dalgo/get.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,9 @@ func getRecord(ctx context.Context, record dal.Record, get func(ctx context.Cont
1212
var item *memcache.Item
1313
if item, err = memcache.Get(ctx, key); err == nil {
1414
if err = json.Unmarshal(item.Value, record.Data()); err == nil {
15+
if Debugf != nil {
16+
Debugf(ctx, "memcache4dalgo.getRecord: hit %s", key)
17+
}
1518
return
1619
}
1720
}

memcache4dalgo/get_multi.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,9 @@ func getMultiRecords(ctx context.Context, records []dal.Record, getMulti func(co
1919
for key, item := range items {
2020
if err = json.Unmarshal(item.Value, recordsByKey[key].Data()); err == nil {
2121
delete(recordsByKey, key)
22+
if Debugf != nil {
23+
Debugf(ctx, "memcache4dalgo.getMultiRecords: hit %s", key)
24+
}
2225
}
2326
}
2427
}

memcache4dalgo/logging.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
package memcache4dalgo
2+
3+
import "context"
4+
5+
var Debugf func(ctx context.Context, format string, args ...interface{}) = nil

memcache4dalgo/transaction.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ import (
55
"encoding/json"
66
"github.com/dal-go/dalgo/dal"
77
"google.golang.org/appengine/memcache"
8+
"strings"
89
)
910

1011
type transaction struct {
@@ -69,6 +70,9 @@ func (t transaction) UpdateMulti(ctx context.Context, keys []*dal.Key, updates [
6970
func deleteCached(ctx context.Context, key *dal.Key) {
7071
mk := key.String()
7172
_ = memcache.Delete(ctx, mk)
73+
if Debugf != nil {
74+
Debugf(ctx, "memcache4dalgo.deleteCached: %s", mk)
75+
}
7276
}
7377

7478
func deleteCachedByKeys(ctx context.Context, keys []*dal.Key) {
@@ -77,6 +81,9 @@ func deleteCachedByKeys(ctx context.Context, keys []*dal.Key) {
7781
mks[i] = k.String()
7882
}
7983
_ = memcache.DeleteMulti(ctx, mks)
84+
if Debugf != nil {
85+
Debugf(ctx, "memcache4dalgo.deleteCachedByKeys: %v", strings.Join(mks, ", "))
86+
}
8087
}
8188

8289
func deleteCached4records(ctx context.Context, records []dal.Record) {

0 commit comments

Comments
 (0)