summaryrefslogtreecommitdiff
path: root/plugins/status/rpc.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-02-24 14:16:59 +0300
committerGitHub <[email protected]>2021-02-24 14:16:59 +0300
commitb3cb0cd2428f1bfdd959ea8f3461e2992b6acdb2 (patch)
tree0d226eb8ad9730ede1f7cd80b5f7b44d1fb23b0a /plugins/status/rpc.go
parent3c5a85bf8a0d1c8b8f8f71c215f75b338c4e7510 (diff)
parentcaea9cb452fda97a9496bc33190c95fbc27e54c3 (diff)
Merge pull request #551 from spiral/rc.4-releasev2.0.0-RC.4
âš¡ release(RC.4): Release RC.4
Diffstat (limited to 'plugins/status/rpc.go')
-rw-r--r--plugins/status/rpc.go27
1 files changed, 27 insertions, 0 deletions
diff --git a/plugins/status/rpc.go b/plugins/status/rpc.go
new file mode 100644
index 00000000..396ff451
--- /dev/null
+++ b/plugins/status/rpc.go
@@ -0,0 +1,27 @@
+package status
+
+import (
+ "github.com/spiral/errors"
+ "github.com/spiral/roadrunner/v2/plugins/logger"
+)
+
+type rpc struct {
+ srv *Plugin
+ log logger.Logger
+}
+
+// Status return current status of the provided plugin
+func (rpc *rpc) Status(service string, status *Status) error {
+ const op = errors.Op("checker_rpc_status")
+ rpc.log.Debug("started Status method", "service", service)
+ st, err := rpc.srv.Status(service)
+ if err != nil {
+ return errors.E(op, err)
+ }
+
+ *status = st
+
+ rpc.log.Debug("status code", "code", st.Code)
+ rpc.log.Debug("successfully finished Status method")
+ return nil
+}