internal/pkg/node/node.go

   1 package node
   2
   3 import (
   4         "ovn4nfv-k8s-plugin/internal/pkg/ovn"
   5
   6         logf "sigs.k8s.io/controller-runtime/pkg/runtime/log"
   7 )
   8
   9 var log = logf.Log.WithName("node")
  10
  11 //AddNodeLogicalPorts return nodeIntfMacAddr and nodeIntfIPAddr
  12 func AddNodeLogicalPorts(node string) (nodeIntfMacAddr, nodeIntfIPAddr string, err error) {
  13         ovnCtl, err := ovn.GetOvnController()
  14         if err != nil {
  15                 return "", "", err
  16         }
  17
  18         log.Info("Calling CreateNodeLogicalPorts")
  19         nodeIntfMacAddr, nodeIntfIPAddr, err = ovnCtl.AddNodeLogicalPorts(node)
  20         if err != nil {
  21                 return "", "", err
  22         }
  23         return nodeIntfMacAddr, nodeIntfIPAddr, nil
  24 }
  25
  26 //DeleteNodeLogicalPorts return nil
  27 func DeleteNodeLogicalPorts(name, namesapce string) error {
  28         // Run delete for all controllers;
  29         // Todo
  30         return nil
  31 }