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
clientAsync::Redis::Client The Redis client instance.
-
parameter
keyString 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
idString 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