()
| 1896 | } |
| 1897 | |
| 1898 | func (m *KV) cleanupObsoleteEntries() { |
| 1899 | m.storeMu.Lock() |
| 1900 | defer m.storeMu.Unlock() |
| 1901 | |
| 1902 | for k, v := range m.store { |
| 1903 | if v.Deleted && time.Since(v.UpdateTime) > m.cfg.ObsoleteEntriesTimeout { |
| 1904 | delete(m.store, k) |
| 1905 | } |
| 1906 | } |
| 1907 | } |
| 1908 | |
| 1909 | func addMessageToBuffer(msgs []Message, size int, limit int, msg Message) ([]Message, int) { |
| 1910 | msgs = append(msgs, msg) |