- Folders struct

- Initial ephemeral broker commit
- Initial RPC

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 14 insertions, 1 deletions

diff --git a/plugins/jobs/rpc.go b/plugins/jobs/rpc.go
index dbe7f808..e77cda59 100644
--- a/plugins/jobs/rpc.go
+++ b/plugins/jobs/rpc.go
@@ -1,7 +1,20 @@
 package jobs
 
-import "github.com/spiral/roadrunner/v2/plugins/logger"
+import (
+	"github.com/spiral/roadrunner/v2/plugins/jobs/structs"
+	"github.com/spiral/roadrunner/v2/plugins/logger"
+)
 
 type rpc struct {
 	log logger.Logger
+	p   *Plugin
+}
+
+func (r *rpc) Push(j *structs.Job, idRet *string) error {
+	id, err := r.p.Push(j)
+	if err != nil {
+		panic(err)
+	}
+	*idRet = id
+	return nil
 }