Function TestServerlessGoCBConnectionString

rest/serverless_test.go:177–225

(t *testing.T)

}

func TestServerlessGoCBConnectionString(t *testing.T) {
	if base.UnitTestUrlIsWalrus() {
		t.Skip("This test only works against Couchbase Server due to testing gocb connection strings")
	}
	tests := []struct {
		name                 string
		expectedConnstrQuery string
		specKvConn           string
		kvConnCount          int
	}{
		{
			name:                 "serverless connection",
			expectedConnstrQuery: "?dcp_buffer_size=1048576&idle_http_connection_timeout=90000&kv_buffer_size=1048576&kv_pool_size=1&max_idle_http_connections=64000&max_perhost_idle_http_connections=256",
			kvConnCount:          1,
		},
		{
			name:                 "serverless connection with kv pool specified",
			specKvConn:           "?idle_http_connection_timeout=90000&kv_pool_size=3&max_idle_http_connections=64000&max_perhost_idle_http_connections=256",
			expectedConnstrQuery: "?dcp_buffer_size=1048576&idle_http_connection_timeout=90000&kv_buffer_size=1048576&kv_pool_size=3&max_idle_http_connections=64000&max_perhost_idle_http_connections=256",
			kvConnCount:          3,
		},
	}
	for _, test := range tests {
		t.Run(test.name, func(t *testing.T) {
			t.Skip("here")
			ctx := base.TestCtx(t)
			tb := base.GetTestBucket(t)
			defer tb.Close(ctx)
			bucketServer := tb.BucketSpec.Server
			expectedServer := bucketServer + test.expectedConnstrQuery

			if test.specKvConn != "" {
				tb.BucketSpec.Server = bucketServer + "?kv_pool_size=3"
			}

			rt := NewRestTester(t, &RestTesterConfig{CustomTestBucket: tb.NoCloseClone(), PersistentConfig: true, serverless: true})
			defer rt.Close()
			sc := rt.ServerContext()
			require.True(t, sc.Config.IsServerless())

			resp := rt.SendAdminRequest(http.MethodPut, "/db/", fmt.Sprintf(`{"bucket": "%s", "use_views": %t, "num_index_replicas": 0}`,
				tb.GetName(), base.TestsDisableGSI()))
			RequireStatus(t, resp, http.StatusCreated)

			assert.Equal(t, expectedServer, sc.getBucketSpec("db").Server)
		})
	}

}

func TestServerlessUnsupportedOptions(t *testing.T) {
	RequireBucketSpecificCredentials(t)