Don't create a EventStore if the event limit is set to 0
This commit is contained in:
parent
75195c38c8
commit
0d4e44fa34
@ -281,14 +281,19 @@ func (self *events) updateEventStore(e *info.Event) {
|
|||||||
self.eventsLock.Lock()
|
self.eventsLock.Lock()
|
||||||
defer self.eventsLock.Unlock()
|
defer self.eventsLock.Unlock()
|
||||||
if _, ok := self.eventStore[e.EventType]; !ok {
|
if _, ok := self.eventStore[e.EventType]; !ok {
|
||||||
maxAge := self.storagePolicy.DefaultMaxAge
|
|
||||||
maxNumEvents := self.storagePolicy.DefaultMaxNumEvents
|
maxNumEvents := self.storagePolicy.DefaultMaxNumEvents
|
||||||
if age, ok := self.storagePolicy.PerTypeMaxAge[e.EventType]; ok {
|
|
||||||
maxAge = age
|
|
||||||
}
|
|
||||||
if numEvents, ok := self.storagePolicy.PerTypeMaxNumEvents[e.EventType]; ok {
|
if numEvents, ok := self.storagePolicy.PerTypeMaxNumEvents[e.EventType]; ok {
|
||||||
maxNumEvents = numEvents
|
maxNumEvents = numEvents
|
||||||
}
|
}
|
||||||
|
if maxNumEvents == 0 {
|
||||||
|
// Event storage is disabled for e.EventType
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
maxAge := self.storagePolicy.DefaultMaxAge
|
||||||
|
if age, ok := self.storagePolicy.PerTypeMaxAge[e.EventType]; ok {
|
||||||
|
maxAge = age
|
||||||
|
}
|
||||||
|
|
||||||
self.eventStore[e.EventType] = utils.NewTimedStore(maxAge, maxNumEvents)
|
self.eventStore[e.EventType] = utils.NewTimedStore(maxAge, maxNumEvents)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user