3 files changed, 9 insertions, 11 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)
 }
diff --git a/pkg/worker/state.go b/pkg/worker/state.go
index 502f8199..9c4543c8 100755
--- a/pkg/worker/state.go
+++ b/pkg/worker/state.go
@@ -24,10 +24,10 @@ const (
 	// StateKilling - process is being forcibly stopped
 	StateKilling
 
-	// State of worker, when no need to allocate new one
+	// StateDestroyed State of worker, when no need to allocate new one
 	StateDestroyed
 
-	// State of worker, when it reached executions limit
+	// StateMaxJobsReached State of worker, when it reached executions limit
 	StateMaxJobsReached
 
 	// StateStopped - process has been terminated.
@@ -91,17 +91,17 @@ func (s *StateImpl) IsActive() bool {
 	return val == StateWorking || val == StateReady
 }
 
-// change StateImpl value (status)
+// Set change StateImpl value (status)
 func (s *StateImpl) Set(value int64) {
 	atomic.StoreInt64(&s.value, value)
 }
 
-// register new execution atomically
+// RegisterExec register new execution atomically
 func (s *StateImpl) RegisterExec() {
 	atomic.AddUint64(&s.numExecs, 1)
 }
 
-// Update last used time
+// SetLastUsed Update last used time
 func (s *StateImpl) SetLastUsed(lu uint64) {
 	atomic.StoreUint64(&s.lastUsed, lu)
 }
diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go
index b04e1363..69c438b0 100755
--- a/pkg/worker/worker.go
+++ b/pkg/worker/worker.go
@@ -96,14 +96,12 @@ func (w *Process) State() State {
 	return w.state
 }
 
-// State return receive-only Process state object, state can be used to safely access
-// Process status, time when status changed and number of Process executions.
+// AttachRelay attaches relay to the worker
 func (w *Process) AttachRelay(rl relay.Relay) {
 	w.relay = rl
 }
 
-// State return receive-only Process state object, state can be used to safely access
-// Process status, time when status changed and number of Process executions.
+// Relay returns relay attached to the worker
 func (w *Process) Relay() relay.Relay {
 	return w.relay
 }