File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -118,7 +118,7 @@ func WithLogger(logger zerolog.Logger) Option {
118118 }
119119}
120120
121- func WithConcurrency (concurrency uint64 ) Option {
121+ func WithConcurrency (concurrency int ) Option {
122122 return func (s * Scheduler ) {
123123 s .concurrency = concurrency
124124 }
@@ -158,7 +158,7 @@ type Scheduler struct {
158158 tableSems []* semaphore.Weighted
159159 // Logger to call, this logger is passed to the serve.Serve Client, if not defined Serve will create one instead.
160160 logger zerolog.Logger
161- concurrency uint64
161+ concurrency int
162162}
163163
164164type syncClient struct {
@@ -387,7 +387,7 @@ func maxDepth(tables schema.Tables) uint64 {
387387
388388// unparam's suggestion to remove the second parameter is not good advice here.
389389// nolint:unparam
390- func max (a , b uint64 ) uint64 {
390+ func max (a , b int ) int {
391391 if a > b {
392392 return a
393393 }
You can’t perform that action at this time.
0 commit comments