From 53279580afc48c90cbd28ab61799d9e81e41fffa Mon Sep 17 00:00:00 2001 From: Ritu Sood Date: Fri, 27 Sep 2019 12:33:48 -0700 Subject: Adding gRPC proto and server gRPC server is required to send updates to nfn-agent running on all the nodes in the cluster, to setup provider networks as defined in the provider network CR. This patch includes proto file and generated code along with gRPC server code Change-Id: I891629d84932ae662ba7545ebfe4d9921448fdc1 Signed-off-by: Ritu Sood --- cmd/nfn-operator/nfn-operator.go | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) (limited to 'cmd/nfn-operator') diff --git a/cmd/nfn-operator/nfn-operator.go b/cmd/nfn-operator/nfn-operator.go index 4749506..acd5924 100644 --- a/cmd/nfn-operator/nfn-operator.go +++ b/cmd/nfn-operator/nfn-operator.go @@ -10,8 +10,9 @@ import ( _ "k8s.io/client-go/plugin/pkg/client/auth" "github.com/spf13/pflag" - "ovn4nfv-k8s-plugin/pkg/apis" + notif "ovn4nfv-k8s-plugin/internal/pkg/nfnNotify" "ovn4nfv-k8s-plugin/internal/pkg/ovn" + "ovn4nfv-k8s-plugin/pkg/apis" "ovn4nfv-k8s-plugin/pkg/controller" "sigs.k8s.io/controller-runtime/pkg/client/config" "sigs.k8s.io/controller-runtime/pkg/log/zap" @@ -48,8 +49,8 @@ func main() { printVersion() // Create an OVN Controller - _, err := ovn.NewOvnController(nil) - if err != nil { + _, err := ovn.NewOvnController(nil) + if err != nil { log.Error(err, "") os.Exit(1) } @@ -61,6 +62,10 @@ func main() { log.Error(err, "") os.Exit(1) } + + // Start GRPC Notification Server + go notif.SetupNotifServer(cfg) + // Create a new Cmd to provide shared dependencies and start components mgr, err := manager.New(cfg, manager.Options{}) if err != nil { @@ -88,4 +93,5 @@ func main() { log.Error(err, "Manager exited non-zero") os.Exit(1) } + } -- cgit 1.2.3-korg