GeminiDB: other apis (#892)

Author: artem-lifshits

acceptance/openstack/gemini/v3/logs_test.go

@@ -0,0 +1,44 @@
+package v3
+
+import (
+	"os"
+	"testing"
+	"time"
+
+	"github.com/opentelekomcloud/gophertelekomcloud/acceptance/clients"
+	"github.com/opentelekomcloud/gophertelekomcloud/acceptance/tools"
+	"github.com/opentelekomcloud/gophertelekomcloud/openstack/gemini/v3/instance"
+	"github.com/opentelekomcloud/gophertelekomcloud/openstack/gemini/v3/logs"
+	th "github.com/opentelekomcloud/gophertelekomcloud/testhelper"
+)
+
+func TestGeminiInstanceLogs(t *testing.T) {
+	t.Skip("too long to run in ci")
+	vpcID := os.Getenv("OS_VPC_ID")
+	subnetID := os.Getenv("OS_NETWORK_ID")
+	secGroupID := os.Getenv("OS_SECURITY_GROUP_ID")
+
+	client, err := clients.NewGeminiDBClient()
+	th.AssertNoErr(t, err)
+
+	createResp := createGeminiInstance(t, client, vpcID, subnetID, secGroupID)
+
+	t.Cleanup(func() {
+		t.Logf("Attempting to delete gemini db")
+		_, err = instance.Delete(client, createResp.Id)
+		th.AssertNoErr(t, err)
+	})
+
+	endDate := time.Now().Format("2006-01-02T15:04:05-0700")
+	startDate := time.Now().Add(-1 * time.Hour).Format("2006-01-02T15:04:05-0700")
+
+	logsOpts := logs.GetSlowLogsOpts{
+		InstanceId: createResp.Id,
+		StartDate:  startDate,
+		EndDate:    endDate,
+	}
+
+	slowLogs, err := logs.GetSlowLogs(client, logsOpts)
+	th.AssertNoErr(t, err)
+	tools.PrintResource(t, slowLogs)
+}

acceptance/openstack/gemini/v3/quota_test.go

@@ -0,0 +1,20 @@
+package v3
+
+import (
+	"testing"
+
+	"github.com/opentelekomcloud/gophertelekomcloud/acceptance/clients"
+	"github.com/opentelekomcloud/gophertelekomcloud/acceptance/tools"
+	"github.com/opentelekomcloud/gophertelekomcloud/openstack/gemini/v3/quota"
+	th "github.com/opentelekomcloud/gophertelekomcloud/testhelper"
+)
+
+func TestGeminiGetQuotas(t *testing.T) {
+	client, err := clients.NewGeminiDBClient()
+	th.AssertNoErr(t, err)
+
+	t.Logf("Attempting to get Gemini db quotas")
+	listResp, err := quota.GetQuotas(client)
+	th.AssertNoErr(t, err)
+	tools.PrintResource(t, listResp)
+}

openstack/gemini/v3/logs/GetSlowLogs.go

@@ -0,0 +1,62 @@
+package logs
+
+import (
+	"bytes"
+
+	golangsdk "github.com/opentelekomcloud/gophertelekomcloud"
+	"github.com/opentelekomcloud/gophertelekomcloud/internal/extract"
+	"github.com/opentelekomcloud/gophertelekomcloud/pagination"
+)
+
+type GetSlowLogsOpts struct {
+	InstanceId string `json:"-"`
+	StartDate  string `q:"start_date" required:"true"`
+	EndDate    string `q:"end_date" required:"true"`
+	NodeId     string `q:"node_id"`
+	Offset     int    `q:"offset"`
+	Limit      int    `q:"limit"`
+	Type       string `q:"type"`
+}
+
+func GetSlowLogs(client *golangsdk.ServiceClient, opts GetSlowLogsOpts) ([]SlowlogResult, error) {
+	url, err := golangsdk.NewURLBuilder().
+		WithEndpoints("instances", opts.InstanceId, "slowlog").
+		WithQueryParams(&opts).Build()
+	if err != nil {
+		return nil, err
+	}
+
+	pages, err := pagination.Pager{
+		Client:     client,
+		InitialURL: client.ServiceURL(url.String()),
+		CreatePage: func(r pagination.NewPageResult) pagination.NewPage {
+			return SlowLogPage{NewSinglePageBase: pagination.NewSinglePageBase{NewPageResult: r}}
+		},
+	}.NewAllPages()
+
+	if err != nil {
+		return nil, err
+	}
+	return ExtractSlowLogs(pages)
+}
+
+func ExtractSlowLogs(r pagination.NewPage) ([]SlowlogResult, error) {
+	var s struct {
+		SlowLogList []SlowlogResult `json:"slow_log_list"`
+		TotalRecord int             `json:"total_record"`
+	}
+	err := extract.Into(bytes.NewReader((r.(SlowLogPage)).Body), &s)
+	return s.SlowLogList, err
+}
+
+type SlowLogPage struct {
+	pagination.NewSinglePageBase
+}
+
+type SlowlogResult struct {
+	Time        string `json:"time"`
+	Database    string `json:"database"`
+	QuerySample string `json:"query_sample"`
+	Type        string `json:"type"`
+	StartTime   string `json:"start_time"`
+}

openstack/gemini/v3/quota/GetQuotas.go

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