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