-
Notifications
You must be signed in to change notification settings - Fork 431
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: add simple gateway implementation
- Loading branch information
Showing
8 changed files
with
423 additions
and
10 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,59 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "bitbucket.org/mathildetech/kube-ovn/pkg/gateway" | ||
| "bitbucket.org/mathildetech/kube-ovn/pkg/ovs" | ||
| "bitbucket.org/mathildetech/kube-ovn/pkg/util" | ||
| "github.com/vishvananda/netlink" | ||
| "k8s.io/klog" | ||
| "os" | ||
| ) | ||
|
|
||
| func main() { | ||
| klog.SetOutput(os.Stdout) | ||
| defer klog.Flush() | ||
|
|
||
| config, err := gateway.ParseFlags() | ||
| if err != nil { | ||
| klog.Errorf("parse config failed %v", err) | ||
| os.Exit(1) | ||
| } | ||
|
|
||
| bridge, err := util.NicToBridge(config.Interface) | ||
| if err != nil { | ||
| klog.Errorf("failed to move nic to bridge %v", err) | ||
| os.Exit(1) | ||
| } | ||
| klog.Infof("create bridge %v for gw", bridge) | ||
|
|
||
| ovnClient := ovs.NewClient(config.OvnNbHost, config.OvnNbPort, config.OvnSbHost, config.OvnSbPort, "", "", "") | ||
|
|
||
| err = ovnClient.CreateGatewayRouter(config.EdgeRouterName, config.Chassis) | ||
| if err != nil { | ||
| klog.Errorf("failed to crate gateway router %v", err) | ||
| os.Exit(1) | ||
| } | ||
|
|
||
| err = ovnClient.CreateTransitLogicalSwitch(config.TransitSwitchName, config.ClusterRouterName, config.EdgeRouterName, config.ClusterRouterIP, config.EdgeRouterIP) | ||
| if err != nil { | ||
| klog.Errorf("failed to connect edge and cluster by transit %v", err) | ||
| os.Exit(1) | ||
| } | ||
|
|
||
| addrList, err := netlink.AddrList(bridge, netlink.FAMILY_V4) | ||
| if err != nil { | ||
| klog.Errorf("failed to list %s addr %v", bridge, err) | ||
| os.Exit(1) | ||
| } | ||
| if len(addrList) == 0 { | ||
| klog.Errorf("nic %s has no ip address", bridge) | ||
| os.Exit(1) | ||
| } | ||
|
|
||
| err = ovnClient.CreateOutsideLogicalSwitch(config.OutsideSwitchName, config.EdgeRouterName, addrList[0].IPNet.String(), bridge.Attrs().HardwareAddr.String()) | ||
| if err != nil { | ||
| klog.Errorf("failed to connect edge to outside %v", err) | ||
| os.Exit(1) | ||
| } | ||
| return | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,61 @@ | ||
| package gateway | ||
|
|
||
| import ( | ||
| "flag" | ||
| "github.com/spf13/pflag" | ||
| ) | ||
|
|
||
| type Configuration struct { | ||
| Interface string | ||
| SnatIP string | ||
| ClusterRouterIP string | ||
| EdgeRouterName string | ||
| EdgeRouterIP string | ||
| Chassis string | ||
| TransitSwitchName string | ||
| OutsideSwitchName string | ||
| ClusterRouterName string | ||
| OvnNbHost string | ||
| OvnNbPort int | ||
| OvnSbHost string | ||
| OvnSbPort int | ||
| } | ||
|
|
||
| func ParseFlags() (*Configuration, error) { | ||
| var ( | ||
| argInterface = pflag.String("interface", "eth0", "The gateway interface") | ||
| argSnatIP = pflag.String("snat-ip", "", "The snat ip") | ||
| argClusterRouterIP = pflag.String("cluster-router-ip", "172.16.255.2/30", "The cluster route to transit switch ip") | ||
| argEdgeRouterIP = pflag.String("edge-router-ip", "172.16.255.1/30", "The edge router to transit switch ip") | ||
| argChassis = pflag.String("chassis", "", "chassis id found in ovn-sb") | ||
| argTransitSwitchName = pflag.String("transit-switch-name", "transit", "The name of switch between cluster router and edge router.") | ||
| argOutsideSwitchName = pflag.String("outside-switch-name", "outside", "The name of switch between edge router and physic interface.") | ||
| argEdgeRouterName = pflag.String("edge-router-name", "edge", "The edge router name") | ||
| argClusterRouterName = pflag.String("cluster-router-name", "ovn-cluster", "The cluster router name") | ||
| argOvnNbHost = pflag.String("ovn-nb-host", "", "") | ||
| argOvnNbPort = pflag.Int("ovn-nb-port", 6641, "") | ||
| argOvnSbHost = pflag.String("ovn-sb-host", "", "") | ||
| argOvnSbPort = pflag.Int("ovn-sb-port", 6642, "") | ||
| ) | ||
| pflag.CommandLine.AddGoFlagSet(flag.CommandLine) | ||
| pflag.Parse() | ||
| flag.CommandLine.Parse(make([]string, 0)) | ||
|
|
||
| config := &Configuration{ | ||
| Interface: *argInterface, | ||
| SnatIP: *argSnatIP, | ||
| ClusterRouterIP: *argClusterRouterIP, | ||
| EdgeRouterIP: *argEdgeRouterIP, | ||
| EdgeRouterName: *argEdgeRouterName, | ||
| Chassis: *argChassis, | ||
| TransitSwitchName: *argTransitSwitchName, | ||
| ClusterRouterName: *argClusterRouterName, | ||
| OutsideSwitchName: *argOutsideSwitchName, | ||
| OvnNbHost: *argOvnNbHost, | ||
| OvnNbPort: *argOvnNbPort, | ||
| OvnSbHost: *argOvnSbHost, | ||
| OvnSbPort: *argOvnSbPort, | ||
| } | ||
|
|
||
| return config, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.