We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7708924 commit 0714745Copy full SHA for 0714745
orchestrator.go
@@ -8,8 +8,8 @@ import (
8
type WorkerOrchestrator interface {
9
GetQueueLength() int
10
AddJobToQueue(job *Job)
11
- Start(ctx context.Context) []*WorkerResult
12
- StartAsAsync(ctx context.Context, workerResultCh chan *WorkerResult)
+ Start(context.Context) []*WorkerResult
+ StartAsAsync(context.Context, chan *WorkerResult)
13
}
14
15
type workerOrchestrator struct {
worker.go
@@ -3,7 +3,7 @@ package patron
3
type Worker interface {
4
GetID() int
5
GetJob() *Job
6
- SetJob(job *Job)
+ SetJob(*Job)
7
FinalizeJob()
IsBusy() bool
Work() error
0 commit comments