Skip to content

feat(provider): persist provide queue #1167

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
guillaumemichel merged 29 commits into from
Oct 17, 2025
Merged

feat(provider): persist provide queue #1167

Changes from 1 commit
Commits
Show all changes
29 commits
Select commit Hold shift + click to select a range
f8ecb6d
provider: stats
guillaumemichel Sep 5, 2025
34fcc12
use proper struct for stats
guillaumemichel Sep 9, 2025
405e2d9
provide queue stats
guillaumemichel Sep 9, 2025
63b65e7
counting ongoing operations
guillaumemichel Sep 9, 2025
fb00baf
provide counts
guillaumemichel Sep 9, 2025
cb8bca6
floatTimeSeries
guillaumemichel Sep 9, 2025
33d2051
draft: last metrics
guillaumemichel Sep 17, 2025
41c1c07
refactor
guillaumemichel Sep 17, 2025
b513e72
gofmt
guillaumemichel Sep 18, 2025
cfe33ff
tests
guillaumemichel Sep 19, 2025
56a8625
bump reservedpool
guillaumemichel Sep 19, 2025
06ec289
Merge branch 'master' into provider-stats
guillaumemichel Sep 25, 2025
3ec3cf5
Merge branch 'master' into provider-stats
guillaumemichel Sep 26, 2025
ada0917
Merge branch 'master' into provider-stats
guillaumemichel Oct 6, 2025
102a676
make provider inside buffered.SweepingProvider public
guillaumemichel Oct 6, 2025
21c2103
format
guillaumemichel Oct 7, 2025
cb675c4
fix: flaky TestStats
guillaumemichel Oct 7, 2025
45756c5
avg region size metric
guillaumemichel Oct 8, 2025
28b59f8
fix: ongoing provides counter
guillaumemichel Oct 8, 2025
2c5b376
float64 avgPrefixLen
guillaumemichel Oct 9, 2025
84edca4
provider: persist provide queue
guillaumemichel Oct 9, 2025
27946fa
persist & load provide queue to/from datastore
guillaumemichel Oct 9, 2025
5c38378
configure datastore
guillaumemichel Oct 9, 2025
d83a255
test: provide queue persistence after close
guillaumemichel Oct 9, 2025
f4a33fa
limit batch size
guillaumemichel Oct 15, 2025
3888925
addressing review
guillaumemichel Oct 17, 2025
be3bbde
Merge branch 'master' into provider-stats
guillaumemichel Oct 17, 2025
5a08cfc
test: fix edge case
guillaumemichel Oct 17, 2025
ff53652
Merge branch 'provider-stats' into persist-provide-queue
guillaumemichel Oct 17, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
test: fix edge case
  • Loading branch information
@guillaumemichel
guillaumemichel committed Oct 17, 2025
commit 5a08cfcd8a5d7f1b789940c64c32e21a8bf23f6c
4 changes: 2 additions & 2 deletions provider/provider_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -912,7 +912,7 @@ func TestStartProvidingSingle(t *testing.T) {
synctest.Wait()
require.True(t, prov.connectivity.IsOnline())
prov.avgPrefixLenLk.Lock()
require.Greater(t, prov.cachedAvgPrefixLen, 0)
require.GreaterOrEqual(t, prov.cachedAvgPrefixLen, 0)
prov.avgPrefixLenLk.Unlock()

err = prov.StartProviding(true, h)
Expand Down Expand Up @@ -1186,7 +1186,7 @@ func TestStartProvidingUnstableNetwork(t *testing.T) {

synctest.Wait()
prov.avgPrefixLenLk.Lock()
require.Greater(t, prov.cachedAvgPrefixLen, 0)
require.GreaterOrEqual(t, prov.cachedAvgPrefixLen, 0)
prov.avgPrefixLenLk.Unlock()

routerOffline.Store(true)
Expand Down