baalajimaestro/traefik
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions
traefik/provider/ecs/config_test.go

1300 lines
48 KiB
Go
Raw Normal View History

Extract providers to their own package This is just doing that and making it compile :) Signed-off-by: Vincent Demeester <vincent@sbr.pm>
2017-04-17 10:50:02 +00:00
package ecs
Add an ECS provider
2017-01-05 14:24:17 +00:00
import (
"testing"
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
"time"
Add an ECS provider
2017-01-05 14:24:17 +00:00
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/service/ec2"
"github.com/aws/aws-sdk-go/service/ecs"
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
"github.com/containous/flaeg"
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
"github.com/containous/traefik/provider/label"
Factorize labels * refactor(accesslog): factorize file name. * traefik.frontend.rule * traefik.frontend.value * traefik.backend.circuitbreaker.expression * traefik.enable * traefik.backend.loadbalancer.method * traefik.backend.loadbalancer.sticky * traefik.backend.maxconn.amount * traefik.backend.maxconn.extractorfunc * traefik.port * traefik.tags * traefik.backend * traefik.weight * traefik.domain * traefik.protocol * traefik.frontend.passHostHeader * traefik.frontend.whitelistSourceRange * traefik.frontend.priority * traefik.frontend.entryPoints * traefik.frontend.auth.basic * traefik.backend.id * traefik.backend.circuitbreaker * traefik.frontend.rule.type * traefik.portIndex * refactor(docker): specific labels * refactor(rancher): specific labels * traefik.backend.healthcheck.* * refactor(providers): factorize labels.
2017-07-10 14:58:12 +00:00
"github.com/containous/traefik/types"
ECS provider refactoring
2017-09-06 10:10:05 +00:00
"github.com/stretchr/testify/assert"
Add an ECS provider
2017-01-05 14:24:17 +00:00
)
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
func TestBuildConfiguration(t *testing.T) {
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
testCases := []struct {
Factorize labels managements.
2018-04-11 10:26:03 +00:00
desc string
instances []ecsInstance
expected *types.Configuration
err error
Add an ECS provider
2017-01-05 14:24:17 +00:00
}{
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "config parsed successfully",
Factorize labels managements.
2018-04-11 10:26:03 +00:00
instances: []ecsInstance{
{
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Name: "instance",
ID: "1",
containerDefinition: &ecs.ContainerDefinition{
DockerLabels: map[string]*string{},
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
},
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
machine: &machine{
state: ec2.InstanceStateNameRunning,
privateIP: "10.0.0.1",
Allow binding ECS container port
2018-07-04 13:08:03 +00:00
ports: []portMapping{{hostPort: 1337}},
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
},
Factorize labels managements.
2018-04-11 10:26:03 +00:00
},
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
},
expected: &types.Configuration{
Backends: map[string]*types.Backend{
Factorize labels managements.
2018-04-11 10:26:03 +00:00
"backend-instance": {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
Servers: map[string]types.Server{
"server-instance-1": {
Server weight zero
2018-04-11 14:30:04 +00:00
URL: "http://10.0.0.1:1337",
Weight: label.DefaultWeight,
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
}},
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
},
},
Frontends: map[string]*types.Frontend{
Factorize labels managements.
2018-04-11 10:26:03 +00:00
"frontend-instance": {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
EntryPoints: []string{},
Factorize labels managements.
2018-04-11 10:26:03 +00:00
Backend: "backend-instance",
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
Routes: map[string]types.Route{
Factorize labels managements.
2018-04-11 10:26:03 +00:00
"route-frontend-instance": {
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Rule: "Host:instance.",
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
},
},
PassHostHeader: true,
},
},
},
Add an ECS provider
2017-01-05 14:24:17 +00:00
},
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "config parsed successfully with health check labels",
Factorize labels managements.
2018-04-11 10:26:03 +00:00
instances: []ecsInstance{
{
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Name: "instance",
ID: "1",
containerDefinition: &ecs.ContainerDefinition{
DockerLabels: map[string]*string{
label.TraefikBackendHealthCheckPath: aws.String("/health"),
label.TraefikBackendHealthCheckInterval: aws.String("1s"),
}},
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
machine: &machine{
state: ec2.InstanceStateNameRunning,
privateIP: "10.0.0.1",
Allow binding ECS container port
2018-07-04 13:08:03 +00:00
ports: []portMapping{{hostPort: 1337}},
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
},
Factorize labels managements.
2018-04-11 10:26:03 +00:00
},
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
},
expected: &types.Configuration{
Backends: map[string]*types.Backend{
Factorize labels managements.
2018-04-11 10:26:03 +00:00
"backend-instance": {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
HealthCheck: &types.HealthCheck{
Path: "/health",
Interval: "1s",
},
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Servers: map[string]types.Server{
"server-instance-1": {
Server weight zero
2018-04-11 14:30:04 +00:00
URL: "http://10.0.0.1:1337",
Weight: label.DefaultWeight,
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
}},
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
},
},
Frontends: map[string]*types.Frontend{
Factorize labels managements.
2018-04-11 10:26:03 +00:00
"frontend-instance": {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
EntryPoints: []string{},
Factorize labels managements.
2018-04-11 10:26:03 +00:00
Backend: "backend-instance",
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
Routes: map[string]types.Route{
Factorize labels managements.
2018-04-11 10:26:03 +00:00
"route-frontend-instance": {
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Rule: "Host:instance.",
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
},
},
PassHostHeader: true,
Auth support in frontends
2018-07-06 14:52:04 +00:00
},
},
},
},
{
desc: "config parsed successfully with basic auth labels",
instances: []ecsInstance{
{
Name: "instance",
ID: "1",
containerDefinition: &ecs.ContainerDefinition{
DockerLabels: map[string]*string{
Don't pass the Authorization header to the backends
2018-07-16 11:52:03 +00:00
label.TraefikFrontendAuthBasicUsers: aws.String("test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/,test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"),
label.TraefikFrontendAuthBasicUsersFile: aws.String(".htpasswd"),
label.TraefikFrontendAuthBasicRemoveHeader: aws.String("true"),
label.TraefikFrontendAuthHeaderField: aws.String("X-WebAuth-User"),
Auth support in frontends
2018-07-06 14:52:04 +00:00
}},
machine: &machine{
state: ec2.InstanceStateNameRunning,
privateIP: "10.0.0.1",
ports: []portMapping{{hostPort: 1337}},
},
},
},
expected: &types.Configuration{
Backends: map[string]*types.Backend{
"backend-instance": {
Servers: map[string]types.Server{
"server-instance-1": {
URL: "http://10.0.0.1:1337",
Weight: label.DefaultWeight,
}},
},
},
Frontends: map[string]*types.Frontend{
"frontend-instance": {
EntryPoints: []string{},
Backend: "backend-instance",
Routes: map[string]types.Route{
"route-frontend-instance": {
Rule: "Host:instance.",
},
},
Auth: &types.Auth{
HeaderField: "X-WebAuth-User",
Basic: &types.Basic{
Don't pass the Authorization header to the backends
2018-07-16 11:52:03 +00:00
RemoveHeader: true,
Auth support in frontends
2018-07-06 14:52:04 +00:00
Users: []string{"test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/",
"test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"},
UsersFile: ".htpasswd",
},
},
PassHostHeader: true,
},
},
},
},
{
desc: "config parsed successfully with basic auth (backward compatibility) labels",
instances: []ecsInstance{
{
Name: "instance",
ID: "1",
containerDefinition: &ecs.ContainerDefinition{
DockerLabels: map[string]*string{
label.TraefikFrontendAuthBasic: aws.String("test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/,test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"),
}},
machine: &machine{
state: ec2.InstanceStateNameRunning,
privateIP: "10.0.0.1",
ports: []portMapping{{hostPort: 1337}},
},
},
},
expected: &types.Configuration{
Backends: map[string]*types.Backend{
"backend-instance": {
Servers: map[string]types.Server{
"server-instance-1": {
URL: "http://10.0.0.1:1337",
Weight: label.DefaultWeight,
}},
},
},
Frontends: map[string]*types.Frontend{
"frontend-instance": {
EntryPoints: []string{},
Backend: "backend-instance",
Routes: map[string]types.Route{
"route-frontend-instance": {
Rule: "Host:instance.",
},
},
Auth: &types.Auth{
Basic: &types.Basic{
Users: []string{"test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/",
"test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"},
},
},
PassHostHeader: true,
},
},
},
},
{
desc: "config parsed successfully with digest auth labels",
instances: []ecsInstance{
{
Name: "instance",
ID: "1",
containerDefinition: &ecs.ContainerDefinition{
DockerLabels: map[string]*string{
Don't pass the Authorization header to the backends
2018-07-16 11:52:03 +00:00
label.TraefikFrontendAuthDigestRemoveHeader: aws.String("true"),
label.TraefikFrontendAuthDigestUsers: aws.String("test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/,test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"),
label.TraefikFrontendAuthDigestUsersFile: aws.String(".htpasswd"),
label.TraefikFrontendAuthHeaderField: aws.String("X-WebAuth-User"),
Auth support in frontends
2018-07-06 14:52:04 +00:00
}},
machine: &machine{
state: ec2.InstanceStateNameRunning,
privateIP: "10.0.0.1",
ports: []portMapping{{hostPort: 1337}},
},
},
},
expected: &types.Configuration{
Backends: map[string]*types.Backend{
"backend-instance": {
Servers: map[string]types.Server{
"server-instance-1": {
URL: "http://10.0.0.1:1337",
Weight: label.DefaultWeight,
}},
},
},
Frontends: map[string]*types.Frontend{
"frontend-instance": {
EntryPoints: []string{},
Backend: "backend-instance",
Routes: map[string]types.Route{
"route-frontend-instance": {
Rule: "Host:instance.",
},
},
Auth: &types.Auth{
HeaderField: "X-WebAuth-User",
Digest: &types.Digest{
Don't pass the Authorization header to the backends
2018-07-16 11:52:03 +00:00
RemoveHeader: true,
Auth support in frontends
2018-07-06 14:52:04 +00:00
Users: []string{"test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/",
"test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"},
UsersFile: ".htpasswd",
},
},
PassHostHeader: true,
},
},
},
},
{
desc: "config parsed successfully with forward auth labels",
instances: []ecsInstance{
{
Name: "instance",
ID: "1",
containerDefinition: &ecs.ContainerDefinition{
DockerLabels: map[string]*string{
label.TraefikFrontendAuthForwardAddress: aws.String("auth.server"),
label.TraefikFrontendAuthForwardTrustForwardHeader: aws.String("true"),
label.TraefikFrontendAuthForwardTLSCa: aws.String("ca.crt"),
label.TraefikFrontendAuthForwardTLSCaOptional: aws.String("true"),
label.TraefikFrontendAuthForwardTLSCert: aws.String("server.crt"),
label.TraefikFrontendAuthForwardTLSKey: aws.String("server.key"),
label.TraefikFrontendAuthForwardTLSInsecureSkipVerify: aws.String("true"), label.TraefikFrontendAuthHeaderField: aws.String("X-WebAuth-User"),
}},
machine: &machine{
state: ec2.InstanceStateNameRunning,
privateIP: "10.0.0.1",
ports: []portMapping{{hostPort: 1337}},
},
},
},
expected: &types.Configuration{
Backends: map[string]*types.Backend{
"backend-instance": {
Servers: map[string]types.Server{
"server-instance-1": {
URL: "http://10.0.0.1:1337",
Weight: label.DefaultWeight,
}},
},
},
Frontends: map[string]*types.Frontend{
"frontend-instance": {
EntryPoints: []string{},
Backend: "backend-instance",
Routes: map[string]types.Route{
"route-frontend-instance": {
Rule: "Host:instance.",
},
},
Auth: &types.Auth{
HeaderField: "X-WebAuth-User",
Forward: &types.Forward{
Address: "auth.server",
TrustForwardHeader: true,
TLS: &types.ClientTLS{
CA: "ca.crt",
CAOptional: true,
InsecureSkipVerify: true,
Cert: "server.crt",
Key: "server.key",
},
},
},
PassHostHeader: true,
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
},
},
},
Add an ECS provider
2017-01-05 14:24:17 +00:00
},
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
{
desc: "when all labels are set",
Factorize labels managements.
2018-04-11 10:26:03 +00:00
instances: []ecsInstance{
{
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Name: "testing-instance",
ID: "6",
containerDefinition: &ecs.ContainerDefinition{
DockerLabels: map[string]*string{
label.TraefikPort: aws.String("666"),
label.TraefikProtocol: aws.String("https"),
label.TraefikWeight: aws.String("12"),
label.TraefikBackend: aws.String("foobar"),
label.TraefikBackendCircuitBreakerExpression: aws.String("NetworkErrorRatio() > 0.5"),
Override health check scheme
2018-05-14 10:08:03 +00:00
label.TraefikBackendHealthCheckScheme: aws.String("http"),
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
label.TraefikBackendHealthCheckPath: aws.String("/health"),
label.TraefikBackendHealthCheckPort: aws.String("880"),
label.TraefikBackendHealthCheckInterval: aws.String("6"),
Override health check scheme
2018-05-14 10:08:03 +00:00
label.TraefikBackendHealthCheckHostname: aws.String("foo.com"),
label.TraefikBackendHealthCheckHeaders: aws.String("Foo:bar || Bar:foo"),
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
label.TraefikBackendLoadBalancerMethod: aws.String("drr"),
label.TraefikBackendLoadBalancerSticky: aws.String("true"),
label.TraefikBackendLoadBalancerStickiness: aws.String("true"),
label.TraefikBackendLoadBalancerStickinessCookieName: aws.String("chocolate"),
label.TraefikBackendMaxConnAmount: aws.String("666"),
label.TraefikBackendMaxConnExtractorFunc: aws.String("client.ip"),
Request buffering middleware
2018-01-31 14:32:04 +00:00
label.TraefikBackendBufferingMaxResponseBodyBytes: aws.String("10485760"),
label.TraefikBackendBufferingMemResponseBodyBytes: aws.String("2097152"),
label.TraefikBackendBufferingMaxRequestBodyBytes: aws.String("10485760"),
label.TraefikBackendBufferingMemRequestBodyBytes: aws.String("2097152"),
label.TraefikBackendBufferingRetryExpression: aws.String("IsNetworkError() && Attempts() <= 2"),
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Auth support in frontends
2018-07-06 14:52:04 +00:00
label.TraefikFrontendAuthBasic: aws.String("test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/,test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"),
Don't pass the Authorization header to the backends
2018-07-16 11:52:03 +00:00
label.TraefikFrontendAuthBasicRemoveHeader: aws.String("true"),
Auth support in frontends
2018-07-06 14:52:04 +00:00
label.TraefikFrontendAuthBasicUsers: aws.String("test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/,test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"),
label.TraefikFrontendAuthBasicUsersFile: aws.String(".htpasswd"),
Don't pass the Authorization header to the backends
2018-07-16 11:52:03 +00:00
label.TraefikFrontendAuthDigestRemoveHeader: aws.String("true"),
Auth support in frontends
2018-07-06 14:52:04 +00:00
label.TraefikFrontendAuthDigestUsers: aws.String("test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/,test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"),
label.TraefikFrontendAuthDigestUsersFile: aws.String(".htpasswd"),
label.TraefikFrontendAuthForwardAddress: aws.String("auth.server"),
label.TraefikFrontendAuthForwardTrustForwardHeader: aws.String("true"),
label.TraefikFrontendAuthForwardTLSCa: aws.String("ca.crt"),
label.TraefikFrontendAuthForwardTLSCaOptional: aws.String("true"),
label.TraefikFrontendAuthForwardTLSCert: aws.String("server.crt"),
label.TraefikFrontendAuthForwardTLSKey: aws.String("server.key"),
label.TraefikFrontendAuthForwardTLSInsecureSkipVerify: aws.String("true"),
label.TraefikFrontendAuthHeaderField: aws.String("X-WebAuth-User"),
Ability to use "X-Forwarded-For" as a source of IP for white list.
2018-03-23 16:40:04 +00:00
label.TraefikFrontendEntryPoints: aws.String("http,https"),
label.TraefikFrontendPassHostHeader: aws.String("true"),
label.TraefikFrontendPassTLSCert: aws.String("true"),
label.TraefikFrontendPriority: aws.String("666"),
label.TraefikFrontendRedirectEntryPoint: aws.String("https"),
label.TraefikFrontendRedirectRegex: aws.String("nope"),
label.TraefikFrontendRedirectReplacement: aws.String("nope"),
label.TraefikFrontendRedirectPermanent: aws.String("true"),
label.TraefikFrontendRule: aws.String("Host:traefik.io"),
label.TraefikFrontendWhiteListSourceRange: aws.String("10.10.10.10"),
label.TraefikFrontendWhiteListUseXForwardedFor: aws.String("true"),
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
label.TraefikFrontendRequestHeaders: aws.String("Access-Control-Allow-Methods:POST,GET,OPTIONS || Content-type: application/json; charset=utf-8"),
label.TraefikFrontendResponseHeaders: aws.String("Access-Control-Allow-Methods:POST,GET,OPTIONS || Content-type: application/json; charset=utf-8"),
label.TraefikFrontendSSLProxyHeaders: aws.String("Access-Control-Allow-Methods:POST,GET,OPTIONS || Content-type: application/json; charset=utf-8"),
label.TraefikFrontendAllowedHosts: aws.String("foo,bar,bor"),
label.TraefikFrontendHostsProxyHeaders: aws.String("foo,bar,bor"),
label.TraefikFrontendSSLHost: aws.String("foo"),
label.TraefikFrontendCustomFrameOptionsValue: aws.String("foo"),
label.TraefikFrontendContentSecurityPolicy: aws.String("foo"),
label.TraefikFrontendPublicKey: aws.String("foo"),
label.TraefikFrontendReferrerPolicy: aws.String("foo"),
New option in secure middleware
2018-03-02 13:24:03 +00:00
label.TraefikFrontendCustomBrowserXSSValue: aws.String("foo"),
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
label.TraefikFrontendSTSSeconds: aws.String("666"),
Add SSLForceHost support.
2018-05-14 09:44:03 +00:00
label.TraefikFrontendSSLForceHost: aws.String("true"),
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
label.TraefikFrontendSSLRedirect: aws.String("true"),
label.TraefikFrontendSSLTemporaryRedirect: aws.String("true"),
label.TraefikFrontendSTSIncludeSubdomains: aws.String("true"),
label.TraefikFrontendSTSPreload: aws.String("true"),
label.TraefikFrontendForceSTSHeader: aws.String("true"),
label.TraefikFrontendFrameDeny: aws.String("true"),
label.TraefikFrontendContentTypeNosniff: aws.String("true"),
label.TraefikFrontendBrowserXSSFilter: aws.String("true"),
label.TraefikFrontendIsDevelopment: aws.String("true"),
label.Prefix + label.BaseFrontendErrorPage + "foo." + label.SuffixErrorPageStatus: aws.String("404"),
label.Prefix + label.BaseFrontendErrorPage + "foo." + label.SuffixErrorPageBackend: aws.String("foobar"),
label.Prefix + label.BaseFrontendErrorPage + "foo." + label.SuffixErrorPageQuery: aws.String("foo_query"),
label.Prefix + label.BaseFrontendErrorPage + "bar." + label.SuffixErrorPageStatus: aws.String("500,600"),
label.Prefix + label.BaseFrontendErrorPage + "bar." + label.SuffixErrorPageBackend: aws.String("foobar"),
label.Prefix + label.BaseFrontendErrorPage + "bar." + label.SuffixErrorPageQuery: aws.String("bar_query"),
label.TraefikFrontendRateLimitExtractorFunc: aws.String("client.ip"),
label.Prefix + label.BaseFrontendRateLimit + "foo." + label.SuffixRateLimitPeriod: aws.String("6"),
label.Prefix + label.BaseFrontendRateLimit + "foo." + label.SuffixRateLimitAverage: aws.String("12"),
label.Prefix + label.BaseFrontendRateLimit + "foo." + label.SuffixRateLimitBurst: aws.String("18"),
label.Prefix + label.BaseFrontendRateLimit + "bar." + label.SuffixRateLimitPeriod: aws.String("3"),
label.Prefix + label.BaseFrontendRateLimit + "bar." + label.SuffixRateLimitAverage: aws.String("6"),
label.Prefix + label.BaseFrontendRateLimit + "bar." + label.SuffixRateLimitBurst: aws.String("9"),
}},
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
machine: &machine{
state: ec2.InstanceStateNameRunning,
privateIP: "10.0.0.1",
Allow binding ECS container port
2018-07-04 13:08:03 +00:00
ports: []portMapping{{hostPort: 1337}},
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
},
Factorize labels managements.
2018-04-11 10:26:03 +00:00
},
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
},
expected: &types.Configuration{
Backends: map[string]*types.Backend{
Support `traefik.backend` for ECS
2018-07-04 12:22:03 +00:00
"backend-foobar": {
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Servers: map[string]types.Server{
"server-testing-instance-6": {
URL: "https://10.0.0.1:666",
Weight: 12,
},
},
CircuitBreaker: &types.CircuitBreaker{
Expression: "NetworkErrorRatio() > 0.5",
},
LoadBalancer: &types.LoadBalancer{
Method: "drr",
Sticky: true,
Stickiness: &types.Stickiness{
CookieName: "chocolate",
},
},
MaxConn: &types.MaxConn{
Amount: 666,
ExtractorFunc: "client.ip",
},
HealthCheck: &types.HealthCheck{
Override health check scheme
2018-05-14 10:08:03 +00:00
Scheme: "http",
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Path: "/health",
Port: 880,
Interval: "6",
Override health check scheme
2018-05-14 10:08:03 +00:00
Hostname: "foo.com",
Headers: map[string]string{
"Foo": "bar",
"Bar": "foo",
},
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
},
Request buffering middleware
2018-01-31 14:32:04 +00:00
Buffering: &types.Buffering{
MaxResponseBodyBytes: 10485760,
MemResponseBodyBytes: 2097152,
MaxRequestBodyBytes: 10485760,
MemRequestBodyBytes: 2097152,
RetryExpression: "IsNetworkError() && Attempts() <= 2",
},
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
},
},
Frontends: map[string]*types.Frontend{
Support `traefik.backend` for ECS
2018-07-04 12:22:03 +00:00
"frontend-foobar": {
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
EntryPoints: []string{
"http",
"https",
},
Support `traefik.backend` for ECS
2018-07-04 12:22:03 +00:00
Backend: "backend-foobar",
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Routes: map[string]types.Route{
Support `traefik.backend` for ECS
2018-07-04 12:22:03 +00:00
"route-frontend-foobar": {
Rule: "Host:traefik.io",
},
},
PassHostHeader: true,
PassTLSCert: true,
Priority: 666,
Auth support in frontends
2018-07-06 14:52:04 +00:00
Auth: &types.Auth{
HeaderField: "X-WebAuth-User",
Basic: &types.Basic{
Don't pass the Authorization header to the backends
2018-07-16 11:52:03 +00:00
RemoveHeader: true,
Auth support in frontends
2018-07-06 14:52:04 +00:00
Users: []string{"test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/",
"test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"},
UsersFile: ".htpasswd",
},
Support `traefik.backend` for ECS
2018-07-04 12:22:03 +00:00
},
WhiteList: &types.WhiteList{
SourceRange: []string{"10.10.10.10"},
UseXForwardedFor: true,
},
Headers: &types.Headers{
CustomRequestHeaders: map[string]string{
"Access-Control-Allow-Methods": "POST,GET,OPTIONS",
"Content-Type": "application/json; charset=utf-8",
},
CustomResponseHeaders: map[string]string{
"Access-Control-Allow-Methods": "POST,GET,OPTIONS",
"Content-Type": "application/json; charset=utf-8",
},
AllowedHosts: []string{
"foo",
"bar",
"bor",
},
HostsProxyHeaders: []string{
"foo",
"bar",
"bor",
},
SSLRedirect: true,
SSLTemporaryRedirect: true,
SSLForceHost: true,
SSLHost: "foo",
SSLProxyHeaders: map[string]string{
"Access-Control-Allow-Methods": "POST,GET,OPTIONS",
"Content-Type": "application/json; charset=utf-8",
},
STSSeconds: 666,
STSIncludeSubdomains: true,
STSPreload: true,
ForceSTSHeader: true,
FrameDeny: true,
CustomFrameOptionsValue: "foo",
ContentTypeNosniff: true,
BrowserXSSFilter: true,
CustomBrowserXSSValue: "foo",
ContentSecurityPolicy: "foo",
PublicKey: "foo",
ReferrerPolicy: "foo",
IsDevelopment: true,
},
Errors: map[string]*types.ErrorPage{
"bar": {
Status: []string{
"500",
"600",
},
Backend: "backend-foobar",
Query: "bar_query",
},
"foo": {
Status: []string{
"404",
},
Backend: "backend-foobar",
Query: "foo_query",
},
},
RateLimit: &types.RateLimit{
RateSet: map[string]*types.Rate{
"bar": {
Period: flaeg.Duration(3 * time.Second),
Average: 6,
Burst: 9,
},
"foo": {
Period: flaeg.Duration(6 * time.Second),
Average: 12,
Burst: 18,
},
},
ExtractorFunc: "client.ip",
},
Redirect: &types.Redirect{
EntryPoint: "https",
Regex: "",
Replacement: "",
Permanent: true,
},
},
},
},
},
{
desc: "Containers with same backend name",
instances: []ecsInstance{
{
Name: "testing-instance-v1",
ID: "6",
containerDefinition: &ecs.ContainerDefinition{
DockerLabels: map[string]*string{
label.TraefikPort: aws.String("666"),
label.TraefikProtocol: aws.String("https"),
label.TraefikWeight: aws.String("12"),
label.TraefikBackend: aws.String("foobar"),
label.TraefikBackendCircuitBreakerExpression: aws.String("NetworkErrorRatio() > 0.5"),
label.TraefikBackendHealthCheckScheme: aws.String("http"),
label.TraefikBackendHealthCheckPath: aws.String("/health"),
label.TraefikBackendHealthCheckPort: aws.String("880"),
label.TraefikBackendHealthCheckInterval: aws.String("6"),
label.TraefikBackendHealthCheckHostname: aws.String("foo.com"),
label.TraefikBackendHealthCheckHeaders: aws.String("Foo:bar || Bar:foo"),
label.TraefikBackendLoadBalancerMethod: aws.String("drr"),
label.TraefikBackendLoadBalancerSticky: aws.String("true"),
label.TraefikBackendLoadBalancerStickiness: aws.String("true"),
label.TraefikBackendLoadBalancerStickinessCookieName: aws.String("chocolate"),
label.TraefikBackendMaxConnAmount: aws.String("666"),
label.TraefikBackendMaxConnExtractorFunc: aws.String("client.ip"),
label.TraefikBackendBufferingMaxResponseBodyBytes: aws.String("10485760"),
label.TraefikBackendBufferingMemResponseBodyBytes: aws.String("2097152"),
label.TraefikBackendBufferingMaxRequestBodyBytes: aws.String("10485760"),
label.TraefikBackendBufferingMemRequestBodyBytes: aws.String("2097152"),
label.TraefikBackendBufferingRetryExpression: aws.String("IsNetworkError() && Attempts() <= 2"),
Auth support in frontends
2018-07-06 14:52:04 +00:00
label.TraefikFrontendAuthBasicUsers: aws.String("test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/,test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"),
Support `traefik.backend` for ECS
2018-07-04 12:22:03 +00:00
label.TraefikFrontendEntryPoints: aws.String("http,https"),
label.TraefikFrontendPassHostHeader: aws.String("true"),
label.TraefikFrontendPassTLSCert: aws.String("true"),
label.TraefikFrontendPriority: aws.String("666"),
label.TraefikFrontendRedirectEntryPoint: aws.String("https"),
label.TraefikFrontendRedirectRegex: aws.String("nope"),
label.TraefikFrontendRedirectReplacement: aws.String("nope"),
label.TraefikFrontendRedirectPermanent: aws.String("true"),
label.TraefikFrontendRule: aws.String("Host:traefik.io"),
label.TraefikFrontendWhiteListSourceRange: aws.String("10.10.10.10"),
label.TraefikFrontendWhiteListUseXForwardedFor: aws.String("true"),
label.TraefikFrontendRequestHeaders: aws.String("Access-Control-Allow-Methods:POST,GET,OPTIONS || Content-type: application/json; charset=utf-8"),
label.TraefikFrontendResponseHeaders: aws.String("Access-Control-Allow-Methods:POST,GET,OPTIONS || Content-type: application/json; charset=utf-8"),
label.TraefikFrontendSSLProxyHeaders: aws.String("Access-Control-Allow-Methods:POST,GET,OPTIONS || Content-type: application/json; charset=utf-8"),
label.TraefikFrontendAllowedHosts: aws.String("foo,bar,bor"),
label.TraefikFrontendHostsProxyHeaders: aws.String("foo,bar,bor"),
label.TraefikFrontendSSLHost: aws.String("foo"),
label.TraefikFrontendCustomFrameOptionsValue: aws.String("foo"),
label.TraefikFrontendContentSecurityPolicy: aws.String("foo"),
label.TraefikFrontendPublicKey: aws.String("foo"),
label.TraefikFrontendReferrerPolicy: aws.String("foo"),
label.TraefikFrontendCustomBrowserXSSValue: aws.String("foo"),
label.TraefikFrontendSTSSeconds: aws.String("666"),
label.TraefikFrontendSSLForceHost: aws.String("true"),
label.TraefikFrontendSSLRedirect: aws.String("true"),
label.TraefikFrontendSSLTemporaryRedirect: aws.String("true"),
label.TraefikFrontendSTSIncludeSubdomains: aws.String("true"),
label.TraefikFrontendSTSPreload: aws.String("true"),
label.TraefikFrontendForceSTSHeader: aws.String("true"),
label.TraefikFrontendFrameDeny: aws.String("true"),
label.TraefikFrontendContentTypeNosniff: aws.String("true"),
label.TraefikFrontendBrowserXSSFilter: aws.String("true"),
label.TraefikFrontendIsDevelopment: aws.String("true"),
label.Prefix + label.BaseFrontendErrorPage + "foo." + label.SuffixErrorPageStatus: aws.String("404"),
label.Prefix + label.BaseFrontendErrorPage + "foo." + label.SuffixErrorPageBackend: aws.String("foobar"),
label.Prefix + label.BaseFrontendErrorPage + "foo." + label.SuffixErrorPageQuery: aws.String("foo_query"),
label.Prefix + label.BaseFrontendErrorPage + "bar." + label.SuffixErrorPageStatus: aws.String("500,600"),
label.Prefix + label.BaseFrontendErrorPage + "bar." + label.SuffixErrorPageBackend: aws.String("foobar"),
label.Prefix + label.BaseFrontendErrorPage + "bar." + label.SuffixErrorPageQuery: aws.String("bar_query"),
label.TraefikFrontendRateLimitExtractorFunc: aws.String("client.ip"),
label.Prefix + label.BaseFrontendRateLimit + "foo." + label.SuffixRateLimitPeriod: aws.String("6"),
label.Prefix + label.BaseFrontendRateLimit + "foo." + label.SuffixRateLimitAverage: aws.String("12"),
label.Prefix + label.BaseFrontendRateLimit + "foo." + label.SuffixRateLimitBurst: aws.String("18"),
label.Prefix + label.BaseFrontendRateLimit + "bar." + label.SuffixRateLimitPeriod: aws.String("3"),
label.Prefix + label.BaseFrontendRateLimit + "bar." + label.SuffixRateLimitAverage: aws.String("6"),
label.Prefix + label.BaseFrontendRateLimit + "bar." + label.SuffixRateLimitBurst: aws.String("9"),
}},
machine: &machine{
state: ec2.InstanceStateNameRunning,
privateIP: "10.0.0.1",
Allow binding ECS container port
2018-07-04 13:08:03 +00:00
ports: []portMapping{{hostPort: 1337}},
Support `traefik.backend` for ECS
2018-07-04 12:22:03 +00:00
},
},
{
Name: "testing-instance-v2",
ID: "6",
containerDefinition: &ecs.ContainerDefinition{
DockerLabels: map[string]*string{
label.TraefikPort: aws.String("555"),
label.TraefikProtocol: aws.String("https"),
label.TraefikWeight: aws.String("15"),
label.TraefikBackend: aws.String("foobar"),
label.TraefikBackendCircuitBreakerExpression: aws.String("NetworkErrorRatio() > 0.5"),
label.TraefikBackendHealthCheckScheme: aws.String("http"),
label.TraefikBackendHealthCheckPath: aws.String("/health"),
label.TraefikBackendHealthCheckPort: aws.String("880"),
label.TraefikBackendHealthCheckInterval: aws.String("6"),
label.TraefikBackendHealthCheckHostname: aws.String("bar.com"),
label.TraefikBackendHealthCheckHeaders: aws.String("Foo:bar || Bar:foo"),
label.TraefikBackendLoadBalancerMethod: aws.String("drr"),
label.TraefikBackendLoadBalancerSticky: aws.String("true"),
label.TraefikBackendLoadBalancerStickiness: aws.String("true"),
label.TraefikBackendLoadBalancerStickinessCookieName: aws.String("chocolate"),
label.TraefikBackendMaxConnAmount: aws.String("666"),
label.TraefikBackendMaxConnExtractorFunc: aws.String("client.ip"),
label.TraefikBackendBufferingMaxResponseBodyBytes: aws.String("10485760"),
label.TraefikBackendBufferingMemResponseBodyBytes: aws.String("2097152"),
label.TraefikBackendBufferingMaxRequestBodyBytes: aws.String("10485760"),
label.TraefikBackendBufferingMemRequestBodyBytes: aws.String("2097152"),
label.TraefikBackendBufferingRetryExpression: aws.String("IsNetworkError() && Attempts() <= 2"),
label.TraefikFrontendAuthBasic: aws.String("test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/,test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"),
label.TraefikFrontendEntryPoints: aws.String("http,https"),
label.TraefikFrontendPassHostHeader: aws.String("true"),
label.TraefikFrontendPassTLSCert: aws.String("true"),
label.TraefikFrontendPriority: aws.String("666"),
label.TraefikFrontendRedirectEntryPoint: aws.String("https"),
label.TraefikFrontendRedirectRegex: aws.String("nope"),
label.TraefikFrontendRedirectReplacement: aws.String("nope"),
label.TraefikFrontendRedirectPermanent: aws.String("true"),
label.TraefikFrontendRule: aws.String("Host:traefik.io"),
label.TraefikFrontendWhiteListSourceRange: aws.String("10.10.10.10"),
label.TraefikFrontendWhiteListUseXForwardedFor: aws.String("true"),
label.TraefikFrontendRequestHeaders: aws.String("Access-Control-Allow-Methods:POST,GET,OPTIONS || Content-type: application/json; charset=utf-8"),
label.TraefikFrontendResponseHeaders: aws.String("Access-Control-Allow-Methods:POST,GET,OPTIONS || Content-type: application/json; charset=utf-8"),
label.TraefikFrontendSSLProxyHeaders: aws.String("Access-Control-Allow-Methods:POST,GET,OPTIONS || Content-type: application/json; charset=utf-8"),
label.TraefikFrontendAllowedHosts: aws.String("foo,bar,bor"),
label.TraefikFrontendHostsProxyHeaders: aws.String("foo,bar,bor"),
label.TraefikFrontendSSLHost: aws.String("foo"),
label.TraefikFrontendCustomFrameOptionsValue: aws.String("foo"),
label.TraefikFrontendContentSecurityPolicy: aws.String("foo"),
label.TraefikFrontendPublicKey: aws.String("foo"),
label.TraefikFrontendReferrerPolicy: aws.String("foo"),
label.TraefikFrontendCustomBrowserXSSValue: aws.String("foo"),
label.TraefikFrontendSTSSeconds: aws.String("666"),
label.TraefikFrontendSSLForceHost: aws.String("true"),
label.TraefikFrontendSSLRedirect: aws.String("true"),
label.TraefikFrontendSSLTemporaryRedirect: aws.String("true"),
label.TraefikFrontendSTSIncludeSubdomains: aws.String("true"),
label.TraefikFrontendSTSPreload: aws.String("true"),
label.TraefikFrontendForceSTSHeader: aws.String("true"),
label.TraefikFrontendFrameDeny: aws.String("true"),
label.TraefikFrontendContentTypeNosniff: aws.String("true"),
label.TraefikFrontendBrowserXSSFilter: aws.String("true"),
label.TraefikFrontendIsDevelopment: aws.String("true"),
label.Prefix + label.BaseFrontendErrorPage + "foo." + label.SuffixErrorPageStatus: aws.String("404"),
label.Prefix + label.BaseFrontendErrorPage + "foo." + label.SuffixErrorPageBackend: aws.String("foobar"),
label.Prefix + label.BaseFrontendErrorPage + "foo." + label.SuffixErrorPageQuery: aws.String("foo_query"),
label.Prefix + label.BaseFrontendErrorPage + "bar." + label.SuffixErrorPageStatus: aws.String("500,600"),
label.Prefix + label.BaseFrontendErrorPage + "bar." + label.SuffixErrorPageBackend: aws.String("foobar"),
label.Prefix + label.BaseFrontendErrorPage + "bar." + label.SuffixErrorPageQuery: aws.String("bar_query"),
label.TraefikFrontendRateLimitExtractorFunc: aws.String("client.ip"),
label.Prefix + label.BaseFrontendRateLimit + "foo." + label.SuffixRateLimitPeriod: aws.String("6"),
label.Prefix + label.BaseFrontendRateLimit + "foo." + label.SuffixRateLimitAverage: aws.String("12"),
label.Prefix + label.BaseFrontendRateLimit + "foo." + label.SuffixRateLimitBurst: aws.String("18"),
label.Prefix + label.BaseFrontendRateLimit + "bar." + label.SuffixRateLimitPeriod: aws.String("3"),
label.Prefix + label.BaseFrontendRateLimit + "bar." + label.SuffixRateLimitAverage: aws.String("6"),
label.Prefix + label.BaseFrontendRateLimit + "bar." + label.SuffixRateLimitBurst: aws.String("9"),
}},
machine: &machine{
state: ec2.InstanceStateNameRunning,
privateIP: "10.2.2.1",
Allow binding ECS container port
2018-07-04 13:08:03 +00:00
ports: []portMapping{{hostPort: 1337}},
Support `traefik.backend` for ECS
2018-07-04 12:22:03 +00:00
},
},
},
expected: &types.Configuration{
Backends: map[string]*types.Backend{
"backend-foobar": {
Servers: map[string]types.Server{
"server-testing-instance-v1-6": {
URL: "https://10.0.0.1:666",
Weight: 12,
},
"server-testing-instance-v2-6": {
URL: "https://10.2.2.1:555",
Weight: 15,
},
},
CircuitBreaker: &types.CircuitBreaker{
Expression: "NetworkErrorRatio() > 0.5",
},
LoadBalancer: &types.LoadBalancer{
Method: "drr",
Sticky: true,
Stickiness: &types.Stickiness{
CookieName: "chocolate",
},
},
MaxConn: &types.MaxConn{
Amount: 666,
ExtractorFunc: "client.ip",
},
HealthCheck: &types.HealthCheck{
Scheme: "http",
Path: "/health",
Port: 880,
Interval: "6",
Hostname: "foo.com",
Headers: map[string]string{
"Foo": "bar",
"Bar": "foo",
},
},
Buffering: &types.Buffering{
MaxResponseBodyBytes: 10485760,
MemResponseBodyBytes: 2097152,
MaxRequestBodyBytes: 10485760,
MemRequestBodyBytes: 2097152,
RetryExpression: "IsNetworkError() && Attempts() <= 2",
},
},
},
Frontends: map[string]*types.Frontend{
"frontend-foobar": {
EntryPoints: []string{
"http",
"https",
},
Backend: "backend-foobar",
Routes: map[string]types.Route{
"route-frontend-foobar": {
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Rule: "Host:traefik.io",
},
},
PassHostHeader: true,
PassTLSCert: true,
Priority: 666,
Auth support in frontends
2018-07-06 14:52:04 +00:00
Auth: &types.Auth{
Basic: &types.Basic{
Users: []string{"test:$apr1$H6uskkkW$IgXLP6ewTrSuBkTrqE8wj/",
"test2:$apr1$d9hr9HBB$4HxwgUir3HP4EsggP/QNo0"},
},
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
},
Ability to use "X-Forwarded-For" as a source of IP for white list.
2018-03-23 16:40:04 +00:00
WhiteList: &types.WhiteList{
SourceRange: []string{"10.10.10.10"},
UseXForwardedFor: true,
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
},
Headers: &types.Headers{
CustomRequestHeaders: map[string]string{
"Access-Control-Allow-Methods": "POST,GET,OPTIONS",
"Content-Type": "application/json; charset=utf-8",
},
CustomResponseHeaders: map[string]string{
"Access-Control-Allow-Methods": "POST,GET,OPTIONS",
"Content-Type": "application/json; charset=utf-8",
},
AllowedHosts: []string{
"foo",
"bar",
"bor",
},
HostsProxyHeaders: []string{
"foo",
"bar",
"bor",
},
SSLRedirect: true,
SSLTemporaryRedirect: true,
Add SSLForceHost support.
2018-05-14 09:44:03 +00:00
SSLForceHost: true,
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
SSLHost: "foo",
SSLProxyHeaders: map[string]string{
"Access-Control-Allow-Methods": "POST,GET,OPTIONS",
"Content-Type": "application/json; charset=utf-8",
},
STSSeconds: 666,
STSIncludeSubdomains: true,
STSPreload: true,
ForceSTSHeader: true,
FrameDeny: true,
CustomFrameOptionsValue: "foo",
ContentTypeNosniff: true,
BrowserXSSFilter: true,
New option in secure middleware
2018-03-02 13:24:03 +00:00
CustomBrowserXSSValue: "foo",
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
ContentSecurityPolicy: "foo",
PublicKey: "foo",
ReferrerPolicy: "foo",
IsDevelopment: true,
},
Errors: map[string]*types.ErrorPage{
"bar": {
Status: []string{
"500",
"600",
},
Fix: error pages
2018-04-11 11:54:03 +00:00
Backend: "backend-foobar",
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Query: "bar_query",
},
"foo": {
Status: []string{
"404",
},
Fix: error pages
2018-04-11 11:54:03 +00:00
Backend: "backend-foobar",
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Query: "foo_query",
},
},
RateLimit: &types.RateLimit{
RateSet: map[string]*types.Rate{
"bar": {
Period: flaeg.Duration(3 * time.Second),
Average: 6,
Burst: 9,
},
"foo": {
Period: flaeg.Duration(6 * time.Second),
Average: 12,
Burst: 18,
},
},
ExtractorFunc: "client.ip",
},
Redirect: &types.Redirect{
EntryPoint: "https",
Regex: "",
Replacement: "",
Redirection: permanent move option.
2018-01-31 18:10:04 +00:00
Permanent: true,
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
},
},
},
},
},
Add an ECS provider
2017-01-05 14:24:17 +00:00
}
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
for _, test := range testCases {
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
test := test
ECS provider refactoring
2017-09-06 10:10:05 +00:00
t.Run(test.desc, func(t *testing.T) {
refactor(ecs): template readability.
2017-12-16 18:22:16 +00:00
t.Parallel()
Factorize labels managements.
2018-04-11 10:26:03 +00:00
p := &Provider{ExposedByDefault: true}
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
Factorize labels managements.
2018-04-11 10:26:03 +00:00
instances := fakeLoadTraefikLabels(test.instances)
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
Factorize labels managements.
2018-04-11 10:26:03 +00:00
got, err := p.buildConfiguration(instances)
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
assert.Equal(t, test.err, err) // , err.Error()
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
assert.Equal(t, test.expected, got, test.desc)
ECS provider refactoring
2017-09-06 10:10:05 +00:00
})
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
}
}
func TestFilterInstance(t *testing.T) {
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
testCases := []struct {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc string
instanceInfo ecsInstance
exposedByDefault bool
expected bool
Add support for ECS constraints
2018-06-29 22:14:03 +00:00
constrain bool
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
}{
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Instance without enable label and exposed by default enabled should be not filtered",
instanceInfo: simpleEcsInstance(map[string]*string{}),
exposedByDefault: true,
expected: true,
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
},
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Instance without enable label and exposed by default disabled should be filtered",
instanceInfo: simpleEcsInstance(map[string]*string{}),
exposedByDefault: false,
expected: false,
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
},
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Instance with enable label set to false and exposed by default enabled should be filtered",
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
instanceInfo: simpleEcsInstance(map[string]*string{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
label.TraefikEnable: aws.String("false"),
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
}),
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
exposedByDefault: true,
expected: false,
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
},
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Instance with enable label set to true and exposed by default disabled should be not filtered",
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
instanceInfo: simpleEcsInstance(map[string]*string{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
label.TraefikEnable: aws.String("true"),
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
}),
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
exposedByDefault: false,
expected: true,
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
},
{
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
desc: "Instance with empty private ip and exposed by default enabled should be filtered",
Factorize labels managements.
2018-04-11 10:26:03 +00:00
instanceInfo: func() ecsInstance {
nilPrivateIP := simpleEcsInstance(map[string]*string{})
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
nilPrivateIP.machine.privateIP = ""
Factorize labels managements.
2018-04-11 10:26:03 +00:00
return nilPrivateIP
}(),
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
exposedByDefault: true,
expected: false,
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
},
{
Factorize labels managements.
2018-04-11 10:26:03 +00:00
desc: "Instance with nil machine and exposed by default enabled should be filtered",
instanceInfo: func() ecsInstance {
nilMachine := simpleEcsInstance(map[string]*string{})
nilMachine.machine = nil
return nilMachine
}(),
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
exposedByDefault: true,
expected: false,
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
},
{
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
desc: "Instance with empty machine state and exposed by default enabled should be filtered",
Factorize labels managements.
2018-04-11 10:26:03 +00:00
instanceInfo: func() ecsInstance {
nilMachineState := simpleEcsInstance(map[string]*string{})
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
nilMachineState.machine.state = ""
Factorize labels managements.
2018-04-11 10:26:03 +00:00
return nilMachineState
}(),
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
exposedByDefault: true,
expected: false,
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
},
{
Factorize labels managements.
2018-04-11 10:26:03 +00:00
desc: "Instance with invalid machine state and exposed by default enabled should be filtered",
instanceInfo: func() ecsInstance {
invalidMachineState := simpleEcsInstance(map[string]*string{})
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
invalidMachineState.machine.state = ec2.InstanceStateNameStopped
Factorize labels managements.
2018-04-11 10:26:03 +00:00
return invalidMachineState
}(),
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
exposedByDefault: true,
expected: false,
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
},
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Instance with no port mappings should be filtered",
Factorize labels managements.
2018-04-11 10:26:03 +00:00
instanceInfo: simpleEcsInstanceNoNetwork(map[string]*string{}),
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
exposedByDefault: true,
expected: false,
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
},
{
Factorize labels managements.
2018-04-11 10:26:03 +00:00
desc: "Instance with no port mapping and with label should not be filtered",
instanceInfo: simpleEcsInstanceNoNetwork(map[string]*string{
label.TraefikPort: aws.String("80"),
}),
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
exposedByDefault: true,
expected: true,
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
},
Add support for ECS constraints
2018-06-29 22:14:03 +00:00
{
desc: "Instance with failing constraint should be filtered",
instanceInfo: simpleEcsInstance(map[string]*string{
label.TraefikTags: aws.String("private"),
}),
exposedByDefault: true,
expected: false,
constrain: true,
},
{
desc: "Instance with passing constraint should not be filtered",
instanceInfo: simpleEcsInstance(map[string]*string{
label.TraefikTags: aws.String("public"),
}),
exposedByDefault: true,
expected: true,
constrain: true,
},
Try harder to query all the possible ec2 instances, and filter on instance state / lack of IP address
2017-02-08 23:18:38 +00:00
}
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
for _, test := range testCases {
ECS provider refactoring
2017-09-06 10:10:05 +00:00
test := test
t.Run(test.desc, func(t *testing.T) {
t.Parallel()
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
prov := &Provider{
ExposedByDefault: test.exposedByDefault,
}
Add support for ECS constraints
2018-06-29 22:14:03 +00:00
if test.constrain {
constraints := types.Constraints{}
assert.NoError(t, constraints.Set("tag==public"))
prov.Constraints = constraints
}
Factorize labels managements.
2018-04-11 10:26:03 +00:00
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
actual := prov.filterInstance(test.instanceInfo)
ECS provider refactoring
2017-09-06 10:10:05 +00:00
assert.Equal(t, test.expected, actual)
})
Add an ECS provider
2017-01-05 14:24:17 +00:00
}
}
Chunk taskArns into groups of 100 If the ECS cluster has > 100 tasks, passing them to ecs.DescribeTasksRequest() will result in the AWS API returning errors. This patch breaks them into chunks of at most 100, and calls DescribeTasks for each chunk. We also return early in case ListTasks returns no values; this prevents DescribeTasks from throwing HTTP errors.
2017-03-01 18:06:34 +00:00
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
func TestGetHost(t *testing.T) {
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
testCases := []struct {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc string
expected string
instanceInfo ecsInstance
}{
{
desc: "Default host should be 10.0.0.0",
expected: "10.0.0.0",
instanceInfo: simpleEcsInstance(map[string]*string{}),
},
}
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
for _, test := range testCases {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
test := test
t.Run(test.desc, func(t *testing.T) {
t.Parallel()
refactor(ecs): template readability.
2017-12-16 18:22:16 +00:00
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
actual := getHost(test.instanceInfo)
assert.Equal(t, test.expected, actual)
})
}
}
func TestGetPort(t *testing.T) {
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
testCases := []struct {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc string
expected string
instanceInfo ecsInstance
Add basic auth for ecs
2017-09-07 15:34:03 +00:00
}{
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Default port should be 80",
expected: "80",
instanceInfo: simpleEcsInstance(map[string]*string{}),
},
{
desc: "Label should override network port",
expected: "4242",
instanceInfo: simpleEcsInstance(map[string]*string{
label.TraefikPort: aws.String("4242"),
}),
Add basic auth for ecs
2017-09-07 15:34:03 +00:00
},
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Label should provide exposed port",
expected: "80",
instanceInfo: simpleEcsInstanceNoNetwork(map[string]*string{
label.TraefikPort: aws.String("80"),
Add basic auth for ecs
2017-09-07 15:34:03 +00:00
}),
},
Allow binding ECS container port
2018-07-04 13:08:03 +00:00
{
desc: "Container label should provide exposed port",
expected: "6536",
instanceInfo: simpleEcsInstanceDynamicPorts(map[string]*string{
label.TraefikPort: aws.String("8080"),
}),
},
{
desc: "Wrong port container label should provide default exposed port",
expected: "9000",
instanceInfo: simpleEcsInstanceDynamicPorts(map[string]*string{
label.TraefikPort: aws.String("9000"),
}),
},
{
desc: "Invalid port container label should provide default exposed port",
expected: "6535",
instanceInfo: simpleEcsInstanceDynamicPorts(map[string]*string{
label.TraefikPort: aws.String("foo"),
}),
},
Add basic auth for ecs
2017-09-07 15:34:03 +00:00
}
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
for _, test := range testCases {
Add basic auth for ecs
2017-09-07 15:34:03 +00:00
test := test
t.Run(test.desc, func(t *testing.T) {
t.Parallel()
refactor(ecs): template readability.
2017-12-16 18:22:16 +00:00
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
actual := getPort(test.instanceInfo)
Add basic auth for ecs
2017-09-07 15:34:03 +00:00
assert.Equal(t, test.expected, actual)
})
}
}
Add missing functions for ECS template
2017-10-25 15:18:03 +00:00
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
func TestGetFuncStringValue(t *testing.T) {
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
testCases := []struct {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc string
expected string
instanceInfo ecsInstance
Add missing functions for ECS template
2017-10-25 15:18:03 +00:00
}{
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Protocol label is not set should return a string equals to http",
expected: "http",
instanceInfo: simpleEcsInstance(map[string]*string{}),
Add health check label to ECS
2017-11-21 10:06:03 +00:00
},
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Protocol label is set to http should return a string equals to http",
expected: "http",
instanceInfo: simpleEcsInstance(map[string]*string{
label.TraefikProtocol: aws.String("http"),
}),
},
{
desc: "Protocol label is set to https should return a string equals to https",
expected: "https",
instanceInfo: simpleEcsInstance(map[string]*string{
label.TraefikProtocol: aws.String("https"),
}),
Add missing functions for ECS template
2017-10-25 15:18:03 +00:00
},
}
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
for _, test := range testCases {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
test := test
Add missing functions for ECS template
2017-10-25 15:18:03 +00:00
t.Run(test.desc, func(t *testing.T) {
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
t.Parallel()
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
actual := getFuncStringValueV1(label.TraefikProtocol, label.DefaultProtocol)(test.instanceInfo)
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
assert.Equal(t, test.expected, actual)
Add missing functions for ECS template
2017-10-25 15:18:03 +00:00
})
}
}
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
func TestGetFuncSliceString(t *testing.T) {
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
testCases := []struct {
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
desc string
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
expected []string
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
instanceInfo ecsInstance
}{
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Frontend entrypoints label not set should return empty array",
expected: nil,
instanceInfo: simpleEcsInstance(map[string]*string{}),
},
{
desc: "Frontend entrypoints label set to http should return a string array of 1 element",
expected: []string{"http"},
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
instanceInfo: simpleEcsInstance(map[string]*string{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
label.TraefikFrontendEntryPoints: aws.String("http"),
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
}),
},
{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
desc: "Frontend entrypoints label set to http,https should return a string array of 2 elements",
expected: []string{"http", "https"},
instanceInfo: simpleEcsInstance(map[string]*string{
label.TraefikFrontendEntryPoints: aws.String("http,https"),
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
}),
},
}
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
for _, test := range testCases {
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
test := test
t.Run(test.desc, func(t *testing.T) {
t.Parallel()
refactor(ecs): template readability.
2017-12-16 18:22:16 +00:00
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
actual := getFuncSliceStringV1(label.TraefikFrontendEntryPoints)(test.instanceInfo)
Support Host NetworkMode for ECS provider
2017-10-31 10:44:03 +00:00
assert.Equal(t, test.expected, actual)
})
}
}
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
func makeEcsInstance(containerDef *ecs.ContainerDefinition) ecsInstance {
container := &ecs.Container{
Name: containerDef.Name,
NetworkBindings: make([]*ecs.NetworkBinding, len(containerDef.PortMappings)),
}
for i, pm := range containerDef.PortMappings {
container.NetworkBindings[i] = &ecs.NetworkBinding{
HostPort: pm.HostPort,
ContainerPort: pm.ContainerPort,
Protocol: pm.Protocol,
BindIP: aws.String("0.0.0.0"),
}
}
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
instance := ecsInstance{
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
Name: "foo-http",
ID: "123456789abc",
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
containerDefinition: containerDef,
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
machine: &machine{
state: ec2.InstanceStateNameRunning,
privateIP: "10.0.0.0",
Allow binding ECS container port
2018-07-04 13:08:03 +00:00
ports: []portMapping{{hostPort: 1337}},
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
},
}
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
if containerDef != nil {
instance.TraefikLabels = aws.StringValueMap(containerDef.DockerLabels)
}
return instance
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
}
func simpleEcsInstance(labels map[string]*string) ecsInstance {
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
instance := makeEcsInstance(&ecs.ContainerDefinition{
Name: aws.String("http"),
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
DockerLabels: labels,
})
Allow binding ECS container port
2018-07-04 13:08:03 +00:00
instance.machine.ports = []portMapping{{hostPort: 80}}
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
return instance
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
}
func simpleEcsInstanceNoNetwork(labels map[string]*string) ecsInstance {
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
instance := makeEcsInstance(&ecs.ContainerDefinition{
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
Name: aws.String("http"),
DockerLabels: labels,
})
Allow binding ECS container port
2018-07-04 13:08:03 +00:00
instance.machine.ports = []portMapping{}
return instance
}
func simpleEcsInstanceDynamicPorts(labels map[string]*string) ecsInstance {
instance := makeEcsInstance(&ecs.ContainerDefinition{
Name: aws.String("http"),
DockerLabels: labels,
})
instance.machine.ports = []portMapping{
{
containerPort: 80,
hostPort: 6535,
},
{
containerPort: 8080,
hostPort: 6536,
},
}
AWS ECS Fargate
2018-05-28 16:52:03 +00:00
return instance
refactor(ecs): rewrite configuration system.
2017-12-02 18:30:16 +00:00
}
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
Factorize labels managements.
2018-04-11 10:26:03 +00:00
func fakeLoadTraefikLabels(instances []ecsInstance) []ecsInstance {
var result []ecsInstance
for _, instance := range instances {
instance.TraefikLabels = aws.StringValueMap(instance.containerDefinition.DockerLabels)
result = append(result, instance)
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
}
refactor: ECS labels.
2018-03-28 00:13:48 +00:00
return result
homogenization of templates: ECS
2018-01-10 17:28:03 +00:00
}
Reference in a new issue Copy permalink