diff options
author | Valery Piashchynski <[email protected]> | 2020-11-04 15:32:55 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2020-11-04 15:32:55 +0300 |
commit | e0a0c0d31cf9724754c63c67865403af7fceb1a4 (patch) | |
tree | 3c7fcde78a280d8058c38816931c8b15d1779c8e /plugins/rpc/tests/plugin1.go | |
parent | edc45b3e24afdb5e56e74ffbbbd50e0e3b04922b (diff) |
Update structure, add tests for RPC
Diffstat (limited to 'plugins/rpc/tests/plugin1.go')
-rw-r--r-- | plugins/rpc/tests/plugin1.go | 42 |
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 +} |