From 8295a28f6d6e14f5adb62138271de393015061e9 Mon Sep 17 00:00:00 2001 From: Ritu Sood Date: Tue, 6 Aug 2019 19:35:42 -0700 Subject: Use controller runtime and operator sdk Changing the framework to use controller runtime and operator sdk. This allows to add CRD controllers for Network, Provider Network etc in the same operator. Binary renamed to nfn-operator (Network funtion networking). Change-Id: Ic25a3c3f5f1418fc0614f3aede48b41d9c1156cd Signed-off-by: Ritu Sood --- cmd/ovn4nfvk8s-cni/ovn4nfvk8s-cni.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) (limited to 'cmd/ovn4nfvk8s-cni') diff --git a/cmd/ovn4nfvk8s-cni/ovn4nfvk8s-cni.go b/cmd/ovn4nfvk8s-cni/ovn4nfvk8s-cni.go index 3a6b7f0..2585fcf 100644 --- a/cmd/ovn4nfvk8s-cni/ovn4nfvk8s-cni.go +++ b/cmd/ovn4nfvk8s-cni/ovn4nfvk8s-cni.go @@ -26,6 +26,10 @@ import ( "ovn4nfv-k8s-plugin/internal/pkg/config" ) +const ( + ovn4nfvAnnotationTag = "k8s.plugin.opnfv.org/ovnInterfaces" +) + func argString2Map(args string) (map[string]string, error) { argsMap := make(map[string]string) @@ -110,7 +114,7 @@ func addMultipleInterfaces(args *skel.CmdArgs, ovnAnnotation, namespace, podName var ovnAnnotatedMap []map[string]string ovnAnnotatedMap, err := parseOvnNetworkObject(ovnAnnotation) if err != nil { - logrus.Errorf("addLogicalPort : Error Parsing Ovn Network List %v", ovnAnnotatedMap) + logrus.Errorf("addLogicalPort : Error Parsing Ovn Network List %v %v", ovnAnnotatedMap, err) return nil } if namespace == "" || podName == "" { @@ -275,7 +279,7 @@ func cmdAdd(args *skel.CmdArgs) error { logrus.Warningf("Error while obtaining pod annotations - %v", err) return false, nil } - if _, ok := annotation["ovnIfaceList"]; ok { + if _, ok := annotation[ovn4nfvAnnotationTag]; ok { return true, nil } return false, nil @@ -283,7 +287,7 @@ func cmdAdd(args *skel.CmdArgs) error { return fmt.Errorf("failed to get pod annotation - %v", err) } logrus.Infof("ovn4nfvk8s-cni: Annotation Found ") - ovnAnnotation, ok := annotation["ovnIfaceList"] + ovnAnnotation, ok := annotation[ovn4nfvAnnotationTag] if !ok { return fmt.Errorf("Error while obtaining pod annotations") } @@ -326,7 +330,7 @@ func main() { return err } - skel.PluginMain(cmdAdd, cmdDel, version.All) + skel.PluginMain(cmdAdd, nil, cmdDel, version.All, "") return nil } -- cgit 1.2.3-korg