úÎ!ˆªƒbT      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRS None "#MPX_k hasql-queueEnqueue a payload. hasql-queueDequeue a list of payloads hasql-queuePayload encoder hasql-queueList of payloads to enqueue hasql-queuePayload decoder hasql-queue Element countNone "#MPX_k(  hasql-queue-To aid in observability and white box testing hasql-queueTAn event that is trigger after the initial action, e.g. before dequeue is called. hasql-queueDAn event that is triggered before the blocking on a notification.  hasql-queuedThe fundemental record stored in the queue. The queue is a single table and each row consists of a   hasql-queueQInternal payload id. Used by the public api as continuation token for pagination. hasql-queueA  ) can exist in three states in the queue,  , and Dequeued. A   starts in the X state and is locked so some sort of process can occur with it, usually something in T*. Once the processing is complete, the   is moved the Dequeued' state, which is the terminal state. hasql-queue  decoder! hasql-queueGet the   given a " hasql-queueGet the number of rows in the  state., hasql-queue<Retrieve the payloads that have entered a failed state. See -Š for how that occurs. The function returns a list of values and an id. The id is used the starting place for the next batch of values. If U, is passed the list starts at the beginning., hasql-queuePayload decoder hasql-queue$Starting position of payloads. Pass U to start at the beginning hasql-queueCount-   !"#$%&'()*+,-.-   !"# $%&'()*+,-.None "#MPX_k" @ hasql-queueEnqueue a payload.A hasql-queueDequeue a list of payloads.@ hasql-queue Connection hasql-queuePayload encoder hasql-queueList of payloads to enqueueA hasql-queue Connection hasql-queuePayload decoder hasql-queue Element count@A@ANone "#MPX_k:éB hasql-queueEnqueue a list of payloads.C hasql-queuezWait for the next payload and process it. If the continuation throws an exception the payloads are put back in the queue. V is caught and C& will retry up to the retry count. If C  fails after too many retries the final exception is rethrown. If individual payloads are are attempted more than the retry count they are set as "failed". See D( to receive the list of failed payloads.If the queue is empty C return U. If there are any entries C will wrap the list in W.D hasql-queue<Retrieve the payloads that have entered a failed state. See CŠ for how that occurs. The function returns a list of values and an id. The id is used the starting place for the next batch of values. If U, is passed the list starts at the beginning.E hasql-queue%Permantently remove a failed payload.F hasql-queue'A more general configurable version of C . Unlike C” one can specify the exception that causes a retry. Additionally event handlers can be specified to observe the internal behavior of the retry loop.B hasql-queue Connection hasql-queuePayload encoder hasql-queueList of payloads to enqueueC hasql-queue Connection hasql-queuePayload decoder hasql-queue Retry count hasql-queue Element count hasql-queue ContinuationD hasql-queuePayload decoder hasql-queue$Starting position of payloads. Pass U to start at the beginning hasql-queueCountF hasql-queue Connection hasql-queuePayload decoder hasql-queue Retry count hasql-queue Element count hasql-queue ContinuationBCDEFBCDEFNone "#MPX_kFG hasql-queue?Enqueue a payload send a notification on the specified channel.G hasql-queue:Notification channel name. Any valid PostgreSQL identifier hasql-queuePayload encoder hasql-queueList of payloads to enqueueH hasql-queue:Notification channel name. Any valid PostgreSQL identifier hasql-queue Connection hasql-queuePayload decoder hasql-queue Batch count hasql-queueTransaction runnerI hasql-queue(Event handlers for events that occur as  withDequeWith loops hasql-queue:Notification channel name. Any valid PostgreSQL identifier hasql-queue Connection hasql-queuePayload decoder hasql-queue Batch count hasql-queueTransaction runnerGHIGHINone "#MPX_kLçJ hasql-queueEnqueue a payload.K hasql-queueDequeue a list of payloads.J hasql-queue:Notification channel name. Any valid PostgreSQL identifier hasql-queue Connection hasql-queuePayload encoder hasql-queueList of payloads to enqueueK hasql-queue:Notification channel name. Any valid PostgreSQL identifier hasql-queue Connection hasql-queuePayload decoder hasql-queue Element countJKJKNone "#MPX_kjpL hasql-queueEnqueue a list of payloads.M hasql-queuezWait for the next payload and process it. If the continuation throws an exception the payloads are put back in the queue. V is caught and M& will retry up to the retry count. If M  fails after too many retries the final exception is rethrown. If individual payloads are are attempted more than the retry count they are set as "failed". See N( to receive the list of failed payloads.If the queue is empty MH will block until it recieves a notification from the PostgreSQL server.N hasql-queue<Retrieve the payloads that have entered a failed state. See MŠ for how that occurs. The function returns a list of values and an id. The id is used the starting place for the next batch of values. If U, is passed the list starts at the beginning.O hasql-queue%Permantently remove a failed payload.P hasql-queue'A more general configurable version of M . Unlike M” one can specify the exception that causes a retry. Additionally event handlers can be specified to observe the internal behavior of the retry loop.L hasql-queue:Notification channel name. Any valid PostgreSQL identifier hasql-queue Connection hasql-queuePayload encoder hasql-queueList of payloads to enqueueM hasql-queue:Notification channel name. Any valid PostgreSQL identifier hasql-queue Connection hasql-queuePayload decoder hasql-queue Retry count hasql-queue Element count hasql-queue ContinuationN hasql-queuePayload decoder hasql-queue$Starting position of payloads. Pass U to start at the beginning hasql-queueCountP hasql-queue(Event handlers for events that occur as  withDequeWith loops hasql-queue:Notification channel name. Any valid PostgreSQL identifier hasql-queue Connection hasql-queuePayload decoder hasql-queue Retry count hasql-queue Element count hasql-queue Continuation LMNOP LMNOPNone "#MPX_k‚ŽQ hasql-queue;The DDL statements to create the schema given a value type.R hasql-queuetThis function creates a table and enumeration type that is appriopiate for the queue. The following sql is used. ÿ)DO $$ CREATE OR REPLACE FUNCTION notify_on(channel text) RETURNs VOID AS $$ BEGIN EXECUTE (format(E'NOTIFY %I', channel)); END; $$ LANGUAGE plpgsql; CREATE OR REPLACE FUNCTION listen_on(channel text) RETURNS VOID AS $$ BEGIN EXECUTE (format(E'LISTEN %I', channel)); END; $$ LANGUAGE plpgsql; CREATE OR REPLACE FUNCTION unlisten_on(channel text) RETURNS VOID AS $$ BEGIN EXECUTE (format(E'UNLISTEN %I', channel)); END; $$ LANGUAGE plpgsql; DO $$ BEGIN IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = state_t)) THEN CREATE TYPE state_t AS ENUM (enqueued, failedÕ); END IF; END$$; CREATE SEQUENCE IF NOT EXISTS modified_index START 1; CREATE TABLE IF NOT EXISTS payloads ( id BIGSERIAL PRIMARY KEY , attempts int NOT NULL DEFAULT 0 , state state_t NOT NULL DEFAULT enqueued. , modified_at int8 NOT NULL DEFAULT nextval(modified_index™) , value ${VALUE_TYPE} NOT NULL ); CREATE INDEX IF NOT EXISTS active_modified_at_idx ON payloads USING btree (modified_at, state) WHERE (state = enqueued); The  VALUE_TYPE0 needs to passed in through the second argument.S hasql-queueDrop everything created by RQ hasql-queuevalue column type, e.g. int4 or jsonb.R hasql-queueThe type of the value columnQRSQRS None "#MPX_kƒ=XYZ[\]^_`       !"#$%&'()*+,-./0123456789:;<=>?@ABCD   213E 2E   213EFGHIJKLMNLOPLMQ R S T U V W X YZ*hasql-queue-1.2.0.1-LK62ujAC4O4GFUZ0RL92VdHasql.Queue.High.ExactlyOnceHasql.Queue.InternalHasql.Queue.High.AtMostOnceHasql.Queue.High.AtLeastOnceHasql.Queue.Low.ExactlyOnceHasql.Queue.Low.AtMostOnceHasql.Queue.Low.AtLeastOnceHasql.Queue.MigratePaths_hasql_queueenqueuedequeueNoRowsWithNotifyHandlerswithNotifyHandlersAfterAction$withNotifyHandlersBeforeNotificationQueryExceptionPayloadpIdpState pAttempts pModifiedAtpValue PayloadId unPayloadIdStateEnqueuedFailedstate stateDecoder stateEncoderinitialPayloadIdpayloadDecoderpayloadIdEncoderpayloadIdDecoder payloadIdRowenqueuePayloaddequeuePayload getPayloadgetCountincrementAttemptsrunThrowexecute notifyPayloadwithNotifyWithfst3snd3trd3 listStatefailures withDequeuedelete$fExceptionQueryException$fMonoidWithNotifyHandlers$fSemigroupWithNotifyHandlers$fExceptionNoRows $fShowState $fEqState $fOrdState $fEnumState$fBoundedState $fEqPayloadId$fShowPayloadId $fShowPayload $fEqPayload$fEqQueryException$fShowQueryException $fShowNoRows $fEqNoRowswithDequeueWithmigrationQueryStringmigrateteardownghc-prim GHC.TypesIObase GHC.MaybeNothingGHC.IO.ExceptionIOErrorJustversion getBinDir getLibDir getDynLibDir getDataDir getLibexecDir getSysconfDirgetDataFileName