-
Notifications
You must be signed in to change notification settings - Fork 0
/
methods_optionsMutate.go
67 lines (50 loc) · 1.28 KB
/
methods_optionsMutate.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
64
65
66
67
package cache
import "time"
func (c *Cache) SetMaxValues(n int) {
defer c.mutex.Unlock()
c.mutex.Lock()
c.setStatus(statusHasMutatedSinceCleanedFully)
c.options.MaxValues = n
c.startCleanWatchIfNecessary()
}
func (c *Cache) recalculateCleanInterval() {
select {
case c.cleanIntervalChan <- struct{}{}:
break
default:
break
}
}
func (c *Cache) SetExpiryDuration(d time.Duration) {
defer c.mutex.Unlock()
c.mutex.Lock()
c.setStatus(statusHasMutatedSinceCleanedFully)
c.options.ExpiryDuration = d
c.startCleanWatchIfNecessary()
c.recalculateCleanInterval()
}
func (c *Cache) SetCleanDuration(d time.Duration) {
defer c.mutex.Unlock()
c.mutex.Lock()
c.setStatus(statusHasMutatedSinceCleanedFully)
c.options.CleanDuration = d
c.recalculateCleanInterval()
}
func (c *Cache) SetCleanMaxValuesPerSweep(n int) {
defer c.mutex.Unlock()
c.mutex.Lock()
c.setStatus(statusHasMutatedSinceCleanedFully)
c.options.CleanMaxValuesPerSweep = n
}
func (c *Cache) SetUnsetPreFunc(p CallbackFunc) {
defer c.mutex.Unlock()
c.mutex.Lock()
c.setStatus(statusHasMutatedSinceCleanedFully)
c.options.UnsetPreFunc = p
}
func (c *Cache) SetUnsetPostFunc(p CallbackFunc) {
defer c.mutex.Unlock()
c.mutex.Lock()
c.setStatus(statusHasMutatedSinceCleanedFully)
c.options.UnsetPostFunc = p
}