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
Pause_And_Resume_TogglesPausedFlag
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:133
Method
Pause_And_Resume_TogglesPausedFlag
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:119
Method
Pause_SetsQueueToPaused
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:233
Method
PgResult
(IReadOnlyList<string> columns, IReadOnlyList<object?[]> rows)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:13
Method
PostgresBackend
( string name, PostgresConnection connection, bool ownsConnection, int lockDur
dotnet/src/BullMQ/PostgresBackend.cs:37
Method
PostgresConnection
(PostgresOptions options)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:82
Method
PrioritizedJob_HasPrioritizedState
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:189
Method
ProcessJob
(IQueueBackend backend, Job job, string token)
dotnet/src/BullMQ/Worker.cs:273
Method
PromoteAsync
<summary>Promotes a single delayed job so it can be processed as soon as possible.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:120
Method
PromoteAsync
(string jobId)
dotnet/src/BullMQ/RedisBackend.cs:600
Method
PromoteAsync
(string jobId)
dotnet/src/BullMQ/PostgresBackend.cs:304
Method
PromoteJobsAsync
<summary>Promotes up to <paramref name="count"/> delayed jobs back to wait.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:133
Method
PromoteJobsAsync
(int count)
dotnet/src/BullMQ/RedisBackend.cs:632
Method
PromoteJobsAsync
(int count)
dotnet/src/BullMQ/PostgresBackend.cs:331
Method
PromoteJobs_MovesDelayedToWaiting
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:116
Method
PublishEventAsync
<summary> Appends a custom event to the queue's event stream and returns its id. <paramref name="fields"/> is a flattened <c>[field, value, ...]</c> l
dotnet/src/BullMQ/IQueueBackend.cs:306
Method
PublishEventAsync
(IReadOnlyList<string> fields, int maxEvents)
dotnet/src/BullMQ/RedisBackend.cs:1086
Method
PublishEventAsync
(IReadOnlyList<string> fields, int maxEvents)
dotnet/src/BullMQ/PostgresBackend.cs:836
Method
Put
(string key, string column)
dotnet/src/BullMQ/PostgresBackend.cs:722
Method
QueueEvents
(string name, QueueEventsOptions opts)
dotnet/src/BullMQ/QueueEvents.cs:97
Method
QueueKeys
(string prefix = "bull")
dotnet/src/BullMQ/QueueKeys.cs:15
Method
QueueMeta_SetAndGet
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:305
Method
QuoteSchemaName
(string schema)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:586
Method
ReadEventsAsync
<summary> Reads events newer than <paramref name="id"/> (or <c>"$"</c> for "from now on"), blocking up to <paramref name="blockTimeoutSeconds"/> for t
dotnet/src/BullMQ/IQueueBackend.cs:314
Method
ReadEventsAsync
(string id, double blockTimeoutSeconds)
dotnet/src/BullMQ/PostgresBackend.cs:863
Method
ReadResource
(Assembly assembly, string resourceName)
dotnet/src/BullMQ/Redis/LuaScripts.cs:83
Method
ReadResource
(Assembly assembly, string resourceName)
dotnet/src/BullMQ/Postgres/SqlLoader.cs:74
Method
RedisBackend
( string name, RedisConnection connection, string prefix, bool ownsConnection,
dotnet/src/BullMQ/RedisBackend.cs:41
Method
RedisConnection
(IConnectionMultiplexer multiplexer, bool ownsConnection, int database)
dotnet/src/BullMQ/Redis/RedisConnection.cs:22
Method
RemoveAsync
<summary>Removes a job and (optionally) its children. Returns 1 if removed, 0 otherwise.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:148
Method
RemoveAsync
(string jobId, bool removeChildren)
dotnet/src/BullMQ/RedisBackend.cs:683
Method
RemoveAsync
(string jobId, bool removeChildren)
dotnet/src/BullMQ/PostgresBackend.cs:367
Method
RemoveAsync
<summary>Removes the given job (and optionally its children).</summary>
dotnet/src/BullMQ/Queue.cs:278
Method
RemoveDeprecatedPriorityKeyAsync
<summary>Removes the deprecated priority helper key.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:232
Method
RemoveDeprecatedPriorityKeyAsync
()
dotnet/src/BullMQ/RedisBackend.cs:909
Method
RemoveDeprecatedPriorityKeyAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:596
Method
RemoveJobSchedulerAsync
<summary>Removes a scheduler. Returns true when it existed.</summary>
dotnet/src/BullMQ/JobScheduler.cs:126
Method
RemoveJobSchedulerAsync
<summary>Removes a scheduler. Returns 0 if it was removed, 1 if it did not exist.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:263
Method
RemoveJobSchedulerAsync
(string schedulerId)
dotnet/src/BullMQ/RedisBackend.cs:988
Method
RemoveJobSchedulerAsync
(string schedulerId)
dotnet/src/BullMQ/PostgresBackend.cs:656
Method
Remove_DeletesJob
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:151
Method
Remove_DeletesJobFromQueue
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:98
Method
RenewalLoopAsync
(CancellationToken token)
dotnet/src/BullMQ/LockManager.cs:101
Method
ReprocessJobAsync
<summary>Reprocesses a finished (failed/completed) job, moving it back to wait.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:117
Method
ReprocessJobAsync
( Job job, string state, bool resetAttemptsMade = false, bool resetAttemptsStarted = false)
dotnet/src/BullMQ/PostgresBackend.cs:295
Method
ResetEventsChannelAsync
()
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:505
Method
ResetJobChannelAsync
()
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:428
Method
ResolveTimeZone
(string? tz)
dotnet/src/BullMQ/RepeatStrategy.cs:59
Method
RetryAsync
<summary>Reprocesses a finished job (moving it back to wait).</summary>
dotnet/src/BullMQ/Job.cs:181
Method
RetryJobAsync
<summary>Retries a failed/active job immediately by pushing it back to wait.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:114
Method
RetryJobAsync
(string jobId, bool lifo, string token = "0")
dotnet/src/BullMQ/RedisBackend.cs:548
Method
RetryJobAsync
(string jobId, bool lifo, string token = "0")
dotnet/src/BullMQ/PostgresBackend.cs:287
Method
RetryJobsAsync
<summary>Moves up to <paramref name="count"/> finished jobs of the given state back to wait.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:130
Method
RetryJobsAsync
(string state, int count, long timestamp)
dotnet/src/BullMQ/RedisBackend.cs:629
Method
RetryJobsAsync
(string state, int count, long timestamp)
dotnet/src/BullMQ/PostgresBackend.cs:322
Method
RetryJobs_MovesFailedBackToWaiting
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:156
Method
RowToJobMap
(IReadOnlyDictionary<string, object?> row)
dotnet/src/BullMQ/PostgresBackend.cs:1010
Method
RunAsync
<summary> Starts consuming events (only needed when <see cref="QueueEventsOptions.Autorun"/> is disabled). Returns a task that completes when the list
dotnet/src/BullMQ/QueueEvents.cs:133
Method
RunAsync
( string command, IReadOnlyList<object?> parameters, string? op = null, string
dotnet/src/BullMQ/PostgresBackend.cs:938
Method
RunAsync
<summary>Executes a parameterized command (native <c>$1..$N</c> placeholders).</summary>
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:228
Method
RunInternalAsync
()
dotnet/src/BullMQ/Worker.cs:134
Method
RunJobAsync
(IQueueBackend backend, Job job, string token)
dotnet/src/BullMQ/Worker.cs:231
Method
RunMigrationsAsync
(NpgsqlConnection conn)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:157
Method
SafeDelayAsync
(int ms)
dotnet/src/BullMQ/Worker.cs:390
Method
ScheduleNextIterationAsync
<summary> When a fetched job was produced by a scheduler, enqueue the scheduler's next iteration (matching the reference worker's reschedule-on-fetch)
dotnet/src/BullMQ/Worker.cs:247
Method
SetNameAsync
<summary>Sets a human-readable name on the underlying connection.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:34
Method
SetNameAsync
(string name)
dotnet/src/BullMQ/RedisBackend.cs:117
Method
SetNameAsync
(string name)
dotnet/src/BullMQ/PostgresBackend.cs:75
Method
SetQueueMetaAsync
<summary>Sets one or more queue metadata fields.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:220
Method
SetQueueMetaAsync
(IReadOnlyDictionary<string, object> values)
dotnet/src/BullMQ/PostgresBackend.cs:575
Method
StalledCheckerLoopAsync
(IQueueBackend backend)
dotnet/src/BullMQ/Worker.cs:357
Method
Start
<summary>Starts the background renewal loop. Idempotent.</summary>
dotnet/src/BullMQ/LockManager.cs:45
Method
Str
(object? value)
dotnet/src/BullMQ/PostgresBackend.cs:1051
Method
ThrowIfNegative
(RedisResult result, string? jobId, string command, string? state)
dotnet/src/BullMQ/RedisBackend.cs:1177
Method
ToBool
(object? value)
dotnet/src/BullMQ/PostgresBackend.cs:1074
Method
ToInt
(object? value)
dotnet/src/BullMQ/PostgresBackend.cs:1061
Method
ToJson
<summary>Serializes the storage options map to compact JSON.</summary>
dotnet/src/BullMQ/OptsCodec.cs:111
Method
ToKey
<summary>Builds a namespaced sub-key/identifier of the given type.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:59
Method
ToKey
(string type)
dotnet/src/BullMQ/RedisBackend.cs:140
Method
ToKey
(string type)
dotnet/src/BullMQ/PostgresBackend.cs:91
Method
ToLong
(RedisResult result)
dotnet/src/BullMQ/RedisBackend.cs:1291
Method
ToMap
(object?[] row)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:26
Method
ToObjectMap
(IReadOnlyDictionary<string, object?> map)
dotnet/src/BullMQ/RedisBackend.cs:1174
Method
ToStringList
(RedisResult result)
dotnet/src/BullMQ/RedisBackend.cs:1189
Method
ToWireString
(this JobState state)
dotnet/src/BullMQ/JobState.cs:22
Method
TrackJob
<summary>Registers a job for lock renewal.</summary>
dotnet/src/BullMQ/LockManager.cs:57
Method
Transform
(string key, IReadOnlyDictionary<string, string> fields, long? next)
dotnet/src/BullMQ/JobScheduler.cs:246
Method
TrimEventsAsync
<summary>Trims the event stream to an approximate maximum length.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:229
Method
TrimEventsAsync
(long maxLength)
dotnet/src/BullMQ/RedisBackend.cs:905
Method
TrimEventsAsync
(long maxLength)
dotnet/src/BullMQ/PostgresBackend.cs:594
Method
UniqueName
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:19
Method
UniqueName
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:20
Method
UniqueName
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:19
Method
UniqueName
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:18
Method
UniqueName
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:18
Method
UnrecoverableException
(string message)
dotnet/src/BullMQ/Errors.cs:20
Method
UntrackJob
<summary>Stops renewing the lock for the given job.</summary>
dotnet/src/BullMQ/LockManager.cs:68
Method
UpdateDataAsync
<summary>Replaces a job's data payload.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:166
Method
UpdateDataAsync
(string jobId, object? data)
dotnet/src/BullMQ/RedisBackend.cs:722
Method
UpdateDataAsync
(string jobId, object? data)
dotnet/src/BullMQ/PostgresBackend.cs:396
← previous
next →
1,601–1,700 of 3,768, ranked by callers