feat: add gorpc

go.mod

@@ -2,4 +2,7 @@ module github.com/getstackhead/pluginlib
 
 go 1.17
 
-require github.com/asaskevich/EventBus v0.0.0-20200907212545-49d423059eef
+require (
+	github.com/asaskevich/EventBus v0.0.0-20200907212545-49d423059eef
+	github.com/valyala/gorpc v0.0.0-20160519171614-908281bef774
+)

go.sum

@@ -1,2 +1,4 @@
 github.com/asaskevich/EventBus v0.0.0-20200907212545-49d423059eef h1:2JGTg6JapxP9/R33ZaagQtAM4EkkSYnIAlOG5EI8gkM=
 github.com/asaskevich/EventBus v0.0.0-20200907212545-49d423059eef/go.mod h1:JS7hed4L1fj0hXcyEejnW57/7LCetXggd+vwrRnYeII=
+github.com/valyala/gorpc v0.0.0-20160519171614-908281bef774 h1:SUHFQHAaySqF0YHCmmm0EIFooFZpDPpi5KTom7YJ07c=
+github.com/valyala/gorpc v0.0.0-20160519171614-908281bef774/go.mod h1:8uNqM1i7pr0jO7gdvbNCgsSa8Ki2vMh7JCQxO9BlF90=

install.go

@@ -4,10 +4,10 @@ type PackageName struct {
 	ApkPackageName string
 }
 
-func InstallPackage(packageName PackageName) <-chan error {
-	return StackHeadMain.Execute(IntCmdInstallPkgApk, packageName.ApkPackageName)
+func InstallPackage(packageName PackageName) error {
+	return ExecCmd(IntCmdInstallPkgApk, packageName.ApkPackageName)
 }
 
-func UninstallPackage(packageName PackageName) <-chan error {
-	return StackHeadMain.Execute(IntCmdUninstallPkgApk, packageName.ApkPackageName)
+func UninstallPackage(packageName PackageName) error {
+	return ExecCmd(IntCmdUninstallPkgApk, packageName.ApkPackageName)
 }

stackhead.go

@@ -1,12 +1,18 @@
 package pluginlib
 
-type IStackHeadMain interface {
-	Execute(command string, args ...interface{}) <-chan error
-}
+import "github.com/valyala/gorpc"
 
 const (
 	IntCmdInstallPkgApk   string = "stackhead:install:package:apk"
 	IntCmdUninstallPkgApk string = "stackhead:uninstall:package:apk"
 )
 
-var StackHeadMain IStackHeadMain = nil
+func ExecCmd(command string, args ...interface{}) error {
+	c := &gorpc.Client{Addr: "localhost:1412"}
+	c.Start()
+	defer c.Stop()
+	// All client methods issuing RPCs are thread-safe and goroutine-safe,
+	// i.e. it is safe to call them from multiple concurrently running goroutines.
+	_, err := c.Call(command, args...)
+	return err
+}