summaryrefslogtreecommitdiff
path: root/sync_worker.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-11-26 12:44:12 +0300
committerValery Piashchynski <[email protected]>2020-11-26 12:44:12 +0300
commit574f351aaecdee1176b9700bb6d7eb61fe170906 (patch)
tree6271704950d2c89a43de3edafb677a003d50a406 /sync_worker.go
parente5313529e4293b7ad985cce72cec54b08462259d (diff)
Remove context from worker wait function. Explicitly enable ubuntu 20.04
in the CI
Diffstat (limited to 'sync_worker.go')
-rwxr-xr-xsync_worker.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/sync_worker.go b/sync_worker.go
index 6f5b20d9..cd0f934e 100755
--- a/sync_worker.go
+++ b/sync_worker.go
@@ -17,7 +17,6 @@ var EmptyPayload = Payload{}
type SyncWorker interface {
// WorkerBase provides basic functionality for the SyncWorker
WorkerBase
-
// Exec used to execute payload on the SyncWorker, there is no TIMEOUTS
Exec(rqs Payload) (Payload, error)
// ExecWithContext used to handle Exec with TTL
@@ -28,6 +27,7 @@ type syncWorker struct {
w WorkerBase
}
+// NewSyncWorker creates SyncWorker from WorkerBasa
func NewSyncWorker(w WorkerBase) (SyncWorker, error) {
return &syncWorker{
w: w,
@@ -191,8 +191,8 @@ func (tw *syncWorker) Start() error {
return tw.w.Start()
}
-func (tw *syncWorker) Wait(ctx context.Context) error {
- return tw.w.Wait(ctx)
+func (tw *syncWorker) Wait() error {
+ return tw.w.Wait()
}
func (tw *syncWorker) Stop(ctx context.Context) error {