Release 1.30.0

Author: l-technicore

pkg/cloudprovider/providers/oci/instances.go

@@ -320,7 +320,7 @@ func (cp *CloudProvider) checkForAuthorizationError(ctx context.Context, instanc
 		return false, err
 	}
 	// to eliminate AD specific issues, list all ADs and make AD specific requests
-	availabilityDomains, err := cp.client.Identity().ListAvailabilityDomains(ctx, compartmentId)
+	availabilityDomains, err := cp.client.Identity(nil).ListAvailabilityDomains(ctx, compartmentId)
 	for _, availabilityDomain := range availabilityDomains {
 		instances, err := cp.client.Compute().ListInstancesByCompartmentAndAD(ctx, compartmentId, *availabilityDomain.Name)
 		// if we are getting errors for ListInstances the issue can be authorization or other issues

pkg/oci/client/client_factory.go

@@ -19,7 +19,7 @@ import (
 	"go.uber.org/zap"
 )
 
-//GetClient returns the client for given Configuration
+// GetClient returns the client for given Configuration
 func GetClient(logger *zap.SugaredLogger, cfg *config.Config) (Interface, error) {
 	cp, err := config.NewConfigurationProvider(cfg)
 	if err != nil {
@@ -29,6 +29,6 @@ func GetClient(logger *zap.SugaredLogger, cfg *config.Config) (Interface, error)
 
 	rateLimiter := NewRateLimiter(logger, cfg.RateLimiter)
 
-	c, err := New(logger, cp, &rateLimiter)
+	c, err := New(logger, cp, &rateLimiter, cfg.Auth.TenancyID)
 	return c, err
 }

pkg/oci/client/identity.go

@@ -28,6 +28,24 @@ import (
 // by the volume provisioner.
 type IdentityInterface interface {
 	GetAvailabilityDomainByName(ctx context.Context, compartmentID, name string) (*identity.AvailabilityDomain, error)
+	ListAvailabilityDomains(ctx context.Context, compartmentID string) ([]identity.AvailabilityDomain, error)
+}
+
+func (c *client) ListAvailabilityDomains(ctx context.Context, compartmentID string) ([]identity.AvailabilityDomain, error) {
+	if !c.rateLimiter.Reader.TryAccept() {
+		return nil, RateLimitError(false, "ListAvailabilityDomains")
+	}
+
+	resp, err := c.identity.ListAvailabilityDomains(ctx, identity.ListAvailabilityDomainsRequest{
+		CompartmentId:   &compartmentID,
+		RequestMetadata: c.requestMetadata,
+	})
+	incRequestCounter(err, listVerb, availabilityDomainResource)
+	if err != nil {
+		return nil, errors.WithStack(err)
+	}
+
+	return resp.Items, nil
 }
 
 func (c *client) GetAvailabilityDomainByName(ctx context.Context, compartmentID, name string) (*identity.AvailabilityDomain, error) {

pkg/volume/provisioner/core/provisioner.go

@@ -124,7 +124,7 @@ func NewOCIProvisioner(logger *zap.SugaredLogger, kubeClient kubernetes.Interfac
 
 	rateLimiter := client.NewRateLimiter(logger, cfg.RateLimiter)
 
-	client, err := client.New(logger, cp, &rateLimiter)
+	client, err := client.New(logger, cp, &rateLimiter, cfg.Auth.TenancyID)
 	if err != nil {
 		return nil, errors.Wrapf(err, "unable to construct OCI client")
 	}