Expose cluster listener protocol names.

Author: samuel-williams-shopify

examples/cluster/readme.md

@@ -4,7 +4,7 @@ This example shows how to run Falcon cluster workers on independently bound Unix
 
 Each worker lazily constructs an `IO::Endpoint.unix` endpoint using its process ID and current thread object ID. Consequently, process, threaded, and hybrid workers never compete for the same socket path, and the socket directory reflects every independently bound worker.
 
-After binding, Falcon describes each worker using a `Falcon::Service::Cluster::Listener`. The listener exposes its logical name, scheme, protocol, bound endpoint, and all concrete socket addresses. Service discovery integrations can use `prepare_worker!(instance, listener:)` to register exactly what the worker bound.
+After binding, Falcon describes each worker using a `Falcon::Service::Cluster::Listener`. The listener exposes its logical name, scheme, supported protocol names, bound endpoint, and all concrete socket addresses. Service discovery integrations can use `prepare_worker!(instance, listener:)` to register exactly what the worker bound.
 
 ## Usage
 

falcon.gemspec

@@ -28,7 +28,7 @@ Gem::Specification.new do |spec|
 
 	spec.add_dependency "async"
 	spec.add_dependency "async-container", "~> 0.20"
-	spec.add_dependency "async-http", "~> 0.75"
+	spec.add_dependency "async-http", "~> 0.97"
 	spec.add_dependency "async-http-cache", "~> 0.4"
 	spec.add_dependency "async-service", "~> 0.19"
 	spec.add_dependency "async-utilization", "~> 0.3"

gems.rb

@@ -25,7 +25,7 @@
 
 # gem "fiber-profiler"
 
-gem "async-service-supervisor"
+gem "async-service-supervisor", "~> 0.18"
 
 group :maintenance, optional: true do
 	gem "bake-modernize"

lib/falcon/service/cluster.rb

@@ -15,12 +15,12 @@ class Listener
 				# Initialize a bound listener.
 				# @parameter name [String] The logical listener name.
 				# @parameter scheme [String] The application protocol scheme.
-				# @parameter protocol [Object] The application protocol implementation.
+				# @parameter protocols [Array(String)] The supported application protocol names.
 				# @parameter endpoint [IO::Endpoint::BoundEndpoint] The endpoint bound by the worker.
-				def initialize(name:, scheme:, protocol:, endpoint:)
+				def initialize(name:, scheme:, protocols:, endpoint:)
 					@name = name
 					@scheme = scheme
-					@protocol = protocol
+					@protocols = protocols.map(&:to_s).freeze
 					@endpoint = endpoint
 					@addresses = endpoint.sockets.map{|socket| socket.to_io.local_address}.freeze
 					freeze
@@ -32,8 +32,8 @@ def initialize(name:, scheme:, protocol:, endpoint:)
 				# @attribute [String] The application protocol scheme.
 				attr_reader :scheme
 
-				# @attribute [Object] The application protocol implementation.
-				attr_reader :protocol
+				# @attribute [Array(String)] The supported application protocol names.
+				attr_reader :protocols
 
 				# @attribute [IO::Endpoint::BoundEndpoint] The endpoint bound by the worker.
 				attr_reader :endpoint
@@ -74,7 +74,7 @@ def setup(container)
 							listener = Listener.new(
 								name: evaluator.name,
 								scheme: endpoint.scheme,
-								protocol: endpoint.protocol,
+								protocols: endpoint.protocol.names,
 								endpoint: bound_endpoint,
 							)
 

test/falcon/service/cluster.rb

@@ -14,14 +14,14 @@
 describe Falcon::Service::Cluster do
 	let(:ports_path) {File.expand_path(".cluster/ports.txt", __dir__)}
 
-	def make_listener(*addresses, name: "hello", scheme: "http", protocol: Async::HTTP::Protocol::HTTP1)
+	def make_listener(*addresses, name: "hello", scheme: "http", protocols: ["http/1.1", "http/1.0"])
 		sockets = addresses.map do |address|
 			io = Struct.new(:local_address).new(address)
 			Struct.new(:to_io).new(io)
 		end
 
 		endpoint = Struct.new(:sockets).new(sockets)
-		subject::Listener.new(name: name, scheme: scheme, protocol: protocol, endpoint: endpoint)
+		subject::Listener.new(name: name, scheme: scheme, protocols: protocols, endpoint: endpoint)
 	end
 
 	it "describes the bound listener" do
@@ -32,11 +32,12 @@ def make_listener(*addresses, name: "hello", scheme: "http", protocol: Async::HT
 		expect(listener).to have_attributes(
 			name: be == "hello",
 			scheme: be == "http",
-			protocol: be == Async::HTTP::Protocol::HTTP1,
+			protocols: be == ["http/1.1", "http/1.0"],
 			addresses: be == [ip_address, unix_address],
 			frozen?: be == true,
 		)
 		expect(listener.addresses.frozen?).to be == true
+		expect(listener.protocols.frozen?).to be == true
 	end
 
 	let(:recorder) do