› Async::Job::Processor::Redis › Source › Async › Job › Processor › Redis

`module Redis`

Redis-based job processor implementation. Provides distributed job processing capabilities using Redis as the backend.

Nested

Definitions

`def self.new(delegate, endpoint: Async::Redis.local_endpoint, **options)`

Create a new Redis job processor server.

Signature

parameter　delegate　Object: The delegate object that will process jobs.
parameter　endpoint　Async::Redis::Endpoint: The Redis endpoint to connect to.
parameter　options　Hash: Additional options passed to the server.
returns　Server: A new Redis job processor server instance.

Implementation

def self.new(delegate, endpoint: Async::Redis.local_endpoint, **options)
	client = Async::Redis::Client.new(endpoint)
	return Server.new(delegate, client, **options)
end