1 files changed, 66 insertions, 0 deletions
diff --git a/msb2pilot/src/msb2pilot/pilot/controller.go b/msb2pilot/src/msb2pilot/pilot/controller.go
new file mode 100644
index 0000000..d931605
--- /dev/null
+++ b/msb2pilot/src/msb2pilot/pilot/controller.go
@@ -0,0 +1,66 @@
+/**
+ * Copyright (c) 2018 ZTE Corporation.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * and the Apache License 2.0 which both accompany this distribution,
+ * and are available at http://www.eclipse.org/legal/epl-v10.html
+ * and http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Contributors:
+ *     ZTE - initial Project
+ */
+package pilot
+
+import (
+	"errors"
+	"msb2pilot/log"
+
+	"istio.io/istio/pilot/pkg/config/kube/crd"
+	"istio.io/istio/pilot/pkg/model"
+)
+
+type Operation string
+
+var (
+	client *crd.Client
+)
+
+func init() {
+	var err error
+	client, err = crd.NewClient("k8s.yml", model.ConfigDescriptor{
+		model.RouteRule,
+		model.DestinationPolicy,
+		model.DestinationRule,
+	}, "")
+
+	if err != nil {
+		log.Log.Error("fail to init crd", err)
+	}
+}
+
+func Get(typ, namespace, name string) (*model.Config, bool) {
+	proto, err := protoSchema(typ)
+	if err != nil {
+		log.Log.Informational("get resource error", err)
+		return &model.Config{}, false
+	}
+	return client.Get(proto.Type, name, namespace)
+}
+
+func protoSchema(typ string) (model.ProtoSchema, error) {
+	for _, desc := range client.ConfigDescriptor() {
+		switch typ {
+		case crd.ResourceName(desc.Type), crd.ResourceName(desc.Plural):
+			return desc, nil
+		}
+	}
+	return model.ProtoSchema{}, errors.New("can not find this kind of resources:[" + typ + "]")
+}
+
+func List(typ, namespace string) ([]model.Config, error) {
+	proto, err := protoSchema(typ)
+	if err != nil {
+		return nil, err
+	}
+	return client.List(proto.Type, namespace)
+}