RCBC-398: Add ClusterRegistry

lib/couchbase/cluster.rb

@@ -15,6 +15,7 @@
 require "couchbase/configuration"
 require "couchbase/authenticator"
 require "couchbase/bucket"
+require "couchbase/cluster_registry"
 
 require "couchbase/management"
 require "couchbase/options"
@@ -62,7 +63,12 @@ class Cluster
     #
     # @return [Cluster]
     def self.connect(connection_string, *options)
-      Cluster.new(connection_string, *options)
+      regexp = /^((couchbases?|http):\/\/.*)$/i
+      if regexp.match?(connection_string) || !connection_string.include?("://")
+        Cluster.new(connection_string, *options)
+      else
+        ClusterRegistry.instance.connect(connection_string, *options)
+      end
     end
 
     # Returns an instance of the {Bucket}

lib/couchbase/cluster_registry.rb

@@ -0,0 +1,44 @@
+# frozen_string_literal: true
+
+#  Copyright 2023 Couchbase, Inc.
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+
+require "singleton"
+
+require "couchbase/errors"
+
+module Couchbase
+  class ClusterRegistry
+    include Singleton
+
+    def initialize
+      @handlers = {}
+    end
+
+    def connect(connection_string, *options)
+      @handlers.each do |regexp, cluster_class|
+        return cluster_class.connect(connection_string, *options) if regexp.match?(connection_string)
+      end
+      raise(Error::FeatureNotAvailable, "Connection string '#{connection_string}' not supported.")
+    end
+
+    def register_connection_handler(regexp, cluster_class)
+      @handlers[regexp] = cluster_class
+    end
+
+    def deregister_connection_handler(regexp)
+      @handlers.delete(regexp)
+    end
+  end
+end