summaryrefslogtreecommitdiff
path: root/plugins/rpc/tests/plugin1.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-11-04 15:32:55 +0300
committerValery Piashchynski <[email protected]>2020-11-04 15:32:55 +0300
commite0a0c0d31cf9724754c63c67865403af7fceb1a4 (patch)
tree3c7fcde78a280d8058c38816931c8b15d1779c8e /plugins/rpc/tests/plugin1.go
parentedc45b3e24afdb5e56e74ffbbbd50e0e3b04922b (diff)
Update structure, add tests for RPC
Diffstat (limited to 'plugins/rpc/tests/plugin1.go')
-rw-r--r--plugins/rpc/tests/plugin1.go42
1 files changed, 42 insertions, 0 deletions
diff --git a/plugins/rpc/tests/plugin1.go b/plugins/rpc/tests/plugin1.go
new file mode 100644
index 00000000..788e6a2c
--- /dev/null
+++ b/plugins/rpc/tests/plugin1.go
@@ -0,0 +1,42 @@
+package tests
+
+import (
+ "fmt"
+
+ "github.com/spiral/roadrunner/v2/plugins/config"
+)
+
+type Plugin1 struct {
+ config config.Configurer
+}
+
+func (p1 *Plugin1) Init(cfg config.Configurer) error {
+ p1.config = cfg
+ return nil
+}
+
+func (p1 *Plugin1) Serve() chan error {
+ errCh := make(chan error, 1)
+ return errCh
+}
+
+func (p1 *Plugin1) Stop() error {
+ return nil
+}
+
+func (p1 *Plugin1) Name() string {
+ return "rpc_test.plugin1"
+}
+
+func (p1 *Plugin1) RPCService() (interface{}, error) {
+ return &PluginRpc{srv: p1}, nil
+}
+
+type PluginRpc struct {
+ srv *Plugin1
+}
+
+func (r *PluginRpc) Hello(in string, out *string) error {
+ *out = fmt.Sprintf("Hello, username: %s", in)
+ return nil
+}