bump tools/clean to newest SDK

Author: s-urbaniak

tools/clean/atlas/data_federation.go

@@ -24,7 +24,7 @@ import (
 
 func (c *Cleaner) listFederatedDatabases(ctx context.Context, projectID string) []admin.DataLakeTenant {
 	federatedDBs, _, err := c.client.DataFederationApi.
-		ListFederatedDatabases(ctx, projectID).
+		ListDataFederation(ctx, projectID).
 		Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to list federated databases for project %s: %s", projectID, err))
@@ -43,7 +43,7 @@ func (c *Cleaner) deleteFederatedDatabases(ctx context.Context, projectID string
 			continue
 		}
 
-		_, err := c.client.DataFederationApi.DeleteFederatedDatabase(ctx, projectID, fedDB.GetName()).Execute()
+		_, err := c.client.DataFederationApi.DeleteDataFederation(ctx, projectID, fedDB.GetName()).Execute()
 		if err != nil {
 			fmt.Println(text.FgRed.Sprintf("\t\t\tFailed to request deletion of Federated Database %s: %s", fedDB.GetName(), err))
 		}

tools/clean/atlas/data_federation_private_endpoints.go

@@ -23,7 +23,7 @@ import (
 )
 
 func (c *Cleaner) listFederatedDBPrivateEndpoints(ctx context.Context, projectID string) []admin.PrivateNetworkEndpointIdEntry {
-	federatedDBPEs, _, err := c.client.DataFederationApi.ListDataFederationPrivateEndpoints(ctx, projectID).Execute()
+	federatedDBPEs, _, err := c.client.DataFederationApi.ListPrivateEndpointIds(ctx, projectID).Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to list federated databases for project %s: %s", projectID, err))
 
@@ -35,7 +35,7 @@ func (c *Cleaner) listFederatedDBPrivateEndpoints(ctx context.Context, projectID
 
 func (c *Cleaner) deleteFederatedDBPrivateEndpoints(ctx context.Context, projectID string, dbpes []admin.PrivateNetworkEndpointIdEntry) {
 	for _, fedDBPE := range dbpes {
-		_, err := c.client.DataFederationApi.DeleteDataFederationPrivateEndpoint(ctx, projectID, fedDBPE.GetEndpointId()).Execute()
+		_, err := c.client.DataFederationApi.DeletePrivateEndpointId(ctx, projectID, fedDBPE.GetEndpointId()).Execute()
 		if err != nil {
 			fmt.Println(text.FgRed.Sprintf("\t\t\tFailed to request deletion of Federated DB private endpoint %s: %s", fedDBPE.GetEndpointId(), err))
 		}

tools/clean/atlas/network_peering.go

@@ -34,8 +34,8 @@ func (c *Cleaner) listNetworkPeering(ctx context.Context, projectID string, prov
 }
 
 func (c *Cleaner) listNetworkPeeringForProvider(ctx context.Context, projectID, providerName string) []admin.BaseNetworkPeeringConnectionSettings {
-	queryArgs := admin.ListPeeringConnectionsApiParams{GroupId: projectID, ProviderName: &providerName}
-	peers, _, err := c.client.NetworkPeeringApi.ListPeeringConnectionsWithParams(ctx, &queryArgs).Execute()
+	queryArgs := admin.ListGroupPeersApiParams{GroupId: projectID, ProviderName: &providerName}
+	peers, _, err := c.client.NetworkPeeringApi.ListGroupPeersWithParams(ctx, &queryArgs).Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to list %s networking peering for project %s: %s", providerName, projectID, err))
 		return []admin.BaseNetworkPeeringConnectionSettings{}
@@ -44,7 +44,7 @@ func (c *Cleaner) listNetworkPeeringForProvider(ctx context.Context, projectID,
 }
 
 func (c *Cleaner) getNetworkPeeringContainer(ctx context.Context, projectID, ID string) *admin.CloudProviderContainer {
-	container, _, err := c.client.NetworkPeeringApi.GetPeeringContainer(ctx, projectID, ID).Execute()
+	container, _, err := c.client.NetworkPeeringApi.GetGroupContainer(ctx, projectID, ID).Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\t\t\tFailed to get network peering container %s: %s", ID, err))
 
@@ -85,7 +85,7 @@ func (c *Cleaner) deleteNetworkPeering(ctx context.Context, projectID string, pe
 			}
 		}
 
-		_, _, err := c.client.NetworkPeeringApi.DeletePeeringConnection(ctx, projectID, peer.GetId()).Execute()
+		_, _, err := c.client.NetworkPeeringApi.DeleteGroupPeer(ctx, projectID, peer.GetId()).Execute()
 		if err != nil {
 			fmt.Println(text.FgRed.Sprintf("\t\t\tFailed to request deletion of network peering %s: %s", peer.GetId(), err))
 

tools/clean/atlas/private_endpoints.go

@@ -24,7 +24,7 @@ import (
 
 func (c *Cleaner) listPrivateEndpoints(ctx context.Context, projectID, cloudProvider string) []admin.EndpointService {
 	endpoints, _, err := c.client.PrivateEndpointServicesApi.
-		ListPrivateEndpointServices(ctx, projectID, cloudProvider).
+		ListPrivateEndpointService(ctx, projectID, cloudProvider).
 		Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to list %s private endpoints for project %s: %s", cloudProvider, projectID, err))

tools/clean/atlas/projects.go

@@ -25,7 +25,7 @@ import (
 
 func (c *Cleaner) listProjectsByOrg(ctx context.Context, orgID string) []admin.Group {
 	projectsList, _, err := c.client.OrganizationsApi.
-		ListOrganizationProjects(ctx, orgID).
+		GetOrgGroups(ctx, orgID).
 		Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("Failed to list projects of organization %s: %s", orgID, err))
@@ -43,7 +43,7 @@ func (c *Cleaner) listProjectsByOrg(ctx context.Context, orgID string) []admin.G
 }
 
 func (c *Cleaner) deleteProject(ctx context.Context, p *admin.Group) {
-	_, err := c.client.ProjectsApi.DeleteProject(ctx, p.GetId()).Execute()
+	_, err := c.client.ProjectsApi.DeleteGroup(ctx, p.GetId()).Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to request deletion of project %s(%s): %s", p.GetName(), p.GetId(), err))
 

tools/clean/atlas/streams.go

@@ -23,7 +23,7 @@ import (
 )
 
 func (c *Cleaner) listStreams(ctx context.Context, id string) []admin.StreamsTenant {
-	streams, _, err := c.client.StreamsApi.ListStreamInstances(ctx, id).Execute()
+	streams, _, err := c.client.StreamsApi.ListStreamWorkspaces(ctx, id).Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to list stream instances for project %s: %s", id, err))
 		return nil
@@ -33,7 +33,7 @@ func (c *Cleaner) listStreams(ctx context.Context, id string) []admin.StreamsTen
 
 func (c *Cleaner) deleteStreams(ctx context.Context, id string, streams []admin.StreamsTenant) {
 	for _, stream := range streams {
-		_, err := c.client.StreamsApi.DeleteStreamInstance(ctx, id, stream.GetName()).Execute()
+		_, err := c.client.StreamsApi.DeleteStreamWorkspace(ctx, id, stream.GetName()).Execute()
 		if err != nil {
 			fmt.Println(text.FgRed.Sprintf("\t\t\tFailed to delete Stream instance %s", stream.GetId()), err)
 

tools/clean/atlas/teams.go

@@ -24,7 +24,7 @@ import (
 
 func (c *Cleaner) listTeamsByOrg(ctx context.Context, orgID string) []admin.TeamResponse {
 	teamsList, _, err := c.client.TeamsApi.
-		ListOrganizationTeams(ctx, orgID).
+		ListOrgTeams(ctx, orgID).
 		Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("Failed to list teams of organization %s: %s", orgID, err))
@@ -42,7 +42,7 @@ func (c *Cleaner) listTeamsByOrg(ctx context.Context, orgID string) []admin.Team
 }
 
 func (c *Cleaner) deleteTeam(ctx context.Context, orgID string, team *admin.TeamResponse) {
-	_, err := c.client.TeamsApi.DeleteTeam(ctx, orgID, team.GetId()).Execute()
+	_, err := c.client.TeamsApi.DeleteOrgTeam(ctx, orgID, team.GetId()).Execute()
 	if err != nil {
 		fmt.Println(text.FgRed.Sprintf("\tFailed to request deletion of team %s(%s): %s", team.GetName(), team.GetId(), err))