chore: add loadpoint reference to cache values
This commit is contained in:
parent
75c29e797f
commit
6cdb4a8886
1 changed files with 6 additions and 1 deletions
|
|
@ -1,6 +1,7 @@
|
|||
package util
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"sync"
|
||||
)
|
||||
|
||||
|
|
@ -22,7 +23,11 @@ func (c *Cache) Run(in <-chan Param) {
|
|||
log := NewLogger("cache")
|
||||
|
||||
for p := range in {
|
||||
log.DEBUG.Printf("%s: %v", p.Key, p.Val)
|
||||
key := p.Key
|
||||
if p.LoadPoint != nil {
|
||||
key = fmt.Sprintf("lp-%d/%s", *p.LoadPoint+1, key)
|
||||
}
|
||||
log.DEBUG.Printf("%s: %v", key, p.Val)
|
||||
c.Add(p.UniqueID(), p)
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue