BufferedUpdatesCount returns the number of buffered updates which are currently waiting to be flushed to the store. The returned values are for success & failure, respectively.
()
| 231 | // BufferedUpdatesCount returns the number of buffered updates which are currently waiting to be flushed to the store. |
| 232 | // The returned values are for success & failure, respectively. |
| 233 | func (m *Manager) BufferedUpdatesCount() (success int, failure int) { |
| 234 | return len(m.success), len(m.failure) |
| 235 | } |
| 236 | |
| 237 | // syncUpdates updates messages in the store based on the given successful and failed message dispatch results. |
| 238 | func (m *Manager) syncUpdates(ctx context.Context) { |
no outgoing calls