From d5cafca6ac3b58c61138e75e5b4656ef562e3a97 Mon Sep 17 00:00:00 2001 From: Marcin Kaciuba Date: Tue, 20 Aug 2024 09:24:30 +0200 Subject: [PATCH] chore: add examples without self-reference of module (#359) * chore: add examples without self-reference of module * terraform fmt * make generate-sdk --- castai/sdk/api.gen.go | 40 ++- castai/sdk/client.gen.go | 286 ++++++++++++++++++ castai/sdk/mock/client.go | 70 +++++ .../aks_cluster_autoscaler_policies/castai.tf | 18 +- .../eks_cluster_autoscaler_policies/castai.tf | 18 +- .../gke_cluster_autoscaler_policies/castai.tf | 12 +- 6 files changed, 419 insertions(+), 25 deletions(-) diff --git a/castai/sdk/api.gen.go b/castai/sdk/api.gen.go index 6cd484e0..5ca92349 100644 --- a/castai/sdk/api.gen.go +++ b/castai/sdk/api.gen.go @@ -683,6 +683,11 @@ type CastaiInventoryV1beta1GetCommitmentAssignmentsResponse struct { Assignments *[]CastaiInventoryV1beta1CommitmentAssignment `json:"assignments,omitempty"` } +// CastaiInventoryV1beta1GetCommitmentResponse defines model for castai.inventory.v1beta1.GetCommitmentResponse. +type CastaiInventoryV1beta1GetCommitmentResponse struct { + Commitment *CastaiInventoryV1beta1Commitment `json:"commitment,omitempty"` +} + // CastaiInventoryV1beta1GetCommitmentsAssignmentsResponse defines model for castai.inventory.v1beta1.GetCommitmentsAssignmentsResponse. type CastaiInventoryV1beta1GetCommitmentsAssignmentsResponse struct { CommitmentsAssignments *[]CastaiInventoryV1beta1CommitmentAssignment `json:"commitmentsAssignments,omitempty"` @@ -1221,6 +1226,12 @@ type CastaiUsersV1beta1DeleteInvitationResponse = map[string]interface{} // Defines the empty response to organization deletion. type CastaiUsersV1beta1DeleteOrganizationResponse = map[string]interface{} +// CastaiUsersV1beta1GroupRef defines model for castai.users.v1beta1.GroupRef. +type CastaiUsersV1beta1GroupRef struct { + Id string `json:"id"` + Name string `json:"name"` +} + // Defines container for the organization's pending invitations. type CastaiUsersV1beta1ListInvitationsResponse struct { // Array of organization's pending invitations. @@ -1242,7 +1253,8 @@ type CastaiUsersV1beta1ListOrganizationsResponse struct { // Membership describes user-organization membership details. type CastaiUsersV1beta1Membership struct { - Role string `json:"role"` + Groups *[]CastaiUsersV1beta1GroupRef `json:"groups,omitempty"` + Role string `json:"role"` // User represents a single system user. User CastaiUsersV1beta1User `json:"user"` @@ -1308,6 +1320,9 @@ type CastaiUsersV1beta1PendingInvitation struct { ValidUntil *time.Time `json:"validUntil,omitempty"` } +// Defines the response for removing users from an organization. +type CastaiUsersV1beta1RemoveOrganizationUsersResponse = map[string]interface{} + // Defines the response for removing a user from an organization. type CastaiUsersV1beta1RemoveUserFromOrganizationResponse = map[string]interface{} @@ -3301,6 +3316,7 @@ type WorkloadoptimizationV1RecommendationPolicies struct { // MANAGED - workload watched (metrics collected), CAST AI may perform actions on the workload. ManagementOption WorkloadoptimizationV1ManagementOption `json:"managementOption"` Memory WorkloadoptimizationV1ResourcePolicies `json:"memory"` + Startup *WorkloadoptimizationV1StartupSettings `json:"startup,omitempty"` } // WorkloadoptimizationV1ResourceConfig defines model for workloadoptimization.v1.ResourceConfig. @@ -3390,6 +3406,13 @@ type WorkloadoptimizationV1Resources struct { Requests *WorkloadoptimizationV1ResourceQuantity `json:"requests,omitempty"` } +// WorkloadoptimizationV1StartupSettings defines model for workloadoptimization.v1.StartupSettings. +type WorkloadoptimizationV1StartupSettings struct { + // Startup period defines the duration of increased resource usage during startup. + // Recommendations will be adjusted to ignore the spikes during regular execution. If not set workload will get usual recommendations. + PeriodSeconds *int32 `json:"periodSeconds"` +} + // WorkloadoptimizationV1SurgeContainer defines model for workloadoptimization.v1.SurgeContainer. type WorkloadoptimizationV1SurgeContainer struct { Name string `json:"name"` @@ -3788,6 +3811,12 @@ type InventoryAPIAddReservationJSONBody = CastaiInventoryV1beta1GenericReservati // InventoryAPIOverwriteReservationsJSONBody defines parameters for InventoryAPIOverwriteReservations. type InventoryAPIOverwriteReservationsJSONBody = CastaiInventoryV1beta1GenericReservationsList +// UsersAPIRemoveOrganizationUsersParams defines parameters for UsersAPIRemoveOrganizationUsers. +type UsersAPIRemoveOrganizationUsersParams struct { + // Users is the list of user ids to remove. + Users []string `form:"users" json:"users"` +} + // UsersAPIAddUserToOrganizationJSONBody defines parameters for UsersAPIAddUserToOrganization. type UsersAPIAddUserToOrganizationJSONBody = CastaiUsersV1beta1NewMembership @@ -3857,6 +3886,15 @@ type CommitmentsAPIGetGCPCommitmentsImportScriptParams struct { Projects *[]string `form:"projects,omitempty" json:"projects,omitempty"` } +// CommitmentsAPIGetCommitmentParams defines parameters for CommitmentsAPIGetCommitment. +type CommitmentsAPIGetCommitmentParams struct { + // get commitments that are assigned to a cluster + ClusterId *string `form:"clusterId,omitempty" json:"clusterId,omitempty"` + + // indicated if commitment usage should be included in a response + IncludeUsage *bool `form:"includeUsage,omitempty" json:"includeUsage,omitempty"` +} + // CommitmentsAPIUpdateCommitmentJSONBody defines parameters for CommitmentsAPIUpdateCommitment. type CommitmentsAPIUpdateCommitmentJSONBody = CastaiInventoryV1beta1UpdateCommitmentInput diff --git a/castai/sdk/client.gen.go b/castai/sdk/client.gen.go index 0a50fe44..e0d3aa22 100644 --- a/castai/sdk/client.gen.go +++ b/castai/sdk/client.gen.go @@ -358,6 +358,9 @@ type ClientInterface interface { // InventoryAPIDeleteReservation request InventoryAPIDeleteReservation(ctx context.Context, organizationId string, reservationId string, reqEditors ...RequestEditorFn) (*http.Response, error) + // UsersAPIRemoveOrganizationUsers request + UsersAPIRemoveOrganizationUsers(ctx context.Context, organizationId string, params *UsersAPIRemoveOrganizationUsersParams, reqEditors ...RequestEditorFn) (*http.Response, error) + // UsersAPIListOrganizationUsers request UsersAPIListOrganizationUsers(ctx context.Context, organizationId string, reqEditors ...RequestEditorFn) (*http.Response, error) @@ -421,6 +424,9 @@ type ClientInterface interface { // CommitmentsAPIDeleteCommitment request CommitmentsAPIDeleteCommitment(ctx context.Context, commitmentId string, reqEditors ...RequestEditorFn) (*http.Response, error) + // CommitmentsAPIGetCommitment request + CommitmentsAPIGetCommitment(ctx context.Context, commitmentId string, params *CommitmentsAPIGetCommitmentParams, reqEditors ...RequestEditorFn) (*http.Response, error) + // CommitmentsAPIUpdateCommitment request with any body CommitmentsAPIUpdateCommitmentWithBody(ctx context.Context, commitmentId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error) @@ -1697,6 +1703,18 @@ func (c *Client) InventoryAPIDeleteReservation(ctx context.Context, organization return c.Client.Do(req) } +func (c *Client) UsersAPIRemoveOrganizationUsers(ctx context.Context, organizationId string, params *UsersAPIRemoveOrganizationUsersParams, reqEditors ...RequestEditorFn) (*http.Response, error) { + req, err := NewUsersAPIRemoveOrganizationUsersRequest(c.Server, organizationId, params) + if err != nil { + return nil, err + } + req = req.WithContext(ctx) + if err := c.applyEditors(ctx, req, reqEditors); err != nil { + return nil, err + } + return c.Client.Do(req) +} + func (c *Client) UsersAPIListOrganizationUsers(ctx context.Context, organizationId string, reqEditors ...RequestEditorFn) (*http.Response, error) { req, err := NewUsersAPIListOrganizationUsersRequest(c.Server, organizationId) if err != nil { @@ -1973,6 +1991,18 @@ func (c *Client) CommitmentsAPIDeleteCommitment(ctx context.Context, commitmentI return c.Client.Do(req) } +func (c *Client) CommitmentsAPIGetCommitment(ctx context.Context, commitmentId string, params *CommitmentsAPIGetCommitmentParams, reqEditors ...RequestEditorFn) (*http.Response, error) { + req, err := NewCommitmentsAPIGetCommitmentRequest(c.Server, commitmentId, params) + if err != nil { + return nil, err + } + req = req.WithContext(ctx) + if err := c.applyEditors(ctx, req, reqEditors); err != nil { + return nil, err + } + return c.Client.Do(req) +} + func (c *Client) CommitmentsAPIUpdateCommitmentWithBody(ctx context.Context, commitmentId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error) { req, err := NewCommitmentsAPIUpdateCommitmentRequestWithBody(c.Server, commitmentId, contentType, body) if err != nil { @@ -5703,6 +5733,56 @@ func NewInventoryAPIDeleteReservationRequest(server string, organizationId strin return req, nil } +// NewUsersAPIRemoveOrganizationUsersRequest generates requests for UsersAPIRemoveOrganizationUsers +func NewUsersAPIRemoveOrganizationUsersRequest(server string, organizationId string, params *UsersAPIRemoveOrganizationUsersParams) (*http.Request, error) { + var err error + + var pathParam0 string + + pathParam0, err = runtime.StyleParamWithLocation("simple", false, "organizationId", runtime.ParamLocationPath, organizationId) + if err != nil { + return nil, err + } + + serverURL, err := url.Parse(server) + if err != nil { + return nil, err + } + + operationPath := fmt.Sprintf("/v1/organizations/%s/users", pathParam0) + if operationPath[0] == '/' { + operationPath = "." + operationPath + } + + queryURL, err := serverURL.Parse(operationPath) + if err != nil { + return nil, err + } + + queryValues := queryURL.Query() + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "users", runtime.ParamLocationQuery, params.Users); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + queryURL.RawQuery = queryValues.Encode() + + req, err := http.NewRequest("DELETE", queryURL.String(), nil) + if err != nil { + return nil, err + } + + return req, nil +} + // NewUsersAPIListOrganizationUsersRequest generates requests for UsersAPIListOrganizationUsers func NewUsersAPIListOrganizationUsersRequest(server string, organizationId string) (*http.Request, error) { var err error @@ -6454,6 +6534,76 @@ func NewCommitmentsAPIDeleteCommitmentRequest(server string, commitmentId string return req, nil } +// NewCommitmentsAPIGetCommitmentRequest generates requests for CommitmentsAPIGetCommitment +func NewCommitmentsAPIGetCommitmentRequest(server string, commitmentId string, params *CommitmentsAPIGetCommitmentParams) (*http.Request, error) { + var err error + + var pathParam0 string + + pathParam0, err = runtime.StyleParamWithLocation("simple", false, "commitmentId", runtime.ParamLocationPath, commitmentId) + if err != nil { + return nil, err + } + + serverURL, err := url.Parse(server) + if err != nil { + return nil, err + } + + operationPath := fmt.Sprintf("/v1/savings/commitments/%s", pathParam0) + if operationPath[0] == '/' { + operationPath = "." + operationPath + } + + queryURL, err := serverURL.Parse(operationPath) + if err != nil { + return nil, err + } + + queryValues := queryURL.Query() + + if params.ClusterId != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "clusterId", runtime.ParamLocationQuery, *params.ClusterId); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.IncludeUsage != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "includeUsage", runtime.ParamLocationQuery, *params.IncludeUsage); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + queryURL.RawQuery = queryValues.Encode() + + req, err := http.NewRequest("GET", queryURL.String(), nil) + if err != nil { + return nil, err + } + + return req, nil +} + // NewCommitmentsAPIUpdateCommitmentRequest calls the generic CommitmentsAPIUpdateCommitment builder with application/json body func NewCommitmentsAPIUpdateCommitmentRequest(server string, commitmentId string, body CommitmentsAPIUpdateCommitmentJSONRequestBody) (*http.Request, error) { var bodyReader io.Reader @@ -8011,6 +8161,9 @@ type ClientWithResponsesInterface interface { // InventoryAPIDeleteReservation request InventoryAPIDeleteReservationWithResponse(ctx context.Context, organizationId string, reservationId string) (*InventoryAPIDeleteReservationResponse, error) + // UsersAPIRemoveOrganizationUsers request + UsersAPIRemoveOrganizationUsersWithResponse(ctx context.Context, organizationId string, params *UsersAPIRemoveOrganizationUsersParams) (*UsersAPIRemoveOrganizationUsersResponse, error) + // UsersAPIListOrganizationUsers request UsersAPIListOrganizationUsersWithResponse(ctx context.Context, organizationId string) (*UsersAPIListOrganizationUsersResponse, error) @@ -8074,6 +8227,9 @@ type ClientWithResponsesInterface interface { // CommitmentsAPIDeleteCommitment request CommitmentsAPIDeleteCommitmentWithResponse(ctx context.Context, commitmentId string) (*CommitmentsAPIDeleteCommitmentResponse, error) + // CommitmentsAPIGetCommitment request + CommitmentsAPIGetCommitmentWithResponse(ctx context.Context, commitmentId string, params *CommitmentsAPIGetCommitmentParams) (*CommitmentsAPIGetCommitmentResponse, error) + // CommitmentsAPIUpdateCommitment request with any body CommitmentsAPIUpdateCommitmentWithBodyWithResponse(ctx context.Context, commitmentId string, contentType string, body io.Reader) (*CommitmentsAPIUpdateCommitmentResponse, error) @@ -10342,6 +10498,36 @@ func (r InventoryAPIDeleteReservationResponse) GetBody() []byte { // TODO: to have common interface. https://github.com/deepmap/oapi-codegen/issues/240 +type UsersAPIRemoveOrganizationUsersResponse struct { + Body []byte + HTTPResponse *http.Response + JSON200 *CastaiUsersV1beta1RemoveOrganizationUsersResponse +} + +// Status returns HTTPResponse.Status +func (r UsersAPIRemoveOrganizationUsersResponse) Status() string { + if r.HTTPResponse != nil { + return r.HTTPResponse.Status + } + return http.StatusText(0) +} + +// StatusCode returns HTTPResponse.StatusCode +func (r UsersAPIRemoveOrganizationUsersResponse) StatusCode() int { + if r.HTTPResponse != nil { + return r.HTTPResponse.StatusCode + } + return 0 +} + +// TODO: to have common interface. https://github.com/deepmap/oapi-codegen/issues/240 +// Body returns body of byte array +func (r UsersAPIRemoveOrganizationUsersResponse) GetBody() []byte { + return r.Body +} + +// TODO: to have common interface. https://github.com/deepmap/oapi-codegen/issues/240 + type UsersAPIListOrganizationUsersResponse struct { Body []byte HTTPResponse *http.Response @@ -10852,6 +11038,36 @@ func (r CommitmentsAPIDeleteCommitmentResponse) GetBody() []byte { // TODO: to have common interface. https://github.com/deepmap/oapi-codegen/issues/240 +type CommitmentsAPIGetCommitmentResponse struct { + Body []byte + HTTPResponse *http.Response + JSON200 *CastaiInventoryV1beta1GetCommitmentResponse +} + +// Status returns HTTPResponse.Status +func (r CommitmentsAPIGetCommitmentResponse) Status() string { + if r.HTTPResponse != nil { + return r.HTTPResponse.Status + } + return http.StatusText(0) +} + +// StatusCode returns HTTPResponse.StatusCode +func (r CommitmentsAPIGetCommitmentResponse) StatusCode() int { + if r.HTTPResponse != nil { + return r.HTTPResponse.StatusCode + } + return 0 +} + +// TODO: to have common interface. https://github.com/deepmap/oapi-codegen/issues/240 +// Body returns body of byte array +func (r CommitmentsAPIGetCommitmentResponse) GetBody() []byte { + return r.Body +} + +// TODO: to have common interface. https://github.com/deepmap/oapi-codegen/issues/240 + type CommitmentsAPIUpdateCommitmentResponse struct { Body []byte HTTPResponse *http.Response @@ -12514,6 +12730,15 @@ func (c *ClientWithResponses) InventoryAPIDeleteReservationWithResponse(ctx cont return ParseInventoryAPIDeleteReservationResponse(rsp) } +// UsersAPIRemoveOrganizationUsersWithResponse request returning *UsersAPIRemoveOrganizationUsersResponse +func (c *ClientWithResponses) UsersAPIRemoveOrganizationUsersWithResponse(ctx context.Context, organizationId string, params *UsersAPIRemoveOrganizationUsersParams) (*UsersAPIRemoveOrganizationUsersResponse, error) { + rsp, err := c.UsersAPIRemoveOrganizationUsers(ctx, organizationId, params) + if err != nil { + return nil, err + } + return ParseUsersAPIRemoveOrganizationUsersResponse(rsp) +} + // UsersAPIListOrganizationUsersWithResponse request returning *UsersAPIListOrganizationUsersResponse func (c *ClientWithResponses) UsersAPIListOrganizationUsersWithResponse(ctx context.Context, organizationId string) (*UsersAPIListOrganizationUsersResponse, error) { rsp, err := c.UsersAPIListOrganizationUsers(ctx, organizationId) @@ -12715,6 +12940,15 @@ func (c *ClientWithResponses) CommitmentsAPIDeleteCommitmentWithResponse(ctx con return ParseCommitmentsAPIDeleteCommitmentResponse(rsp) } +// CommitmentsAPIGetCommitmentWithResponse request returning *CommitmentsAPIGetCommitmentResponse +func (c *ClientWithResponses) CommitmentsAPIGetCommitmentWithResponse(ctx context.Context, commitmentId string, params *CommitmentsAPIGetCommitmentParams) (*CommitmentsAPIGetCommitmentResponse, error) { + rsp, err := c.CommitmentsAPIGetCommitment(ctx, commitmentId, params) + if err != nil { + return nil, err + } + return ParseCommitmentsAPIGetCommitmentResponse(rsp) +} + // CommitmentsAPIUpdateCommitmentWithBodyWithResponse request with arbitrary body returning *CommitmentsAPIUpdateCommitmentResponse func (c *ClientWithResponses) CommitmentsAPIUpdateCommitmentWithBodyWithResponse(ctx context.Context, commitmentId string, contentType string, body io.Reader) (*CommitmentsAPIUpdateCommitmentResponse, error) { rsp, err := c.CommitmentsAPIUpdateCommitmentWithBody(ctx, commitmentId, contentType, body) @@ -14892,6 +15126,32 @@ func ParseInventoryAPIDeleteReservationResponse(rsp *http.Response) (*InventoryA return response, nil } +// ParseUsersAPIRemoveOrganizationUsersResponse parses an HTTP response from a UsersAPIRemoveOrganizationUsersWithResponse call +func ParseUsersAPIRemoveOrganizationUsersResponse(rsp *http.Response) (*UsersAPIRemoveOrganizationUsersResponse, error) { + bodyBytes, err := ioutil.ReadAll(rsp.Body) + defer rsp.Body.Close() + if err != nil { + return nil, err + } + + response := &UsersAPIRemoveOrganizationUsersResponse{ + Body: bodyBytes, + HTTPResponse: rsp, + } + + switch { + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 200: + var dest CastaiUsersV1beta1RemoveOrganizationUsersResponse + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON200 = &dest + + } + + return response, nil +} + // ParseUsersAPIListOrganizationUsersResponse parses an HTTP response from a UsersAPIListOrganizationUsersWithResponse call func ParseUsersAPIListOrganizationUsersResponse(rsp *http.Response) (*UsersAPIListOrganizationUsersResponse, error) { bodyBytes, err := ioutil.ReadAll(rsp.Body) @@ -15334,6 +15594,32 @@ func ParseCommitmentsAPIDeleteCommitmentResponse(rsp *http.Response) (*Commitmen return response, nil } +// ParseCommitmentsAPIGetCommitmentResponse parses an HTTP response from a CommitmentsAPIGetCommitmentWithResponse call +func ParseCommitmentsAPIGetCommitmentResponse(rsp *http.Response) (*CommitmentsAPIGetCommitmentResponse, error) { + bodyBytes, err := ioutil.ReadAll(rsp.Body) + defer rsp.Body.Close() + if err != nil { + return nil, err + } + + response := &CommitmentsAPIGetCommitmentResponse{ + Body: bodyBytes, + HTTPResponse: rsp, + } + + switch { + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 200: + var dest CastaiInventoryV1beta1GetCommitmentResponse + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON200 = &dest + + } + + return response, nil +} + // ParseCommitmentsAPIUpdateCommitmentResponse parses an HTTP response from a CommitmentsAPIUpdateCommitmentWithResponse call func ParseCommitmentsAPIUpdateCommitmentResponse(rsp *http.Response) (*CommitmentsAPIUpdateCommitmentResponse, error) { bodyBytes, err := ioutil.ReadAll(rsp.Body) diff --git a/castai/sdk/mock/client.go b/castai/sdk/mock/client.go index fdd5fe3c..e005d951 100644 --- a/castai/sdk/mock/client.go +++ b/castai/sdk/mock/client.go @@ -275,6 +275,26 @@ func (mr *MockClientInterfaceMockRecorder) CommitmentsAPIDeleteCommitmentAssignm return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CommitmentsAPIDeleteCommitmentAssignment", reflect.TypeOf((*MockClientInterface)(nil).CommitmentsAPIDeleteCommitmentAssignment), varargs...) } +// CommitmentsAPIGetCommitment mocks base method. +func (m *MockClientInterface) CommitmentsAPIGetCommitment(ctx context.Context, commitmentId string, params *sdk.CommitmentsAPIGetCommitmentParams, reqEditors ...sdk.RequestEditorFn) (*http.Response, error) { + m.ctrl.T.Helper() + varargs := []interface{}{ctx, commitmentId, params} + for _, a := range reqEditors { + varargs = append(varargs, a) + } + ret := m.ctrl.Call(m, "CommitmentsAPIGetCommitment", varargs...) + ret0, _ := ret[0].(*http.Response) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// CommitmentsAPIGetCommitment indicates an expected call of CommitmentsAPIGetCommitment. +func (mr *MockClientInterfaceMockRecorder) CommitmentsAPIGetCommitment(ctx, commitmentId, params interface{}, reqEditors ...interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + varargs := append([]interface{}{ctx, commitmentId, params}, reqEditors...) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CommitmentsAPIGetCommitment", reflect.TypeOf((*MockClientInterface)(nil).CommitmentsAPIGetCommitment), varargs...) +} + // CommitmentsAPIGetCommitmentAssignments mocks base method. func (m *MockClientInterface) CommitmentsAPIGetCommitmentAssignments(ctx context.Context, commitmentId string, reqEditors ...sdk.RequestEditorFn) (*http.Response, error) { m.ctrl.T.Helper() @@ -2715,6 +2735,26 @@ func (mr *MockClientInterfaceMockRecorder) UsersAPIListOrganizations(ctx, params return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UsersAPIListOrganizations", reflect.TypeOf((*MockClientInterface)(nil).UsersAPIListOrganizations), varargs...) } +// UsersAPIRemoveOrganizationUsers mocks base method. +func (m *MockClientInterface) UsersAPIRemoveOrganizationUsers(ctx context.Context, organizationId string, params *sdk.UsersAPIRemoveOrganizationUsersParams, reqEditors ...sdk.RequestEditorFn) (*http.Response, error) { + m.ctrl.T.Helper() + varargs := []interface{}{ctx, organizationId, params} + for _, a := range reqEditors { + varargs = append(varargs, a) + } + ret := m.ctrl.Call(m, "UsersAPIRemoveOrganizationUsers", varargs...) + ret0, _ := ret[0].(*http.Response) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// UsersAPIRemoveOrganizationUsers indicates an expected call of UsersAPIRemoveOrganizationUsers. +func (mr *MockClientInterfaceMockRecorder) UsersAPIRemoveOrganizationUsers(ctx, organizationId, params interface{}, reqEditors ...interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + varargs := append([]interface{}{ctx, organizationId, params}, reqEditors...) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UsersAPIRemoveOrganizationUsers", reflect.TypeOf((*MockClientInterface)(nil).UsersAPIRemoveOrganizationUsers), varargs...) +} + // UsersAPIRemoveUserFromOrganization mocks base method. func (m *MockClientInterface) UsersAPIRemoveUserFromOrganization(ctx context.Context, organizationId, userId string, reqEditors ...sdk.RequestEditorFn) (*http.Response, error) { m.ctrl.T.Helper() @@ -3403,6 +3443,21 @@ func (mr *MockClientWithResponsesInterfaceMockRecorder) CommitmentsAPIGetCommitm return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CommitmentsAPIGetCommitmentAssignmentsWithResponse", reflect.TypeOf((*MockClientWithResponsesInterface)(nil).CommitmentsAPIGetCommitmentAssignmentsWithResponse), ctx, commitmentId) } +// CommitmentsAPIGetCommitmentWithResponse mocks base method. +func (m *MockClientWithResponsesInterface) CommitmentsAPIGetCommitmentWithResponse(ctx context.Context, commitmentId string, params *sdk.CommitmentsAPIGetCommitmentParams) (*sdk.CommitmentsAPIGetCommitmentResponse, error) { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "CommitmentsAPIGetCommitmentWithResponse", ctx, commitmentId, params) + ret0, _ := ret[0].(*sdk.CommitmentsAPIGetCommitmentResponse) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// CommitmentsAPIGetCommitmentWithResponse indicates an expected call of CommitmentsAPIGetCommitmentWithResponse. +func (mr *MockClientWithResponsesInterfaceMockRecorder) CommitmentsAPIGetCommitmentWithResponse(ctx, commitmentId, params interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CommitmentsAPIGetCommitmentWithResponse", reflect.TypeOf((*MockClientWithResponsesInterface)(nil).CommitmentsAPIGetCommitmentWithResponse), ctx, commitmentId, params) +} + // CommitmentsAPIGetCommitmentsAssignmentsWithResponse mocks base method. func (m *MockClientWithResponsesInterface) CommitmentsAPIGetCommitmentsAssignmentsWithResponse(ctx context.Context) (*sdk.CommitmentsAPIGetCommitmentsAssignmentsResponse, error) { m.ctrl.T.Helper() @@ -5218,6 +5273,21 @@ func (mr *MockClientWithResponsesInterfaceMockRecorder) UsersAPIListOrganization return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UsersAPIListOrganizationsWithResponse", reflect.TypeOf((*MockClientWithResponsesInterface)(nil).UsersAPIListOrganizationsWithResponse), ctx, params) } +// UsersAPIRemoveOrganizationUsersWithResponse mocks base method. +func (m *MockClientWithResponsesInterface) UsersAPIRemoveOrganizationUsersWithResponse(ctx context.Context, organizationId string, params *sdk.UsersAPIRemoveOrganizationUsersParams) (*sdk.UsersAPIRemoveOrganizationUsersResponse, error) { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "UsersAPIRemoveOrganizationUsersWithResponse", ctx, organizationId, params) + ret0, _ := ret[0].(*sdk.UsersAPIRemoveOrganizationUsersResponse) + ret1, _ := ret[1].(error) + return ret0, ret1 +} + +// UsersAPIRemoveOrganizationUsersWithResponse indicates an expected call of UsersAPIRemoveOrganizationUsersWithResponse. +func (mr *MockClientWithResponsesInterfaceMockRecorder) UsersAPIRemoveOrganizationUsersWithResponse(ctx, organizationId, params interface{}) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UsersAPIRemoveOrganizationUsersWithResponse", reflect.TypeOf((*MockClientWithResponsesInterface)(nil).UsersAPIRemoveOrganizationUsersWithResponse), ctx, organizationId, params) +} + // UsersAPIRemoveUserFromOrganizationWithResponse mocks base method. func (m *MockClientWithResponsesInterface) UsersAPIRemoveUserFromOrganizationWithResponse(ctx context.Context, organizationId, userId string) (*sdk.UsersAPIRemoveUserFromOrganizationResponse, error) { m.ctrl.T.Helper() diff --git a/examples/aks/aks_cluster_autoscaler_policies/castai.tf b/examples/aks/aks_cluster_autoscaler_policies/castai.tf index 06ece089..b29c309d 100644 --- a/examples/aks/aks_cluster_autoscaler_policies/castai.tf +++ b/examples/aks/aks_cluster_autoscaler_policies/castai.tf @@ -36,7 +36,7 @@ module "castai-aks-cluster" { subscription_id = data.azurerm_subscription.current.subscription_id tenant_id = data.azurerm_subscription.current.tenant_id - default_node_configuration = module.castai-aks-cluster.castai_node_configurations["default"] + default_node_configuration_name = "default" node_configurations = { default = { @@ -55,11 +55,11 @@ module "castai-aks-cluster" { node_templates = { default_by_castai = { - name = "default-by-castai" - configuration_id = module.castai-aks-cluster.castai_node_configurations["default"] - is_default = true - is_enabled = true - should_taint = false + name = "default-by-castai" + configuration_name = "default" + is_default = true + is_enabled = true + should_taint = false constraints = { on_demand = true @@ -71,9 +71,9 @@ module "castai-aks-cluster" { } } spot_tmpl = { - configuration_id = module.castai-aks-cluster.castai_node_configurations["default"] - is_enabled = true - should_taint = true + configuration_name = "default" + is_enabled = true + should_taint = true custom_labels = { custom-label-key-1 = "custom-label-value-1" diff --git a/examples/eks/eks_cluster_autoscaler_policies/castai.tf b/examples/eks/eks_cluster_autoscaler_policies/castai.tf index 71422efa..912358cc 100644 --- a/examples/eks/eks_cluster_autoscaler_policies/castai.tf +++ b/examples/eks/eks_cluster_autoscaler_policies/castai.tf @@ -66,7 +66,7 @@ module "castai-eks-cluster" { aws_assume_role_arn = module.castai-eks-role-iam.role_arn delete_nodes_on_disconnect = var.delete_nodes_on_disconnect - default_node_configuration = module.castai-eks-cluster.castai_node_configurations["default"] + default_node_configuration_name = "default" node_configurations = { default = { @@ -103,11 +103,11 @@ module "castai-eks-cluster" { node_templates = { default_by_castai = { - name = "default-by-castai" - configuration_id = module.castai-eks-cluster.castai_node_configurations["default"] - is_default = true - is_enabled = true - should_taint = false + name = "default-by-castai" + configuration_name = "default" + is_default = true + is_enabled = true + should_taint = false constraints = { on_demand = true @@ -122,9 +122,9 @@ module "castai-eks-cluster" { } } spot_tmpl = { - configuration_id = module.castai-eks-cluster.castai_node_configurations["default"] - is_enabled = true - should_taint = true + configuration_name = "default" + is_enabled = true + should_taint = true custom_labels = { custom-label-key-1 = "custom-label-value-1" diff --git a/examples/gke/gke_cluster_autoscaler_policies/castai.tf b/examples/gke/gke_cluster_autoscaler_policies/castai.tf index 322f915b..268712db 100644 --- a/examples/gke/gke_cluster_autoscaler_policies/castai.tf +++ b/examples/gke/gke_cluster_autoscaler_policies/castai.tf @@ -40,7 +40,7 @@ module "castai-gke-cluster" { gke_credentials = module.castai-gke-iam.private_key delete_nodes_on_disconnect = var.delete_nodes_on_disconnect - default_node_configuration = module.castai-gke-cluster.castai_node_configurations["default"] + default_node_configuration_name = "default" node_configurations = { default = { @@ -62,11 +62,11 @@ module "castai-gke-cluster" { node_templates = { default_by_castai = { - name = "default-by-castai" - configuration_id = module.castai-gke-cluster.castai_node_configurations["default"] - is_default = true - is_enabled = true - should_taint = false + name = "default-by-castai" + configuration_name = "default" + is_default = true + is_enabled = true + should_taint = false constraints = { on_demand = true