MEDIUM: ring: implement ring section

Author: amelhusic

configure_data_plane.go

@@ -345,6 +345,13 @@ func configureAPI(api *operations.DataPlaneAPI) http.Handler {
 	api.BackendGetBackendsHandler = &handlers.GetBackendsHandlerImpl{Client: client}
 	api.BackendReplaceBackendHandler = &handlers.ReplaceBackendHandlerImpl{Client: client, ReloadAgent: ra}
 
+	// setup ring handlers
+	api.RingCreateRingHandler = &handlers.CreateRingHandlerImpl{Client: client, ReloadAgent: ra}
+	api.RingDeleteRingHandler = &handlers.DeleteRingHandlerImpl{Client: client, ReloadAgent: ra}
+	api.RingGetRingHandler = &handlers.GetRingHandlerImpl{Client: client}
+	api.RingGetRingsHandler = &handlers.GetRingsHandlerImpl{Client: client}
+	api.RingReplaceRingHandler = &handlers.ReplaceRingHandlerImpl{Client: client, ReloadAgent: ra}
+
 	// setup frontend handlers
 	api.FrontendCreateFrontendHandler = &handlers.CreateFrontendHandlerImpl{Client: client, ReloadAgent: ra}
 	api.FrontendDeleteFrontendHandler = &handlers.DeleteFrontendHandlerImpl{Client: client, ReloadAgent: ra}

e2e/tests/rings/data/post.json

@@ -0,0 +1,9 @@
+{
+  "description": "My local buffer",
+  "format": "rfc3164",
+  "maxlen": 1200,
+  "name": "test_ring",
+  "size": 32764,
+  "timeout_connect": 5,
+  "timeout_server": 10
+}

e2e/tests/rings/data/put.json

@@ -0,0 +1,9 @@
+{
+  "description": "My local buffer update",
+  "format": "iso",
+  "maxlen": 1400,
+  "name": "myring2",
+  "size": 32740,
+  "timeout_connect": 15,
+  "timeout_server": 20
+}

e2e/tests/rings/test.bats

@@ -0,0 +1,65 @@
+#!/usr/bin/env bats
+#
+# Copyright 2021 HAProxy Technologies
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http:#www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+load '../../libs/dataplaneapi'
+load '../../libs/get_json_path'
+load '../../libs/resource_client'
+load '../../libs/version'
+
+load 'utils/_helpers'
+
+@test "rings: Add a ring" {
+  if haproxy_version_ge "2.1"
+  then
+	resource_post "$_RING_BASE_PATH" "data/post.json" "force_reload=true"
+	assert_equal "$SC" "201"
+  fi
+}
+
+@test "rings: Return a ring" {
+  if haproxy_version_ge "2.1"
+  then
+	resource_get "$_RING_BASE_PATH/test_ring"
+	assert_equal "$SC" 200
+	assert_equal "test_ring" "$(get_json_path "$BODY" '.data.name')"
+  fi
+}
+
+@test "rings: Replace a ring" {
+  if haproxy_version_ge "2.1"
+  then
+	resource_put "$_RING_BASE_PATH/test_ring" "data/put.json" "force_reload=true"
+	assert_equal "$SC" 200
+  fi
+}
+
+@test "rings: Return an array of rings" {
+  if haproxy_version_ge "2.1"
+  then
+	resource_get "$_RING_BASE_PATH"
+	assert_equal "$SC" 200
+	assert_equal "test_ring" "$(get_json_path "$BODY" '.data[0].name')"
+  fi
+}
+
+@test "rings: Delete a ring" {
+  if haproxy_version_ge "2.1"
+  then
+	resource_delete "$_RING_BASE_PATH/test_ring" "force_reload=true"
+	assert_equal "$SC" 204
+  fi
+}

e2e/tests/rings/utils/_helpers.bash

@@ -0,0 +1,18 @@
+#!/usr/bin/env bash
+#
+# Copyright 2021 HAProxy Technologies
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http:#www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+_RING_BASE_PATH="/services/haproxy/configuration/rings"