Functions — github.com/taskforcesh/bullmq

CodeHub MCPcopy Create free account

hub / github.com/taskforcesh/bullmq / functions

Functions3,768 in github.com/taskforcesh/bullmq

⨍ Functions 3,768◇ Types & classes 487↳ Endpoints 8

MethodUpdateJobSchedulerNextMillisAsync

<summary> Advances an existing scheduler to its next iteration (no template change). Returns the new delayed job id, or null when none was produced. <

dotnet/src/BullMQ/IQueueBackend.cs:255

MethodUpdateJobSchedulerNextMillisAsync

( string schedulerId, long nextMillis, string templateData, IReadOnlyDictionar

dotnet/src/BullMQ/PostgresBackend.cs:633

MethodUpdateProgressAsync

<summary>Updates a job's progress and emits the corresponding event.</summary>

dotnet/src/BullMQ/IQueueBackend.cs:169

MethodUpdateProgressAsync

(string jobId, object? progress)

dotnet/src/BullMQ/RedisBackend.cs:730

MethodUpdateProgressAsync

(string jobId, object? progress)

dotnet/src/BullMQ/PostgresBackend.cs:405

MethodUpdateProgress_And_UpdateData_Persist

dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:245

MethodUpsertJobSchedulerAsync

<summary> Creates or updates a job scheduler and enqueues its next iteration. Returns the <see cref="Job"/> for that iteration, or null when none was

dotnet/src/BullMQ/JobScheduler.cs:30

MethodUpsertJobScheduler_CreatesScheduler

dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:314

MethodWaitCoreAsync

(NpgsqlConnection listenConn, TimeSpan timeout, bool isEvents, CancellationToken cancellationToken = default)

dotnet/src/BullMQ/Postgres/PostgresConnection.cs:400

MethodWaitForAsync

(Task<T> task, TimeSpan timeout)

dotnet/tests/BullMQ.Tests/QueueEventsTests.cs:69

MethodWaitForAsync

(Task<T> task, TimeSpan timeout)

dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:179

MethodWaitForAsync

(Task<T> task, TimeSpan timeout)

dotnet/tests/BullMQ.Tests/FlowProducerTests.cs:251

MethodWaitForAsync

(Task<T> task, TimeSpan timeout)

dotnet/tests/BullMQ.Tests/QueueTests.cs:282

MethodWaitForJobAsync

<summary> Blocks (up to <paramref name="blockTimeoutSeconds"/>) until the queue signals that a job may be available, returning the marker entry or nul

dotnet/src/BullMQ/IQueueBackend.cs:294

MethodWaitForJobAsync

(double blockTimeoutSeconds, CancellationToken cancellationToken = default)

dotnet/src/BullMQ/RedisBackend.cs:1046

MethodWaitForJobAsync

(double blockTimeoutSeconds, CancellationToken cancellationToken = default)

dotnet/src/BullMQ/PostgresBackend.cs:751

MethodWaitForJob_ReturnsMarker_WhenJobWaiting

dotnet/tests/BullMQ.Tests/BackendConformanceTests.cs:289

MethodWaitUntilReadyAsync

<summary>Resolves once the backend's connection(s) are ready.</summary>

dotnet/src/BullMQ/IQueueBackend.cs:22

MethodWaitUntilReadyAsync

dotnet/src/BullMQ/RedisBackend.cs:81

MethodWaitUntilReadyAsync

dotnet/src/BullMQ/PostgresBackend.cs:63

MethodWaitUntilReadyAsync

<summary>Pings the server to confirm the connection is ready.</summary>

dotnet/src/BullMQ/Redis/RedisConnection.cs:64

MethodWaitUntilReadyAsync

dotnet/src/BullMQ/Postgres/PostgresConnection.cs:99

(string name, Processor processor, WorkerOptions opts)

dotnet/src/BullMQ/Worker.cs:75

MethodWorker_FailingProcessor_MarksJobFailed

dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:89

MethodWorker_ForceClose_DoesNotFailActiveJob

dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:389

MethodWorker_InvalidConcurrency_Throws

dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:379

MethodWorker_ManualMoveToDelayed_ThrowDelayedException_DoesNotFailJob

dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:435

MethodWorker_ManualMoveToDelayed_WithoutToken_UsesJobToken

dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:484

MethodWorker_ProcessesJob_AndMarksCompleted

dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:60

MethodWorker_ProcessesMultipleJobs

dotnet/tests/BullMQ.Tests/QueueWorkerTests.cs:140

MethodWriteArray

(List<byte> buffer, System.Collections.IEnumerable seq)

dotnet/src/BullMQ/Serialization/MsgPack.cs:190

MethodWriteArrayHeader

(List<byte> buffer, int count)

dotnet/src/BullMQ/Serialization/MsgPack.cs:205

MethodWriteBigEndian

(List<byte> buffer, short value)

dotnet/src/BullMQ/Serialization/MsgPack.cs:248

MethodWriteBinary

(List<byte> buffer, byte[] value)

dotnet/src/BullMQ/Serialization/MsgPack.cs:168

MethodWriteDouble

(List<byte> buffer, double value)

dotnet/src/BullMQ/Serialization/MsgPack.cs:129

(List<byte> buffer, long value)

dotnet/src/BullMQ/Serialization/MsgPack.cs:67

(List<byte> buffer, System.Collections.IDictionary map)

dotnet/src/BullMQ/Serialization/MsgPack.cs:223

MethodWriteString

(List<byte> buffer, string value)

dotnet/src/BullMQ/Serialization/MsgPack.cs:140

MethodWriteUInt

(List<byte> buffer, ulong value)

dotnet/src/BullMQ/Serialization/MsgPack.cs:101

MethodWriteValue

(List<byte> buffer, object? value)

dotnet/src/BullMQ/Serialization/MsgPack.cs:27

Method__aenter__

python/tests/flow_producer_test.py:55

Method__aenter__

python/tests/postgres_backend_test.py:110

Method__aenter__

python/tests/postgres_backend_test.py:136

Method__aexit__

(self, exc_type, exc, tb)

python/tests/flow_producer_test.py:58

Method__aexit__

(self, exc_type, exc, tb)

python/tests/postgres_backend_test.py:113

Method__aexit__

(self, exc_type, exc, tb)

python/tests/postgres_backend_test.py:139

Method__aiter__

python/tests/postgres_backend_test.py:304

Method__anext__

python/tests/postgres_backend_test.py:307

Method__construct

* Create a new Queue instance. * * @param string $name The name of the queue * @param array{ * prefix?: string, * connect

php/src/Queue.php:64

Method__construct

(string $prefix = 'bull')

php/src/QueueKeys.php:14

Method__construct

* Create a new Job instance. * * @param Queue $queue The queue this job belongs to * @param string $name The name of the job * @pa

php/src/Job.php:115

Method__construct

* Create a new Redis connection. * * @param array<string, mixed>|PredisClient|string $options Connection options, Predis client, or Redis UR

php/src/RedisConnection.php:25

Method__construct

(string $prefix, string $queueName, RedisConnection $redisConnection)

php/src/Scripts.php:41

Method__destruct

* Destructor - clean up resources. */

php/src/Queue.php:617

Function__getattr__

python/bullmq/backends/__init__.py:35

python/bullmq/event_emitter.py:7

( self, name: str, opts: Optional[QueueEventsProducerOptions] = None, )

python/bullmq/queue_events_producer.py:29

(self, prefix: str, queueName: str, redisConnection: RedisConnection)

python/bullmq/scripts.py:28

( self, redisOpts: Union[dict, str, redis.Redis] = {}, skipVersionCheck: bool = False,

python/bullmq/redis_connection.py:77

( self, name: str, opts: Optional[QueueEventsOptions] = None, )

python/bullmq/queue_events.py:55

(self, queue: "Queue", repeat_strategy=None)

python/bullmq/job_scheduler.py:122

(self, queue: Queue, name: str, data: Any, opts: JobOptions = {}, job_id: str = None)

python/bullmq/job.py:35

Initialize a connection

python/bullmq/flow_producer.py:55

(self, interval: float, callback: Callable[..., Awaitable[Any]], emit_callback: Callable[[str, Any], None], *a

python/bullmq/timer.py:8

(self, reason: Optional[str] = None)

python/bullmq/abort_controller.py:44

python/bullmq/abort_controller.py:55

python/bullmq/abort_controller.py:83

@param worker: The Worker that owns this manager. Used to access `backend.extendLocks` and to emit events. @pa

python/bullmq/lock_manager.py:33

(self, prefix: str = 'bull')

python/bullmq/queue_keys.py:6

(self, name: str, processor: Callable[..., asyncio.Future], opts: WorkerOptions = {})

python/bullmq/worker.py:85

Initialize a connection

python/bullmq/queue.py:16

( self, name: str, connection: RedisConnection, blocking_connection: Optional[

python/bullmq/backends/redis_backend.py:60

(self, columns: list[str], rows: list[tuple], rowcount: int)

python/bullmq/backends/postgres_connection.py:78

(self, opts: dict = {})

python/bullmq/backends/postgres_connection.py:156

( self, name: str, connection: PostgresConnection, owns_connection: bool = Tru

python/bullmq/backends/postgres_backend.py:214

python/tests/flow_producer_test.py:10

(self, results)

python/tests/flow_producer_test.py:52

(self, current_version)

python/tests/postgres_backend_test.py:106

python/tests/postgres_backend_test.py:124

python/tests/postgres_backend_test.py:133

python/tests/postgres_backend_test.py:299

python/tests/postgres_backend_test.py:316

python/tests/postgres_backend_test.py:329

Function__toESM

(mod, isNodeMode, target)

tests/fixtures/fixture_processor_esbuild.js:30

python/tests/postgres_backend_test.py:320

Function_pg_backend

python/tests/conftest.py:87

Function_pg_create_backend

(name, opts=None, blocking=False, with_blocking_connection=False)

python/tests/conftest.py:66

python/bullmq/abort_controller.py:60

Functionaccepts_prequalified_parent_queue_keys_for_current_prefix

rust/src/keys.rs:293

Methodacquire_concurrency_slot

Wait until a concurrency slot is available. Returns false if closing.

rust/src/worker.rs:1015

rust/src/keys.rs:92

tests/telemetry_interface.test.ts:136

* Adds a new job to the queue. * * @param string $name The name of the job * @param mixed $data The data payload for the job * @pa

php/src/Queue.php:118

* Adds a new job to the queue. * * @param name - Name of the job to be added to the queue. * @param data - Arbitrary data to append to the jo

src/classes/queue.ts:314

* Adds a flow. * * This call would be atomic, either it fails and no jobs will * be added to the queues, or it succeeds and all jobs will be

src/classes/flow-producer.ts:211

(value: number, attributes?: Attributes)

tests/telemetry_interface.test.ts:51

* Adds an array of jobs to the queue. This method may be faster than adding * one job at a time in a sequence. * * @param jobs - The array of

src/classes/queue.ts:390

* Adds multiple flows. * * A flow is a tree-like structure of jobs that depend on each other. * Whenever the children of a given parent are c

src/classes/flow-producer.ts:310

(name: string, attributes?: Attributes)

tests/telemetry_interface.test.ts:182

Atomically insert a flow (tree) of jobs that may span multiple queues. ``entries`` is a flat, topologically ordered list of ``{"job":

python/bullmq/backend.py:130

← previous next →1,701–1,800 of 3,768, ranked by callers