diff options
Diffstat (limited to 'pkg/worker')
| -rw-r--r-- | pkg/worker/interface.go | 2 | ||||
| -rwxr-xr-x | pkg/worker/sync_worker.go | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/pkg/worker/interface.go b/pkg/worker/interface.go index 96eb25bc..2b68717a 100644 --- a/pkg/worker/interface.go +++ b/pkg/worker/interface.go @@ -70,5 +70,5 @@ type SyncWorker interface { // Exec used to execute payload on the SyncWorker, there is no TIMEOUTS Exec(rqs payload.Payload) (payload.Payload, error) // ExecWithContext used to handle Exec with TTL - ExecWithTimeout(ctx context.Context, p payload.Payload) (payload.Payload, error) + ExecWithTTL(ctx context.Context, p payload.Payload) (payload.Payload, error) } diff --git a/pkg/worker/sync_worker.go b/pkg/worker/sync_worker.go index 82a5462a..ac987c14 100755 --- a/pkg/worker/sync_worker.go +++ b/pkg/worker/sync_worker.go @@ -63,7 +63,7 @@ type wexec struct { } // Exec payload without TTL timeout. -func (tw *SyncWorkerImpl) ExecWithTimeout(ctx context.Context, p payload.Payload) (payload.Payload, error) { +func (tw *SyncWorkerImpl) ExecWithTTL(ctx context.Context, p payload.Payload) (payload.Payload, error) { const op = errors.Op("sync_worker_exec_worker_with_timeout") c := make(chan wexec, 1) |