Provide a runtime API

README.md

@@ -33,6 +33,10 @@ clusters:
     # insecure: set true when the cluster CA is self-signed
     insecure_disable_certificate_verify: false
 
+api: # optional
+  enabled: false # set true to enable api to get insights
+  address: "localhost:6655" # default, optional
+
 bgp:
   router_id: "10.0.1.1"
   local_as: 45678

go.mod

@@ -6,6 +6,7 @@ require (
 	github.com/bio-routing/bio-rd v0.0.3-pre7
 	github.com/pkg/errors v0.9.1
 	github.com/sirupsen/logrus v1.4.2
+	google.golang.org/grpc v1.28.0
 	gopkg.in/yaml.v2 v2.4.0
 	k8s.io/api v0.21.0
 	k8s.io/client-go v0.21.0

main.go

@@ -3,21 +3,30 @@ package main
 import (
 	"context"
 	"flag"
+	"net"
 	"os"
 	"os/signal"
 	"syscall"
 
 	bnet "github.com/bio-routing/bio-rd/net"
+	bgpapi "github.com/bio-routing/bio-rd/protocols/bgp/api"
 	bgp "github.com/bio-routing/bio-rd/protocols/bgp/server"
 	"github.com/ffddorf/kube-route-reflector/reflector"
 	"github.com/ffddorf/kube-route-reflector/watcher"
 	"github.com/sirupsen/logrus"
+	"google.golang.org/grpc"
 	"gopkg.in/yaml.v2"
 )
 
+type APIConfig struct {
+	Enabled bool   `yaml:"enabled"`
+	Address string `yaml:"address"`
+}
+
 type Config struct {
 	Clusters []watcher.KubernetesConfig `yaml:"clusters"`
 	BGP      reflector.BGPConfig        `yaml:"bgp"`
+	API      APIConfig                  `yaml:"api"`
 }
 
 func loadConfig(path string) (*Config, error) {
@@ -60,6 +69,11 @@ func main() {
 		"[::]:179",
 		"0.0.0.0:179",
 	})
+	if conf.API.Enabled {
+		if err := startBGPAPI(bgpServer, conf.API.Address); err != nil {
+			log.WithError(err).Fatal("failed to start api server")
+		}
+	}
 
 	server := reflector.NewServer(log.WithField("component", "reflector"), bgpServer, conf.BGP)
 	if err := server.Start(log); err != nil {
@@ -72,3 +86,21 @@ func main() {
 
 	watcher.WatchClusters(ctx, log, conf.Clusters, server)
 }
+
+func startBGPAPI(server bgp.BGPServer, address string) error {
+	grpcServer := grpc.NewServer()
+
+	api := bgp.NewBGPAPIServer(server)
+	bgpapi.RegisterBgpServiceServer(grpcServer, api)
+
+	if address == "" {
+		address = "localhost:5566"
+	}
+
+	lis, err := net.Listen("tcp", address)
+	if err != nil {
+		return err
+	}
+	go grpcServer.Serve(lis)
+	return nil
+}