summaryrefslogtreecommitdiff
path: root/pkg/worker/worker.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-04-20 10:06:45 +0300
committerGitHub <[email protected]>2021-04-20 10:06:45 +0300
commit3362f211f6358d60bea47ac2de4cc29a47373973 (patch)
treed36dc3ce9a36fff1b15b8795e8fa08d397317d14 /pkg/worker/worker.go
parent35d6a50aa3640c870b99c120b26c9b9012b424be (diff)
parent779cc3f5aebb749ab4bc6190e03cc86ff3f151a0 (diff)
#634 feat(plugin): new plugin `service`v2.1.0-beta.2
feat(plugin): new plugin `service`
Diffstat (limited to 'pkg/worker/worker.go')
-rwxr-xr-xpkg/worker/worker.go6
1 files changed, 2 insertions, 4 deletions
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
}