Async::Job::Processor::RedisSourceAsyncJobProcessorRedisJobStore

class JobStore

Stores job data using Redis hashes. Provides persistent storage for job payloads indexed by job ID.

Definitions

def initialize(client, key)

Initialize a new job store.

Signature

parameter client Async::Redis::Client

The Redis client instance.

parameter key String

The Redis key for the job data hash.

Implementation

def initialize(client, key)
	@client = client
	@key = key
end

attr :key

Signature

attribute String

The Redis key for this job store.

def get(id)

Retrieve job data by ID.

Signature

parameter id String

The job ID to retrieve.

returns String, nil

The serialized job data, or nil if not found.

Implementation

def get(id)
	@client.hget(@key, id)
end