Adds Kubernetes provider support

cmd/configuration.go

@@ -14,13 +14,13 @@ import (
 	"github.com/containous/traefik/old/provider/ecs"
 	"github.com/containous/traefik/old/provider/etcd"
 	"github.com/containous/traefik/old/provider/eureka"
-	"github.com/containous/traefik/old/provider/kubernetes"
 	"github.com/containous/traefik/old/provider/mesos"
 	"github.com/containous/traefik/old/provider/rancher"
 	"github.com/containous/traefik/old/provider/zk"
 	"github.com/containous/traefik/ping"
 	"github.com/containous/traefik/provider/docker"
 	"github.com/containous/traefik/provider/file"
+	"github.com/containous/traefik/provider/kubernetes"
 	"github.com/containous/traefik/provider/marathon"
 	"github.com/containous/traefik/provider/rest"
 	"github.com/containous/traefik/tracing/datadog"

cmd/traefik/traefik.go

@@ -27,9 +27,9 @@ import (
 	"github.com/containous/traefik/job"
 	"github.com/containous/traefik/log"
 	"github.com/containous/traefik/old/provider/ecs"
-	"github.com/containous/traefik/old/provider/kubernetes"
 	oldtypes "github.com/containous/traefik/old/types"
 	"github.com/containous/traefik/provider/aggregator"
+	"github.com/containous/traefik/provider/kubernetes"
 	"github.com/containous/traefik/safe"
 	"github.com/containous/traefik/server"
 	"github.com/containous/traefik/server/router"

config/static/static_config.go

@@ -15,14 +15,14 @@ import (
 	"github.com/containous/traefik/old/provider/ecs"
 	"github.com/containous/traefik/old/provider/etcd"
 	"github.com/containous/traefik/old/provider/eureka"
-	"github.com/containous/traefik/old/provider/kubernetes"
 	"github.com/containous/traefik/old/provider/mesos"
 	"github.com/containous/traefik/old/provider/rancher"
 	"github.com/containous/traefik/old/provider/zk"
 	"github.com/containous/traefik/ping"
 	acmeprovider "github.com/containous/traefik/provider/acme"
 	"github.com/containous/traefik/provider/docker"
 	"github.com/containous/traefik/provider/file"
+	"github.com/containous/traefik/provider/kubernetes"
 	"github.com/containous/traefik/provider/marathon"
 	"github.com/containous/traefik/provider/rest"
 	"github.com/containous/traefik/tls"

provider/aggregator/aggregator.go

@@ -35,6 +35,10 @@ func NewProviderAggregator(conf static.Providers) ProviderAggregator {
 		p.quietAddProvider(conf.Rest)
 	}
 
+	if conf.Kubernetes != nil {
+		p.quietAddProvider(conf.Kubernetes)
+	}
+
 	return p
 }
 

provider/kubernetes/builder_endpoint_test.go

@@ -0,0 +1,158 @@
+package kubernetes
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/types"
+)
+
+func buildEndpoint(opts ...func(*corev1.Endpoints)) *corev1.Endpoints {
+	e := &corev1.Endpoints{}
+	for _, opt := range opts {
+		opt(e)
+	}
+	return e
+}
+
+func eNamespace(value string) func(*corev1.Endpoints) {
+	return func(i *corev1.Endpoints) {
+		i.Namespace = value
+	}
+}
+
+func eName(value string) func(*corev1.Endpoints) {
+	return func(i *corev1.Endpoints) {
+		i.Name = value
+	}
+}
+
+func eUID(value types.UID) func(*corev1.Endpoints) {
+	return func(i *corev1.Endpoints) {
+		i.UID = value
+	}
+}
+
+func subset(opts ...func(*corev1.EndpointSubset)) func(*corev1.Endpoints) {
+	return func(e *corev1.Endpoints) {
+		s := &corev1.EndpointSubset{}
+		for _, opt := range opts {
+			opt(s)
+		}
+		e.Subsets = append(e.Subsets, *s)
+	}
+}
+
+func eAddresses(opts ...func(*corev1.EndpointAddress)) func(*corev1.EndpointSubset) {
+	return func(subset *corev1.EndpointSubset) {
+		for _, opt := range opts {
+			a := &corev1.EndpointAddress{}
+			opt(a)
+			subset.Addresses = append(subset.Addresses, *a)
+		}
+	}
+}
+
+func eAddress(ip string) func(*corev1.EndpointAddress) {
+	return func(address *corev1.EndpointAddress) {
+		address.IP = ip
+	}
+}
+
+func eAddressWithTargetRef(targetRef, ip string) func(*corev1.EndpointAddress) {
+	return func(address *corev1.EndpointAddress) {
+		address.TargetRef = &corev1.ObjectReference{Name: targetRef}
+		address.IP = ip
+	}
+}
+
+func ePorts(opts ...func(port *corev1.EndpointPort)) func(*corev1.EndpointSubset) {
+	return func(spec *corev1.EndpointSubset) {
+		for _, opt := range opts {
+			p := &corev1.EndpointPort{}
+			opt(p)
+			spec.Ports = append(spec.Ports, *p)
+		}
+	}
+}
+
+func ePort(port int32, name string) func(*corev1.EndpointPort) {
+	return func(sp *corev1.EndpointPort) {
+		sp.Port = port
+		sp.Name = name
+	}
+}
+
+// Test
+
+func TestBuildEndpoint(t *testing.T) {
+	actual := buildEndpoint(
+		eNamespace("testing"),
+		eName("service3"),
+		eUID("3"),
+		subset(
+			eAddresses(eAddress("10.15.0.1")),
+			ePorts(
+				ePort(8080, "http"),
+				ePort(8443, "https"),
+			),
+		),
+		subset(
+			eAddresses(eAddress("10.15.0.2")),
+			ePorts(
+				ePort(9080, "http"),
+				ePort(9443, "https"),
+			),
+		),
+	)
+
+	assert.EqualValues(t, sampleEndpoint1(), actual)
+}
+
+func sampleEndpoint1() *corev1.Endpoints {
+	return &corev1.Endpoints{
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      "service3",
+			UID:       "3",
+			Namespace: "testing",
+		},
+		Subsets: []corev1.EndpointSubset{
+			{
+				Addresses: []corev1.EndpointAddress{
+					{
+						IP: "10.15.0.1",
+					},
+				},
+				Ports: []corev1.EndpointPort{
+					{
+						Name: "http",
+						Port: 8080,
+					},
+					{
+						Name: "https",
+						Port: 8443,
+					},
+				},
+			},
+			{
+				Addresses: []corev1.EndpointAddress{
+					{
+						IP: "10.15.0.2",
+					},
+				},
+				Ports: []corev1.EndpointPort{
+					{
+						Name: "http",
+						Port: 9080,
+					},
+					{
+						Name: "https",
+						Port: 9443,
+					},
+				},
+			},
+		},
+	}
+}