proletarian.protocols
QueueWorkercljprotocol
The process that runs the job workers for a particular queue.
The process that runs the job workers for a particular queue.
start!clj
(start! _)Sets up a thread pool and starts polling for jobs.
Sets up a thread pool and starts polling for jobs.
stop!clj
(stop! _)Shuts down the job workers and the thread pool. Will allow running jobs to complete before shutting down the thread pool.
Shuts down the job workers and the thread pool. Will allow running jobs to complete before shutting down the thread pool.
Serializercljprotocol
The Serializer encodes and decodes the job data payload as it is written to and read from the database tables.
The Serializer encodes and decodes the job data payload as it is written to and read from the database tables.
decodeclj
(decode _ data-string)Decode the data-as-string after reading.
Decode the data-as-string after reading.
encodeclj
(encode _ data)Encode the data as a string before writing.
Encode the data as a string before writing.
UuidSerializercljprotocol
The UuidSerializer encodes and decodes UUIDs (i.e., the job-id) as it is written to and read from database tables.
The UuidSerializer encodes and decodes UUIDs (i.e., the job-id) as it is written to and read from database tables.
uuid-decodeclj
(uuid-decode _ job-id)Decode the job-id depending on the chosen database implemenation.)) The default is proletarian.uuid.postgresql.
Decode the job-id depending on the chosen database implemenation.)) The default is proletarian.uuid.postgresql.
uuid-encodeclj
(uuid-encode _ job-id)Encode the job-id depending on the chosen database implemenation. The default is proletarian.uuid.postgresql.
Encode the job-id depending on the chosen database implemenation. The default is proletarian.uuid.postgresql.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close