Added provider for Zevenet loadbalancer

.dockerignore

@@ -2,3 +2,6 @@
 ./.dapper
 ./dist
 ./.trash-cache
+./Dockerfile.dapper*
+./external-lb.exe
+./providers/zevenet/zevenet_test.go

.gitignore

@@ -5,3 +5,5 @@ external-lb
 /dist
 *.swp
 /.trash-cache
+/Dockerfile.dapper*
+/external-lb.exe

main.go

@@ -15,6 +15,8 @@ import (
 	_ "github.com/rancher/external-lb/providers/avi"
 	_ "github.com/rancher/external-lb/providers/elbv1"
 	_ "github.com/rancher/external-lb/providers/f5"
+	_ "github.com/rancher/external-lb/providers/gravitee"
+	_ "github.com/rancher/external-lb/providers/zevenet"
 )
 
 const (
@@ -119,6 +121,19 @@ func main() {
 				continue
 			}
 
+			// filter regarding provider
+			if true {
+				metadataLBConfigsFiltered := make(map[string]model.LBConfig)
+
+				for k, v := range metadataLBConfigs {
+					if pn, ok := v.LBLabels["provider"]; !ok || strings.EqualFold(pn, *providerName) {
+						metadataLBConfigsFiltered[k] = v
+					}
+				}
+
+				metadataLBConfigs = metadataLBConfigsFiltered
+			}
+
 			logrus.Debugf("LB configs from metadata: %v", metadataLBConfigs)
 
 			// A flapping service might cause the metadata version to change

metadata/metadata.go

@@ -2,15 +2,17 @@ package metadata
 
 import (
 	"fmt"
+	"strings"
+	"time"
+
 	"github.com/Sirupsen/logrus"
 	"github.com/rancher/external-lb/model"
 	"github.com/rancher/go-rancher-metadata/metadata"
-	"strings"
-	"time"
 )
 
 const (
 	metadataURLTemplate        = "http://%v/2015-12-19"
+	serviceLabelsPrefix        = "io.rancher.service.external_lb."
 	serviceLabelEndpoint       = "io.rancher.service.external_lb.endpoint"
 	serviceLabelEndpointLegacy = "io.rancher.service.external_lb_endpoint"
 
@@ -109,7 +111,19 @@ func (m *MetadataClient) GetMetadataLBConfigs(targetPoolSuffix string) (map[stri
 				continue
 			}
 
+			// copy labels
+			labels := make(map[string]string)
+
+			for key, value := range service.Labels {
+				if strings.HasPrefix(key, serviceLabelsPrefix) {
+					newKey := key[len(serviceLabelsPrefix):]
+
+					labels[newKey] = value
+				}
+			}
+
 			lbConfig := model.LBConfig{}
+			lbConfig.LBLabels = labels
 			lbConfig.LBEndpoint = endpoint
 			lbConfig.LBTargetPort = portspec[0]
 			lbConfig.LBTargetPoolName = fmt.Sprintf("%s_%s_%s_%s", service.Name, service.StackName,

model/lb.go

@@ -9,6 +9,9 @@ type LBConfig struct {
 	LBTargetPoolName string
 	LBTargetPort     string
 	LBTargets        []LBTarget
+
+	// LBLabels contains all Rancher labels starting with "io.rancher.service.external_lb"
+	LBLabels map[string]string
 }
 
 type LBTarget struct {

providers/avi/aviutils.go

@@ -128,7 +128,12 @@ func formLBConfig(vs map[string]interface{},
 
 	vsName := vs["name"].(string)
 	poolName := pool["name"].(string)
-	return model.LBConfig{vsName, poolName, defaultPort, lbTargets}
+	return model.LBConfig{
+		LBEndpoint:       vsName,
+		LBTargetPoolName: poolName,
+		LBTargetPort:     defaultPort,
+		LBTargets:        lbTargets,
+	}
 }
 
 func GetVsFqdn(vs map[string]interface{}) (string, error) {

providers/gravitee/README.md

@@ -0,0 +1,30 @@
+# Gravitee Management API Provider
+
+## Labels (on Rancher services)
+
+The following labels are supported on backend container, which host the services to be added to the Gravitee API.
+
+| Label Name | Description | Example | Optional |
+|-----------|------|-------|-------|
+| io.rancher.service.external_lb.endpoint | Gravitee API label to look for. | my-fancy-api | No 
+| io.rancher.service.external_lb.provider | Has to be set to 'gravitee' to be handled by LB provider. Ignored if not set. | gravitee | Yes
+| io.rancher.service.external_lb.encrypt | The backend service port is an HTTPS endpoint and re-encryption is required. Default is false. | true | Yes 
+| io.rancher.service.external_lb.keep_alive | Requests to the backend service will use HTTP keep alive. Default is true. | false | Yes
+| io.rancher.service.external_lb.pipelining | Requests to the backend service will be written to connections without waiting for previous responses to return. Default is false. | true | Yes
+| io.rancher.service.external_lb.compress | Enables gzip compression support, and will be able to handle compressed response bodies. Default is true. | false | Yes
+| io.rancher.service.external_lb.follow_redirects | Follows redirects returned by the backend service. Default is false. | true | Yes
+| io.rancher.service.external_lb.conn_timeout | Time in milliseconds to wait for the backend service to accept the connection. Default is 5000. | 10000 | Yes
+| io.rancher.service.external_lb.read_timeout | Time in milliseconds to wait for the backend service to start sending the response. Default is 10000. | 60000 | Yes
+| io.rancher.service.external_lb.idle_timeout | Time in milliseconds to wait for an idle connection to be closed. Default is 60000. | 60000 | Yes
+| io.rancher.service.external_lb.max_conn | Maximum amount of concurrent connections to a single backend service. Default is 100. | 5000 | Yes
+
+Important: The `io.rancher.service.external_lb.endpoint` has to exist to trigger the load-balancer integration.
+
+## Environment Variables
+
+| Variable Name | Description | Default Value   | Optional   |
+|-----------|------|-------|------|
+| GRAVITEE_HOST | The hostname of the Gravitee Management API, like *api.mygravitee.net* or *http://my-gravitee:8080* |   | No  |
+| GRAVITEE_USER | The name of the user to user for Management API access.  |   | No    |
+| GRAVITEE_PWD | The password of the user to user for Management API access.  |   | No    |
+| LB_TARGET_RANCHER_SUFFIX | Service names in the farm will have this suffix. Choose something simple, like "rancher". | "rancher.internal" | Yes |