MCPcopy Create free account

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

MethodPause_And_Resume_TogglesPausedFlag
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:133
MethodPause_And_Resume_TogglesPausedFlag
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:119
MethodPause_SetsQueueToPaused
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:233
MethodPgResult
(IReadOnlyList<string> columns, IReadOnlyList<object?[]> rows)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:13
MethodPostgresBackend
( string name, PostgresConnection connection, bool ownsConnection, int lockDur
dotnet/src/BullMQ/PostgresBackend.cs:37
MethodPostgresConnection
(PostgresOptions options)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:82
MethodPrioritizedJob_HasPrioritizedState
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:189
MethodProcessJob
(IQueueBackend backend, Job job, string token)
dotnet/src/BullMQ/Worker.cs:273
MethodPromoteAsync
<summary>Promotes a single delayed job so it can be processed as soon as possible.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:120
MethodPromoteAsync
(string jobId)
dotnet/src/BullMQ/RedisBackend.cs:600
MethodPromoteAsync
(string jobId)
dotnet/src/BullMQ/PostgresBackend.cs:304
MethodPromoteJobsAsync
<summary>Promotes up to <paramref name="count"/> delayed jobs back to wait.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:133
MethodPromoteJobsAsync
(int count)
dotnet/src/BullMQ/RedisBackend.cs:632
MethodPromoteJobsAsync
(int count)
dotnet/src/BullMQ/PostgresBackend.cs:331
MethodPromoteJobs_MovesDelayedToWaiting
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:116
MethodPublishEventAsync
<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
MethodPublishEventAsync
(IReadOnlyList<string> fields, int maxEvents)
dotnet/src/BullMQ/RedisBackend.cs:1086
MethodPublishEventAsync
(IReadOnlyList<string> fields, int maxEvents)
dotnet/src/BullMQ/PostgresBackend.cs:836
MethodPut
(string key, string column)
dotnet/src/BullMQ/PostgresBackend.cs:722
MethodQueueEvents
(string name, QueueEventsOptions opts)
dotnet/src/BullMQ/QueueEvents.cs:97
MethodQueueKeys
(string prefix = "bull")
dotnet/src/BullMQ/QueueKeys.cs:15
MethodQueueMeta_SetAndGet
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:305
MethodQuoteSchemaName
(string schema)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:586
MethodReadEventsAsync
<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
MethodReadEventsAsync
(string id, double blockTimeoutSeconds)
dotnet/src/BullMQ/PostgresBackend.cs:863
MethodReadResource
(Assembly assembly, string resourceName)
dotnet/src/BullMQ/Redis/LuaScripts.cs:83
MethodReadResource
(Assembly assembly, string resourceName)
dotnet/src/BullMQ/Postgres/SqlLoader.cs:74
MethodRedisBackend
( string name, RedisConnection connection, string prefix, bool ownsConnection,
dotnet/src/BullMQ/RedisBackend.cs:41
MethodRedisConnection
(IConnectionMultiplexer multiplexer, bool ownsConnection, int database)
dotnet/src/BullMQ/Redis/RedisConnection.cs:22
MethodRemoveAsync
<summary>Removes a job and (optionally) its children. Returns 1 if removed, 0 otherwise.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:148
MethodRemoveAsync
(string jobId, bool removeChildren)
dotnet/src/BullMQ/RedisBackend.cs:683
MethodRemoveAsync
(string jobId, bool removeChildren)
dotnet/src/BullMQ/PostgresBackend.cs:367
MethodRemoveAsync
<summary>Removes the given job (and optionally its children).</summary>
dotnet/src/BullMQ/Queue.cs:278
MethodRemoveDeprecatedPriorityKeyAsync
<summary>Removes the deprecated priority helper key.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:232
MethodRemoveDeprecatedPriorityKeyAsync
()
dotnet/src/BullMQ/RedisBackend.cs:909
MethodRemoveDeprecatedPriorityKeyAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:596
MethodRemoveJobSchedulerAsync
<summary>Removes a scheduler. Returns true when it existed.</summary>
dotnet/src/BullMQ/JobScheduler.cs:126
MethodRemoveJobSchedulerAsync
<summary>Removes a scheduler. Returns 0 if it was removed, 1 if it did not exist.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:263
MethodRemoveJobSchedulerAsync
(string schedulerId)
dotnet/src/BullMQ/RedisBackend.cs:988
MethodRemoveJobSchedulerAsync
(string schedulerId)
dotnet/src/BullMQ/PostgresBackend.cs:656
MethodRemove_DeletesJob
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:151
MethodRemove_DeletesJobFromQueue
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:98
MethodRenewalLoopAsync
(CancellationToken token)
dotnet/src/BullMQ/LockManager.cs:101
MethodReprocessJobAsync
<summary>Reprocesses a finished (failed/completed) job, moving it back to wait.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:117
MethodReprocessJobAsync
( Job job, string state, bool resetAttemptsMade = false, bool resetAttemptsStarted = false)
dotnet/src/BullMQ/PostgresBackend.cs:295
MethodResetEventsChannelAsync
()
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:505
MethodResetJobChannelAsync
()
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:428
MethodResolveTimeZone
(string? tz)
dotnet/src/BullMQ/RepeatStrategy.cs:59
MethodRetryAsync
<summary>Reprocesses a finished job (moving it back to wait).</summary>
dotnet/src/BullMQ/Job.cs:181
MethodRetryJobAsync
<summary>Retries a failed/active job immediately by pushing it back to wait.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:114
MethodRetryJobAsync
(string jobId, bool lifo, string token = "0")
dotnet/src/BullMQ/RedisBackend.cs:548
MethodRetryJobAsync
(string jobId, bool lifo, string token = "0")
dotnet/src/BullMQ/PostgresBackend.cs:287
MethodRetryJobsAsync
<summary>Moves up to <paramref name="count"/> finished jobs of the given state back to wait.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:130
MethodRetryJobsAsync
(string state, int count, long timestamp)
dotnet/src/BullMQ/RedisBackend.cs:629
MethodRetryJobsAsync
(string state, int count, long timestamp)
dotnet/src/BullMQ/PostgresBackend.cs:322
MethodRetryJobs_MovesFailedBackToWaiting
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:156
MethodRowToJobMap
(IReadOnlyDictionary<string, object?> row)
dotnet/src/BullMQ/PostgresBackend.cs:1010
MethodRunAsync
<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
MethodRunAsync
( string command, IReadOnlyList<object?> parameters, string? op = null, string
dotnet/src/BullMQ/PostgresBackend.cs:938
MethodRunAsync
<summary>Executes a parameterized command (native <c>$1..$N</c> placeholders).</summary>
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:228
MethodRunInternalAsync
()
dotnet/src/BullMQ/Worker.cs:134
MethodRunJobAsync
(IQueueBackend backend, Job job, string token)
dotnet/src/BullMQ/Worker.cs:231
MethodRunMigrationsAsync
(NpgsqlConnection conn)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:157
MethodSafeDelayAsync
(int ms)
dotnet/src/BullMQ/Worker.cs:390
MethodScheduleNextIterationAsync
<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
MethodSetNameAsync
<summary>Sets a human-readable name on the underlying connection.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:34
MethodSetNameAsync
(string name)
dotnet/src/BullMQ/RedisBackend.cs:117
MethodSetNameAsync
(string name)
dotnet/src/BullMQ/PostgresBackend.cs:75
MethodSetQueueMetaAsync
<summary>Sets one or more queue metadata fields.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:220
MethodSetQueueMetaAsync
(IReadOnlyDictionary<string, object> values)
dotnet/src/BullMQ/PostgresBackend.cs:575
MethodStalledCheckerLoopAsync
(IQueueBackend backend)
dotnet/src/BullMQ/Worker.cs:357
MethodStart
<summary>Starts the background renewal loop. Idempotent.</summary>
dotnet/src/BullMQ/LockManager.cs:45
MethodStr
(object? value)
dotnet/src/BullMQ/PostgresBackend.cs:1051
MethodThrowIfNegative
(RedisResult result, string? jobId, string command, string? state)
dotnet/src/BullMQ/RedisBackend.cs:1177
MethodToBool
(object? value)
dotnet/src/BullMQ/PostgresBackend.cs:1074
MethodToInt
(object? value)
dotnet/src/BullMQ/PostgresBackend.cs:1061
MethodToJson
<summary>Serializes the storage options map to compact JSON.</summary>
dotnet/src/BullMQ/OptsCodec.cs:111
MethodToKey
<summary>Builds a namespaced sub-key/identifier of the given type.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:59
MethodToKey
(string type)
dotnet/src/BullMQ/RedisBackend.cs:140
MethodToKey
(string type)
dotnet/src/BullMQ/PostgresBackend.cs:91
MethodToLong
(RedisResult result)
dotnet/src/BullMQ/RedisBackend.cs:1291
MethodToMap
(object?[] row)
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:26
MethodToObjectMap
(IReadOnlyDictionary<string, object?> map)
dotnet/src/BullMQ/RedisBackend.cs:1174
MethodToStringList
(RedisResult result)
dotnet/src/BullMQ/RedisBackend.cs:1189
MethodToWireString
(this JobState state)
dotnet/src/BullMQ/JobState.cs:22
MethodTrackJob
<summary>Registers a job for lock renewal.</summary>
dotnet/src/BullMQ/LockManager.cs:57
MethodTransform
(string key, IReadOnlyDictionary<string, string> fields, long? next)
dotnet/src/BullMQ/JobScheduler.cs:246
MethodTrimEventsAsync
<summary>Trims the event stream to an approximate maximum length.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:229
MethodTrimEventsAsync
(long maxLength)
dotnet/src/BullMQ/RedisBackend.cs:905
MethodTrimEventsAsync
(long maxLength)
dotnet/src/BullMQ/PostgresBackend.cs:594
MethodUniqueName
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:19
MethodUniqueName
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:20
MethodUniqueName
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:19
MethodUniqueName
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:18
MethodUniqueName
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:18
MethodUnrecoverableException
(string message)
dotnet/src/BullMQ/Errors.cs:20
MethodUntrackJob
<summary>Stops renewing the lock for the given job.</summary>
dotnet/src/BullMQ/LockManager.cs:68
MethodUpdateDataAsync
<summary>Replaces a job's data payload.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:166
MethodUpdateDataAsync
(string jobId, object? data)
dotnet/src/BullMQ/RedisBackend.cs:722
MethodUpdateDataAsync
(string jobId, object? data)
dotnet/src/BullMQ/PostgresBackend.cs:396
← previousnext →1,601–1,700 of 3,768, ranked by callers