mirror/groupcache
1
0
Fork 0
mirror of https://github.com/mailgun/groupcache.git synced 2024-11-16 14:10:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Logging.

Browse Source
This commit is contained in:
Shawn Poulson 2024-06-26 17:00:27 -04:00
parent 73db6704c7
commit 18965b4c54
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
groupcache.go
View File

@ -28,6 +28,7 @@ import (
"context" "context"
"errors" "errors"
"strconv" "strconv"
"strings"
"sync" "sync"
"sync/atomic" "sync/atomic"
"time" "time"
@ -297,6 +298,16 @@ func (g *Group) Set(ctx context.Context, key string, value []byte, expire time.T
func (g *Group) Remove(ctx context.Context, key string) error { func (g *Group) Remove(ctx context.Context, key string) error {
g.peersOnce.Do(g.initPeers) g.peersOnce.Do(g.initPeers)
var peerList []string
for _, peer := range g.peers.GetAll() {
peerList = append(peerList, peer.GetURL())
}
logrus.WithFields(logrus.Fields{
"name": g.name,
"peers": strings.Join(peerList, ","),
"key": key,
}).Info("Group.Remove()")
_, err := g.removeGroup.Do(key, func() (interface{}, error) { _, err := g.removeGroup.Do(key, func() (interface{}, error) {
// Remove from key owner first // Remove from key owner first
owner, ok := g.peers.PickPeer(key) owner, ok := g.peers.PickPeer(key)