MCPcopy Create free account

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

MethodIsPausedAsync
()
dotnet/src/BullMQ/RedisBackend.cs:868
MethodIsPausedAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:558
MethodIsWaitingAsync
<summary>Returns whether this job is waiting (or prioritized).</summary>
dotnet/src/BullMQ/Job.cs:239
MethodIsWaitingChildrenAsync
<summary>Returns whether this job is waiting for its children.</summary>
dotnet/src/BullMQ/Job.cs:246
MethodJob
* Helper to easily extend Job class calls.
src/classes/queue-base.ts:110
MethodJob
* Helper to easily extend Job class calls.
src/classes/flow-producer.ts:180
MethodJob
(IQueueBackend backend, string queueName, string name, object? data, JobsOptions opts)
dotnet/src/BullMQ/Job.cs:77
MethodJobLog_And_GetJobLogs_RoundTrip
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:235
MethodJobScheduler
(IQueueBackend backend, string queueName)
dotnet/src/BullMQ/JobScheduler.cs:19
MethodJobScheduler_ProducesRepeatingJobs
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:343
MethodJob_Remove_DeletesJob
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:277
MethodJob_UpdateProgress_Persists
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:257
MethodJson
(IReadOnlyDictionary<string, object?> map)
dotnet/src/BullMQ/PostgresBackend.cs:997
MethodKeepJobsToMap
(KeepJobs keep)
dotnet/src/BullMQ/RedisBackend.cs:1224
MethodKeepToMap
(KeepJobs keep)
dotnet/src/BullMQ/OptsCodec.cs:94
MethodLoad
(string marker)
dotnet/src/BullMQ/Postgres/SqlLoader.cs:54
MethodLoadAll
()
dotnet/src/BullMQ/Redis/LuaScripts.cs:39
MethodLockManager
( IQueueBackend backend, int lockRenewTime, int lockDuration, Action<Exception
dotnet/src/BullMQ/LockManager.cs:28
MethodMainLoopAsync
<summary> The main fetch loop. A semaphore bounds in-flight processing to <see cref="WorkerOptions.Concurrency"/>: each free slot triggers a fetch, jo
dotnet/src/BullMQ/Worker.cs:159
MethodMap
(params string[] names)
dotnet/src/BullMQ/RedisBackend.cs:286
MethodMapKeys
(params string[] names)
dotnet/src/BullMQ/RedisBackend.cs:1161
MethodMapSchedulerRow
( IReadOnlyDictionary<string, object?> row)
dotnet/src/BullMQ/PostgresBackend.cs:717
MethodMergeOpts
(JobsOptions? opts)
dotnet/src/BullMQ/Queue.cs:349
MethodMoveJobsToWaitAsync
(string state, int count, long timestamp)
dotnet/src/BullMQ/RedisBackend.cs:635
MethodMoveStalledJobsToWaitAsync
<summary>Recovers stalled jobs (active jobs whose lock expired) back to wait.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:123
MethodMoveStalledJobsToWaitAsync
(int maxStalledCount, int stalledInterval)
dotnet/src/BullMQ/PostgresBackend.cs:310
MethodMoveToActiveAsync
<summary>Moves the next eligible job to active, returning its data (or delay signals).</summary>
dotnet/src/BullMQ/IQueueBackend.cs:86
MethodMoveToActiveAsync
(string token, string? name = null)
dotnet/src/BullMQ/PostgresBackend.cs:206
MethodMoveToActive_ThenCompleted_TransitionsState
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:89
MethodMoveToActive_ThenFailed_TransitionsState
()
dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:113
MethodMoveToCompletedAsync
<summary>Moves an active job to completed and optionally fetches the next job.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:89
MethodMoveToCompletedAsync
( Job job, string returnValueJson, object? removeOnComplete, string token, bool fetchNext)
dotnet/src/BullMQ/RedisBackend.cs:380
MethodMoveToCompletedAsync
( Job job, string returnValueJson, object? removeOnComplete, string token, bool fetchNext)
dotnet/src/BullMQ/PostgresBackend.cs:217
MethodMoveToDelayedAsync
<summary> Moves a job to the delayed state, scheduling it after <paramref name="delay"/> ms. Set <paramref name="skipAttempt"/> to true for manual-del
dotnet/src/BullMQ/IQueueBackend.cs:102
MethodMoveToDelayedAsync
( string jobId, long timestamp, long delay, string token = "0", bool f
dotnet/src/BullMQ/RedisBackend.cs:450
MethodMoveToDelayedAsync
( string jobId, long timestamp, long delay, string token = "0", bool f
dotnet/src/BullMQ/PostgresBackend.cs:257
MethodMoveToFailedAsync
<summary>Moves an active job to failed and optionally fetches the next job.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:93
MethodMoveToFailedAsync
( Job job, string failedReason, object? removeOnFail, string token, bool fetchNext, string? st
dotnet/src/BullMQ/RedisBackend.cs:384
MethodMoveToFailedAsync
( Job job, string failedReason, object? removeOnFail, string token, bool fetchNext, string? st
dotnet/src/BullMQ/PostgresBackend.cs:221
MethodMoveToFinishedAsync
( Job job, string value, string propVal, object? shouldRemove, string target, string token, bo
dotnet/src/BullMQ/RedisBackend.cs:389
MethodMoveToFinishedAsync
( Job job, string target, string value, string? stackTraceJson, object? shouldRemove, string token, bo
dotnet/src/BullMQ/PostgresBackend.cs:226
MethodMoveToWaitingChildrenAsync
<summary>Moves a parent job to the waiting-children state. Returns true if moved.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:111
MethodMoveToWaitingChildrenAsync
(string jobId, string token, string? childKey = null)
dotnet/src/BullMQ/RedisBackend.cs:510
MethodMoveToWaitingChildrenAsync
(string jobId, string token, string? childKey = null)
dotnet/src/BullMQ/PostgresBackend.cs:280
MethodMoveToWaitingChildrenAsync
<summary>Moves this (parent) job to the waiting-children state.</summary>
dotnet/src/BullMQ/Job.cs:187
MethodNewQueueEventsOptions
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:18
MethodNewQueueEventsOptions
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:93
MethodNewQueueEventsOptions
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:110
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:14
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:87
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:104
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:15
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:533
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:547
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:14
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:269
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:283
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:14
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:300
MethodNewQueueOptions
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:314
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:16
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:90
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:107
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:17
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:536
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:550
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:16
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:272
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:286
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:16
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:303
MethodNewWorkerOptions
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:317
MethodNextDelayMsAsync
()
dotnet/src/BullMQ/PostgresBackend.cs:825
MethodNextJobResultAsync
(PgResult result, int? limiterMax, long now)
dotnet/src/BullMQ/PostgresBackend.cs:957
FunctionNoopProc
(job: Job)
tests/job_scheduler.test.ts:29
FunctionNoopProc
()
tests/stalled_jobs.test.ts:18
FunctionNoopProc
()
tests/worker.redis.test.ts:41
FunctionNoopProc
()
tests/child-pool.test.ts:5
FunctionNoopProc
()
tests/worker.test.ts:35
MethodNormalizeKeep
(object? removeOn)
dotnet/src/BullMQ/PostgresBackend.cs:1000
MethodNormalizeRemove
(object value)
dotnet/src/BullMQ/OptsCodec.cs:88
MethodNowMs
()
dotnet/src/BullMQ/JobScheduler.cs:312
MethodNowMs
()
dotnet/src/BullMQ/RedisBackend.cs:1172
MethodNowMs
()
dotnet/src/BullMQ/PostgresBackend.cs:1049
MethodNowMs
()
dotnet/src/BullMQ/LockManager.cs:188
MethodObliterateAsync
<summary>Irreversibly destroys the queue and its contents; returns a cursor (0 = done).</summary>
dotnet/src/BullMQ/IQueueBackend.cs:145
MethodObliterateAsync
(bool force, int count)
dotnet/src/BullMQ/RedisBackend.cs:667
MethodObliterateAsync
(bool force, int count)
dotnet/src/BullMQ/PostgresBackend.cs:350
MethodObliterate_EmptiesTheQueue
()
dotnet/tests/BullMQ.Tests/QueueTests.cs:219
MethodOpenWithRetryAsync
<summary> Opens a fresh physical connection, retrying a few times on transient failures. Some servers (notably Postgres.app on macOS) intermittently r
dotnet/src/BullMQ/Postgres/PostgresConnection.cs:311
MethodOptsJson
(JobsOptions opts)
dotnet/src/BullMQ/PostgresBackend.cs:994
MethodParentParts
(object? parent)
dotnet/src/BullMQ/PostgresBackend.cs:983
MethodParseAddJobResult
(RedisResult result, Job job)
dotnet/src/BullMQ/RedisBackend.cs:205
MethodParseCron
(string pattern)
dotnet/src/BullMQ/RepeatStrategy.cs:52
MethodParseNextJobData
(RedisResult result)
dotnet/src/BullMQ/RedisBackend.cs:1240
MethodParseOpts
(string optsJson)
dotnet/src/BullMQ/Job.cs:309
MethodParseRepeat
(string optsJson)
dotnet/src/BullMQ/Job.cs:369
MethodPauseAsync
<summary>Pauses or resumes the whole queue.</summary>
dotnet/src/BullMQ/IQueueBackend.cs:136
MethodPauseAsync
(bool pause)
dotnet/src/BullMQ/RedisBackend.cs:643
MethodPauseAsync
(bool pause)
dotnet/src/BullMQ/PostgresBackend.cs:337
← previousnext →1,501–1,600 of 3,768, ranked by callers