[FGS]: quotas & invocation

acceptance/openstack/fgs/v2/functiongraph_test.go

@@ -29,21 +29,8 @@ def handler (event, context):
 func TestFunctionGraphLifecycle(t *testing.T) {
 	client, err := clients.NewFuncGraphClient()
 	th.AssertNoErr(t, err)
-	funcName := "funcgraph-" + tools.RandomString("acctest", 4)
 
-	createOpts := function.CreateOpts{
-		Name:       funcName,
-		Package:    "default",
-		Runtime:    "Python3.9",
-		Timeout:    200,
-		Handler:    "index.py",
-		MemorySize: 512,
-		CodeType:   "zip",
-		CodeURL:    "https://regr-func-graph.obs.eu-de.otc.t-systems.com/index.py",
-	}
-
-	createResp, err := function.Create(client, createOpts)
-	th.AssertNoErr(t, err)
+	createResp, funcName := createFunctionGraph(t, client)
 
 	funcUrn := strings.TrimSuffix(createResp.FuncURN, ":latest")
 
@@ -95,6 +82,10 @@ func TestFunctionGraphLifecycle(t *testing.T) {
 		})
 	th.AssertNoErr(t, err)
 	th.AssertEquals(t, updateFuncInstance.StrategyConfig.Concurrency, 200)
+
+	// API not registered
+	// err = function.UpdateStatus(client, funcUrn, "true")
+	// th.AssertNoErr(t, err)
 }
 
 func TestFunctionGraphList(t *testing.T) {
@@ -105,3 +96,23 @@ func TestFunctionGraphList(t *testing.T) {
 	_, err = function.List(client, listOpts)
 	th.AssertNoErr(t, err)
 }
+
+func createFunctionGraph(t *testing.T, client *golangsdk.ServiceClient) (*function.FuncGraph, string) {
+	funcName := "funcgraph-" + tools.RandomString("acctest", 4)
+
+	createOpts := function.CreateOpts{
+		Name:       funcName,
+		Package:    "default",
+		Runtime:    "Python3.9",
+		Timeout:    200,
+		Handler:    "index.py",
+		MemorySize: 512,
+		CodeType:   "zip",
+		CodeURL:    "https://regr-func-graph.obs.eu-de.otc.t-systems.com/index.py",
+	}
+
+	createResp, err := function.Create(client, createOpts)
+	th.AssertNoErr(t, err)
+
+	return createResp, funcName
+}

acceptance/openstack/fgs/v2/invocation_test.go

@@ -0,0 +1,63 @@
+package v2
+
+import (
+	"os"
+	"strings"
+	"testing"
+
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/acceptance/clients"
+	"github.com/opentelekomcloud/gophertelekomcloud/acceptance/tools"
+	"github.com/opentelekomcloud/gophertelekomcloud/openstack/fgs/v2/function"
+	"github.com/opentelekomcloud/gophertelekomcloud/openstack/fgs/v2/invoke"
+	th "github.com/opentelekomcloud/gophertelekomcloud/testhelper"
+)
+
+func TestFunctionGraphSync(t *testing.T) {
+	if funcGraph := os.Getenv("FUNCGRAPH_TEST"); funcGraph == "" {
+		t.Skip("`FUNCGRAPH_TEST`needs to be defined to run this test")
+	}
+	client, err := clients.NewFuncGraphClient()
+	th.AssertNoErr(t, err)
+
+	createResp, _ := createFunctionGraph(t, client)
+
+	funcUrn := strings.TrimSuffix(createResp.FuncURN, ":latest")
+
+	defer func(client *golangsdk.ServiceClient, id string) {
+		err = function.Delete(client, id)
+		th.AssertNoErr(t, err)
+	}(client, funcUrn)
+
+	syncResp, err := invoke.LaunchSync(client, funcUrn)
+	th.AssertNoErr(t, err)
+
+	tools.PrintResource(t, syncResp)
+}
+
+func TestFunctionGraphAsync(t *testing.T) {
+	if funcGraph := os.Getenv("FUNCGRAPH_TEST"); funcGraph == "" {
+		t.Skip("`FUNCGRAPH_TEST`needs to be defined to run this test")
+	}
+	client, err := clients.NewFuncGraphClient()
+	th.AssertNoErr(t, err)
+
+	createResp, _ := createFunctionGraph(t, client)
+
+	funcUrn := strings.TrimSuffix(createResp.FuncURN, ":latest")
+
+	defer func(client *golangsdk.ServiceClient, id string) {
+		err = function.Delete(client, id)
+		th.AssertNoErr(t, err)
+	}(client, funcUrn)
+
+	asyncOpts := map[string]string{
+		"k":    "v",
+		"test": "start",
+	}
+
+	syncResp, err := invoke.LaunchAsync(client, funcUrn, asyncOpts)
+	th.AssertNoErr(t, err)
+
+	tools.PrintResource(t, syncResp)
+}

acceptance/openstack/fgs/v2/quota_test.go

@@ -0,0 +1,19 @@
+package v2
+
+import (
+	"testing"
+
+	"github.com/opentelekomcloud/gophertelekomcloud/acceptance/clients"
+	"github.com/opentelekomcloud/gophertelekomcloud/acceptance/tools"
+	"github.com/opentelekomcloud/gophertelekomcloud/openstack/fgs/v2/quotas"
+	th "github.com/opentelekomcloud/gophertelekomcloud/testhelper"
+)
+
+func TestFunctionGraphQuotas(t *testing.T) {
+	client, err := clients.NewFuncGraphClient()
+	th.AssertNoErr(t, err)
+
+	listQuotasResp, err := quotas.ListQuotas(client)
+	th.AssertNoErr(t, err)
+	tools.PrintResource(t, listQuotasResp)
+}

openstack/fgs/v2/function/UpdateStatus.go

@@ -0,0 +1,12 @@
+package function
+
+import (
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+)
+
+func UpdateStatus(client *golangsdk.ServiceClient, funcUrn, state string) (err error) {
+	_, err = client.Put(client.ServiceURL("fgs", "functions", funcUrn, "collect", state), nil, nil, &golangsdk.RequestOpts{
+		OkCodes: []int{200},
+	})
+	return
+}

openstack/fgs/v2/invoke/InvokeAsync.go

@@ -0,0 +1,28 @@
+package invoke
+
+import (
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/build"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/extract"
+)
+
+func LaunchAsync(client *golangsdk.ServiceClient, funcUrn string, opts map[string]string) (*LaunchAsyncResp, error) {
+	b, err := build.RequestBody(opts, "body")
+	if err != nil {
+		return nil, err
+	}
+
+	raw, err := client.Post(client.ServiceURL("fgs", "functions", funcUrn, "invocations-async"), b, nil, &golangsdk.RequestOpts{
+		OkCodes: []int{202},
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	var res LaunchAsyncResp
+	return &res, extract.Into(raw.Body, &res)
+}
+
+type LaunchAsyncResp struct {
+	RequestID string `json:"request_id"`
+}

openstack/fgs/v2/invoke/InvokeSync.go

@@ -0,0 +1,25 @@
+package invoke
+
+import (
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/extract"
+)
+
+func LaunchSync(client *golangsdk.ServiceClient, funcUrn string) (*LaunchSyncResp, error) {
+	raw, err := client.Post(client.ServiceURL("fgs", "functions", funcUrn, "invocations"), nil, nil, &golangsdk.RequestOpts{
+		OkCodes: []int{200},
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	var res LaunchSyncResp
+	return &res, extract.Into(raw.Body, &res)
+}
+
+type LaunchSyncResp struct {
+	RequestID string `json:"request_id"`
+	Result    string `json:"result"`
+	Log       string `json:"log"`
+	Status    string `json:"status"`
+}

openstack/fgs/v2/quotas/ListQuotas.go

@@ -0,0 +1,28 @@
+package quotas
+
+import (
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/extract"
+)
+
+func ListQuotas(client *golangsdk.ServiceClient) (*ListQuotasResults, error) {
+	raw, err := client.Get(client.ServiceURL("fgs", "quotas"), nil, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	var res ListQuotasResults
+	err = extract.IntoStructPtr(raw.Body, &res, "quotas")
+	return &res, err
+}
+
+type ListQuotasResults struct {
+	Resources []Resources `json:"resources"`
+}
+
+type Resources struct {
+	Quota int    `json:"quota"`
+	Used  int    `json:"used"`
+	Type  string `json:"type"`
+	Unit  string `json:"unit"`
+}