From 3f19ab3c8cb8b5d0ee4aed32eb58e92519b22f3e Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期二, 24 十二月 2019 09:18:01 +0800
Subject: [PATCH] update
---
app/slave/sdkLoad.go | 8 +++++---
1 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/app/slave/sdkLoad.go b/app/slave/sdkLoad.go
index f99828c..fa13bf1 100644
--- a/app/slave/sdkLoad.go
+++ b/app/slave/sdkLoad.go
@@ -10,12 +10,14 @@
// func Create(config string, typ, id string, gpu int, shm bool, ipc2Rule string, ruleMaxSize int, fn func(...interface{}), reserved map[string]string) interface{}
// func Run(ctx context.Context, i interface{}) {
-type sdk struct {
+// SDK plugin Func
+type SDK struct {
fnCreate func(string, string, string, int, bool, string, int, func(...interface{}), map[string]interface{}) interface{}
fnRun func(context.Context, interface{})
}
-func loadSDK(soFile string) *sdk {
+// LoadSDK from plugin
+func LoadSDK(soFile string) *SDK {
plug, err := plugin.Open(soFile)
if err != nil {
logo.Errorln("Slave Open so File: ", soFile, " Error: ", err)
@@ -33,7 +35,7 @@
logo.Errorln("Load Func Run From: ", soFile, " Error: ", err)
return nil
}
- return &sdk{
+ return &SDK{
fnCreate: fnC.(func(string, string, string, int, bool, string, int, func(...interface{}), map[string]interface{}) interface{}),
fnRun: fnR.(func(context.Context, interface{})),
}
--
Gitblit v1.8.0