1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
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)
}
|
