diff options
| author | cl2017 <chenlin.liu@daocloud.io> | 2023-10-12 18:18:14 +0800 |
|---|---|---|
| committer | wbc6080 <wangbincheng4@huawei.com> | 2023-11-27 10:56:17 +0800 |
| commit | e3018fa9fc550d1f380c478394da28fa32a157d6 (patch) | |
| tree | 89c458df81feefc8a7548753f4658a997510445a | |
| parent | Merge pull request #5204 from Shelley-BaoYue/automated-cherry-pick-of-#5112-u... (diff) | |
| download | kubeedge-e3018fa9fc550d1f380c478394da28fa32a157d6.tar.gz | |
mapper framework fix
Signed-off-by: cl2017 <chenlin.liu@daocloud.io>
| -rw-r--r-- | staging/src/github.com/kubeedge/mapper-framework/_template/mapper/cmd/main.go | 4 | ||||
| -rw-r--r-- | staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/device.go | 2 | ||||
| -rw-r--r-- | staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/devicetwin.go | 2 | ||||
| -rw-r--r-- | staging/src/github.com/kubeedge/mapper-framework/pkg/grpcclient/config.go (renamed from staging/src/github.com/kubeedge/mapper-framework/pkg/util/grpcclient/config.go) | 0 | ||||
| -rw-r--r-- | staging/src/github.com/kubeedge/mapper-framework/pkg/grpcclient/register.go (renamed from staging/src/github.com/kubeedge/mapper-framework/pkg/util/grpcclient/register.go) | 3 | ||||
| -rw-r--r-- | staging/src/github.com/kubeedge/mapper-framework/pkg/grpcclient/report.go (renamed from staging/src/github.com/kubeedge/mapper-framework/pkg/util/grpcclient/report.go) | 0 | ||||
| -rw-r--r-- | staging/src/github.com/kubeedge/mapper-framework/pkg/util/parse/parse.go | 8 |
7 files changed, 8 insertions, 11 deletions
diff --git a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/cmd/main.go b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/cmd/main.go index 3ca00fb82..2f398d589 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/cmd/main.go +++ b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/cmd/main.go @@ -9,9 +9,9 @@ import ( "github.com/kubeedge/Template/device" "github.com/kubeedge/Template/pkg/common" "github.com/kubeedge/Template/pkg/config" + "github.com/kubeedge/Template/pkg/grpcclient" "github.com/kubeedge/Template/pkg/grpcserver" "github.com/kubeedge/Template/pkg/httpserver" - "github.com/kubeedge/Template/pkg/util/grpcclient" "github.com/kubeedge/Template/pkg/util/parse" ) @@ -50,7 +50,7 @@ func main() { // if dev init mode is register, mapper's dev will init when registry to edgecore if c.DevInit.Mode != common.DevInitModeRegister { klog.Infoln("======dev init mode is not register, will register to edgecore") - if _, _, err = grpcclient.RegisterMapper(&c, false); err != nil { + if _, _, err = grpcclient.RegisterMapper(false); err != nil { klog.Fatal(err) } klog.Infoln("registerMapper finished") diff --git a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/device.go b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/device.go index f0077566d..c4ddf7de8 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/device.go +++ b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/device.go @@ -277,7 +277,7 @@ func (d *DevPanel) DevInit(cfg *config.Config) error { // return err // } case common.DevInitModeRegister: - if err := parse.ParseByUsingRegister(cfg, devs, d.models, d.protocols); err != nil { + if err := parse.ParseByUsingRegister(devs, d.models, d.protocols); err != nil { return err } } diff --git a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/devicetwin.go b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/devicetwin.go index e5563f4a5..5df21570e 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/devicetwin.go +++ b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/device/devicetwin.go @@ -12,7 +12,7 @@ import ( "github.com/kubeedge/Template/driver" "github.com/kubeedge/Template/pkg/common" dmiapi "github.com/kubeedge/Template/pkg/dmi-api" - "github.com/kubeedge/Template/pkg/util/grpcclient" + "github.com/kubeedge/Template/pkg/grpcclient" "github.com/kubeedge/Template/pkg/util/parse" ) diff --git a/staging/src/github.com/kubeedge/mapper-framework/pkg/util/grpcclient/config.go b/staging/src/github.com/kubeedge/mapper-framework/pkg/grpcclient/config.go index 7de4d6233..7de4d6233 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/pkg/util/grpcclient/config.go +++ b/staging/src/github.com/kubeedge/mapper-framework/pkg/grpcclient/config.go diff --git a/staging/src/github.com/kubeedge/mapper-framework/pkg/util/grpcclient/register.go b/staging/src/github.com/kubeedge/mapper-framework/pkg/grpcclient/register.go index 3f577f956..f582de56e 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/pkg/util/grpcclient/register.go +++ b/staging/src/github.com/kubeedge/mapper-framework/pkg/grpcclient/register.go @@ -9,12 +9,11 @@ import ( "google.golang.org/grpc" "github.com/kubeedge/Template/pkg/common" - "github.com/kubeedge/Template/pkg/config" dmiapi "github.com/kubeedge/Template/pkg/dmi-api" ) // RegisterMapper if withData is true, edgecore will send device and model list. -func RegisterMapper(cfg *config.Config, withData bool) ([]*dmiapi.Device, []*dmiapi.DeviceModel, error) { +func RegisterMapper(withData bool) ([]*dmiapi.Device, []*dmiapi.DeviceModel, error) { // connect grpc server conn, err := grpc.Dial(cfg.Common.EdgeCoreSock, grpc.WithInsecure(), diff --git a/staging/src/github.com/kubeedge/mapper-framework/pkg/util/grpcclient/report.go b/staging/src/github.com/kubeedge/mapper-framework/pkg/grpcclient/report.go index 4e18d9b82..4e18d9b82 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/pkg/util/grpcclient/report.go +++ b/staging/src/github.com/kubeedge/mapper-framework/pkg/grpcclient/report.go diff --git a/staging/src/github.com/kubeedge/mapper-framework/pkg/util/parse/parse.go b/staging/src/github.com/kubeedge/mapper-framework/pkg/util/parse/parse.go index 6c02d9a7f..74558bbd8 100644 --- a/staging/src/github.com/kubeedge/mapper-framework/pkg/util/parse/parse.go +++ b/staging/src/github.com/kubeedge/mapper-framework/pkg/util/parse/parse.go @@ -22,17 +22,15 @@ import ( "k8s.io/klog/v2" "github.com/kubeedge/Template/pkg/common" - "github.com/kubeedge/Template/pkg/config" - "github.com/kubeedge/Template/pkg/util/grpcclient" + "github.com/kubeedge/Template/pkg/grpcclient" ) var ErrEmptyData error = errors.New("device or device model list is empty") -func ParseByUsingRegister(cfg *config.Config, - devices map[string]*common.DeviceInstance, +func ParseByUsingRegister(devices map[string]*common.DeviceInstance, dms map[string]common.DeviceModel, protocols map[string]common.ProtocolConfig) error { - deviceList, deviceModelList, err := grpcclient.RegisterMapper(cfg, true) + deviceList, deviceModelList, err := grpcclient.RegisterMapper(true) if err != nil { return err } |
