úÎ!XáUÉ2      !"#$%&'()*+,-./01None"#2>EHMPSVXHMPSVXk@q consumersID of a consumer. consumersYRegister consumer in the consumers table, so that it can reserve jobs using acquired ID. consumers$Unregister consumer with a given ID.None"#2>HMPSVXJ"# consumers%Exception thrown from a child thread.4 consumersOException thrown to a thread to stop its execution. All exceptions other than 4 thrown to threads spawned by ' and (+ are propagated back to the parent thread.% consumersRun an action mO that returns a finalizer and perform the returned finalizer after the action action completes.& consumersStop execution of a thread.' consumersModified version of 59 that propagates thrown exceptions to the parent thread.( consumersModified version of 69 that propagates thrown exceptions to the parent thread.#$%&'(%#$&'(None"#2>HMPSVXTw- consumers¤Run the consumer. The purpose of the returned monadic action is to wait for currently processed jobs and clean up. This function is best used in conjunction with %( to seamlessly handle the finalization.7 consumersfRun the consumer and also signal whenever the consumer is waiting for getNotification or threadDelay./ consumersbSpawn a thread that generates signals for the dispatcher to probe the database for incoming jobs.0 consumers^Spawn a thread that monitors working consumers for activity and periodically updates its own.1 consumers0Spawn a thread that reserves and processes jobs.-./01-./01None"#2>HMPSVXUM #$%&'(-.-.8      !"#$%&'(()*+,-./012345678679:;<=>?=@A(consumers-2.2.0.0-5YgIr38Dyw2CDTwbyNiqhq$Database.PostgreSQL.Consumers.Config&Database.PostgreSQL.Consumers.Consumer#Database.PostgreSQL.Consumers.Utils(Database.PostgreSQL.Consumers.ComponentsDatabase.PostgreSQL.ConsumersConsumerConfig ccJobsTableccConsumersTableccJobSelectors ccJobFetcher ccJobIndexccNotificationChannelccNotificationTimeoutccMaxRunningJobs ccProcessJob ccOnExceptionResultOkFailedAction MarkProcessed RerunAfterRerunAtRemove $fEqAction $fOrdAction $fShowAction $fEqResult $fOrdResult $fShowResult ConsumerIDregisterConsumerunregisterConsumer$fShowConsumerID$fToSQLConsumerID$fFromSQLConsumerID$fPQFormatConsumerID$fEqConsumerID$fOrdConsumerID ThrownFromfinalize stopExecutionforkPgforkP$fExceptionStopExecution$fExceptionThrownFrom$fShowStopExecution$fShowThrownFrom runConsumerrunConsumerWithIdleSignal spawnListener spawnMonitorspawnDispatcherbase GHC.MaybeNothingJust StopExecution+lifted-base-0.2.3.12-7Kori5MZGo66gGfmCMF7rcControl.Concurrent.Liftedfork)lifted-threads-1.0-DshwAUwSRDNDdljMR5bmH2&Control.Concurrent.Thread.Group.LiftedrunConsumerWithMaybeIdleSignal