summaryrefslogtreecommitdiff
path: root/pkg/worker/interface.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-04-19 16:42:28 +0300
committerValery Piashchynski <[email protected]>2021-04-19 16:42:28 +0300
commitbaa12b092578d41218585d918fb7e1425700272d (patch)
tree91881bd0ac32c609ea01fafe3bbc15a13a67c392 /pkg/worker/interface.go
parent112b7b60bbc045f4935e1766be9d2266abf68b31 (diff)
- Add tests, update Informer implementation
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg/worker/interface.go')
-rw-r--r--pkg/worker/interface.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/worker/interface.go b/pkg/worker/interface.go
index 2b68717a..d2cfe2cd 100644
--- a/pkg/worker/interface.go
+++ b/pkg/worker/interface.go
@@ -16,7 +16,7 @@ type State interface {
Value() int64
// Set sets the StateImpl
Set(value int64)
- // NumJobs shows how many times WorkerProcess was invoked
+ // NumExecs shows how many times WorkerProcess was invoked
NumExecs() uint64
// IsActive returns true if WorkerProcess not Inactive or Stopped
IsActive() bool
@@ -69,6 +69,6 @@ type SyncWorker interface {
BaseProcess
// 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
+ // ExecWithTTL used to handle Exec with TTL
ExecWithTTL(ctx context.Context, p payload.Payload) (payload.Payload, error)
}