MCPcopy Create free account

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

MethodEncodesNestedAddJobArgsShape
()
dotnet/tests/BullMQ.Tests/MsgPackTests.cs:67
MethodEncodesNil
()
dotnet/tests/BullMQ.Tests/MsgPackTests.cs:8
MethodEncodesSmallInts
(int value, byte[] expected)
dotnet/tests/BullMQ.Tests/MsgPackTests.cs:18
MethodEncodesUint16
()
dotnet/tests/BullMQ.Tests/MsgPackTests.cs:29
MethodEncodesUint8
()
dotnet/tests/BullMQ.Tests/MsgPackTests.cs:26
MethodEnsureMigratedOnceAsync
()
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:131
MethodExecuteRawAsync
(NpgsqlConnection conn, NpgsqlTransaction tx, string sql)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:217
MethodExtendLockAsync
<summary>Extends the lock of a single active job. Returns 1 if renewed.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:155
MethodExtendLockAsync
(string jobId, string token, int duration)
dotnet/src/BullMQ/PostgresBackend.cs:377
MethodExtendLock_RenewsActiveJob
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:204
MethodExtendLocksAsync
<summary>Extends several locks at once; returns the ids that could not be renewed.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:158
MethodExtendLocksAsync
( IReadOnlyList<string> jobIds, IReadOnlyList<string> tokens, int duration)
dotnet/src/BullMQ/RedisBackend.cs:703
MethodExtendLocksAsync
( IReadOnlyList<string> jobIds, IReadOnlyList<string> tokens, int duration)
dotnet/src/BullMQ/PostgresBackend.cs:383
MethodExtendLocksAsync
(IReadOnlyList<string> jobIds)
dotnet/src/BullMQ/LockManager.cs:145
MethodExtractFileName
(string resourceName)
dotnet/src/BullMQ/Redis/LuaScripts.cs:71
MethodFetchEventsAsync
(string cursor)
dotnet/src/BullMQ/PostgresBackend.cs:898
MethodFlatToDict
(IReadOnlyList<string> flat)
dotnet/src/BullMQ/JobScheduler.cs:301
MethodFlatToJobJson
(RedisResult[] flat)
dotnet/src/BullMQ/RedisBackend.cs:1276
MethodFlowJobEntry
(Job job, string queueName, string prefix, bool isParent)
dotnet/src/BullMQ/FlowProducer.cs:44
MethodFlowProducer
(QueueBaseOptions opts)
dotnet/src/BullMQ/FlowProducer.cs:63
MethodFlow_CrossQueue_ParentWaitsForChildInAnotherQueue
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:210
MethodFlow_MultiLevel_ProcessesLeafToRoot
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:129
MethodFlow_ParentSeesChildrenReturnValues
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:76
MethodFlow_ParentWaitsForChildren
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:20
MethodFlow_SingleRootWithoutChildren_Processes
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:178
MethodForQueue
<summary> Returns a sibling backend bound to a different queue that shares this backend's underlying connection(s). Used by flows spanning queues. </s
dotnet/src/BullMQ/IQueueBackend.cs:40
MethodForQueue
(string queueName, string? prefix = null)
dotnet/src/BullMQ/PostgresBackend.cs:95
MethodGet
(string key)
dotnet/src/BullMQ/QueueEvents.cs:15
MethodGet
(string key)
dotnet/src/BullMQ/PostgresBackend.cs:1012
MethodGetActiveAsync
<summary>Returns active jobs.</summary>
dotnet/src/BullMQ/Queue.cs:221
MethodGetActiveCountAsync
<summary>Returns the number of active jobs.</summary>
dotnet/src/BullMQ/Queue.cs:237
MethodGetBackendAsync
<summary>Resolves the backend, connecting on first use.</summary>
dotnet/src/BullMQ/Queue.cs:47
MethodGetClientListAsync
<summary>Returns the raw worker/client list(s) for the queue's datastore.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:213
MethodGetClientListAsync
()
dotnet/src/BullMQ/RedisBackend.cs:871
MethodGetClientListAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:564
MethodGetCompletedAsync
<summary>Returns completed jobs.</summary>
dotnet/src/BullMQ/Queue.cs:225
MethodGetConnAsync
()
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:290
MethodGetCountsAsync
<summary>Returns the counts for the given job types, in order.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:197
MethodGetCountsAsync
(params string[] types)
dotnet/src/BullMQ/PostgresBackend.cs:487
MethodGetCountsPerPriorityAsync
<summary>Returns the number of jobs per priority, in order.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:200
MethodGetCountsPerPriorityAsync
(IReadOnlyList<long> priorities)
dotnet/src/BullMQ/RedisBackend.cs:826
MethodGetCountsPerPriorityAsync
(IReadOnlyList<long> priorities)
dotnet/src/BullMQ/PostgresBackend.cs:514
MethodGetCountsPerPriority_ReturnsJobCountsPerPriority
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:253
MethodGetFailedAsync
<summary>Returns failed jobs.</summary>
dotnet/src/BullMQ/Queue.cs:229
MethodGetInt
(string key, int fallback = 0)
dotnet/src/BullMQ/JobJson.cs:49
MethodGetJobCounts_ReflectsWaitingAndDelayed
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:20
MethodGetJobDataAsync
<summary>Returns the stored data for a job, or null if missing.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:188
MethodGetJobDataAsync
(string jobId)
dotnet/src/BullMQ/PostgresBackend.cs:455
MethodGetJobData_RoundTripsNameAndData
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:70
MethodGetJobLogsAsync
<summary>Returns a page of a job's logs together with the total count.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:191
MethodGetJobLogsAsync
(string jobId, int start = 0, int end = -1, bool asc = true)
dotnet/src/BullMQ/RedisBackend.cs:792
MethodGetJobLogsAsync
(string jobId, int start = 0, int end = -1, bool asc = true)
dotnet/src/BullMQ/PostgresBackend.cs:462
MethodGetJobSchedulerAsync
<summary> Returns a scheduler's stored fields (flattened <c>[k, v, ...]</c>) and its next-run score, or <c>(empty, null)</c> when absent. </summary>
dotnet/src/BullMQ/IQueueBackend.cs:269
MethodGetJobSchedulerAsync
(string id)
dotnet/src/BullMQ/RedisBackend.cs:997
MethodGetJobSchedulerAsync
(string id)
dotnet/src/BullMQ/PostgresBackend.cs:662
MethodGetJobSchedulerDataAsync
<summary>Returns the raw stored fields (name -&gt; value) of a scheduler.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:275
MethodGetJobSchedulerDataAsync
(string key)
dotnet/src/BullMQ/PostgresBackend.cs:688
MethodGetJobSchedulersAsync
<summary>Returns a page of registered schedulers.</summary>
dotnet/src/BullMQ/JobScheduler.cs:148
MethodGetJobSchedulersAsync
<summary>Returns a page of registered job schedulers.</summary>
dotnet/src/BullMQ/Queue.cs:169
MethodGetJobSchedulersCountAsync
<summary>Returns the number of registered schedulers.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:284
MethodGetJobSchedulersCountAsync
()
dotnet/src/BullMQ/RedisBackend.cs:1039
MethodGetJobSchedulersCountAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:711
MethodGetJobSchedulersRangeAsync
<summary> Returns a page of scheduler keys with their next-run scores, flattened as <c>[key, score, key, score, ...]</c>. </summary>
dotnet/src/BullMQ/IQueueBackend.cs:281
MethodGetJobSchedulersRangeAsync
(int start, int end, bool asc)
dotnet/src/BullMQ/PostgresBackend.cs:695
MethodGetJobsAsync
<summary>Returns the jobs in the given states (each id resolved to a full job).</summary>
dotnet/src/BullMQ/Queue.cs:191
MethodGetKeepJobs
(object? shouldRemove)
dotnet/src/BullMQ/RedisBackend.cs:1214
MethodGetLong
(string key, long fallback = 0)
dotnet/src/BullMQ/JobJson.cs:46
MethodGetProcessedChildrenValuesAsync
<summary>Returns the raw processed-children map (child key -> serialized value).</summary>
dotnet/src/BullMQ/IQueueBackend.cs:207
MethodGetProcessedChildrenValuesAsync
(string jobId)
dotnet/src/BullMQ/PostgresBackend.cs:541
MethodGetQueueMetaFieldAsync
<summary>Reads a single queue metadata field.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:223
MethodGetQueueMetaFieldAsync
(string field)
dotnet/src/BullMQ/PostgresBackend.cs:582
MethodGetRangesAsync
<summary>Returns a page of job ids for the given states/types.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:203
MethodGetRangesAsync
( IReadOnlyList<string> types, int start = 0, int end = 1, bool asc = false)
dotnet/src/BullMQ/PostgresBackend.cs:522
MethodGetRateLimitTtlAsync
<summary>Returns the ttl (ms) of the current rate-limit window.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:194
MethodGetRateLimitTtlAsync
()
dotnet/src/BullMQ/RedisBackend.cs:811
MethodGetRateLimitTtlAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:481
MethodGetRateLimitTtlAsync
<summary>Returns the ttl (ms) of the current rate-limit window.</summary>
dotnet/src/BullMQ/Queue.cs:310
MethodGetStateAsync
<summary>Returns the current state of a job.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:182
MethodGetStateAsync
(string jobId)
dotnet/src/BullMQ/RedisBackend.cs:763
MethodGetStateAsync
(string jobId)
dotnet/src/BullMQ/PostgresBackend.cs:430
MethodGetVersion_ReturnsBullmqVersion
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:138
MethodGetWaiting_ReturnsAddedJobs
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:214
MethodHasQueueMetaFieldAsync
<summary>Returns whether a queue metadata field exists.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:226
MethodHasQueueMetaFieldAsync
(string field)
dotnet/src/BullMQ/PostgresBackend.cs:588
MethodHasWaitingJobAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:819
MethodHonoursCustomPrefix
()
dotnet/tests/BullMQ.Tests/QueueKeysTests.cs:32
MethodInitBackendAsync
()
dotnet/src/BullMQ/QueueEvents.cs:115
MethodInitBackendAsync
()
dotnet/src/BullMQ/Worker.cs:102
MethodInitBackendAsync
()
dotnet/src/BullMQ/Queue.cs:27
MethodIsActiveAsync
<summary>Returns whether this job is active.</summary>
dotnet/src/BullMQ/Job.cs:236
MethodIsCompletedAsync
<summary>Returns whether this job has completed.</summary>
dotnet/src/BullMQ/Job.cs:227
MethodIsDelayedAsync
<summary>Returns whether this job is delayed.</summary>
dotnet/src/BullMQ/Job.cs:233
MethodIsFailedAsync
<summary>Returns whether this job has failed.</summary>
dotnet/src/BullMQ/Job.cs:230
MethodIsJobInStateAsync
<summary>Returns whether a job id is present in the given state.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:185
MethodIsJobInStateAsync
(string state, string jobId)
dotnet/src/BullMQ/RedisBackend.cs:772
MethodIsJobInStateAsync
(string state, string jobId)
dotnet/src/BullMQ/PostgresBackend.cs:448
MethodIsJobSchedulerAsync
<summary>Returns whether an id corresponds to a registered scheduler.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:272
MethodIsJobSchedulerAsync
(string id)
dotnet/src/BullMQ/RedisBackend.cs:1013
MethodIsJobSchedulerAsync
(string id)
dotnet/src/BullMQ/PostgresBackend.cs:682
MethodIsPausedAsync
<summary>Returns whether the queue is currently paused.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:210
← previousnext →1,401–1,500 of 3,768, ranked by callers