diff --git a/client/internal/netflow/manager.go b/client/internal/netflow/manager.go index b26455141..fa66fcf32 100644 --- a/client/internal/netflow/manager.go +++ b/client/internal/netflow/manager.go @@ -248,6 +248,8 @@ func (m *Manager) receiveACKs(ctx context.Context, client *client.GRPCClient) { } } +// We effectively never drop events (see MaxInterval), which makes eventsWithoutAcks unbounded. +// We may want to limit the max size of the store, and start dropping oldest events when the threshold is reached. func (m *Manager) startRetries(ctx context.Context) { timer := time.NewTimer(m.retryInterval) retryBackoff := backoff.WithContext(&backoff.ExponentialBackOff{