Merge pull request #10387 from bpineau/google_session_affinity
provider/google: allow session affinity for compute_backend_service
This commit is contained in:
commit
973a46c5df
|
@ -128,6 +128,12 @@ func resourceComputeBackendService() *schema.Resource {
|
||||||
Computed: true,
|
Computed: true,
|
||||||
},
|
},
|
||||||
|
|
||||||
|
"session_affinity": &schema.Schema{
|
||||||
|
Type: schema.TypeString,
|
||||||
|
Optional: true,
|
||||||
|
Computed: true,
|
||||||
|
},
|
||||||
|
|
||||||
"timeout_sec": &schema.Schema{
|
"timeout_sec": &schema.Schema{
|
||||||
Type: schema.TypeInt,
|
Type: schema.TypeInt,
|
||||||
Optional: true,
|
Optional: true,
|
||||||
|
@ -167,6 +173,10 @@ func resourceComputeBackendServiceCreate(d *schema.ResourceData, meta interface{
|
||||||
service.Protocol = v.(string)
|
service.Protocol = v.(string)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if v, ok := d.GetOk("session_affinity"); ok {
|
||||||
|
service.SessionAffinity = v.(string)
|
||||||
|
}
|
||||||
|
|
||||||
if v, ok := d.GetOk("timeout_sec"); ok {
|
if v, ok := d.GetOk("timeout_sec"); ok {
|
||||||
service.TimeoutSec = int64(v.(int))
|
service.TimeoutSec = int64(v.(int))
|
||||||
}
|
}
|
||||||
|
@ -225,6 +235,7 @@ func resourceComputeBackendServiceRead(d *schema.ResourceData, meta interface{})
|
||||||
d.Set("enable_cdn", service.EnableCDN)
|
d.Set("enable_cdn", service.EnableCDN)
|
||||||
d.Set("port_name", service.PortName)
|
d.Set("port_name", service.PortName)
|
||||||
d.Set("protocol", service.Protocol)
|
d.Set("protocol", service.Protocol)
|
||||||
|
d.Set("session_affinity", service.SessionAffinity)
|
||||||
d.Set("timeout_sec", service.TimeoutSec)
|
d.Set("timeout_sec", service.TimeoutSec)
|
||||||
d.Set("fingerprint", service.Fingerprint)
|
d.Set("fingerprint", service.Fingerprint)
|
||||||
d.Set("self_link", service.SelfLink)
|
d.Set("self_link", service.SelfLink)
|
||||||
|
@ -272,6 +283,10 @@ func resourceComputeBackendServiceUpdate(d *schema.ResourceData, meta interface{
|
||||||
service.TimeoutSec = int64(v.(int))
|
service.TimeoutSec = int64(v.(int))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if d.HasChange("session_affinity") {
|
||||||
|
service.SessionAffinity = d.Get("session_affinity").(string)
|
||||||
|
}
|
||||||
|
|
||||||
if d.HasChange("enable_cdn") {
|
if d.HasChange("enable_cdn") {
|
||||||
service.EnableCDN = d.Get("enable_cdn").(bool)
|
service.EnableCDN = d.Get("enable_cdn").(bool)
|
||||||
}
|
}
|
||||||
|
|
|
@ -187,6 +187,40 @@ func TestAccComputeBackendService_withCDNEnabled(t *testing.T) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestAccComputeBackendService_withSessionAffinity(t *testing.T) {
|
||||||
|
serviceName := fmt.Sprintf("tf-test-%s", acctest.RandString(10))
|
||||||
|
checkName := fmt.Sprintf("tf-test-%s", acctest.RandString(10))
|
||||||
|
var svc compute.BackendService
|
||||||
|
|
||||||
|
resource.Test(t, resource.TestCase{
|
||||||
|
PreCheck: func() { testAccPreCheck(t) },
|
||||||
|
Providers: testAccProviders,
|
||||||
|
CheckDestroy: testAccCheckComputeBackendServiceDestroy,
|
||||||
|
Steps: []resource.TestStep{
|
||||||
|
resource.TestStep{
|
||||||
|
Config: testAccComputeBackendService_withSessionAffinity(
|
||||||
|
serviceName, checkName, "CLIENT_IP"),
|
||||||
|
Check: resource.ComposeTestCheckFunc(
|
||||||
|
testAccCheckComputeBackendServiceExists(
|
||||||
|
"google_compute_backend_service.foobar", &svc),
|
||||||
|
),
|
||||||
|
},
|
||||||
|
resource.TestStep{
|
||||||
|
Config: testAccComputeBackendService_withSessionAffinity(
|
||||||
|
serviceName, checkName, "GENERATED_COOKIE"),
|
||||||
|
Check: resource.ComposeTestCheckFunc(
|
||||||
|
testAccCheckComputeBackendServiceExists(
|
||||||
|
"google_compute_backend_service.foobar", &svc),
|
||||||
|
),
|
||||||
|
},
|
||||||
|
},
|
||||||
|
})
|
||||||
|
|
||||||
|
if svc.SessionAffinity != "GENERATED_COOKIE" {
|
||||||
|
t.Errorf("Expected SessionAffinity == \"GENERATED_COOKIE\", got %t", svc.SessionAffinity)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func testAccComputeBackendService_basic(serviceName, checkName string) string {
|
func testAccComputeBackendService_basic(serviceName, checkName string) string {
|
||||||
return fmt.Sprintf(`
|
return fmt.Sprintf(`
|
||||||
resource "google_compute_backend_service" "foobar" {
|
resource "google_compute_backend_service" "foobar" {
|
||||||
|
@ -291,3 +325,20 @@ resource "google_compute_http_health_check" "default" {
|
||||||
}
|
}
|
||||||
`, serviceName, timeout, igName, itName, checkName)
|
`, serviceName, timeout, igName, itName, checkName)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func testAccComputeBackendService_withSessionAffinity(serviceName, checkName, affinityName string) string {
|
||||||
|
return fmt.Sprintf(`
|
||||||
|
resource "google_compute_backend_service" "foobar" {
|
||||||
|
name = "%s"
|
||||||
|
health_checks = ["${google_compute_http_health_check.zero.self_link}"]
|
||||||
|
session_affinity = "%s"
|
||||||
|
}
|
||||||
|
|
||||||
|
resource "google_compute_http_health_check" "zero" {
|
||||||
|
name = "%s"
|
||||||
|
request_path = "/"
|
||||||
|
check_interval_sec = 1
|
||||||
|
timeout_sec = 1
|
||||||
|
}
|
||||||
|
`, serviceName, affinityName, checkName)
|
||||||
|
}
|
||||||
|
|
|
@ -89,6 +89,10 @@ The following arguments are supported:
|
||||||
* `region` - (Optional) The Region in which the created address should reside.
|
* `region` - (Optional) The Region in which the created address should reside.
|
||||||
If it is not provided, the provider region is used.
|
If it is not provided, the provider region is used.
|
||||||
|
|
||||||
|
* `session_affinity` - (Optional) How to distribute load. Options are "NONE" (no
|
||||||
|
affinity), "CLIENT\_IP" (hash of the source/dest addresses / ports), and
|
||||||
|
"GENERATED\_COOKIE" (distribute load using a generated session cookie).
|
||||||
|
|
||||||
* `timeout_sec` - (Optional) The number of secs to wait for a backend to respond
|
* `timeout_sec` - (Optional) The number of secs to wait for a backend to respond
|
||||||
to a request before considering the request failed. Defaults to `30`.
|
to a request before considering the request failed. Defaults to `30`.
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue