From 97c342a86d6214d05bd450c5f1bb4bc02634e532 Mon Sep 17 00:00:00 2001
From: Murad Biashimov <murad.biashimov@aiven.io>
Date: Wed, 7 Feb 2024 11:27:02 +0100
Subject: [PATCH] fix(generator): add missing err return
---
client_generated.go | 1 +
generator/main.go | 4 +-
handler/account/account.go | 36 ++++++++++
.../accountauthentication.go | 12 ++++
handler/accountteam/accountteam.go | 12 ++++
.../accountteammember/accountteammember.go | 6 ++
handler/billinggroup/billinggroup.go | 30 ++++++++
handler/clickhouse/clickhouse.go | 6 ++
handler/cloud/cloud.go | 6 ++
handler/domain/domain.go | 12 ++++
handler/flink/flink.go | 3 +
handler/flinkapplication/flinkapplication.go | 15 ++++
.../flinkapplicationdeployment.go | 18 +++++
.../flinkapplicationversion.go | 12 ++++
handler/flinkjob/flinkjob.go | 6 ++
handler/kafka/kafka.go | 24 +++++++
handler/kafkaconnect/kafkaconnect.go | 18 +++++
handler/kafkamirrormaker/kafkamirrormaker.go | 9 +++
.../kafkaschemaregistry.go | 33 +++++++++
handler/kafkatopic/kafkatopic.go | 12 ++++
handler/mysql/mysql.go | 3 +
handler/opensearch/opensearch.go | 21 ++++++
handler/organization/organization.go | 21 ++++++
handler/organizationuser/organizationuser.go | 21 ++++++
handler/postgresql/postgresql.go | 9 +++
handler/privatelink/privatelink.go | 39 ++++++++++
handler/project/project.go | 36 ++++++++++
handler/projectbilling/projectbilling.go | 9 +++
handler/service/service.go | 72 +++++++++++++++++++
.../serviceintegration/serviceintegration.go | 30 ++++++++
handler/serviceuser/serviceuser.go | 12 ++++
handler/staticip/staticip.go | 21 ++++++
handler/user/user.go | 54 ++++++++++++++
handler/usergroup/usergroup.go | 15 ++++
handler/vpc/vpc.go | 27 +++++++
35 files changed, 664 insertions(+), 1 deletion(-)
diff --git a/client_generated.go b/client_generated.go
index 7c67138..d692b7f 100644
--- a/client_generated.go
+++ b/client_generated.go
@@ -4,6 +4,7 @@ package aiven
import (
"context"
+
account "github.com/aiven/go-client-codegen/handler/account"
accountauthentication "github.com/aiven/go-client-codegen/handler/accountauthentication"
accountteam "github.com/aiven/go-client-codegen/handler/accountteam"
diff --git a/generator/main.go b/generator/main.go
index b28dc9b..2144b82 100644
--- a/generator/main.go
+++ b/generator/main.go
@@ -314,9 +314,11 @@ func exec() error {
),
}
+ ifErr := jen.If(jen.Err().Op("!=").Nil()).Block(returnErr)
if rsp == nil {
block = append(block, jen.Return(jen.Err()))
} else {
+ block = append(block, ifErr)
outReturn := jen.Id("out")
if rsp.CamelName != schemaOut.CamelName {
// Takes original name and turns to camel.
@@ -333,7 +335,7 @@ func exec() error {
block,
jen.Id("out").Op(":=").New(jen.Id(schemaOut.CamelName)),
jen.Err().Op("=").Qual("encoding/json", "Unmarshal").Call(jen.Id("b"), jen.Id("out")),
- jen.If(jen.Err().Op("!=").Nil()).Block(returnErr),
+ ifErr,
jen.Return(outReturn, jen.Nil()),
)
}
diff --git a/handler/account/account.go b/handler/account/account.go
index fa61d27..026555f 100644
--- a/handler/account/account.go
+++ b/handler/account/account.go
@@ -96,6 +96,9 @@ type AccountHandler struct {
func (h *AccountHandler) AccountAttachPaymentMethod(ctx context.Context, accountId string, in *AccountAttachPaymentMethodIn) (*AccountAttachPaymentMethodOut, error) {
path := fmt.Sprintf("/account/%s/payment_methods", accountId)
b, err := h.doer.Do(ctx, "AccountAttachPaymentMethod", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(accountAttachPaymentMethodOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -106,6 +109,9 @@ func (h *AccountHandler) AccountAttachPaymentMethod(ctx context.Context, account
func (h *AccountHandler) AccountBillingGroupList(ctx context.Context, accountId string) ([]AccountBillingGroupOut, error) {
path := fmt.Sprintf("/account/%s/billing-group", accountId)
b, err := h.doer.Do(ctx, "AccountBillingGroupList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountBillingGroupListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -116,6 +122,9 @@ func (h *AccountHandler) AccountBillingGroupList(ctx context.Context, accountId
func (h *AccountHandler) AccountCreate(ctx context.Context, in *AccountCreateIn) (*AccountCreateOut, error) {
path := fmt.Sprintf("/account")
b, err := h.doer.Do(ctx, "AccountCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(accountCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -131,6 +140,9 @@ func (h *AccountHandler) AccountDelete(ctx context.Context, accountId string) er
func (h *AccountHandler) AccountEventList(ctx context.Context, accountId string) ([]EventOut, error) {
path := fmt.Sprintf("/account/%s/events", accountId)
b, err := h.doer.Do(ctx, "AccountEventList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountEventListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -141,6 +153,9 @@ func (h *AccountHandler) AccountEventList(ctx context.Context, accountId string)
func (h *AccountHandler) AccountGet(ctx context.Context, accountId string) (*AccountGetOut, error) {
path := fmt.Sprintf("/account/%s", accountId)
b, err := h.doer.Do(ctx, "AccountGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -151,6 +166,9 @@ func (h *AccountHandler) AccountGet(ctx context.Context, accountId string) (*Acc
func (h *AccountHandler) AccountList(ctx context.Context) ([]AccountOut, error) {
path := fmt.Sprintf("/account")
b, err := h.doer.Do(ctx, "AccountList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -161,6 +179,9 @@ func (h *AccountHandler) AccountList(ctx context.Context) ([]AccountOut, error)
func (h *AccountHandler) AccountMove(ctx context.Context, accountId string, in *AccountMoveIn) (*AccountMoveOut, error) {
path := fmt.Sprintf("/account/%s/parent_account", accountId)
b, err := h.doer.Do(ctx, "AccountMove", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(accountMoveOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -176,6 +197,9 @@ func (h *AccountHandler) AccountPaymentMethodDelete(ctx context.Context, account
func (h *AccountHandler) AccountPaymentMethodsList(ctx context.Context, accountId string) ([]CardOut, error) {
path := fmt.Sprintf("/account/%s/payment_methods", accountId)
b, err := h.doer.Do(ctx, "AccountPaymentMethodsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountPaymentMethodsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -186,6 +210,9 @@ func (h *AccountHandler) AccountPaymentMethodsList(ctx context.Context, accountI
func (h *AccountHandler) AccountProjectsList(ctx context.Context, accountId string) (*AccountProjectsListOut, error) {
path := fmt.Sprintf("/account/%s/projects", accountId)
b, err := h.doer.Do(ctx, "AccountProjectsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(AccountProjectsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -196,6 +223,9 @@ func (h *AccountHandler) AccountProjectsList(ctx context.Context, accountId stri
func (h *AccountHandler) AccountUpdate(ctx context.Context, accountId string, in *AccountUpdateIn) (*AccountUpdateOut, error) {
path := fmt.Sprintf("/account/%s", accountId)
b, err := h.doer.Do(ctx, "AccountUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(accountUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -206,6 +236,9 @@ func (h *AccountHandler) AccountUpdate(ctx context.Context, accountId string, in
func (h *AccountHandler) AccountUserProjectsList(ctx context.Context, accountId string, userId string) ([]UserProjectOut, error) {
path := fmt.Sprintf("/account/%s/user/%s/projects", accountId, userId)
b, err := h.doer.Do(ctx, "AccountUserProjectsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountUserProjectsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -216,6 +249,9 @@ func (h *AccountHandler) AccountUserProjectsList(ctx context.Context, accountId
func (h *AccountHandler) AccountUsersSearch(ctx context.Context, accountId string, in *AccountUsersSearchIn) ([]UserOut, error) {
path := fmt.Sprintf("/account/%s/users/search", accountId)
b, err := h.doer.Do(ctx, "AccountUsersSearch", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(accountUsersSearchOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/accountauthentication/accountauthentication.go b/handler/accountauthentication/accountauthentication.go
index dfc7bf0..af250ea 100644
--- a/handler/accountauthentication/accountauthentication.go
+++ b/handler/accountauthentication/accountauthentication.go
@@ -51,6 +51,9 @@ type AccountAuthenticationHandler struct {
func (h *AccountAuthenticationHandler) AccountAuthenticationMethodCreate(ctx context.Context, accountId string, in *AccountAuthenticationMethodCreateIn) (*AccountAuthenticationMethodCreateOut, error) {
path := fmt.Sprintf("/account/%s/authentication", accountId)
b, err := h.doer.Do(ctx, "AccountAuthenticationMethodCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(accountAuthenticationMethodCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -66,6 +69,9 @@ func (h *AccountAuthenticationHandler) AccountAuthenticationMethodDelete(ctx con
func (h *AccountAuthenticationHandler) AccountAuthenticationMethodGet(ctx context.Context, accountId string, accountAuthenticationMethodId string) (*AccountAuthenticationMethodGetOut, error) {
path := fmt.Sprintf("/account/%s/authentication/%s", accountId, accountAuthenticationMethodId)
b, err := h.doer.Do(ctx, "AccountAuthenticationMethodGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountAuthenticationMethodGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -76,6 +82,9 @@ func (h *AccountAuthenticationHandler) AccountAuthenticationMethodGet(ctx contex
func (h *AccountAuthenticationHandler) AccountAuthenticationMethodUpdate(ctx context.Context, accountId string, accountAuthenticationMethodId string, in *AccountAuthenticationMethodUpdateIn) (*AccountAuthenticationMethodUpdateOut, error) {
path := fmt.Sprintf("/account/%s/authentication/%s", accountId, accountAuthenticationMethodId)
b, err := h.doer.Do(ctx, "AccountAuthenticationMethodUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(accountAuthenticationMethodUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -86,6 +95,9 @@ func (h *AccountAuthenticationHandler) AccountAuthenticationMethodUpdate(ctx con
func (h *AccountAuthenticationHandler) AccountAuthenticationMethodsList(ctx context.Context, accountId string) ([]AuthenticationMethodOut, error) {
path := fmt.Sprintf("/account/%s/authentication", accountId)
b, err := h.doer.Do(ctx, "AccountAuthenticationMethodsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountAuthenticationMethodsListOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/accountteam/accountteam.go b/handler/accountteam/accountteam.go
index e815e17..100efa2 100644
--- a/handler/accountteam/accountteam.go
+++ b/handler/accountteam/accountteam.go
@@ -66,6 +66,9 @@ func (h *AccountTeamHandler) AccountTeamDelete(ctx context.Context, accountId st
func (h *AccountTeamHandler) AccountTeamGet(ctx context.Context, accountId string, teamId string) (*AccountTeamGetOut, error) {
path := fmt.Sprintf("/account/%s/team/%s", accountId, teamId)
b, err := h.doer.Do(ctx, "AccountTeamGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountTeamGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -76,6 +79,9 @@ func (h *AccountTeamHandler) AccountTeamGet(ctx context.Context, accountId strin
func (h *AccountTeamHandler) AccountTeamInvitesList(ctx context.Context, accountId string, teamId string) ([]AccountInviteOut, error) {
path := fmt.Sprintf("/account/%s/team/%s/invites", accountId, teamId)
b, err := h.doer.Do(ctx, "AccountTeamInvitesList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountTeamInvitesListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -86,6 +92,9 @@ func (h *AccountTeamHandler) AccountTeamInvitesList(ctx context.Context, account
func (h *AccountTeamHandler) AccountTeamList(ctx context.Context, accountId string) ([]TeamOut, error) {
path := fmt.Sprintf("/account/%s/teams", accountId)
b, err := h.doer.Do(ctx, "AccountTeamList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountTeamListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -106,6 +115,9 @@ func (h *AccountTeamHandler) AccountTeamProjectDisassociate(ctx context.Context,
func (h *AccountTeamHandler) AccountTeamUpdate(ctx context.Context, accountId string, teamId string, in *AccountTeamUpdateIn) (*AccountTeamUpdateOut, error) {
path := fmt.Sprintf("/account/%s/team/%s", accountId, teamId)
b, err := h.doer.Do(ctx, "AccountTeamUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(accountTeamUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/accountteammember/accountteammember.go b/handler/accountteammember/accountteammember.go
index 1eb63d1..ee8adeb 100644
--- a/handler/accountteammember/accountteammember.go
+++ b/handler/accountteammember/accountteammember.go
@@ -51,6 +51,9 @@ func (h *AccountTeamMemberHandler) AccountTeamMemberCancelInvite(ctx context.Con
func (h *AccountTeamMemberHandler) AccountTeamMemberVerifyInvite(ctx context.Context, accountId string, inviteVerificationCode string) (*AccountTeamMemberVerifyInviteOut, error) {
path := fmt.Sprintf("/account/%s/invite/%s", accountId, inviteVerificationCode)
b, err := h.doer.Do(ctx, "AccountTeamMemberVerifyInvite", "POST", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountTeamMemberVerifyInviteOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -66,6 +69,9 @@ func (h *AccountTeamMemberHandler) AccountTeamMembersInvite(ctx context.Context,
func (h *AccountTeamMemberHandler) AccountTeamMembersList(ctx context.Context, accountId string, teamId string) ([]MemberOut, error) {
path := fmt.Sprintf("/account/%s/team/%s/members", accountId, teamId)
b, err := h.doer.Do(ctx, "AccountTeamMembersList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accountTeamMembersListOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/billinggroup/billinggroup.go b/handler/billinggroup/billinggroup.go
index 6a1cee3..e01eed0 100644
--- a/handler/billinggroup/billinggroup.go
+++ b/handler/billinggroup/billinggroup.go
@@ -91,6 +91,9 @@ type BillingGroupHandler struct {
func (h *BillingGroupHandler) BillingGroupCreate(ctx context.Context, in *BillingGroupCreateIn) (*BillingGroupCreateOut, error) {
path := fmt.Sprintf("/billing-group")
b, err := h.doer.Do(ctx, "BillingGroupCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(billingGroupCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -101,6 +104,9 @@ func (h *BillingGroupHandler) BillingGroupCreate(ctx context.Context, in *Billin
func (h *BillingGroupHandler) BillingGroupCreditsClaim(ctx context.Context, billingGroupId string, in *BillingGroupCreditsClaimIn) (*BillingGroupCreditsClaimOut, error) {
path := fmt.Sprintf("/billing-group/%s/credits", billingGroupId)
b, err := h.doer.Do(ctx, "BillingGroupCreditsClaim", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(billingGroupCreditsClaimOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -111,6 +117,9 @@ func (h *BillingGroupHandler) BillingGroupCreditsClaim(ctx context.Context, bill
func (h *BillingGroupHandler) BillingGroupCreditsList(ctx context.Context, billingGroupId string) ([]CreditOut, error) {
path := fmt.Sprintf("/billing-group/%s/credits", billingGroupId)
b, err := h.doer.Do(ctx, "BillingGroupCreditsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(billingGroupCreditsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -126,6 +135,9 @@ func (h *BillingGroupHandler) BillingGroupDelete(ctx context.Context, billingGro
func (h *BillingGroupHandler) BillingGroupEventList(ctx context.Context, billingGroupId string) ([]EventOut, error) {
path := fmt.Sprintf("/billing-group/%s/events", billingGroupId)
b, err := h.doer.Do(ctx, "BillingGroupEventList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(billingGroupEventListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -136,6 +148,9 @@ func (h *BillingGroupHandler) BillingGroupEventList(ctx context.Context, billing
func (h *BillingGroupHandler) BillingGroupGet(ctx context.Context, billingGroupId string) (*BillingGroupGetOut, error) {
path := fmt.Sprintf("/billing-group/%s", billingGroupId)
b, err := h.doer.Do(ctx, "BillingGroupGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(billingGroupGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -146,6 +161,9 @@ func (h *BillingGroupHandler) BillingGroupGet(ctx context.Context, billingGroupI
func (h *BillingGroupHandler) BillingGroupInvoiceLinesList(ctx context.Context, billingGroupId string, invoiceNumber string) ([]LineOut, error) {
path := fmt.Sprintf("/billing-group/%s/invoice/%s/lines", billingGroupId, invoiceNumber)
b, err := h.doer.Do(ctx, "BillingGroupInvoiceLinesList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(billingGroupInvoiceLinesListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -156,6 +174,9 @@ func (h *BillingGroupHandler) BillingGroupInvoiceLinesList(ctx context.Context,
func (h *BillingGroupHandler) BillingGroupInvoiceList(ctx context.Context, billingGroupId string) ([]InvoiceOut, error) {
path := fmt.Sprintf("/billing-group/%s/invoice", billingGroupId)
b, err := h.doer.Do(ctx, "BillingGroupInvoiceList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(billingGroupInvoiceListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -166,6 +187,9 @@ func (h *BillingGroupHandler) BillingGroupInvoiceList(ctx context.Context, billi
func (h *BillingGroupHandler) BillingGroupList(ctx context.Context) ([]BillingGroupOut, error) {
path := fmt.Sprintf("/billing-group")
b, err := h.doer.Do(ctx, "BillingGroupList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(billingGroupListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -181,6 +205,9 @@ func (h *BillingGroupHandler) BillingGroupProjectAssign(ctx context.Context, bil
func (h *BillingGroupHandler) BillingGroupProjectList(ctx context.Context, billingGroupId string) ([]ProjectOut, error) {
path := fmt.Sprintf("/billing-group/%s/projects", billingGroupId)
b, err := h.doer.Do(ctx, "BillingGroupProjectList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(billingGroupProjectListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -196,6 +223,9 @@ func (h *BillingGroupHandler) BillingGroupProjectsAssign(ctx context.Context, bi
func (h *BillingGroupHandler) BillingGroupUpdate(ctx context.Context, billingGroupId string, in *BillingGroupUpdateIn) (*BillingGroupUpdateOut, error) {
path := fmt.Sprintf("/billing-group/%s", billingGroupId)
b, err := h.doer.Do(ctx, "BillingGroupUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(billingGroupUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/clickhouse/clickhouse.go b/handler/clickhouse/clickhouse.go
index bcb0f90..d45f10a 100644
--- a/handler/clickhouse/clickhouse.go
+++ b/handler/clickhouse/clickhouse.go
@@ -55,6 +55,9 @@ func (h *ClickHouseHandler) ServiceClickHouseDatabaseDelete(ctx context.Context,
func (h *ClickHouseHandler) ServiceClickHouseQueryStats(ctx context.Context, project string, serviceName string) ([]QueryOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/clickhouse/query/stats", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceClickHouseQueryStats", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceClickHouseQueryStatsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -65,6 +68,9 @@ func (h *ClickHouseHandler) ServiceClickHouseQueryStats(ctx context.Context, pro
func (h *ClickHouseHandler) ServiceClickHouseTieredStorageSummary(ctx context.Context, project string, serviceName string) (*ServiceClickHouseTieredStorageSummaryOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/clickhouse/tiered-storage/summary", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceClickHouseTieredStorageSummary", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceClickHouseTieredStorageSummaryOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/cloud/cloud.go b/handler/cloud/cloud.go
index b1b9ade..ae37b37 100644
--- a/handler/cloud/cloud.go
+++ b/handler/cloud/cloud.go
@@ -35,6 +35,9 @@ type CloudHandler struct {
func (h *CloudHandler) ListClouds(ctx context.Context) ([]CloudOut, error) {
path := fmt.Sprintf("/clouds")
b, err := h.doer.Do(ctx, "ListClouds", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(listCloudsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -45,6 +48,9 @@ func (h *CloudHandler) ListClouds(ctx context.Context) ([]CloudOut, error) {
func (h *CloudHandler) ListProjectClouds(ctx context.Context, project string) ([]CloudOut, error) {
path := fmt.Sprintf("/project/%s/clouds", project)
b, err := h.doer.Do(ctx, "ListProjectClouds", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(listProjectCloudsOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/domain/domain.go b/handler/domain/domain.go
index 8b38e4e..386bb25 100644
--- a/handler/domain/domain.go
+++ b/handler/domain/domain.go
@@ -51,6 +51,9 @@ type DomainHandler struct {
func (h *DomainHandler) OrganizationDomainAdd(ctx context.Context, organizationId string, in *OrganizationDomainAddIn) (*OrganizationDomainAddOut, error) {
path := fmt.Sprintf("/organization/%s/domains", organizationId)
b, err := h.doer.Do(ctx, "OrganizationDomainAdd", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationDomainAddOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -61,6 +64,9 @@ func (h *DomainHandler) OrganizationDomainAdd(ctx context.Context, organizationI
func (h *DomainHandler) OrganizationDomainUpdate(ctx context.Context, organizationId string, domainId string, in *OrganizationDomainUpdateIn) (*OrganizationDomainUpdateOut, error) {
path := fmt.Sprintf("/organization/%s/domains/%s", organizationId, domainId)
b, err := h.doer.Do(ctx, "OrganizationDomainUpdate", "PATCH", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationDomainUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -71,6 +77,9 @@ func (h *DomainHandler) OrganizationDomainUpdate(ctx context.Context, organizati
func (h *DomainHandler) OrganizationDomainVerify(ctx context.Context, organizationId string, domainId string) (*OrganizationDomainVerifyOut, error) {
path := fmt.Sprintf("/organization/%s/domains/%s/verify", organizationId, domainId)
b, err := h.doer.Do(ctx, "OrganizationDomainVerify", "POST", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationDomainVerifyOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -81,6 +90,9 @@ func (h *DomainHandler) OrganizationDomainVerify(ctx context.Context, organizati
func (h *DomainHandler) OrganizationDomainsList(ctx context.Context, organizationId string) ([]DomainOut, error) {
path := fmt.Sprintf("/organization/%s/domains", organizationId)
b, err := h.doer.Do(ctx, "OrganizationDomainsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(organizationDomainsListOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/flink/flink.go b/handler/flink/flink.go
index 6c8ba90..5055ef2 100644
--- a/handler/flink/flink.go
+++ b/handler/flink/flink.go
@@ -30,6 +30,9 @@ type FlinkHandler struct {
func (h *FlinkHandler) ServiceFlinkOverview(ctx context.Context, project string, serviceName string) (*ServiceFlinkOverviewOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/overview", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceFlinkOverview", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkOverviewOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/flinkapplication/flinkapplication.go b/handler/flinkapplication/flinkapplication.go
index db3a652..8f7b2cb 100644
--- a/handler/flinkapplication/flinkapplication.go
+++ b/handler/flinkapplication/flinkapplication.go
@@ -51,6 +51,9 @@ type FlinkApplicationHandler struct {
func (h *FlinkApplicationHandler) ServiceFlinkCreateApplication(ctx context.Context, project string, serviceName string, in *ServiceFlinkCreateApplicationIn) (*ServiceFlinkCreateApplicationOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceFlinkCreateApplication", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkCreateApplicationOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -61,6 +64,9 @@ func (h *FlinkApplicationHandler) ServiceFlinkCreateApplication(ctx context.Cont
func (h *FlinkApplicationHandler) ServiceFlinkDeleteApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkDeleteApplicationOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s", project, serviceName, applicationId)
b, err := h.doer.Do(ctx, "ServiceFlinkDeleteApplication", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkDeleteApplicationOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -71,6 +77,9 @@ func (h *FlinkApplicationHandler) ServiceFlinkDeleteApplication(ctx context.Cont
func (h *FlinkApplicationHandler) ServiceFlinkGetApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkGetApplicationOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s", project, serviceName, applicationId)
b, err := h.doer.Do(ctx, "ServiceFlinkGetApplication", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkGetApplicationOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -81,6 +90,9 @@ func (h *FlinkApplicationHandler) ServiceFlinkGetApplication(ctx context.Context
func (h *FlinkApplicationHandler) ServiceFlinkListApplications(ctx context.Context, project string, serviceName string) ([]ApplicationOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceFlinkListApplications", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceFlinkListApplicationsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -91,6 +103,9 @@ func (h *FlinkApplicationHandler) ServiceFlinkListApplications(ctx context.Conte
func (h *FlinkApplicationHandler) ServiceFlinkUpdateApplication(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkUpdateApplicationIn) (*ServiceFlinkUpdateApplicationOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s", project, serviceName, applicationId)
b, err := h.doer.Do(ctx, "ServiceFlinkUpdateApplication", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkUpdateApplicationOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/flinkapplicationdeployment/flinkapplicationdeployment.go b/handler/flinkapplicationdeployment/flinkapplicationdeployment.go
index 17a6755..518cff1 100644
--- a/handler/flinkapplicationdeployment/flinkapplicationdeployment.go
+++ b/handler/flinkapplicationdeployment/flinkapplicationdeployment.go
@@ -56,6 +56,9 @@ type FlinkApplicationDeploymentHandler struct {
func (h *FlinkApplicationDeploymentHandler) ServiceFlinkCancelApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkCancelApplicationDeploymentOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment/%s/cancel", project, serviceName, applicationId, deploymentId)
b, err := h.doer.Do(ctx, "ServiceFlinkCancelApplicationDeployment", "POST", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkCancelApplicationDeploymentOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -66,6 +69,9 @@ func (h *FlinkApplicationDeploymentHandler) ServiceFlinkCancelApplicationDeploym
func (h *FlinkApplicationDeploymentHandler) ServiceFlinkCreateApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkCreateApplicationDeploymentIn) (*ServiceFlinkCreateApplicationDeploymentOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment", project, serviceName, applicationId)
b, err := h.doer.Do(ctx, "ServiceFlinkCreateApplicationDeployment", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkCreateApplicationDeploymentOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -76,6 +82,9 @@ func (h *FlinkApplicationDeploymentHandler) ServiceFlinkCreateApplicationDeploym
func (h *FlinkApplicationDeploymentHandler) ServiceFlinkDeleteApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkDeleteApplicationDeploymentOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment/%s", project, serviceName, applicationId, deploymentId)
b, err := h.doer.Do(ctx, "ServiceFlinkDeleteApplicationDeployment", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkDeleteApplicationDeploymentOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -86,6 +95,9 @@ func (h *FlinkApplicationDeploymentHandler) ServiceFlinkDeleteApplicationDeploym
func (h *FlinkApplicationDeploymentHandler) ServiceFlinkGetApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkGetApplicationDeploymentOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment/%s", project, serviceName, applicationId, deploymentId)
b, err := h.doer.Do(ctx, "ServiceFlinkGetApplicationDeployment", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkGetApplicationDeploymentOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -96,6 +108,9 @@ func (h *FlinkApplicationDeploymentHandler) ServiceFlinkGetApplicationDeployment
func (h *FlinkApplicationDeploymentHandler) ServiceFlinkListApplicationDeployments(ctx context.Context, project string, serviceName string, applicationId string) ([]DeploymentOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment", project, serviceName, applicationId)
b, err := h.doer.Do(ctx, "ServiceFlinkListApplicationDeployments", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceFlinkListApplicationDeploymentsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -106,6 +121,9 @@ func (h *FlinkApplicationDeploymentHandler) ServiceFlinkListApplicationDeploymen
func (h *FlinkApplicationDeploymentHandler) ServiceFlinkStopApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkStopApplicationDeploymentOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/deployment/%s/stop", project, serviceName, applicationId, deploymentId)
b, err := h.doer.Do(ctx, "ServiceFlinkStopApplicationDeployment", "POST", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkStopApplicationDeploymentOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/flinkapplicationversion/flinkapplicationversion.go b/handler/flinkapplicationversion/flinkapplicationversion.go
index f21e2bc..f4a52dc 100644
--- a/handler/flinkapplicationversion/flinkapplicationversion.go
+++ b/handler/flinkapplicationversion/flinkapplicationversion.go
@@ -46,6 +46,9 @@ type FlinkApplicationVersionHandler struct {
func (h *FlinkApplicationVersionHandler) ServiceFlinkCreateApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkCreateApplicationVersionIn) (*ServiceFlinkCreateApplicationVersionOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/version", project, serviceName, applicationId)
b, err := h.doer.Do(ctx, "ServiceFlinkCreateApplicationVersion", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkCreateApplicationVersionOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -56,6 +59,9 @@ func (h *FlinkApplicationVersionHandler) ServiceFlinkCreateApplicationVersion(ct
func (h *FlinkApplicationVersionHandler) ServiceFlinkDeleteApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, applicationVersionId string) (*ServiceFlinkDeleteApplicationVersionOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/version/%s", project, serviceName, applicationId, applicationVersionId)
b, err := h.doer.Do(ctx, "ServiceFlinkDeleteApplicationVersion", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkDeleteApplicationVersionOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -66,6 +72,9 @@ func (h *FlinkApplicationVersionHandler) ServiceFlinkDeleteApplicationVersion(ct
func (h *FlinkApplicationVersionHandler) ServiceFlinkGetApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, applicationVersionId string) (*ServiceFlinkGetApplicationVersionOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/version/%s", project, serviceName, applicationId, applicationVersionId)
b, err := h.doer.Do(ctx, "ServiceFlinkGetApplicationVersion", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkGetApplicationVersionOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -76,6 +85,9 @@ func (h *FlinkApplicationVersionHandler) ServiceFlinkGetApplicationVersion(ctx c
func (h *FlinkApplicationVersionHandler) ServiceFlinkValidateApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkValidateApplicationVersionIn) (*ServiceFlinkValidateApplicationVersionOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/application/%s/version/validate", project, serviceName, applicationId)
b, err := h.doer.Do(ctx, "ServiceFlinkValidateApplicationVersion", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkValidateApplicationVersionOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/flinkjob/flinkjob.go b/handler/flinkjob/flinkjob.go
index 97feeb4..5d877f5 100644
--- a/handler/flinkjob/flinkjob.go
+++ b/handler/flinkjob/flinkjob.go
@@ -35,6 +35,9 @@ type FlinkJobHandler struct {
func (h *FlinkJobHandler) ServiceFlinkJobDetails(ctx context.Context, project string, serviceName string, jobId string) (*ServiceFlinkJobDetailsOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/job/%s", project, serviceName, jobId)
b, err := h.doer.Do(ctx, "ServiceFlinkJobDetails", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceFlinkJobDetailsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -45,6 +48,9 @@ func (h *FlinkJobHandler) ServiceFlinkJobDetails(ctx context.Context, project st
func (h *FlinkJobHandler) ServiceFlinkJobsList(ctx context.Context, project string, serviceName string) ([]JobOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/flink/job", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceFlinkJobsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceFlinkJobsListOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/kafka/kafka.go b/handler/kafka/kafka.go
index 06f0ea1..35a6e53 100644
--- a/handler/kafka/kafka.go
+++ b/handler/kafka/kafka.go
@@ -75,6 +75,9 @@ type KafkaHandler struct {
func (h *KafkaHandler) ServiceKafkaAclAdd(ctx context.Context, project string, serviceName string, in *ServiceKafkaAclAddIn) ([]AclOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/acl", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaAclAdd", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaAclAddOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -85,6 +88,9 @@ func (h *KafkaHandler) ServiceKafkaAclAdd(ctx context.Context, project string, s
func (h *KafkaHandler) ServiceKafkaAclDelete(ctx context.Context, project string, serviceName string, kafkaAclId string) ([]AclOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/acl/%s", project, serviceName, kafkaAclId)
b, err := h.doer.Do(ctx, "ServiceKafkaAclDelete", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaAclDeleteOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -95,6 +101,9 @@ func (h *KafkaHandler) ServiceKafkaAclDelete(ctx context.Context, project string
func (h *KafkaHandler) ServiceKafkaAclList(ctx context.Context, project string, serviceName string) ([]AclOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/acl", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaAclList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaAclListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -115,6 +124,9 @@ func (h *KafkaHandler) ServiceKafkaQuotaDelete(ctx context.Context, project stri
func (h *KafkaHandler) ServiceKafkaQuotaDescribe(ctx context.Context, project string, serviceName string) (*ServiceKafkaQuotaDescribeOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/quota/describe", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaQuotaDescribe", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaQuotaDescribeOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -125,6 +137,9 @@ func (h *KafkaHandler) ServiceKafkaQuotaDescribe(ctx context.Context, project st
func (h *KafkaHandler) ServiceKafkaQuotaList(ctx context.Context, project string, serviceName string) ([]QuotaOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/quota", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaQuotaList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaQuotaListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -135,6 +150,9 @@ func (h *KafkaHandler) ServiceKafkaQuotaList(ctx context.Context, project string
func (h *KafkaHandler) ServiceKafkaTieredStorageStorageUsageByTopic(ctx context.Context, project string, serviceName string) (map[string]any, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/tiered-storage/storage-usage/by-topic", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaTieredStorageStorageUsageByTopic", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaTieredStorageStorageUsageByTopicOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -145,6 +163,9 @@ func (h *KafkaHandler) ServiceKafkaTieredStorageStorageUsageByTopic(ctx context.
func (h *KafkaHandler) ServiceKafkaTieredStorageStorageUsageTotal(ctx context.Context, project string, serviceName string) (int, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/tiered-storage/storage-usage/total", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaTieredStorageStorageUsageTotal", "GET", path, nil)
+ if err != nil {
+ return 0, err
+ }
out := new(serviceKafkaTieredStorageStorageUsageTotalOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -155,6 +176,9 @@ func (h *KafkaHandler) ServiceKafkaTieredStorageStorageUsageTotal(ctx context.Co
func (h *KafkaHandler) ServiceKafkaTieredStorageSummary(ctx context.Context, project string, serviceName string) (*ServiceKafkaTieredStorageSummaryOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/tiered-storage/summary", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaTieredStorageSummary", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceKafkaTieredStorageSummaryOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/kafkaconnect/kafkaconnect.go b/handler/kafkaconnect/kafkaconnect.go
index 2f77f5a..f101600 100644
--- a/handler/kafkaconnect/kafkaconnect.go
+++ b/handler/kafkaconnect/kafkaconnect.go
@@ -80,6 +80,9 @@ type KafkaConnectHandler struct {
func (h *KafkaConnectHandler) ServiceKafkaConnectCreateConnector(ctx context.Context, project string, serviceName string, in *ServiceKafkaConnectCreateConnectorIn) (*ServiceKafkaConnectCreateConnectorOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/connectors", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaConnectCreateConnector", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaConnectCreateConnectorOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -95,6 +98,9 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectDeleteConnector(ctx context.Con
func (h *KafkaConnectHandler) ServiceKafkaConnectEditConnector(ctx context.Context, project string, serviceName string, connectorName string, in *ServiceKafkaConnectEditConnectorIn) (*ServiceKafkaConnectEditConnectorOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/connectors/%s", project, serviceName, connectorName)
b, err := h.doer.Do(ctx, "ServiceKafkaConnectEditConnector", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaConnectEditConnectorOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -105,6 +111,9 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectEditConnector(ctx context.Conte
func (h *KafkaConnectHandler) ServiceKafkaConnectGetAvailableConnectors(ctx context.Context, project string, serviceName string) ([]PluginOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/available-connectors", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaConnectGetAvailableConnectors", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaConnectGetAvailableConnectorsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -115,6 +124,9 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectGetAvailableConnectors(ctx cont
func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorConfiguration(ctx context.Context, project string, serviceName string, connectorName string) ([]ConfigurationSchemaOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/connector-plugins/%s/configuration", project, serviceName, connectorName)
b, err := h.doer.Do(ctx, "ServiceKafkaConnectGetConnectorConfiguration", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaConnectGetConnectorConfigurationOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -125,6 +137,9 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorConfiguration(ctx c
func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorStatus(ctx context.Context, project string, serviceName string, connectorName string) (*ServiceKafkaConnectGetConnectorStatusOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/connectors/%s/status", project, serviceName, connectorName)
b, err := h.doer.Do(ctx, "ServiceKafkaConnectGetConnectorStatus", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaConnectGetConnectorStatusOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -135,6 +150,9 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorStatus(ctx context.
func (h *KafkaConnectHandler) ServiceKafkaConnectList(ctx context.Context, project string, serviceName string) ([]ConnectorOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/connectors", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaConnectList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaConnectListOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/kafkamirrormaker/kafkamirrormaker.go b/handler/kafkamirrormaker/kafkamirrormaker.go
index 38c1cfc..285ee3b 100644
--- a/handler/kafkamirrormaker/kafkamirrormaker.go
+++ b/handler/kafkamirrormaker/kafkamirrormaker.go
@@ -60,6 +60,9 @@ func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerDeleteReplicationFlow(c
func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, targetCluster string) (*ServiceKafkaMirrorMakerGetReplicationFlowOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/mirrormaker/replication-flows/%s/%s", project, serviceName, sourceCluster, targetCluster)
b, err := h.doer.Do(ctx, "ServiceKafkaMirrorMakerGetReplicationFlow", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaMirrorMakerGetReplicationFlowOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -70,6 +73,9 @@ func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlow(ctx
func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlows(ctx context.Context, project string, serviceName string) ([]ReplicationFlowOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/mirrormaker/replication-flows", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaMirrorMakerGetReplicationFlows", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaMirrorMakerGetReplicationFlowsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -80,6 +86,9 @@ func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerGetReplicationFlows(ctx
func (h *KafkaMirrorMakerHandler) ServiceKafkaMirrorMakerPatchReplicationFlow(ctx context.Context, project string, serviceName string, sourceCluster string, targetCluster string, in *ServiceKafkaMirrorMakerPatchReplicationFlowIn) (*ServiceKafkaMirrorMakerPatchReplicationFlowOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/mirrormaker/replication-flows/%s/%s", project, serviceName, sourceCluster, targetCluster)
b, err := h.doer.Do(ctx, "ServiceKafkaMirrorMakerPatchReplicationFlow", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaMirrorMakerPatchReplicationFlowOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/kafkaschemaregistry/kafkaschemaregistry.go b/handler/kafkaschemaregistry/kafkaschemaregistry.go
index c4f1962..4348e4a 100644
--- a/handler/kafkaschemaregistry/kafkaschemaregistry.go
+++ b/handler/kafkaschemaregistry/kafkaschemaregistry.go
@@ -100,6 +100,9 @@ type KafkaSchemaRegistryHandler struct {
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclAdd(ctx context.Context, project string, serviceName string, in *ServiceSchemaRegistryAclAddIn) ([]AclOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema-registry/acl", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistryAclAdd", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceSchemaRegistryAclAddOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -110,6 +113,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclAdd(ctx context.Con
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclDelete(ctx context.Context, project string, serviceName string, schemaRegistryAclId string) ([]AclOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema-registry/acl/%s", project, serviceName, schemaRegistryAclId)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistryAclDelete", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceSchemaRegistryAclDeleteOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -120,6 +126,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclDelete(ctx context.
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclList(ctx context.Context, project string, serviceName string) ([]AclOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema-registry/acl", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistryAclList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceSchemaRegistryAclListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -130,6 +139,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryAclList(ctx context.Co
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryCompatibility(ctx context.Context, project string, serviceName string, subjectName string, versionId int, in *ServiceSchemaRegistryCompatibilityIn) (bool, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/compatibility/subjects/%s/versions/%d", project, serviceName, subjectName, versionId)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistryCompatibility", "POST", path, in)
+ if err != nil {
+ return false, err
+ }
out := new(serviceSchemaRegistryCompatibilityOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -140,6 +152,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryCompatibility(ctx cont
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryGlobalConfigGet(ctx context.Context, project string, serviceName string) (string, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/config", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistryGlobalConfigGet", "GET", path, nil)
+ if err != nil {
+ return "", err
+ }
out := new(serviceSchemaRegistryGlobalConfigGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -150,6 +165,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryGlobalConfigGet(ctx co
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistryGlobalConfigPut(ctx context.Context, project string, serviceName string, in *ServiceSchemaRegistryGlobalConfigPutIn) (string, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/config", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistryGlobalConfigPut", "PUT", path, in)
+ if err != nil {
+ return "", err
+ }
out := new(serviceSchemaRegistryGlobalConfigPutOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -165,6 +183,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySchemaGet(ctx context.
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectConfigGet(ctx context.Context, project string, serviceName string, subjectName string) (string, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/config/%s", project, serviceName, subjectName)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistrySubjectConfigGet", "GET", path, nil)
+ if err != nil {
+ return "", err
+ }
out := new(serviceSchemaRegistrySubjectConfigGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -175,6 +196,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectConfigGet(ctx c
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectConfigPut(ctx context.Context, project string, serviceName string, subjectName string, in *ServiceSchemaRegistrySubjectConfigPutIn) (string, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/config/%s", project, serviceName, subjectName)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistrySubjectConfigPut", "PUT", path, in)
+ if err != nil {
+ return "", err
+ }
out := new(serviceSchemaRegistrySubjectConfigPutOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -200,6 +224,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectVersionGet(ctx
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectVersionPost(ctx context.Context, project string, serviceName string, subjectName string, in *ServiceSchemaRegistrySubjectVersionPostIn) (int, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/subjects/%s/versions", project, serviceName, subjectName)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistrySubjectVersionPost", "POST", path, in)
+ if err != nil {
+ return 0, err
+ }
out := new(serviceSchemaRegistrySubjectVersionPostOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -210,6 +237,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectVersionPost(ctx
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectVersionsGet(ctx context.Context, project string, serviceName string, subjectName string) ([]int, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/subjects/%s/versions", project, serviceName, subjectName)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistrySubjectVersionsGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceSchemaRegistrySubjectVersionsGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -220,6 +250,9 @@ func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjectVersionsGet(ctx
func (h *KafkaSchemaRegistryHandler) ServiceSchemaRegistrySubjects(ctx context.Context, project string, serviceName string) ([]string, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/schema/subjects", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceSchemaRegistrySubjects", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceSchemaRegistrySubjectsOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/kafkatopic/kafkatopic.go b/handler/kafkatopic/kafkatopic.go
index 1e9d7ce..4181702 100644
--- a/handler/kafkatopic/kafkatopic.go
+++ b/handler/kafkatopic/kafkatopic.go
@@ -70,6 +70,9 @@ func (h *KafkaTopicHandler) ServiceKafkaTopicDelete(ctx context.Context, project
func (h *KafkaTopicHandler) ServiceKafkaTopicGet(ctx context.Context, project string, serviceName string, topicName string) (*ServiceKafkaTopicGetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/topic/%s", project, serviceName, topicName)
b, err := h.doer.Do(ctx, "ServiceKafkaTopicGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaTopicGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -80,6 +83,9 @@ func (h *KafkaTopicHandler) ServiceKafkaTopicGet(ctx context.Context, project st
func (h *KafkaTopicHandler) ServiceKafkaTopicList(ctx context.Context, project string, serviceName string) ([]TopicOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/topic", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceKafkaTopicList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaTopicListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -90,6 +96,9 @@ func (h *KafkaTopicHandler) ServiceKafkaTopicList(ctx context.Context, project s
func (h *KafkaTopicHandler) ServiceKafkaTopicMessageList(ctx context.Context, project string, serviceName string, topicName string, in *ServiceKafkaTopicMessageListIn) ([]MessageOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/rest/topics/%s/messages", project, serviceName, topicName)
b, err := h.doer.Do(ctx, "ServiceKafkaTopicMessageList", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceKafkaTopicMessageListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -100,6 +109,9 @@ func (h *KafkaTopicHandler) ServiceKafkaTopicMessageList(ctx context.Context, pr
func (h *KafkaTopicHandler) ServiceKafkaTopicMessageProduce(ctx context.Context, project string, serviceName string, topicName string, in *ServiceKafkaTopicMessageProduceIn) (*ServiceKafkaTopicMessageProduceOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/kafka/rest/topics/%s/produce", project, serviceName, topicName)
b, err := h.doer.Do(ctx, "ServiceKafkaTopicMessageProduce", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceKafkaTopicMessageProduceOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/mysql/mysql.go b/handler/mysql/mysql.go
index 91f7fdd..f93c67b 100644
--- a/handler/mysql/mysql.go
+++ b/handler/mysql/mysql.go
@@ -30,6 +30,9 @@ type MySQLHandler struct {
func (h *MySQLHandler) MySQLServiceQueryStatistics(ctx context.Context, project string, serviceName string, in *MySqlserviceQueryStatisticsIn) ([]QueryOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/mysql/query/stats", project, serviceName)
b, err := h.doer.Do(ctx, "MySQLServiceQueryStatistics", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(mySqlserviceQueryStatisticsOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/opensearch/opensearch.go b/handler/opensearch/opensearch.go
index 9d853b2..755c050 100644
--- a/handler/opensearch/opensearch.go
+++ b/handler/opensearch/opensearch.go
@@ -66,6 +66,9 @@ type OpenSearchHandler struct {
func (h *OpenSearchHandler) ServiceOpenSearchAclGet(ctx context.Context, project string, serviceName string) (*ServiceOpenSearchAclGetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/opensearch/acl", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceOpenSearchAclGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceOpenSearchAclGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -76,6 +79,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchAclGet(ctx context.Context, project
func (h *OpenSearchHandler) ServiceOpenSearchAclSet(ctx context.Context, project string, serviceName string, in *ServiceOpenSearchAclSetIn) (*ServiceOpenSearchAclSetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/opensearch/acl", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceOpenSearchAclSet", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceOpenSearchAclSetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -86,6 +92,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchAclSet(ctx context.Context, project
func (h *OpenSearchHandler) ServiceOpenSearchAclUpdate(ctx context.Context, project string, serviceName string, in *ServiceOpenSearchAclUpdateIn) (*ServiceOpenSearchAclUpdateOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/opensearch/acl", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceOpenSearchAclUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceOpenSearchAclUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -101,6 +110,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchIndexDelete(ctx context.Context, pr
func (h *OpenSearchHandler) ServiceOpenSearchIndexList(ctx context.Context, project string, serviceName string) ([]IndexeOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/index", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceOpenSearchIndexList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceOpenSearchIndexListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -111,6 +123,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchIndexList(ctx context.Context, proj
func (h *OpenSearchHandler) ServiceOpenSearchSecurityGet(ctx context.Context, project string, serviceName string) (*ServiceOpenSearchSecurityGetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/opensearch/security", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceOpenSearchSecurityGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceOpenSearchSecurityGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -121,6 +136,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchSecurityGet(ctx context.Context, pr
func (h *OpenSearchHandler) ServiceOpenSearchSecurityReset(ctx context.Context, project string, serviceName string, in *ServiceOpenSearchSecurityResetIn) (*ServiceOpenSearchSecurityResetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/opensearch/security/admin", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceOpenSearchSecurityReset", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceOpenSearchSecurityResetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -131,6 +149,9 @@ func (h *OpenSearchHandler) ServiceOpenSearchSecurityReset(ctx context.Context,
func (h *OpenSearchHandler) ServiceOpenSearchSecuritySet(ctx context.Context, project string, serviceName string, in *ServiceOpenSearchSecuritySetIn) (*ServiceOpenSearchSecuritySetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/opensearch/security/admin", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceOpenSearchSecuritySet", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceOpenSearchSecuritySetOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/organization/organization.go b/handler/organization/organization.go
index 297bde1..5b89998 100644
--- a/handler/organization/organization.go
+++ b/handler/organization/organization.go
@@ -61,6 +61,9 @@ type OrganizationHandler struct {
func (h *OrganizationHandler) OrganizationAuthenticationConfigGet(ctx context.Context, organizationId string) (*OrganizationAuthenticationConfigGetOut, error) {
path := fmt.Sprintf("/organization/%s/config/authentication", organizationId)
b, err := h.doer.Do(ctx, "OrganizationAuthenticationConfigGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationAuthenticationConfigGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -71,6 +74,9 @@ func (h *OrganizationHandler) OrganizationAuthenticationConfigGet(ctx context.Co
func (h *OrganizationHandler) OrganizationAuthenticationConfigUpdate(ctx context.Context, organizationId string, in *OrganizationAuthenticationConfigUpdateIn) (*OrganizationAuthenticationConfigUpdateOut, error) {
path := fmt.Sprintf("/organization/%s/config/authentication", organizationId)
b, err := h.doer.Do(ctx, "OrganizationAuthenticationConfigUpdate", "PATCH", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationAuthenticationConfigUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -81,6 +87,9 @@ func (h *OrganizationHandler) OrganizationAuthenticationConfigUpdate(ctx context
func (h *OrganizationHandler) OrganizationGet(ctx context.Context, organizationId string) (*OrganizationGetOut, error) {
path := fmt.Sprintf("/organization/%s", organizationId)
b, err := h.doer.Do(ctx, "OrganizationGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -91,6 +100,9 @@ func (h *OrganizationHandler) OrganizationGet(ctx context.Context, organizationI
func (h *OrganizationHandler) OrganizationProjectsList(ctx context.Context, organizationId string) (*OrganizationProjectsListOut, error) {
path := fmt.Sprintf("/organization/%s/projects", organizationId)
b, err := h.doer.Do(ctx, "OrganizationProjectsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationProjectsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -101,6 +113,9 @@ func (h *OrganizationHandler) OrganizationProjectsList(ctx context.Context, orga
func (h *OrganizationHandler) OrganizationUpdate(ctx context.Context, organizationId string, in *OrganizationUpdateIn) (*OrganizationUpdateOut, error) {
path := fmt.Sprintf("/organization/%s", organizationId)
b, err := h.doer.Do(ctx, "OrganizationUpdate", "PATCH", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -111,6 +126,9 @@ func (h *OrganizationHandler) OrganizationUpdate(ctx context.Context, organizati
func (h *OrganizationHandler) UserOrganizationCreate(ctx context.Context, in *UserOrganizationCreateIn) (*UserOrganizationCreateOut, error) {
path := fmt.Sprintf("/organizations")
b, err := h.doer.Do(ctx, "UserOrganizationCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(UserOrganizationCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -121,6 +139,9 @@ func (h *OrganizationHandler) UserOrganizationCreate(ctx context.Context, in *Us
func (h *OrganizationHandler) UserOrganizationsList(ctx context.Context) ([]OrganizationOut, error) {
path := fmt.Sprintf("/organizations")
b, err := h.doer.Do(ctx, "UserOrganizationsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(userOrganizationsListOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/organizationuser/organizationuser.go b/handler/organizationuser/organizationuser.go
index 37b4fff..6aab601 100644
--- a/handler/organizationuser/organizationuser.go
+++ b/handler/organizationuser/organizationuser.go
@@ -91,6 +91,9 @@ type OrganizationUserHandler struct {
func (h *OrganizationUserHandler) OrganizationUserAuthenticationMethodsList(ctx context.Context, organizationId string, memberUserId string) ([]AuthenticationMethodOut, error) {
path := fmt.Sprintf("/organization/%s/user/%s/authentication_methods", organizationId, memberUserId)
b, err := h.doer.Do(ctx, "OrganizationUserAuthenticationMethodsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(organizationUserAuthenticationMethodsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -106,6 +109,9 @@ func (h *OrganizationUserHandler) OrganizationUserDelete(ctx context.Context, or
func (h *OrganizationUserHandler) OrganizationUserGet(ctx context.Context, organizationId string, memberUserId string) (*OrganizationUserGetOut, error) {
path := fmt.Sprintf("/organization/%s/user/%s", organizationId, memberUserId)
b, err := h.doer.Do(ctx, "OrganizationUserGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationUserGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -126,6 +132,9 @@ func (h *OrganizationUserHandler) OrganizationUserInvitationDelete(ctx context.C
func (h *OrganizationUserHandler) OrganizationUserInvitationsList(ctx context.Context, organizationId string) ([]InvitationOut, error) {
path := fmt.Sprintf("/organization/%s/invitation", organizationId)
b, err := h.doer.Do(ctx, "OrganizationUserInvitationsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(organizationUserInvitationsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -141,6 +150,9 @@ func (h *OrganizationUserHandler) OrganizationUserInvite(ctx context.Context, or
func (h *OrganizationUserHandler) OrganizationUserList(ctx context.Context, organizationId string) ([]UserOut, error) {
path := fmt.Sprintf("/organization/%s/user", organizationId)
b, err := h.doer.Do(ctx, "OrganizationUserList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(organizationUserListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -161,6 +173,9 @@ func (h *OrganizationUserHandler) OrganizationUserRevokeToken(ctx context.Contex
func (h *OrganizationUserHandler) OrganizationUserSet(ctx context.Context, organizationId string, memberUserId string) (*OrganizationUserSetOut, error) {
path := fmt.Sprintf("/organization/%s/user/%s", organizationId, memberUserId)
b, err := h.doer.Do(ctx, "OrganizationUserSet", "PUT", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationUserSetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -171,6 +186,9 @@ func (h *OrganizationUserHandler) OrganizationUserSet(ctx context.Context, organ
func (h *OrganizationUserHandler) OrganizationUserTokensList(ctx context.Context, organizationId string, memberUserId string) ([]TokenOut, error) {
path := fmt.Sprintf("/organization/%s/user/%s/access-tokens", organizationId, memberUserId)
b, err := h.doer.Do(ctx, "OrganizationUserTokensList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(organizationUserTokensListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -181,6 +199,9 @@ func (h *OrganizationUserHandler) OrganizationUserTokensList(ctx context.Context
func (h *OrganizationUserHandler) OrganizationUserUpdate(ctx context.Context, organizationId string, memberUserId string, in *OrganizationUserUpdateIn) (*OrganizationUserUpdateOut, error) {
path := fmt.Sprintf("/organization/%s/user/%s", organizationId, memberUserId)
b, err := h.doer.Do(ctx, "OrganizationUserUpdate", "PATCH", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(OrganizationUserUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/postgresql/postgresql.go b/handler/postgresql/postgresql.go
index 254ea52..4440994 100644
--- a/handler/postgresql/postgresql.go
+++ b/handler/postgresql/postgresql.go
@@ -55,6 +55,9 @@ type PostgreSQLHandler struct {
func (h *PostgreSQLHandler) PGServiceAvailableExtensions(ctx context.Context, project string, serviceName string) ([]ExtensionOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/pg/available-extensions", project, serviceName)
b, err := h.doer.Do(ctx, "PGServiceAvailableExtensions", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(pgserviceAvailableExtensionsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -65,6 +68,9 @@ func (h *PostgreSQLHandler) PGServiceAvailableExtensions(ctx context.Context, pr
func (h *PostgreSQLHandler) PGServiceQueryStatistics(ctx context.Context, project string, serviceName string, in *PgserviceQueryStatisticsIn) ([]QueryOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/pg/query/stats", project, serviceName)
b, err := h.doer.Do(ctx, "PGServiceQueryStatistics", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(pgserviceQueryStatisticsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -75,6 +81,9 @@ func (h *PostgreSQLHandler) PGServiceQueryStatistics(ctx context.Context, projec
func (h *PostgreSQLHandler) PgAvailableExtensions(ctx context.Context, tenant string) ([]PgOut, error) {
path := fmt.Sprintf("/tenants/%s/pg-available-extensions", tenant)
b, err := h.doer.Do(ctx, "PgAvailableExtensions", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(pgAvailableExtensionsOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/privatelink/privatelink.go b/handler/privatelink/privatelink.go
index 53fb665..1ac9aab 100644
--- a/handler/privatelink/privatelink.go
+++ b/handler/privatelink/privatelink.go
@@ -90,6 +90,9 @@ type PrivatelinkHandler struct {
func (h *PrivatelinkHandler) PublicPrivatelinkAvailabilityList(ctx context.Context, tenant string) ([]PrivatelinkAvailabilityOut, error) {
path := fmt.Sprintf("/tenants/%s/privatelink-availability", tenant)
b, err := h.doer.Do(ctx, "PublicPrivatelinkAvailabilityList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(publicPrivatelinkAvailabilityListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -100,6 +103,9 @@ func (h *PrivatelinkHandler) PublicPrivatelinkAvailabilityList(ctx context.Conte
func (h *PrivatelinkHandler) ServicePrivatelinkAWSConnectionList(ctx context.Context, project string, serviceName string) ([]ConnectionOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/aws/connections", project, serviceName)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAWSConnectionList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(servicePrivatelinkAwsconnectionListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -110,6 +116,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAWSConnectionList(ctx context.Con
func (h *PrivatelinkHandler) ServicePrivatelinkAWSCreate(ctx context.Context, project string, serviceName string, in *ServicePrivatelinkAwscreateIn) (*ServicePrivatelinkAwscreateOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/aws", project, serviceName)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAWSCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServicePrivatelinkAwscreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -120,6 +129,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAWSCreate(ctx context.Context, pr
func (h *PrivatelinkHandler) ServicePrivatelinkAWSDelete(ctx context.Context, project string, serviceName string) (*ServicePrivatelinkAwsdeleteOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/aws", project, serviceName)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAWSDelete", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServicePrivatelinkAwsdeleteOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -130,6 +142,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAWSDelete(ctx context.Context, pr
func (h *PrivatelinkHandler) ServicePrivatelinkAWSGet(ctx context.Context, project string, serviceName string) (*ServicePrivatelinkAwsgetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/aws", project, serviceName)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAWSGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServicePrivatelinkAwsgetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -140,6 +155,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAWSGet(ctx context.Context, proje
func (h *PrivatelinkHandler) ServicePrivatelinkAWSUpdate(ctx context.Context, project string, serviceName string, in *ServicePrivatelinkAwsupdateIn) (*ServicePrivatelinkAwsupdateOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/aws", project, serviceName)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAWSUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServicePrivatelinkAwsupdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -150,6 +168,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAWSUpdate(ctx context.Context, pr
func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionApproval(ctx context.Context, project string, serviceName string, privatelinkConnectionId string) (*ServicePrivatelinkAzureConnectionApprovalOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure/connections/%s/approve", project, serviceName, privatelinkConnectionId)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureConnectionApproval", "POST", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServicePrivatelinkAzureConnectionApprovalOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -160,6 +181,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionApproval(ctx conte
func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionList(ctx context.Context, project string, serviceName string) ([]ConnectionOutAlt, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure/connections", project, serviceName)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureConnectionList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(servicePrivatelinkAzureConnectionListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -170,6 +194,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionList(ctx context.C
func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionUpdate(ctx context.Context, project string, serviceName string, privatelinkConnectionId string, in *ServicePrivatelinkAzureConnectionUpdateIn) (*ServicePrivatelinkAzureConnectionUpdateOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure/connections/%s", project, serviceName, privatelinkConnectionId)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureConnectionUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServicePrivatelinkAzureConnectionUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -180,6 +207,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureConnectionUpdate(ctx context
func (h *PrivatelinkHandler) ServicePrivatelinkAzureCreate(ctx context.Context, project string, serviceName string, in *ServicePrivatelinkAzureCreateIn) (*ServicePrivatelinkAzureCreateOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure", project, serviceName)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServicePrivatelinkAzureCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -190,6 +220,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureCreate(ctx context.Context,
func (h *PrivatelinkHandler) ServicePrivatelinkAzureDelete(ctx context.Context, project string, serviceName string) (*ServicePrivatelinkAzureDeleteOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure", project, serviceName)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureDelete", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServicePrivatelinkAzureDeleteOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -200,6 +233,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureDelete(ctx context.Context,
func (h *PrivatelinkHandler) ServicePrivatelinkAzureGet(ctx context.Context, project string, serviceName string) (*ServicePrivatelinkAzureGetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure", project, serviceName)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServicePrivatelinkAzureGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -210,6 +246,9 @@ func (h *PrivatelinkHandler) ServicePrivatelinkAzureGet(ctx context.Context, pro
func (h *PrivatelinkHandler) ServicePrivatelinkAzureUpdate(ctx context.Context, project string, serviceName string, in *ServicePrivatelinkAzureUpdateIn) (*ServicePrivatelinkAzureUpdateOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/privatelink/azure", project, serviceName)
b, err := h.doer.Do(ctx, "ServicePrivatelinkAzureUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ServicePrivatelinkAzureUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/project/project.go b/handler/project/project.go
index 226ea66..3096360 100644
--- a/handler/project/project.go
+++ b/handler/project/project.go
@@ -121,6 +121,9 @@ type ProjectHandler struct {
func (h *ProjectHandler) ListProjectVpcPeeringConnectionTypes(ctx context.Context, project string) ([]VpcPeeringConnectionTypeOut, error) {
path := fmt.Sprintf("/project/%s/vpc-peering-connection-types", project)
b, err := h.doer.Do(ctx, "ListProjectVpcPeeringConnectionTypes", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(listProjectVpcPeeringConnectionTypesOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -131,6 +134,9 @@ func (h *ProjectHandler) ListProjectVpcPeeringConnectionTypes(ctx context.Contex
func (h *ProjectHandler) ProjectAlertsList(ctx context.Context, project string) ([]AlertOut, error) {
path := fmt.Sprintf("/project/%s/alerts", project)
b, err := h.doer.Do(ctx, "ProjectAlertsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(projectAlertsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -141,6 +147,9 @@ func (h *ProjectHandler) ProjectAlertsList(ctx context.Context, project string)
func (h *ProjectHandler) ProjectCreate(ctx context.Context, in *ProjectCreateIn) (*ProjectCreateOut, error) {
path := fmt.Sprintf("/project")
b, err := h.doer.Do(ctx, "ProjectCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(projectCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -156,6 +165,9 @@ func (h *ProjectHandler) ProjectDelete(ctx context.Context, project string) erro
func (h *ProjectHandler) ProjectGenerateSbomDownloadUrl(ctx context.Context, project string, fileFormat string) (string, error) {
path := fmt.Sprintf("/project/%s/generate-sbom-download-url/%s", project, fileFormat)
b, err := h.doer.Do(ctx, "ProjectGenerateSbomDownloadUrl", "GET", path, nil)
+ if err != nil {
+ return "", err
+ }
out := new(projectGenerateSbomDownloadUrlOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -166,6 +178,9 @@ func (h *ProjectHandler) ProjectGenerateSbomDownloadUrl(ctx context.Context, pro
func (h *ProjectHandler) ProjectGet(ctx context.Context, project string) (*ProjectGetOut, error) {
path := fmt.Sprintf("/project/%s", project)
b, err := h.doer.Do(ctx, "ProjectGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(projectGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -176,6 +191,9 @@ func (h *ProjectHandler) ProjectGet(ctx context.Context, project string) (*Proje
func (h *ProjectHandler) ProjectGetEventLogs(ctx context.Context, project string) ([]EventOut, error) {
path := fmt.Sprintf("/project/%s/events", project)
b, err := h.doer.Do(ctx, "ProjectGetEventLogs", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(projectGetEventLogsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -191,6 +209,9 @@ func (h *ProjectHandler) ProjectInvite(ctx context.Context, project string, in *
func (h *ProjectHandler) ProjectInviteAccept(ctx context.Context, project string, inviteVerificationCode string) (*ProjectInviteAcceptOut, error) {
path := fmt.Sprintf("/project/%s/invite/%s", project, inviteVerificationCode)
b, err := h.doer.Do(ctx, "ProjectInviteAccept", "POST", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(projectInviteAcceptOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -206,6 +227,9 @@ func (h *ProjectHandler) ProjectInviteDelete(ctx context.Context, project string
func (h *ProjectHandler) ProjectList(ctx context.Context) (*ProjectListOut, error) {
path := fmt.Sprintf("/project")
b, err := h.doer.Do(ctx, "ProjectList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ProjectListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -216,6 +240,9 @@ func (h *ProjectHandler) ProjectList(ctx context.Context) (*ProjectListOut, erro
func (h *ProjectHandler) ProjectPrivatelinkAvailabilityList(ctx context.Context, project string) ([]PrivatelinkAvailabilityOut, error) {
path := fmt.Sprintf("/project/%s/privatelink-availability", project)
b, err := h.doer.Do(ctx, "ProjectPrivatelinkAvailabilityList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(projectPrivatelinkAvailabilityListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -226,6 +253,9 @@ func (h *ProjectHandler) ProjectPrivatelinkAvailabilityList(ctx context.Context,
func (h *ProjectHandler) ProjectTagsList(ctx context.Context, project string) (map[string]string, error) {
path := fmt.Sprintf("/project/%s/tags", project)
b, err := h.doer.Do(ctx, "ProjectTagsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(projectTagsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -246,6 +276,9 @@ func (h *ProjectHandler) ProjectTagsUpdate(ctx context.Context, project string,
func (h *ProjectHandler) ProjectUpdate(ctx context.Context, project string, in *ProjectUpdateIn) (*ProjectUpdateOut, error) {
path := fmt.Sprintf("/project/%s", project)
b, err := h.doer.Do(ctx, "ProjectUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(projectUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -256,6 +289,9 @@ func (h *ProjectHandler) ProjectUpdate(ctx context.Context, project string, in *
func (h *ProjectHandler) ProjectUserList(ctx context.Context, project string) (*ProjectUserListOut, error) {
path := fmt.Sprintf("/project/%s/users", project)
b, err := h.doer.Do(ctx, "ProjectUserList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ProjectUserListOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/projectbilling/projectbilling.go b/handler/projectbilling/projectbilling.go
index bb3cf2f..cdfaf29 100644
--- a/handler/projectbilling/projectbilling.go
+++ b/handler/projectbilling/projectbilling.go
@@ -41,6 +41,9 @@ type ProjectBillingHandler struct {
func (h *ProjectBillingHandler) ProjectCreditsClaim(ctx context.Context, project string, in *ProjectCreditsClaimIn) (*ProjectCreditsClaimOut, error) {
path := fmt.Sprintf("/project/%s/credits", project)
b, err := h.doer.Do(ctx, "ProjectCreditsClaim", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(projectCreditsClaimOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -51,6 +54,9 @@ func (h *ProjectBillingHandler) ProjectCreditsClaim(ctx context.Context, project
func (h *ProjectBillingHandler) ProjectCreditsList(ctx context.Context, project string) ([]CreditOut, error) {
path := fmt.Sprintf("/project/%s/credits", project)
b, err := h.doer.Do(ctx, "ProjectCreditsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(projectCreditsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -61,6 +67,9 @@ func (h *ProjectBillingHandler) ProjectCreditsList(ctx context.Context, project
func (h *ProjectBillingHandler) ProjectInvoiceList(ctx context.Context, project string) ([]InvoiceOut, error) {
path := fmt.Sprintf("/project/%s/invoice", project)
b, err := h.doer.Do(ctx, "ProjectInvoiceList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(projectInvoiceListOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/service/service.go b/handler/service/service.go
index 71c2871..4a9ea37 100644
--- a/handler/service/service.go
+++ b/handler/service/service.go
@@ -176,6 +176,9 @@ type ServiceHandler struct {
func (h *ServiceHandler) ListProjectServiceTypes(ctx context.Context, project string) (*ListProjectServiceTypesOut, error) {
path := fmt.Sprintf("/project/%s/service_types", project)
b, err := h.doer.Do(ctx, "ListProjectServiceTypes", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(listProjectServiceTypesOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -186,6 +189,9 @@ func (h *ServiceHandler) ListProjectServiceTypes(ctx context.Context, project st
func (h *ServiceHandler) ListPublicServiceTypes(ctx context.Context) (*ListPublicServiceTypesOut, error) {
path := fmt.Sprintf("/service_types")
b, err := h.doer.Do(ctx, "ListPublicServiceTypes", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(listPublicServiceTypesOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -196,6 +202,9 @@ func (h *ServiceHandler) ListPublicServiceTypes(ctx context.Context) (*ListPubli
func (h *ServiceHandler) ListServiceVersions(ctx context.Context) ([]ServiceVersionOut, error) {
path := fmt.Sprintf("/service_versions")
b, err := h.doer.Do(ctx, "ListServiceVersions", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(listServiceVersionsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -206,6 +215,9 @@ func (h *ServiceHandler) ListServiceVersions(ctx context.Context) ([]ServiceVers
func (h *ServiceHandler) ProjectGetServiceLogs(ctx context.Context, project string, serviceName string, in *ProjectGetServiceLogsIn) (*ProjectGetServiceLogsOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/logs", project, serviceName)
b, err := h.doer.Do(ctx, "ProjectGetServiceLogs", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ProjectGetServiceLogsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -216,6 +228,9 @@ func (h *ServiceHandler) ProjectGetServiceLogs(ctx context.Context, project stri
func (h *ServiceHandler) ProjectServiceTagsList(ctx context.Context, project string, serviceName string) (map[string]string, error) {
path := fmt.Sprintf("/project/%s/service/%s/tags", project, serviceName)
b, err := h.doer.Do(ctx, "ProjectServiceTagsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(projectServiceTagsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -236,6 +251,9 @@ func (h *ServiceHandler) ProjectServiceTagsUpdate(ctx context.Context, project s
func (h *ServiceHandler) ServiceAlertsList(ctx context.Context, project string, serviceName string) ([]AlertOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/alerts", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceAlertsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceAlertsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -246,6 +264,9 @@ func (h *ServiceHandler) ServiceAlertsList(ctx context.Context, project string,
func (h *ServiceHandler) ServiceBackupToAnotherRegionReport(ctx context.Context, project string, serviceName string, in *ServiceBackupToAnotherRegionReportIn) (map[string]any, error) {
path := fmt.Sprintf("/project/%s/service/%s/backup_to_another_region/report", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceBackupToAnotherRegionReport", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceBackupToAnotherRegionReportOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -256,6 +277,9 @@ func (h *ServiceHandler) ServiceBackupToAnotherRegionReport(ctx context.Context,
func (h *ServiceHandler) ServiceBackupsGet(ctx context.Context, project string, serviceName string) ([]BackupOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/backups", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceBackupsGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceBackupsGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -266,6 +290,9 @@ func (h *ServiceHandler) ServiceBackupsGet(ctx context.Context, project string,
func (h *ServiceHandler) ServiceCancelQuery(ctx context.Context, project string, serviceName string, in *ServiceCancelQueryIn) (bool, error) {
path := fmt.Sprintf("/project/%s/service/%s/query/cancel", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceCancelQuery", "POST", path, in)
+ if err != nil {
+ return false, err
+ }
out := new(serviceCancelQueryOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -276,6 +303,9 @@ func (h *ServiceHandler) ServiceCancelQuery(ctx context.Context, project string,
func (h *ServiceHandler) ServiceCreate(ctx context.Context, project string, in *ServiceCreateIn) (*ServiceCreateOut, error) {
path := fmt.Sprintf("/project/%s/service", project)
b, err := h.doer.Do(ctx, "ServiceCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -296,6 +326,9 @@ func (h *ServiceHandler) ServiceDatabaseDelete(ctx context.Context, project stri
func (h *ServiceHandler) ServiceDatabaseList(ctx context.Context, project string, serviceName string) ([]DatabaseOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/db", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceDatabaseList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceDatabaseListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -311,6 +344,9 @@ func (h *ServiceHandler) ServiceDelete(ctx context.Context, project string, serv
func (h *ServiceHandler) ServiceEnableWrites(ctx context.Context, project string, serviceName string) (string, error) {
path := fmt.Sprintf("/project/%s/service/%s/enable-writes", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceEnableWrites", "POST", path, nil)
+ if err != nil {
+ return "", err
+ }
out := new(serviceEnableWritesOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -321,6 +357,9 @@ func (h *ServiceHandler) ServiceEnableWrites(ctx context.Context, project string
func (h *ServiceHandler) ServiceGet(ctx context.Context, project string, serviceName string) (*ServiceGetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -331,6 +370,9 @@ func (h *ServiceHandler) ServiceGet(ctx context.Context, project string, service
func (h *ServiceHandler) ServiceGetMigrationStatus(ctx context.Context, project string, serviceName string) (*ServiceGetMigrationStatusOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/migration", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceGetMigrationStatus", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceGetMigrationStatusOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -341,6 +383,9 @@ func (h *ServiceHandler) ServiceGetMigrationStatus(ctx context.Context, project
func (h *ServiceHandler) ServiceInfluxDBStats(ctx context.Context, project string, serviceName string) (map[string]any, error) {
path := fmt.Sprintf("/project/%s/service/%s/influxdb/stats", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceInfluxDBStats", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceInfluxDbstatsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -351,6 +396,9 @@ func (h *ServiceHandler) ServiceInfluxDBStats(ctx context.Context, project strin
func (h *ServiceHandler) ServiceKmsGetCA(ctx context.Context, project string, serviceName string, caName string) (string, error) {
path := fmt.Sprintf("/project/%s/service/%s/kms/ca/%s", project, serviceName, caName)
b, err := h.doer.Do(ctx, "ServiceKmsGetCA", "GET", path, nil)
+ if err != nil {
+ return "", err
+ }
out := new(serviceKmsGetCaOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -361,6 +409,9 @@ func (h *ServiceHandler) ServiceKmsGetCA(ctx context.Context, project string, se
func (h *ServiceHandler) ServiceKmsGetKeypair(ctx context.Context, project string, serviceName string, keypairName string) (*ServiceKmsGetKeypairOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/kms/keypairs/%s", project, serviceName, keypairName)
b, err := h.doer.Do(ctx, "ServiceKmsGetKeypair", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ServiceKmsGetKeypairOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -371,6 +422,9 @@ func (h *ServiceHandler) ServiceKmsGetKeypair(ctx context.Context, project strin
func (h *ServiceHandler) ServiceList(ctx context.Context, project string) ([]ServiceOut, error) {
path := fmt.Sprintf("/project/%s/service", project)
b, err := h.doer.Do(ctx, "ServiceList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -386,6 +440,9 @@ func (h *ServiceHandler) ServiceMaintenanceStart(ctx context.Context, project st
func (h *ServiceHandler) ServiceMetricsFetch(ctx context.Context, project string, serviceName string, in *ServiceMetricsFetchIn) (map[string]any, error) {
path := fmt.Sprintf("/project/%s/service/%s/metrics", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceMetricsFetch", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceMetricsFetchOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -396,6 +453,9 @@ func (h *ServiceHandler) ServiceMetricsFetch(ctx context.Context, project string
func (h *ServiceHandler) ServiceQueryActivity(ctx context.Context, project string, serviceName string, in *ServiceQueryActivityIn) ([]QueryOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/query/activity", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceQueryActivity", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceQueryActivityOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -406,6 +466,9 @@ func (h *ServiceHandler) ServiceQueryActivity(ctx context.Context, project strin
func (h *ServiceHandler) ServiceQueryStatisticsReset(ctx context.Context, project string, serviceName string) ([]map[string]any, error) {
path := fmt.Sprintf("/project/%s/service/%s/query/stats/reset", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceQueryStatisticsReset", "PUT", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceQueryStatisticsResetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -416,6 +479,9 @@ func (h *ServiceHandler) ServiceQueryStatisticsReset(ctx context.Context, projec
func (h *ServiceHandler) ServiceTaskCreate(ctx context.Context, project string, serviceName string, in *ServiceTaskCreateIn) (*ServiceTaskCreateOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/task", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceTaskCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceTaskCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -426,6 +492,9 @@ func (h *ServiceHandler) ServiceTaskCreate(ctx context.Context, project string,
func (h *ServiceHandler) ServiceTaskGet(ctx context.Context, project string, serviceName string, taskId string) (*ServiceTaskGetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/task/%s", project, serviceName, taskId)
b, err := h.doer.Do(ctx, "ServiceTaskGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceTaskGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -436,6 +505,9 @@ func (h *ServiceHandler) ServiceTaskGet(ctx context.Context, project string, ser
func (h *ServiceHandler) ServiceUpdate(ctx context.Context, project string, serviceName string, in *ServiceUpdateIn) (*ServiceUpdateOut, error) {
path := fmt.Sprintf("/project/%s/service/%s", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/serviceintegration/serviceintegration.go b/handler/serviceintegration/serviceintegration.go
index b168c35..439b113 100644
--- a/handler/serviceintegration/serviceintegration.go
+++ b/handler/serviceintegration/serviceintegration.go
@@ -85,6 +85,9 @@ type ServiceIntegrationHandler struct {
func (h *ServiceIntegrationHandler) ServiceIntegrationCreate(ctx context.Context, project string, in *ServiceIntegrationCreateIn) (*ServiceIntegrationCreateOut, error) {
path := fmt.Sprintf("/project/%s/integration", project)
b, err := h.doer.Do(ctx, "ServiceIntegrationCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceIntegrationCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -100,6 +103,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationDelete(ctx context.Context
func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointCreate(ctx context.Context, project string, in *ServiceIntegrationEndpointCreateIn) (*ServiceIntegrationEndpointCreateOut, error) {
path := fmt.Sprintf("/project/%s/integration_endpoint", project)
b, err := h.doer.Do(ctx, "ServiceIntegrationEndpointCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceIntegrationEndpointCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -115,6 +121,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointDelete(ctx context
func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointGet(ctx context.Context, project string, integrationEndpointId string) (*ServiceIntegrationEndpointGetOut, error) {
path := fmt.Sprintf("/project/%s/integration_endpoint/%s", project, integrationEndpointId)
b, err := h.doer.Do(ctx, "ServiceIntegrationEndpointGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceIntegrationEndpointGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -125,6 +134,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointGet(ctx context.Co
func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointList(ctx context.Context, project string) ([]ServiceIntegrationEndpointOut, error) {
path := fmt.Sprintf("/project/%s/integration_endpoint", project)
b, err := h.doer.Do(ctx, "ServiceIntegrationEndpointList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceIntegrationEndpointListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -135,6 +147,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointList(ctx context.C
func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointTypes(ctx context.Context, project string) ([]EndpointTypeOut, error) {
path := fmt.Sprintf("/project/%s/integration_endpoint_types", project)
b, err := h.doer.Do(ctx, "ServiceIntegrationEndpointTypes", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceIntegrationEndpointTypesOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -145,6 +160,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointTypes(ctx context.
func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointUpdate(ctx context.Context, project string, integrationEndpointId string, in *ServiceIntegrationEndpointUpdateIn) (*ServiceIntegrationEndpointUpdateOut, error) {
path := fmt.Sprintf("/project/%s/integration_endpoint/%s", project, integrationEndpointId)
b, err := h.doer.Do(ctx, "ServiceIntegrationEndpointUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceIntegrationEndpointUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -155,6 +173,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationEndpointUpdate(ctx context
func (h *ServiceIntegrationHandler) ServiceIntegrationGet(ctx context.Context, project string, integrationId string) (*ServiceIntegrationGetOut, error) {
path := fmt.Sprintf("/project/%s/integration/%s", project, integrationId)
b, err := h.doer.Do(ctx, "ServiceIntegrationGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceIntegrationGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -165,6 +186,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationGet(ctx context.Context, p
func (h *ServiceIntegrationHandler) ServiceIntegrationList(ctx context.Context, project string, serviceName string) ([]ServiceIntegrationOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/integration", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceIntegrationList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceIntegrationListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -175,6 +199,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationList(ctx context.Context,
func (h *ServiceIntegrationHandler) ServiceIntegrationTypes(ctx context.Context, project string) ([]IntegrationTypeOut, error) {
path := fmt.Sprintf("/project/%s/integration_types", project)
b, err := h.doer.Do(ctx, "ServiceIntegrationTypes", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceIntegrationTypesOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -185,6 +212,9 @@ func (h *ServiceIntegrationHandler) ServiceIntegrationTypes(ctx context.Context,
func (h *ServiceIntegrationHandler) ServiceIntegrationUpdate(ctx context.Context, project string, integrationId string, in *ServiceIntegrationUpdateIn) (*ServiceIntegrationUpdateOut, error) {
path := fmt.Sprintf("/project/%s/integration/%s", project, integrationId)
b, err := h.doer.Do(ctx, "ServiceIntegrationUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceIntegrationUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/serviceuser/serviceuser.go b/handler/serviceuser/serviceuser.go
index c8dead4..157bc9b 100644
--- a/handler/serviceuser/serviceuser.go
+++ b/handler/serviceuser/serviceuser.go
@@ -51,6 +51,9 @@ type ServiceUserHandler struct {
func (h *ServiceUserHandler) ServiceUserCreate(ctx context.Context, project string, serviceName string, in *ServiceUserCreateIn) (*ServiceUserCreateOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/user", project, serviceName)
b, err := h.doer.Do(ctx, "ServiceUserCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceUserCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -61,6 +64,9 @@ func (h *ServiceUserHandler) ServiceUserCreate(ctx context.Context, project stri
func (h *ServiceUserHandler) ServiceUserCredentialsModify(ctx context.Context, project string, serviceName string, serviceUsername string, in *ServiceUserCredentialsModifyIn) (*ServiceUserCredentialsModifyOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/user/%s", project, serviceName, serviceUsername)
b, err := h.doer.Do(ctx, "ServiceUserCredentialsModify", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceUserCredentialsModifyOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -71,6 +77,9 @@ func (h *ServiceUserHandler) ServiceUserCredentialsModify(ctx context.Context, p
func (h *ServiceUserHandler) ServiceUserCredentialsReset(ctx context.Context, project string, serviceName string, serviceUsername string) (*ServiceUserCredentialsResetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/user/%s/credentials/reset", project, serviceName, serviceUsername)
b, err := h.doer.Do(ctx, "ServiceUserCredentialsReset", "PUT", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceUserCredentialsResetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -86,6 +95,9 @@ func (h *ServiceUserHandler) ServiceUserDelete(ctx context.Context, project stri
func (h *ServiceUserHandler) ServiceUserGet(ctx context.Context, project string, serviceName string, serviceUsername string) (*ServiceUserGetOut, error) {
path := fmt.Sprintf("/project/%s/service/%s/user/%s", project, serviceName, serviceUsername)
b, err := h.doer.Do(ctx, "ServiceUserGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(serviceUserGetOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/staticip/staticip.go b/handler/staticip/staticip.go
index 9297dfe..cd98304 100644
--- a/handler/staticip/staticip.go
+++ b/handler/staticip/staticip.go
@@ -60,6 +60,9 @@ type StaticIPHandler struct {
func (h *StaticIPHandler) ProjectStaticIPAssociate(ctx context.Context, project string, staticIpAddressId string, in *ProjectStaticIpassociateIn) (*ProjectStaticIpassociateOut, error) {
path := fmt.Sprintf("/project/%s/static-ips/%s/association", project, staticIpAddressId)
b, err := h.doer.Do(ctx, "ProjectStaticIPAssociate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ProjectStaticIpassociateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -70,6 +73,9 @@ func (h *StaticIPHandler) ProjectStaticIPAssociate(ctx context.Context, project
func (h *StaticIPHandler) ProjectStaticIPAvailabilityList(ctx context.Context, project string) ([]StaticIpAddressAvailabilityOut, error) {
path := fmt.Sprintf("/project/%s/static-ip-availability", project)
b, err := h.doer.Do(ctx, "ProjectStaticIPAvailabilityList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(projectStaticIpavailabilityListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -80,6 +86,9 @@ func (h *StaticIPHandler) ProjectStaticIPAvailabilityList(ctx context.Context, p
func (h *StaticIPHandler) ProjectStaticIPDissociate(ctx context.Context, project string, staticIpAddressId string) (*ProjectStaticIpdissociateOut, error) {
path := fmt.Sprintf("/project/%s/static-ips/%s/association", project, staticIpAddressId)
b, err := h.doer.Do(ctx, "ProjectStaticIPDissociate", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(ProjectStaticIpdissociateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -90,6 +99,9 @@ func (h *StaticIPHandler) ProjectStaticIPDissociate(ctx context.Context, project
func (h *StaticIPHandler) ProjectStaticIPPatch(ctx context.Context, project string, staticIpAddressId string, in *ProjectStaticIppatchIn) (*ProjectStaticIppatchOut, error) {
path := fmt.Sprintf("/project/%s/static-ips/%s", project, staticIpAddressId)
b, err := h.doer.Do(ctx, "ProjectStaticIPPatch", "PATCH", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(ProjectStaticIppatchOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -100,6 +112,9 @@ func (h *StaticIPHandler) ProjectStaticIPPatch(ctx context.Context, project stri
func (h *StaticIPHandler) PublicStaticIPAvailabilityList(ctx context.Context, tenant string) ([]StaticIpAddressAvailabilityOut, error) {
path := fmt.Sprintf("/tenants/%s/static-ip-availability", tenant)
b, err := h.doer.Do(ctx, "PublicStaticIPAvailabilityList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(publicStaticIpavailabilityListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -110,6 +125,9 @@ func (h *StaticIPHandler) PublicStaticIPAvailabilityList(ctx context.Context, te
func (h *StaticIPHandler) StaticIPCreate(ctx context.Context, project string, in *StaticIpcreateIn) (*StaticIpcreateOut, error) {
path := fmt.Sprintf("/project/%s/static-ips", project)
b, err := h.doer.Do(ctx, "StaticIPCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(StaticIpcreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -120,6 +138,9 @@ func (h *StaticIPHandler) StaticIPCreate(ctx context.Context, project string, in
func (h *StaticIPHandler) StaticIPList(ctx context.Context, project string) ([]StaticIpOut, error) {
path := fmt.Sprintf("/project/%s/static-ips", project)
b, err := h.doer.Do(ctx, "StaticIPList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(staticIplistOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/user/user.go b/handler/user/user.go
index e76f9a8..dfa753e 100644
--- a/handler/user/user.go
+++ b/handler/user/user.go
@@ -156,6 +156,9 @@ type UserHandler struct {
func (h *UserHandler) AccessTokenCreate(ctx context.Context, in *AccessTokenCreateIn) (*AccessTokenCreateOut, error) {
path := fmt.Sprintf("/access_token")
b, err := h.doer.Do(ctx, "AccessTokenCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(AccessTokenCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -166,6 +169,9 @@ func (h *UserHandler) AccessTokenCreate(ctx context.Context, in *AccessTokenCrea
func (h *UserHandler) AccessTokenList(ctx context.Context) ([]TokenOut, error) {
path := fmt.Sprintf("/access_token")
b, err := h.doer.Do(ctx, "AccessTokenList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(accessTokenListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -181,6 +187,9 @@ func (h *UserHandler) AccessTokenRevoke(ctx context.Context, tokenPrefix string)
func (h *UserHandler) AccessTokenUpdate(ctx context.Context, tokenPrefix string, in *AccessTokenUpdateIn) (*AccessTokenUpdateOut, error) {
path := fmt.Sprintf("/access_token/%s", tokenPrefix)
b, err := h.doer.Do(ctx, "AccessTokenUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(AccessTokenUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -191,6 +200,9 @@ func (h *UserHandler) AccessTokenUpdate(ctx context.Context, tokenPrefix string,
func (h *UserHandler) CheckPasswordStrengthExistingUser(ctx context.Context, in *CheckPasswordStrengthExistingUserIn) (*CheckPasswordStrengthExistingUserOut, error) {
path := fmt.Sprintf("/me/password_strength")
b, err := h.doer.Do(ctx, "CheckPasswordStrengthExistingUser", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(checkPasswordStrengthExistingUserOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -201,6 +213,9 @@ func (h *UserHandler) CheckPasswordStrengthExistingUser(ctx context.Context, in
func (h *UserHandler) CheckPasswordStrengthNewUser(ctx context.Context, in *CheckPasswordStrengthNewUserIn) (*CheckPasswordStrengthNewUserOut, error) {
path := fmt.Sprintf("/user/password_strength")
b, err := h.doer.Do(ctx, "CheckPasswordStrengthNewUser", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(checkPasswordStrengthNewUserOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -211,6 +226,9 @@ func (h *UserHandler) CheckPasswordStrengthNewUser(ctx context.Context, in *Chec
func (h *UserHandler) OrganizationMemberGroupsList(ctx context.Context, organizationId string, memberUserId string) ([]UserGroupOut, error) {
path := fmt.Sprintf("/organization/%s/user/%s/user-groups", organizationId, memberUserId)
b, err := h.doer.Do(ctx, "OrganizationMemberGroupsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(organizationMemberGroupsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -221,6 +239,9 @@ func (h *UserHandler) OrganizationMemberGroupsList(ctx context.Context, organiza
func (h *UserHandler) TwoFactorAuthConfigure(ctx context.Context, in *TwoFactorAuthConfigureIn) (*TwoFactorAuthConfigureOut, error) {
path := fmt.Sprintf("/me/2fa")
b, err := h.doer.Do(ctx, "TwoFactorAuthConfigure", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(TwoFactorAuthConfigureOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -231,6 +252,9 @@ func (h *UserHandler) TwoFactorAuthConfigure(ctx context.Context, in *TwoFactorA
func (h *UserHandler) TwoFactorAuthConfigureOTP(ctx context.Context, in *TwoFactorAuthConfigureOtpIn) (*TwoFactorAuthConfigureOtpOut, error) {
path := fmt.Sprintf("/me/2fa/otp")
b, err := h.doer.Do(ctx, "TwoFactorAuthConfigureOTP", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(TwoFactorAuthConfigureOtpOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -241,6 +265,9 @@ func (h *UserHandler) TwoFactorAuthConfigureOTP(ctx context.Context, in *TwoFact
func (h *UserHandler) UserAccountInvitesAccept(ctx context.Context, in *UserAccountInvitesAcceptIn) ([]AccountInviteOut, error) {
path := fmt.Sprintf("/me/account/invites/accept")
b, err := h.doer.Do(ctx, "UserAccountInvitesAccept", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(userAccountInvitesAcceptOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -251,6 +278,9 @@ func (h *UserHandler) UserAccountInvitesAccept(ctx context.Context, in *UserAcco
func (h *UserHandler) UserAccountInvitesList(ctx context.Context) ([]AccountInviteOut, error) {
path := fmt.Sprintf("/me/account/invites")
b, err := h.doer.Do(ctx, "UserAccountInvitesList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(userAccountInvitesListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -261,6 +291,9 @@ func (h *UserHandler) UserAccountInvitesList(ctx context.Context) ([]AccountInvi
func (h *UserHandler) UserAuth(ctx context.Context, in *UserAuthIn) (*UserAuthOut, error) {
path := fmt.Sprintf("/userauth")
b, err := h.doer.Do(ctx, "UserAuth", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(UserAuthOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -271,6 +304,9 @@ func (h *UserHandler) UserAuth(ctx context.Context, in *UserAuthIn) (*UserAuthOu
func (h *UserHandler) UserAuthLoginOptions(ctx context.Context, in *UserAuthLoginOptionsIn) (*UserAuthLoginOptionsOut, error) {
path := fmt.Sprintf("/userauth/login_options")
b, err := h.doer.Do(ctx, "UserAuthLoginOptions", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(UserAuthLoginOptionsOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -286,6 +322,9 @@ func (h *UserHandler) UserAuthenticationMethodDelete(ctx context.Context, userAu
func (h *UserHandler) UserAuthenticationMethodsList(ctx context.Context) ([]AuthenticationMethodOut, error) {
path := fmt.Sprintf("/me/authentication_methods")
b, err := h.doer.Do(ctx, "UserAuthenticationMethodsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(userAuthenticationMethodsListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -296,6 +335,9 @@ func (h *UserHandler) UserAuthenticationMethodsList(ctx context.Context) ([]Auth
func (h *UserHandler) UserCreate(ctx context.Context, in *UserCreateIn) (*UserCreateOut, error) {
path := fmt.Sprintf("/user")
b, err := h.doer.Do(ctx, "UserCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(UserCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -311,6 +353,9 @@ func (h *UserHandler) UserExpireTokens(ctx context.Context) error {
func (h *UserHandler) UserInfo(ctx context.Context) (*UserInfoOut, error) {
path := fmt.Sprintf("/me")
b, err := h.doer.Do(ctx, "UserInfo", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(userInfoOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -326,6 +371,9 @@ func (h *UserHandler) UserLogout(ctx context.Context) error {
func (h *UserHandler) UserPasswordChange(ctx context.Context, in *UserPasswordChangeIn) (string, error) {
path := fmt.Sprintf("/me/password")
b, err := h.doer.Do(ctx, "UserPasswordChange", "PUT", path, in)
+ if err != nil {
+ return "", err
+ }
out := new(userPasswordChangeOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -346,6 +394,9 @@ func (h *UserHandler) UserPasswordResetRequest(ctx context.Context, in *UserPass
func (h *UserHandler) UserUpdate(ctx context.Context, in *UserUpdateIn) (*UserUpdateOut, error) {
path := fmt.Sprintf("/me")
b, err := h.doer.Do(ctx, "UserUpdate", "PATCH", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(userUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -356,6 +407,9 @@ func (h *UserHandler) UserUpdate(ctx context.Context, in *UserUpdateIn) (*UserUp
func (h *UserHandler) UserVerifyEmail(ctx context.Context, verificationCode string) (*UserVerifyEmailOut, error) {
path := fmt.Sprintf("/user/verify_email/%s", verificationCode)
b, err := h.doer.Do(ctx, "UserVerifyEmail", "POST", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(userVerifyEmailOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/usergroup/usergroup.go b/handler/usergroup/usergroup.go
index 28e8d10..7b1ffc4 100644
--- a/handler/usergroup/usergroup.go
+++ b/handler/usergroup/usergroup.go
@@ -61,6 +61,9 @@ type UserGroupHandler struct {
func (h *UserGroupHandler) UserGroupCreate(ctx context.Context, organizationId string, in *UserGroupCreateIn) (*UserGroupCreateOut, error) {
path := fmt.Sprintf("/organization/%s/user-groups", organizationId)
b, err := h.doer.Do(ctx, "UserGroupCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(UserGroupCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -76,6 +79,9 @@ func (h *UserGroupHandler) UserGroupDelete(ctx context.Context, organizationId s
func (h *UserGroupHandler) UserGroupGet(ctx context.Context, organizationId string, userGroupId string) (*UserGroupGetOut, error) {
path := fmt.Sprintf("/organization/%s/user-groups/%s", organizationId, userGroupId)
b, err := h.doer.Do(ctx, "UserGroupGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(UserGroupGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -86,6 +92,9 @@ func (h *UserGroupHandler) UserGroupGet(ctx context.Context, organizationId stri
func (h *UserGroupHandler) UserGroupMemberList(ctx context.Context, organizationId string, userGroupId string) ([]MemberOut, error) {
path := fmt.Sprintf("/organization/%s/user-groups/%s/members", organizationId, userGroupId)
b, err := h.doer.Do(ctx, "UserGroupMemberList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(userGroupMemberListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -101,6 +110,9 @@ func (h *UserGroupHandler) UserGroupMembersUpdate(ctx context.Context, organizat
func (h *UserGroupHandler) UserGroupUpdate(ctx context.Context, organizationId string, userGroupId string, in *UserGroupUpdateIn) (*UserGroupUpdateOut, error) {
path := fmt.Sprintf("/organization/%s/user-groups/%s", organizationId, userGroupId)
b, err := h.doer.Do(ctx, "UserGroupUpdate", "PATCH", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(UserGroupUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -111,6 +123,9 @@ func (h *UserGroupHandler) UserGroupUpdate(ctx context.Context, organizationId s
func (h *UserGroupHandler) UserGroupsList(ctx context.Context, organizationId string) ([]UserGroupOut, error) {
path := fmt.Sprintf("/organization/%s/user-groups", organizationId)
b, err := h.doer.Do(ctx, "UserGroupsList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(userGroupsListOut)
err = json.Unmarshal(b, out)
if err != nil {
diff --git a/handler/vpc/vpc.go b/handler/vpc/vpc.go
index 8bfd737..29f9873 100644
--- a/handler/vpc/vpc.go
+++ b/handler/vpc/vpc.go
@@ -71,6 +71,9 @@ type VpcHandler struct {
func (h *VpcHandler) VpcCreate(ctx context.Context, project string, in *VpcCreateIn) (*VpcCreateOut, error) {
path := fmt.Sprintf("/project/%s/vpcs", project)
b, err := h.doer.Do(ctx, "VpcCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(VpcCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -81,6 +84,9 @@ func (h *VpcHandler) VpcCreate(ctx context.Context, project string, in *VpcCreat
func (h *VpcHandler) VpcDelete(ctx context.Context, project string, projectVpcId string) (*VpcDeleteOut, error) {
path := fmt.Sprintf("/project/%s/vpcs/%s", project, projectVpcId)
b, err := h.doer.Do(ctx, "VpcDelete", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(VpcDeleteOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -91,6 +97,9 @@ func (h *VpcHandler) VpcDelete(ctx context.Context, project string, projectVpcId
func (h *VpcHandler) VpcGet(ctx context.Context, project string, projectVpcId string) (*VpcGetOut, error) {
path := fmt.Sprintf("/project/%s/vpcs/%s", project, projectVpcId)
b, err := h.doer.Do(ctx, "VpcGet", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(VpcGetOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -101,6 +110,9 @@ func (h *VpcHandler) VpcGet(ctx context.Context, project string, projectVpcId st
func (h *VpcHandler) VpcList(ctx context.Context, project string) ([]VpcOut, error) {
path := fmt.Sprintf("/project/%s/vpcs", project)
b, err := h.doer.Do(ctx, "VpcList", "GET", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(vpcListOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -111,6 +123,9 @@ func (h *VpcHandler) VpcList(ctx context.Context, project string) ([]VpcOut, err
func (h *VpcHandler) VpcPeeringConnectionCreate(ctx context.Context, project string, projectVpcId string, in *VpcPeeringConnectionCreateIn) (*VpcPeeringConnectionCreateOut, error) {
path := fmt.Sprintf("/project/%s/vpcs/%s/peering-connections", project, projectVpcId)
b, err := h.doer.Do(ctx, "VpcPeeringConnectionCreate", "POST", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(VpcPeeringConnectionCreateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -121,6 +136,9 @@ func (h *VpcHandler) VpcPeeringConnectionCreate(ctx context.Context, project str
func (h *VpcHandler) VpcPeeringConnectionDelete(ctx context.Context, project string, projectVpcId string, peerCloudAccount string, peerVpc string) (*VpcPeeringConnectionDeleteOut, error) {
path := fmt.Sprintf("/project/%s/vpcs/%s/peering-connections/peer-accounts/%s/peer-vpcs/%s", project, projectVpcId, peerCloudAccount, peerVpc)
b, err := h.doer.Do(ctx, "VpcPeeringConnectionDelete", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(VpcPeeringConnectionDeleteOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -131,6 +149,9 @@ func (h *VpcHandler) VpcPeeringConnectionDelete(ctx context.Context, project str
func (h *VpcHandler) VpcPeeringConnectionUpdate(ctx context.Context, project string, projectVpcId string, in *VpcPeeringConnectionUpdateIn) (*VpcPeeringConnectionUpdateOut, error) {
path := fmt.Sprintf("/project/%s/vpcs/%s/user-peer-network-cidrs", project, projectVpcId)
b, err := h.doer.Do(ctx, "VpcPeeringConnectionUpdate", "PUT", path, in)
+ if err != nil {
+ return nil, err
+ }
out := new(VpcPeeringConnectionUpdateOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -141,6 +162,9 @@ func (h *VpcHandler) VpcPeeringConnectionUpdate(ctx context.Context, project str
func (h *VpcHandler) VpcPeeringConnectionWithRegionDelete(ctx context.Context, project string, projectVpcId string, peerCloudAccount string, peerVpc string, peerRegion string) (*VpcPeeringConnectionWithRegionDeleteOut, error) {
path := fmt.Sprintf("/project/%s/vpcs/%s/peering-connections/peer-accounts/%s/peer-vpcs/%s/peer-regions/%s", project, projectVpcId, peerCloudAccount, peerVpc, peerRegion)
b, err := h.doer.Do(ctx, "VpcPeeringConnectionWithRegionDelete", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(VpcPeeringConnectionWithRegionDeleteOut)
err = json.Unmarshal(b, out)
if err != nil {
@@ -151,6 +175,9 @@ func (h *VpcHandler) VpcPeeringConnectionWithRegionDelete(ctx context.Context, p
func (h *VpcHandler) VpcPeeringConnectionWithResourceGroupDelete(ctx context.Context, project string, projectVpcId string, peerCloudAccount string, peerResourceGroup string, peerVpc string) (*VpcPeeringConnectionWithResourceGroupDeleteOut, error) {
path := fmt.Sprintf("/project/%s/vpcs/%s/peering-connections/peer-accounts/%s/peer-resource-groups/%s/peer-vpcs/%s", project, projectVpcId, peerCloudAccount, peerResourceGroup, peerVpc)
b, err := h.doer.Do(ctx, "VpcPeeringConnectionWithResourceGroupDelete", "DELETE", path, nil)
+ if err != nil {
+ return nil, err
+ }
out := new(VpcPeeringConnectionWithResourceGroupDeleteOut)
err = json.Unmarshal(b, out)
if err != nil {