Class: Async::GRPC::Dispatcher

Inherits:
Protocol::GRPC::Middleware
  • Object
show all
Defined in:
lib/async/grpc/dispatcher.rb

Overview

Dispatches gRPC requests to registered services. Handles routing based on service name from the request path.

Examples:

Registering services:

dispatcher = Dispatcher.new
dispatcher.register(GreeterService.new(GreeterInterface, "hello.Greeter"))
dispatcher.register(WorldService.new(WorldInterface, "world.Greeter"))

server = Async::HTTP::Server.for(endpoint, dispatcher)

Instance Method Summary collapse

Constructor Details

#initialize(app = nil, services: {}) ⇒ Dispatcher

Initialize the dispatcher.



34
35
36
37
 
# File 'lib/async/grpc/dispatcher.rb', line 34

def initialize(app = nil, services: {})
	super(app)
	@services = services
end

Instance Method Details

#register(service, name: service.service_name) ⇒ Object

Register a service.



42
43
44
 
# File 'lib/async/grpc/dispatcher.rb', line 42

def register(service, name: service.service_name)
	@services[name] = service
end