this repo has no description
add to parallel scheduler doc string
+3
-1
+3
-1
events/schedulers/parallel/parallel.go
+3
-1
events/schedulers/parallel/parallel.go
···
11
11
"github.com/prometheus/client_golang/prometheus"
12
12
)
13
13
14
-
// Scheduler is a parallel scheduler that will run work on a fixed number of workers
14
+
// Scheduler is a parallel scheduler that will run work on a fixed number of workers.
15
+
//
16
+
// Notably, this scheduler uses a per-DID task tracker to ensure that events are not processed concurrently for the same account. This does *not* mean that all events for the same DID are consistently processed by the same worker.
15
17
type Scheduler struct {
16
18
maxConcurrency int
17
19
maxQueue int