summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorfisherxu <xufei40@huawei.com>2021-02-27 16:37:43 +0800
committerfisherxu <xufei40@huawei.com>2021-02-27 18:17:42 +0800
commitd188cb809dec42aae624a093ec7cd6fa25f10a1c (patch)
tree0c3174d8a10d79a847957d328a10221bf3cf11de
parentfix issue for kubelet access (diff)
downloadkubeedge-d188cb809dec42aae624a093ec7cd6fa25f10a1c.tar.gz
fix the golint issue
Signed-off-by: fisherxu <xufei40@huawei.com>
-rw-r--r--cloud/pkg/dynamiccontroller/application/application.go14
-rw-r--r--edge/pkg/metamanager/metaserver/handlerfactory/handler.go15
-rw-r--r--edge/pkg/metamanager/metaserver/kubernetes/storage/storage.go2
-rw-r--r--pkg/metaserver/key.go1
-rw-r--r--tests/integration/framework/cloud.go (renamed from tests/intergration/framework/cloud.go)3
-rw-r--r--tests/integration/framework/edge.go (renamed from tests/intergration/framework/edge.go)2
-rw-r--r--tests/integration/framework/util.go (renamed from tests/intergration/framework/util.go)0
-rw-r--r--tests/integration/metaserver/access_test.go (renamed from tests/intergration/metaserver/access_test.go)0
-rw-r--r--tests/integration/metaserver/main_test.go (renamed from tests/intergration/metaserver/main_test.go)2
9 files changed, 18 insertions, 21 deletions
diff --git a/cloud/pkg/dynamiccontroller/application/application.go b/cloud/pkg/dynamiccontroller/application/application.go
index 23be93804..df69a32b3 100644
--- a/cloud/pkg/dynamiccontroller/application/application.go
+++ b/cloud/pkg/dynamiccontroller/application/application.go
@@ -80,7 +80,7 @@ type PatchInfo struct {
// 0.use Agent.Generate to generate application
// 1.use Agent.Apply to apply application( generate msg and send it to cloud dynamiccontroller)
type Application struct {
- Id string
+ ID string
Key string // group version resource namespaces name
Verb applicationVerb
Nodename string
@@ -126,16 +126,16 @@ func newApplication(ctx context.Context, key string, verb applicationVerb, noden
}
func (a *Application) Identifier() string {
- if a.Id != "" {
- return a.Id
+ if a.ID != "" {
+ return a.ID
}
b := []byte(a.Nodename)
b = append(b, []byte(a.Key)...)
b = append(b, []byte(a.Verb)...)
b = append(b, a.Option...)
b = append(b, a.ReqBody...)
- a.Id = fmt.Sprintf("%x", md5.Sum(b))
- return a.Id
+ a.ID = fmt.Sprintf("%x", md5.Sum(b))
+ return a.ID
}
func (a *Application) String() string {
return fmt.Sprintf("(NodeName=%v;Key=%v;Verb=%v;Status=%v;Reason=%v)", a.Nodename, a.Key, a.Verb, a.Status, a.Reason)
@@ -299,7 +299,7 @@ func (a *Agent) doApply(app *Application) {
// encapsulate as a message
app.Status = InApplying
- msg := model.NewMessage("").SetRoute(MetaServerSource, modules.DynamicControllerModuleGroup).FillBody(*app)
+ msg := model.NewMessage("").SetRoute(MetaServerSource, modules.DynamicControllerModuleGroup).FillBody(app)
msg.SetResourceOperation("null", "null")
resp, err := beehiveContext.SendSync(edgehub.ModuleNameEdgeHub, *msg, 10*time.Second)
if err != nil {
@@ -499,7 +499,7 @@ func (c *Center) Response(app *Application, parentID string, status applicationS
}
msg := model.NewMessage(parentID)
- msg.Content = *app
+ msg.Content = app
resource, err := messagelayer.BuildResource(app.Nodename, Ignore, ApplicationResource, Ignore)
if err != nil {
klog.Warningf("built message resource failed with error: %s", err)
diff --git a/edge/pkg/metamanager/metaserver/handlerfactory/handler.go b/edge/pkg/metamanager/metaserver/handlerfactory/handler.go
index 358dc6dcf..e02dcc978 100644
--- a/edge/pkg/metamanager/metaserver/handlerfactory/handler.go
+++ b/edge/pkg/metamanager/metaserver/handlerfactory/handler.go
@@ -5,7 +5,6 @@ import (
"fmt"
"io"
"io/ioutil"
- "k8s.io/klog/v2"
"net/http"
"strings"
"time"
@@ -20,11 +19,11 @@ import (
"k8s.io/apiserver/pkg/endpoints/handlers"
"k8s.io/apiserver/pkg/endpoints/handlers/responsewriters"
"k8s.io/apiserver/pkg/endpoints/request"
- apirequest "k8s.io/apiserver/pkg/endpoints/request"
+ "k8s.io/klog/v2"
"github.com/kubeedge/kubeedge/cloud/pkg/dynamiccontroller/application"
"github.com/kubeedge/kubeedge/edge/pkg/metamanager/metaserver/kubernetes/fakers"
- . "github.com/kubeedge/kubeedge/edge/pkg/metamanager/metaserver/kubernetes/scope"
+ "github.com/kubeedge/kubeedge/edge/pkg/metamanager/metaserver/kubernetes/scope"
"github.com/kubeedge/kubeedge/edge/pkg/metamanager/metaserver/kubernetes/storage"
"github.com/kubeedge/kubeedge/pkg/metaserver/util"
)
@@ -41,7 +40,7 @@ func NewFactory() Factory {
utilruntime.Must(err)
f := Factory{
storage: s,
- scope: NewRequestScope(),
+ scope: scope.NewRequestScope(),
MinRequestTimeout: 1800 * time.Second,
handlers: make(map[string]http.Handler),
}
@@ -65,7 +64,7 @@ func (f *Factory) List() http.Handler {
}
func (f *Factory) Create(req *request.RequestInfo) http.Handler {
- s := NewRequestScope()
+ s := scope.NewRequestScope()
s.Kind = schema.GroupVersionKind{
Group: req.APIGroup,
Version: req.APIVersion,
@@ -85,7 +84,7 @@ func (f *Factory) Delete() http.Handler {
}
func (f *Factory) Update(req *request.RequestInfo) http.Handler {
- s := NewRequestScope()
+ s := scope.NewRequestScope()
s.Kind = schema.GroupVersionKind{
Group: req.APIGroup,
Version: req.APIVersion,
@@ -96,7 +95,7 @@ func (f *Factory) Update(req *request.RequestInfo) http.Handler {
}
func (f *Factory) Patch(reqInfo *request.RequestInfo) http.Handler {
- scope := wrapScope{RequestScope: NewRequestScope()}
+ scope := wrapScope{RequestScope: scope.NewRequestScope()}
scope.Kind = schema.GroupVersionKind{
Group: reqInfo.APIGroup,
Version: reqInfo.APIVersion,
@@ -147,7 +146,7 @@ func (f *Factory) Patch(reqInfo *request.RequestInfo) http.Handler {
}
options.TypeMeta.SetGroupVersionKind(metav1.SchemeGroupVersion.WithKind("PatchOptions"))
- reqInfo, _ := apirequest.RequestInfoFrom(req.Context())
+ reqInfo, _ := request.RequestInfoFrom(req.Context())
pi := application.PatchInfo{
Name: name,
PatchType: patchType,
diff --git a/edge/pkg/metamanager/metaserver/kubernetes/storage/storage.go b/edge/pkg/metamanager/metaserver/kubernetes/storage/storage.go
index fea219970..e3a4fe906 100644
--- a/edge/pkg/metamanager/metaserver/kubernetes/storage/storage.go
+++ b/edge/pkg/metamanager/metaserver/kubernetes/storage/storage.go
@@ -104,7 +104,7 @@ func (r *REST) Get(ctx context.Context, name string, options *metav1.GetOptions)
if err != nil {
obj, err = r.Store.Get(ctx, "", options) // name is needless, we get all key information from ctx
if err != nil {
- return nil, errors.NewNotFound(schema.GroupResource{info.APIGroup, info.Resource}, info.Name)
+ return nil, errors.NewNotFound(schema.GroupResource{Group: info.APIGroup, Resource: info.Resource}, info.Name)
}
klog.Infof("[metaserver/reststorage] successfully process get req (%v) at local", path)
}
diff --git a/pkg/metaserver/key.go b/pkg/metaserver/key.go
index c4794fee0..8b4ee0c54 100644
--- a/pkg/metaserver/key.go
+++ b/pkg/metaserver/key.go
@@ -87,7 +87,6 @@ func KeyFuncReq(ctx context.Context, _ string) (string, error) {
key += info.Name
} else {
key += v2.NullName
-
}
} else {
return "", fmt.Errorf("no request info in context")
diff --git a/tests/intergration/framework/cloud.go b/tests/integration/framework/cloud.go
index c6e6f8f0b..d9244b3d1 100644
--- a/tests/intergration/framework/cloud.go
+++ b/tests/integration/framework/cloud.go
@@ -26,7 +26,6 @@ func RunCloud(cfgModifyFn func(config *v1alpha1.CloudCoreConfig)) CloseFunc {
}
func RunCloudCore(cfg *v1alpha1.CloudCoreConfig) CloseFunc {
-
client.InitKubeEdgeClient(cfg.KubeAPIConfig)
gis := informers.GetInformersManager()
registerModules(cfg)
@@ -37,7 +36,7 @@ func RunCloudCore(cfg *v1alpha1.CloudCoreConfig) CloseFunc {
closeFn := func() {
beehiveContext.Cancel()
- for name, _ := range core.GetModules() {
+ for name := range core.GetModules() {
beehiveContext.Cleanup(name)
}
}
diff --git a/tests/intergration/framework/edge.go b/tests/integration/framework/edge.go
index d1f69103b..98e77c221 100644
--- a/tests/intergration/framework/edge.go
+++ b/tests/integration/framework/edge.go
@@ -23,7 +23,7 @@ func RunEdgeCore(config *v1alpha1.EdgeCoreConfig) CloseFunc {
closeFn := func() {
beehiveContext.Cancel()
- for name, _ := range core.GetModules() {
+ for name := range core.GetModules() {
beehiveContext.Cleanup(name)
}
}
diff --git a/tests/intergration/framework/util.go b/tests/integration/framework/util.go
index 3ddc17ecf..3ddc17ecf 100644
--- a/tests/intergration/framework/util.go
+++ b/tests/integration/framework/util.go
diff --git a/tests/intergration/metaserver/access_test.go b/tests/integration/metaserver/access_test.go
index e1805141b..e1805141b 100644
--- a/tests/intergration/metaserver/access_test.go
+++ b/tests/integration/metaserver/access_test.go
diff --git a/tests/intergration/metaserver/main_test.go b/tests/integration/metaserver/main_test.go
index b2349326b..531775b8b 100644
--- a/tests/intergration/metaserver/main_test.go
+++ b/tests/integration/metaserver/main_test.go
@@ -5,7 +5,7 @@ import (
cloudconfig "github.com/kubeedge/kubeedge/pkg/apis/componentconfig/cloudcore/v1alpha1"
edgeconfig "github.com/kubeedge/kubeedge/pkg/apis/componentconfig/edgecore/v1alpha1"
- "github.com/kubeedge/kubeedge/tests/intergration/framework"
+ "github.com/kubeedge/kubeedge/tests/integration/framework"
)
func TestMain(m *testing.M) {