Add private support for setting the analytics endpoint,

to support the Spark Connector

Change-Id: I20b161ccfe91784a445b15d1b30ae6b4e5c297f4
Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/213653
Tested-by: Build Bot <[email protected]>
Reviewed-by: David Nault <[email protected]>

Author: programmatix

scala-client/src/main/scala/com/couchbase/client/scala/analytics/AnalyticsOptions.scala

@@ -30,7 +30,7 @@ import scala.concurrent.duration.Duration
   * @author Graham Pople
   * @since 1.0.0
   */
-case class AnalyticsOptions(
+case class AnalyticsOptions private (
     private[scala] val parameters: Option[AnalyticsParameters] = None,
     private[scala] val clientContextId: Option[String] = None,
     private[scala] val retryStrategy: Option[RetryStrategy] = None,
@@ -39,7 +39,8 @@ case class AnalyticsOptions(
     @SinceCouchbase("6.5") private[scala] val readonly: Option[Boolean] = None,
     private[scala] val scanConsistency: Option[AnalyticsScanConsistency] = None,
     private[scala] val parentSpan: Option[RequestSpan] = None,
-    private[scala] val raw: Option[Map[String, Any]] = None
+    private[scala] val raw: Option[Map[String, Any]] = None,
+    private[scala] val _endpointIdx: Int = 0
 ) {
 
   /** Sets the parent `RequestSpan`.
@@ -132,6 +133,9 @@ case class AnalyticsOptions(
   def scanConsistency(scanConsistency: AnalyticsScanConsistency): AnalyticsOptions =
     copy(scanConsistency = Some(scanConsistency))
 
+  private[couchbase] def endpointIdx(idx: Int): AnalyticsOptions =
+    copy(_endpointIdx = idx)
+
   private[scala] def encode() = {
     val out = JsonObject.create
 

scala-client/src/main/scala/com/couchbase/client/scala/query/handlers/AnalyticsHandler.scala

@@ -104,7 +104,9 @@ private[scala] class AnalyticsHandler(hp: HandlerBasicParams) {
           hp.tracer
             .requestSpan(TracingIdentifiers.SPAN_REQUEST_ANALYTICS, options.parentSpan.orNull),
           bucket.orNull,
-          scope.orNull
+          scope.orNull,
+          true,
+          options._endpointIdx
         )
       })
     }