feat: add config setting to force new channel

src/Cache/Internal/DataGrpcManager.php

@@ -10,19 +10,27 @@
 use Momento\Auth\ICredentialProvider;
 use Momento\Cache\Interceptors\AgentInterceptor;
 use Momento\Cache\Interceptors\AuthorizationInterceptor;
+use Momento\Config\IConfiguration;
 
 class DataGrpcManager
 {
     public ScsClient $client;
     private Channel $channel;
 
-    public function __construct(ICredentialProvider $authProvider)
+    public function __construct(ICredentialProvider $authProvider, IConfiguration $configuration)
     {
         $endpoint = $authProvider->getCacheEndpoint();
         $channelArgs = ["credentials" => ChannelCredentials::createSsl()];
         if ($authProvider->getTrustedCacheEndpointCertificateName()) {
             $channelArgs["grpc.ssl_target_name_override"] = $authProvider->getTrustedCacheEndpointCertificateName();
         }
+        $forceNewChannel = $configuration
+            ->getTransportStrategy()
+            ->getGrpcConfig()
+            ->getForceNewChannel();
+        if ($forceNewChannel) {
+            $channelArgs["force_new"] = $forceNewChannel;
+        }
         $this->channel = new Channel($endpoint, $channelArgs);
         $interceptors = [
             new AuthorizationInterceptor($authProvider->getAuthToken()),

src/Cache/Internal/ScsDataClient.php

@@ -168,7 +168,7 @@ public function __construct(IConfiguration $configuration, ICredentialProvider $
         validateOperationTimeout($operationTimeoutMs);
         $this->deadline_milliseconds = $operationTimeoutMs ?? self::$DEFAULT_DEADLINE_MILLISECONDS;
         $this->timeout = $this->deadline_milliseconds * self::$TIMEOUT_MULTIPLIER;
-        $this->grpcManager = new DataGrpcManager($authProvider);
+        $this->grpcManager = new DataGrpcManager($authProvider, $configuration);
         $this->setLogger($configuration->getLoggerFactory()->getLogger(get_class($this)));
     }
 

src/Config/Configuration.php

@@ -55,7 +55,21 @@ public function withTransportStrategy(ITransportStrategy $transportStrategy): IC
      * @param int $clientTimeoutSecs The amount of time in seconds to wait before cancelling the request.
      * @return IConfiguration Configuration object with specified client timeout
      */
-    public function withClientTimeout(int $clientTimeoutSecs): IConfiguration {
+    public function withClientTimeout(int $clientTimeoutSecs): IConfiguration
+    {
         return new Configuration($this->loggerFactory, $this->transportStrategy->withClientTimeout($clientTimeoutSecs));
     }
+
+    /**
+     * Creates a new instance of the Configuration object, updated to use the specified "force_new" value
+     * when creating a gRPC channel
+     *
+     * @param bool $forceNewChannel If set to boolean "true" value, gRPC channels will be constructed with
+     *   "force_new" set to true
+     * @return IConfiguration Configuration object with the specified force new channel setting
+     */
+    public function withForceNewChannel(bool $forceNewChannel): IConfiguration
+    {
+        return new Configuration($this->loggerFactory, $this->transportStrategy->withForceNewChannel($forceNewChannel));
+    }
 }

src/Config/IConfiguration.php

@@ -31,4 +31,14 @@ public function withTransportStrategy(ITransportStrategy $transportStrategy): IC
      * @return IConfiguration Configuration object with specified client timeout
      */
     public function withClientTimeout(int $clientTimeoutSecs): IConfiguration;
+
+    /**
+     * Creates a new instance of the Configuration object, updated to use the specified "force_new" value
+     * when creating a gRPC channel
+     *
+     * @param bool $forceNewChannel If set to boolean "true" value, gRPC channels will be constructed with
+     *   "force_new" set to true
+     * @return IConfiguration Configuration object with the specified force new channel setting
+     */
+    public function withForceNewChannel(bool $forceNewChannel): IConfiguration;
 }

src/Config/Transport/IGrpcConfiguration.php

@@ -8,4 +8,8 @@ interface IGrpcConfiguration
     public function getDeadlineMilliseconds(): ?int;
 
     public function withDeadlineMilliseconds(int $deadlineMilliseconds): IGrpcConfiguration;
+
+    public function getForceNewChannel(): ?bool;
+
+    public function withForceNewChannel(bool $forceNewChannel) : IGrpcConfiguration;
 }

src/Config/Transport/ITransportStrategy.php

@@ -20,4 +20,6 @@ public function withGrpcConfig(IGrpcConfiguration $grpcConfig);
     public function withMaxIdleMillis(int $maxIdleMillis);
 
     public function withClientTimeout(int $clientTimeout);
+
+    public function withForceNewChannel(bool $forceNewChannel);
 }

src/Config/Transport/StaticGrpcConfiguration.php

@@ -7,10 +7,12 @@ class StaticGrpcConfiguration implements IGrpcConfiguration
 {
 
     private ?int $deadlineMilliseconds;
+    private ?bool $forceNewChannel;
 
-    public function __construct(?int $deadlineMilliseconds = null)
+    public function __construct(?int $deadlineMilliseconds = null, ?bool $forceNewChannel = false)
     {
         $this->deadlineMilliseconds = $deadlineMilliseconds;
+        $this->forceNewChannel = $forceNewChannel;
     }
 
     public function getDeadlineMilliseconds(): int|null
@@ -20,6 +22,16 @@ public function getDeadlineMilliseconds(): int|null
 
     public function withDeadlineMilliseconds(int $deadlineMilliseconds): StaticGrpcConfiguration
     {
-        return new StaticGrpcConfiguration($deadlineMilliseconds);
+        return new StaticGrpcConfiguration($deadlineMilliseconds, $this->forceNewChannel);
+    }
+
+    public function getForceNewChannel(): bool|null
+    {
+        return $this->forceNewChannel;
+    }
+
+    public function withForceNewChannel(bool $forceNewChannel): StaticGrpcConfiguration
+    {
+        return new StaticGrpcConfiguration($this->deadlineMilliseconds, $forceNewChannel);
     }
 }

src/Config/Transport/StaticTransportStrategy.php

@@ -70,4 +70,14 @@ public function withClientTimeout(int $clientTimeout): StaticTransportStrategy
             $this->maxIdleMillis
         );
     }
+
+    public function withForceNewChannel(bool $forceNewChannel): StaticTransportStrategy
+    {
+        return new StaticTransportStrategy(
+            $this->maxConcurrentRequests,
+            $this->grpcConfig->withForceNewChannel($forceNewChannel),
+            $this->loggerFactory,
+            $this->maxIdleMillis
+        );
+    }
 }