Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/taskforcesh/bullmq
/ functions
Functions
3,768 in github.com/taskforcesh/bullmq
⨍
Functions
3,768
◇
Types & classes
487
↳
Endpoints
8
Method
EncodesNestedAddJobArgsShape
()
dotnet/tests/BullMQ.Tests/MsgPackTests.cs:67
Method
EncodesNil
()
dotnet/tests/BullMQ.Tests/MsgPackTests.cs:8
Method
EncodesSmallInts
(int value, byte[] expected)
dotnet/tests/BullMQ.Tests/MsgPackTests.cs:18
Method
EncodesUint16
()
dotnet/tests/BullMQ.Tests/MsgPackTests.cs:29
Method
EncodesUint8
()
dotnet/tests/BullMQ.Tests/MsgPackTests.cs:26
Method
EnsureMigratedOnceAsync
()
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:131
Method
ExecuteRawAsync
(NpgsqlConnection conn, NpgsqlTransaction tx, string sql)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:217
Method
ExtendLockAsync
<summary>Extends the lock of a single active job. Returns 1 if renewed.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:155
Method
ExtendLockAsync
(string jobId, string token, int duration)
dotnet/src/BullMQ/PostgresBackend.cs:377
Method
ExtendLock_RenewsActiveJob
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:204
Method
ExtendLocksAsync
<summary>Extends several locks at once; returns the ids that could not be renewed.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:158
Method
ExtendLocksAsync
( IReadOnlyList<string> jobIds, IReadOnlyList<string> tokens, int duration)
dotnet/src/BullMQ/RedisBackend.cs:703
Method
ExtendLocksAsync
( IReadOnlyList<string> jobIds, IReadOnlyList<string> tokens, int duration)
dotnet/src/BullMQ/PostgresBackend.cs:383
Method
ExtendLocksAsync
(IReadOnlyList<string> jobIds)
dotnet/src/BullMQ/LockManager.cs:145
Method
ExtractFileName
(string resourceName)
dotnet/src/BullMQ/Redis/LuaScripts.cs:71
Method
FetchEventsAsync
(string cursor)
dotnet/src/BullMQ/PostgresBackend.cs:898
Method
FlatToDict
(IReadOnlyList<string> flat)
dotnet/src/BullMQ/JobScheduler.cs:301
Method
FlatToJobJson
(RedisResult[] flat)
dotnet/src/BullMQ/RedisBackend.cs:1276
Method
FlowJobEntry
(Job job, string queueName, string prefix, bool isParent)
dotnet/src/BullMQ/FlowProducer.cs:44
Method
FlowProducer
(QueueBaseOptions opts)
dotnet/src/BullMQ/FlowProducer.cs:63
Method
Flow_CrossQueue_ParentWaitsForChildInAnotherQueue
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:210
Method
Flow_MultiLevel_ProcessesLeafToRoot
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:129
Method
Flow_ParentSeesChildrenReturnValues
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:76
Method
Flow_ParentWaitsForChildren
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:20
Method
Flow_SingleRootWithoutChildren_Processes
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:178
Method
ForQueue
<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
Method
ForQueue
(string queueName, string? prefix = null)
dotnet/src/BullMQ/PostgresBackend.cs:95
Method
Get
(string key)
dotnet/src/BullMQ/QueueEvents.cs:15
Method
Get
(string key)
dotnet/src/BullMQ/PostgresBackend.cs:1012
Method
GetActiveAsync
<summary>Returns active jobs.</summary>
dotnet/src/BullMQ/Queue.cs:221
Method
GetActiveCountAsync
<summary>Returns the number of active jobs.</summary>
dotnet/src/BullMQ/Queue.cs:237
Method
GetBackendAsync
<summary>Resolves the backend, connecting on first use.</summary>
dotnet/src/BullMQ/Queue.cs:47
Method
GetClientListAsync
<summary>Returns the raw worker/client list(s) for the queue's datastore.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:213
Method
GetClientListAsync
()
dotnet/src/BullMQ/RedisBackend.cs:871
Method
GetClientListAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:564
Method
GetCompletedAsync
<summary>Returns completed jobs.</summary>
dotnet/src/BullMQ/Queue.cs:225
Method
GetConnAsync
()
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:290
Method
GetCountsAsync
<summary>Returns the counts for the given job types, in order.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:197
Method
GetCountsAsync
(params string[] types)
dotnet/src/BullMQ/PostgresBackend.cs:487
Method
GetCountsPerPriorityAsync
<summary>Returns the number of jobs per priority, in order.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:200
Method
GetCountsPerPriorityAsync
(IReadOnlyList<long> priorities)
dotnet/src/BullMQ/RedisBackend.cs:826
Method
GetCountsPerPriorityAsync
(IReadOnlyList<long> priorities)
dotnet/src/BullMQ/PostgresBackend.cs:514
Method
GetCountsPerPriority_ReturnsJobCountsPerPriority
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:253
Method
GetFailedAsync
<summary>Returns failed jobs.</summary>
dotnet/src/BullMQ/Queue.cs:229
Method
GetInt
(string key, int fallback = 0)
dotnet/src/BullMQ/JobJson.cs:49
Method
GetJobCounts_ReflectsWaitingAndDelayed
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:20
Method
GetJobDataAsync
<summary>Returns the stored data for a job, or null if missing.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:188
Method
GetJobDataAsync
(string jobId)
dotnet/src/BullMQ/PostgresBackend.cs:455
Method
GetJobData_RoundTripsNameAndData
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:70
Method
GetJobLogsAsync
<summary>Returns a page of a job's logs together with the total count.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:191
Method
GetJobLogsAsync
(string jobId, int start = 0, int end = -1, bool asc = true)
dotnet/src/BullMQ/RedisBackend.cs:792
Method
GetJobLogsAsync
(string jobId, int start = 0, int end = -1, bool asc = true)
dotnet/src/BullMQ/PostgresBackend.cs:462
Method
GetJobSchedulerAsync
<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
Method
GetJobSchedulerAsync
(string id)
dotnet/src/BullMQ/RedisBackend.cs:997
Method
GetJobSchedulerAsync
(string id)
dotnet/src/BullMQ/PostgresBackend.cs:662
Method
GetJobSchedulerDataAsync
<summary>Returns the raw stored fields (name -> value) of a scheduler.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:275
Method
GetJobSchedulerDataAsync
(string key)
dotnet/src/BullMQ/PostgresBackend.cs:688
Method
GetJobSchedulersAsync
<summary>Returns a page of registered schedulers.</summary>
dotnet/src/BullMQ/JobScheduler.cs:148
Method
GetJobSchedulersAsync
<summary>Returns a page of registered job schedulers.</summary>
dotnet/src/BullMQ/Queue.cs:169
Method
GetJobSchedulersCountAsync
<summary>Returns the number of registered schedulers.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:284
Method
GetJobSchedulersCountAsync
()
dotnet/src/BullMQ/RedisBackend.cs:1039
Method
GetJobSchedulersCountAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:711
Method
GetJobSchedulersRangeAsync
<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
Method
GetJobSchedulersRangeAsync
(int start, int end, bool asc)
dotnet/src/BullMQ/PostgresBackend.cs:695
Method
GetJobsAsync
<summary>Returns the jobs in the given states (each id resolved to a full job).</summary>
dotnet/src/BullMQ/Queue.cs:191
Method
GetKeepJobs
(object? shouldRemove)
dotnet/src/BullMQ/RedisBackend.cs:1214
Method
GetLong
(string key, long fallback = 0)
dotnet/src/BullMQ/JobJson.cs:46
Method
GetProcessedChildrenValuesAsync
<summary>Returns the raw processed-children map (child key -> serialized value).</summary>
dotnet/src/BullMQ/IQueueBackend.cs:207
Method
GetProcessedChildrenValuesAsync
(string jobId)
dotnet/src/BullMQ/PostgresBackend.cs:541
Method
GetQueueMetaFieldAsync
<summary>Reads a single queue metadata field.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:223
Method
GetQueueMetaFieldAsync
(string field)
dotnet/src/BullMQ/PostgresBackend.cs:582
Method
GetRangesAsync
<summary>Returns a page of job ids for the given states/types.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:203
Method
GetRangesAsync
( IReadOnlyList<string> types, int start = 0, int end = 1, bool asc = false)
dotnet/src/BullMQ/PostgresBackend.cs:522
Method
GetRateLimitTtlAsync
<summary>Returns the ttl (ms) of the current rate-limit window.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:194
Method
GetRateLimitTtlAsync
()
dotnet/src/BullMQ/RedisBackend.cs:811
Method
GetRateLimitTtlAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:481
Method
GetRateLimitTtlAsync
<summary>Returns the ttl (ms) of the current rate-limit window.</summary>
dotnet/src/BullMQ/Queue.cs:310
Method
GetStateAsync
<summary>Returns the current state of a job.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:182
Method
GetStateAsync
(string jobId)
dotnet/src/BullMQ/RedisBackend.cs:763
Method
GetStateAsync
(string jobId)
dotnet/src/BullMQ/PostgresBackend.cs:430
Method
GetVersion_ReturnsBullmqVersion
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:138
Method
GetWaiting_ReturnsAddedJobs
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:214
Method
HasQueueMetaFieldAsync
<summary>Returns whether a queue metadata field exists.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:226
Method
HasQueueMetaFieldAsync
(string field)
dotnet/src/BullMQ/PostgresBackend.cs:588
Method
HasWaitingJobAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:819
Method
HonoursCustomPrefix
()
dotnet/tests/BullMQ.Tests/QueueKeysTests.cs:32
Method
InitBackendAsync
()
dotnet/src/BullMQ/QueueEvents.cs:115
Method
InitBackendAsync
()
dotnet/src/BullMQ/Worker.cs:102
Method
InitBackendAsync
()
dotnet/src/BullMQ/Queue.cs:27
Method
IsActiveAsync
<summary>Returns whether this job is active.</summary>
dotnet/src/BullMQ/Job.cs:236
Method
IsCompletedAsync
<summary>Returns whether this job has completed.</summary>
dotnet/src/BullMQ/Job.cs:227
Method
IsDelayedAsync
<summary>Returns whether this job is delayed.</summary>
dotnet/src/BullMQ/Job.cs:233
Method
IsFailedAsync
<summary>Returns whether this job has failed.</summary>
dotnet/src/BullMQ/Job.cs:230
Method
IsJobInStateAsync
<summary>Returns whether a job id is present in the given state.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:185
Method
IsJobInStateAsync
(string state, string jobId)
dotnet/src/BullMQ/RedisBackend.cs:772
Method
IsJobInStateAsync
(string state, string jobId)
dotnet/src/BullMQ/PostgresBackend.cs:448
Method
IsJobSchedulerAsync
<summary>Returns whether an id corresponds to a registered scheduler.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:272
Method
IsJobSchedulerAsync
(string id)
dotnet/src/BullMQ/RedisBackend.cs:1013
Method
IsJobSchedulerAsync
(string id)
dotnet/src/BullMQ/PostgresBackend.cs:682
Method
IsPausedAsync
<summary>Returns whether the queue is currently paused.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:210
← previous
next →
1,401–1,500 of 3,768, ranked by callers