Auto create cni default network

Signed-off-by: Abhinandan Prativadi <abhi@docker.com>

Author: abhi

client/network.go

@@ -85,7 +85,7 @@ func (cli *NetworkCli) CmdNetworkCreate(chain string, args ...string) error {
 	}
 
 	// Construct network create request body
-	nc := networkCreate{Name: cmd.Arg(0), NetworkType: *flDriver, ID: *flID, IPv4Conf: icList, DriverOpts: driverOpts, NetworkOpts: networkOpts}
+	nc := NetworkCreate{Name: cmd.Arg(0), NetworkType: *flDriver, ID: *flID, IPv4Conf: icList, DriverOpts: driverOpts, NetworkOpts: networkOpts}
 	obj, _, err := readBody(cli.call("POST", "/networks", nc, nil))
 	if err != nil {
 		return err
@@ -137,7 +137,7 @@ func (cli *NetworkCli) CmdNetworkLs(chain string, args ...string) error {
 		*last = 1
 	}
 
-	var networkResources []networkResource
+	var networkResources []NetworkResource
 	err = json.Unmarshal(obj, &networkResources)
 	if err != nil {
 		return err
@@ -189,7 +189,7 @@ func (cli *NetworkCli) CmdNetworkInfo(chain string, args ...string) error {
 	if err != nil {
 		return err
 	}
-	networkResource := &networkResource{}
+	networkResource := &NetworkResource{}
 	if err := json.NewDecoder(bytes.NewReader(obj)).Decode(networkResource); err != nil {
 		return err
 	}
@@ -222,7 +222,7 @@ func lookupNetworkID(cli *NetworkCli, nameID string) (string, error) {
 		return "", fmt.Errorf("name query failed for %s due to : statuscode(%d) %v", nameID, statusCode, string(obj))
 	}
 
-	var list []*networkResource
+	var list []*NetworkResource
 	err = json.Unmarshal(obj, &list)
 	if err != nil {
 		return "", err

client/service.go

@@ -33,7 +33,7 @@ func lookupServiceID(cli *NetworkCli, nwName, svNameID string) (string, error) {
 	if err != nil {
 		return "", err
 	}
-	var nwList []networkResource
+	var nwList []NetworkResource
 	if err = json.Unmarshal(obj, &nwList); err != nil {
 		return "", err
 	}
@@ -46,7 +46,7 @@ func lookupServiceID(cli *NetworkCli, nwName, svNameID string) (string, error) {
 		if err != nil {
 			return "", err
 		}
-		networkResource := &networkResource{}
+		networkResource := &NetworkResource{}
 		if err := json.NewDecoder(bytes.NewReader(obj)).Decode(networkResource); err != nil {
 			return "", err
 		}

client/types.go

@@ -10,8 +10,8 @@ import (
  Resources
 ************/
 
-// networkResource is the body of the "get network" http response message
-type networkResource struct {
+// NetworkResource is the body of the "get network" http response message
+type NetworkResource struct {
 	Name     string             `json:"name"`
 	ID       string             `json:"id"`
 	Type     string             `json:"type"`
@@ -42,8 +42,8 @@ type ipamConf struct {
 	AuxAddresses  map[string]string
 }
 
-// networkCreate is the expected body of the "create network" http request message
-type networkCreate struct {
+// NetworkCreate is the expected body of the "create network" http request message
+type NetworkCreate struct {
 	Name        string            `json:"name"`
 	ID          string            `json:"id"`
 	NetworkType string            `json:"network_type"`

config/config.go

@@ -77,6 +77,10 @@ func ParseConfig(tomlCfgFile string) (*Config, error) {
 	if cfg.Cluster.Discovery == "" {
 		cfg.Cluster.Discovery = os.Getenv("DNET_DISCOVERY")
 	}
+	//TODO (ABHI): Handle this better. default to etcd for now
+	if !(strings.Contains(cfg.Cluster.Discovery, "etcd") || strings.Contains(cfg.Cluster.Discovery, "consul")) {
+		cfg.Cluster.Discovery = "etcd://" + cfg.Cluster.Discovery
+	}
 	fmt.Printf("cluster address=%s, discovery=%s \n", cfg.Cluster.Address, cfg.Cluster.Discovery)
 
 	if _, ok := cfg.Scopes[datastore.GlobalScope]; !ok {

pkg/cniapi/api.go

@@ -56,7 +56,7 @@ func (l *LibNetCniClient) SetupPod(args *skel.CmdArgs) (*current.Result, error)
 	log.Infof("Received Setup Pod %+v", args)
 	podNetInfo, err := validatePodNetworkInfo(args)
 	if err != nil {
-		return nil, fmt.Errorf("failed to valid cni arguements, error: %v", err)
+		return nil, fmt.Errorf("failed to valid cni arguments, error: %v", err)
 	}
 	buf, err := json.Marshal(podNetInfo)
 	if err != nil {
@@ -110,7 +110,7 @@ func (l *LibNetCniClient) TearDownPod(args *skel.CmdArgs) error {
 	log.Infof("Received Teardown Pod request %+v", args)
 	podNetInfo, err := validatePodNetworkInfo(args)
 	if err != nil {
-		return fmt.Errorf("failed to valid cni arguements, error: %v", err)
+		return fmt.Errorf("failed to valid cni arguments, error: %v", err)
 	}
 	buf, err := json.Marshal(podNetInfo)
 	if err != nil {

pkg/server/cniserver/add_pod.go

@@ -106,6 +106,14 @@ func createSandbox(ContainerID, netns string) (string, error) {
 
 func createEndpoint(ContainerID string, netConfig types.NetConf) (client.EndpointInfo, error) {
 	var ep client.EndpointInfo
+	// Create network if it doesnt exist. Need to handle refcount to delete
+	// network on last pod delete. Also handle different network types and option
+	if !networkExists(netConfig.Name) {
+		if err := createNetwork(netConfig.Name, "overlay"); err != nil {
+			return ep, err
+		}
+	}
+
 	sc := client.ServiceCreate{Name: ContainerID, Network: netConfig.Name, DisableResolution: true}
 	obj, _, err := readBody(httpCall("POST", "/services", sc, nil))
 	if err != nil {
@@ -123,3 +131,43 @@ func endpointJoin(sandboxID, endpointID, netns string) (retErr error) {
 
 	return err
 }
+
+func networkExists(networkName string) bool {
+	fmt.Printf("Check if %s network exists \n", networkName)
+	obj, statusCode, err := readBody(httpCall("GET", "/networks?name="+networkName, nil, nil))
+	if err != nil {
+		fmt.Printf("%s network does not exists \n", networkName)
+		return false
+	}
+	if statusCode != http.StatusOK {
+		fmt.Printf("%s network does not exists \n", networkName)
+		return false
+	}
+	var list []*client.NetworkResource
+	err = json.Unmarshal(obj, &list)
+	if err != nil {
+		return false
+	}
+	fmt.Printf("%s network exists \n", networkName)
+	return (len(list) != 0)
+}
+
+// createNetwork is a very simple utility to create a default network
+// if not present. This needs to be expanded into a more full utility function
+func createNetwork(networkName string, driver string) error {
+	fmt.Printf("Creating a network %s driver: %s \n", networkName, driver)
+	driverOpts := make(map[string]string)
+	driverOpts["hostaccess"] = ""
+	nc := client.NetworkCreate{Name: networkName, NetworkType: driver,
+		DriverOpts: driverOpts}
+	obj, _, err := readBody(httpCall("POST", "/networks", nc, nil))
+	if err != nil {
+		return err
+	}
+	var replyID string
+	err = json.Unmarshal(obj, &replyID)
+	if err != nil {
+		return err
+	}
+	return nil
+}