Skip to content
This repository has been archived by the owner on Jun 20, 2023. It is now read-only.

Bulk Provide/Reproviding System #34

Merged
merged 29 commits into from
May 14, 2021
Merged

Bulk Provide/Reproviding System #34

Show file tree
Hide file tree
Changes from 28 commits
Commits
Show all changes
29 commits
Select commit Hold shift + click to select a range
c707e99
fix: in queue sync datastore to disk
aschmahmann Apr 9, 2021
c193919
feat: add a batching provider/reprovider system
aschmahmann Apr 9, 2021
829bc09
simplify batch provider to remove the managed provider list, remove t…
aschmahmann Apr 22, 2021
0fdf1d6
batch provider waits for provider system to be ready before attemptin…
aschmahmann Apr 22, 2021
93ff866
fix: handle periods with no providing, and handle the case of a missi…
aschmahmann Apr 23, 2021
fb01b26
moved import
aschmahmann May 12, 2021
bf3cf56
batched: moved context creation to prevent leakage
aschmahmann May 12, 2021
0023040
cleanup code a bit and add more logging
aschmahmann May 12, 2021
8bbdb3b
remove unnecessary goroutine
aschmahmann May 12, 2021
9e61fa1
rename getTime to parseTime
aschmahmann May 12, 2021
c3fd90b
removed newly added syncs from the provider queue and updated its doc…
aschmahmann May 12, 2021
c52c0b0
batched: wait for goroutines to close before returning from Close
aschmahmann May 12, 2021
34b4e40
batched: reuse timers in the Run function
aschmahmann May 12, 2021
4407f46
renamed variable
aschmahmann May 12, 2021
f498246
some go timer fixes
aschmahmann May 12, 2021
cffff34
have a max collection threshold even when only processing regular pro…
aschmahmann May 12, 2021
6d08b5d
max collection timer only starts once we have our first provide
aschmahmann May 12, 2021
3a94d3a
remove cid from provide queue if its invalid
aschmahmann May 12, 2021
866d979
switch reproviding channel to be unbuffered
aschmahmann May 12, 2021
f84c7d9
batched: do not panic if no key provider is set, instead default to r…
aschmahmann May 12, 2021
8c07658
batched: renamed dynamicCh and dynamicCidLoop to reprovideCh and repr…
aschmahmann May 12, 2021
71c6564
batched: add test
aschmahmann May 12, 2021
b017f26
fix max collection check
aschmahmann May 12, 2021
d366b61
fixed waitgroup usage bug
aschmahmann May 12, 2021
843e75c
batched: internally configurable initial reprovide
aschmahmann May 13, 2021
04452c4
batched: add basic test
aschmahmann May 13, 2021
edb6021
batched: rework timer usage
aschmahmann May 13, 2021
1c19caa
use closure
aschmahmann May 13, 2021
c86f3de
fix debug log usage
aschmahmann May 14, 2021
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
Loading