fix: fix legacy issues of #549 (#604)

Signed-off-by: seeflood <[email protected]>

Author: seeflood

components/custom/registry.go

@@ -64,14 +64,14 @@ func (r *componentRegistry) Register(kind string, fs ...*ComponentFactory) {
 	}
 }
 
-func (r *componentRegistry) Create(compType, name string) (Component, error) {
-	store, ok := r.stores[compType]
+func (r *componentRegistry) Create(kind, compType string) (Component, error) {
+	store, ok := r.stores[kind]
 	if !ok {
-		return nil, fmt.Errorf("custom component type %s is not regsitered", compType)
+		return nil, fmt.Errorf("custom component kind %s is not regsitered", kind)
 	}
-	if f, ok := store[name]; ok {
-		r.info.LoadComponent(compType, name)
+	if f, ok := store[compType]; ok {
+		r.info.LoadComponent(kind, compType)
 		return f(), nil
 	}
-	return nil, fmt.Errorf("custom component %s is not regsitered", name)
+	return nil, fmt.Errorf("custom component %s is not regsitered", compType)
 }

pkg/runtime/runtime.go

@@ -586,7 +586,7 @@ func (m *MosnRuntime) initCustomComponents(kind2factorys map[string][]*custom.Co
 		}
 		name2Config, ok := m.runtimeConfig.CustomComponent[kind]
 		if !ok {
-			log.DefaultLogger.Errorf("[runtime] Your required component type %s is not supported.Please check your configuration", kind)
+			log.DefaultLogger.Errorf("[runtime] Your required component kind %s is not supported. Please check your configuration", kind)
 			continue
 		}
 		// 2.1. register all the factorys

sdk/go-sdk/client/client_test.go

@@ -269,40 +269,34 @@ func (*testRuntimeServer) GetBulkSecret(ctx context.Context, in *runtimev1pb.Get
 }
 
 func (t *testRuntimeServer) TryLock(ctx context.Context, in *runtimev1pb.TryLockRequest) (*runtimev1pb.TryLockResponse, error) {
-
 	if len(t.lock[in.ResourceId]) == 0 {
 		t.lock[in.ResourceId] = in.LockOwner
-		resp := &runtimev1pb.TryLockResponse{
+		return &runtimev1pb.TryLockResponse{
 			Success: true,
-		}
-		return resp, nil
-	} else {
-		resp := &runtimev1pb.TryLockResponse{
-			Success: false,
-		}
-		return resp, nil
+		}, nil
 	}
+	// lock exist
+	return &runtimev1pb.TryLockResponse{
+		Success: false,
+	}, nil
 }
 
 func (t *testRuntimeServer) Unlock(ctx context.Context, in *runtimev1pb.UnlockRequest) (*runtimev1pb.UnlockResponse, error) {
-	if len(t.lock[in.ResourceId]) != 0 {
-		if t.lock[in.ResourceId] == in.LockOwner {
-			delete(t.lock, in.ResourceId)
-			resp := &runtimev1pb.UnlockResponse{
-				Status: pb.UnlockResponse_SUCCESS,
-			}
-			return resp, nil
-		} else {
-			resp := &runtimev1pb.UnlockResponse{
-				Status: pb.UnlockResponse_LOCK_BELONG_TO_OTHERS,
-			}
-			return resp, nil
-		}
-
-	} else {
-		resp := &runtimev1pb.UnlockResponse{
+	// LOCK_UNEXIST
+	if len(t.lock[in.ResourceId]) == 0 {
+		return &runtimev1pb.UnlockResponse{
 			Status: pb.UnlockResponse_LOCK_UNEXIST,
-		}
-		return resp, nil
+		}, nil
 	}
+	// SUCCESS
+	if t.lock[in.ResourceId] == in.LockOwner {
+		delete(t.lock, in.ResourceId)
+		return &runtimev1pb.UnlockResponse{
+			Status: pb.UnlockResponse_SUCCESS,
+		}, nil
+	}
+	// LOCK_BELONG_TO_OTHERS
+	return &runtimev1pb.UnlockResponse{
+		Status: pb.UnlockResponse_LOCK_BELONG_TO_OTHERS,
+	}, nil
 }