From e65bbc17f2a3e8c233bf0e3bd86ef42a8097bbde Mon Sep 17 00:00:00 2001 From: roggervalf Date: Thu, 20 Jul 2023 16:24:22 +0000 Subject: [PATCH] deploy: dd40cf1eaf13767ddcd5e68c4f33d974b65e6f18 --- classes/v1.Backoffs.html | 6 +- classes/v1.ChildPool.html | 6 +- classes/v1.ChildProcessor.html | 6 +- classes/v1.FlowProducer.html | 6 +- classes/v1.Job.html | 6 +- classes/v1.Queue.html | 6 +- classes/v1.Queue3.html | 6 +- classes/v1.QueueBase.html | 6 +- classes/v1.QueueEvents.html | 6 +- classes/v1.QueueGetters.html | 6 +- classes/v1.QueueKeys.html | 6 +- classes/v1.QueueScheduler.html | 6 +- classes/v1.RedisConnection.html | 6 +- classes/v1.Repeat.html | 6 +- classes/v1.ScriptLoader.html | 6 +- classes/v1.ScriptLoaderError.html | 6 +- classes/v1.Scripts.html | 6 +- classes/v1.TimerManager.html | 6 +- classes/v1.UnrecoverableError.html | 6 +- classes/v1.Worker.html | 6 +- classes/v2.Backoffs.html | 6 +- classes/v2.ChildPool.html | 6 +- classes/v2.ChildProcessor.html | 6 +- classes/v2.FlowProducer.html | 6 +- classes/v2.Job.html | 6 +- classes/v2.Queue.html | 6 +- classes/v2.QueueBase.html | 6 +- classes/v2.QueueEvents.html | 6 +- classes/v2.QueueGetters.html | 6 +- classes/v2.QueueKeys.html | 6 +- classes/v2.RedisConnection.html | 6 +- classes/v2.Repeat.html | 6 +- classes/v2.ScriptLoader.html | 6 +- classes/v2.ScriptLoaderError.html | 6 +- classes/v2.Scripts.html | 6 +- classes/v2.TimerManager.html | 6 +- classes/v2.UnrecoverableError.html | 6 +- classes/v2.Worker.html | 6 +- classes/v3.AsyncFifoQueue.html | 6 +- classes/v3.Backoffs.html | 6 +- classes/v3.ChildPool.html | 6 +- classes/v3.ChildProcessor.html | 6 +- classes/v3.DelayedError.html | 6 +- classes/v3.FlowProducer.html | 6 +- classes/v3.Job.html | 6 +- classes/v3.Queue.html | 6 +- classes/v3.QueueBase.html | 6 +- classes/v3.QueueEvents.html | 6 +- classes/v3.QueueGetters.html | 6 +- classes/v3.QueueKeys.html | 6 +- classes/v3.RedisConnection.html | 6 +- classes/v3.Repeat.html | 6 +- classes/v3.ScriptLoader.html | 6 +- classes/v3.ScriptLoaderError.html | 6 +- classes/v3.Scripts.html | 6 +- classes/v3.UnrecoverableError.html | 6 +- classes/v3.WaitingChildrenError.html | 6 +- classes/v3.Worker.html | 6 +- classes/v4.AsyncFifoQueue.html | 22 ++-- classes/v4.Backoffs.html | 14 +- classes/v4.ChildPool.html | 28 ++-- classes/v4.ChildProcessor.html | 24 ++-- classes/v4.DelayedError.html | 10 +- classes/v4.FlowProducer.html | 40 +++--- classes/v4.Job.html | 118 ++++++++--------- classes/v4.Queue.html | 128 +++++++++---------- classes/v4.QueueBase.html | 32 ++--- classes/v4.QueueEvents.html | 40 +++--- classes/v4.QueueGetters.html | 82 ++++++------ classes/v4.QueueKeys.html | 18 +-- classes/v4.RedisConnection.html | 28 ++-- classes/v4.Repeat.html | 42 +++--- classes/v4.ScriptLoader.html | 26 ++-- classes/v4.ScriptLoaderError.html | 16 +-- classes/v4.Scripts.html | 80 ++++++------ classes/v4.UnrecoverableError.html | 10 +- classes/v4.WaitingChildrenError.html | 10 +- classes/v4.Worker.html | 66 +++++----- enums/v1.ChildCommand.html | 6 +- enums/v1.ClientType.html | 6 +- enums/v1.ErrorCode.html | 6 +- enums/v1.MetricsTime.html | 6 +- enums/v1.ParentCommand.html | 6 +- enums/v2.ChildCommand.html | 6 +- enums/v2.ClientType.html | 6 +- enums/v2.ErrorCode.html | 6 +- enums/v2.MetricsTime.html | 6 +- enums/v2.ParentCommand.html | 6 +- enums/v3.ChildCommand.html | 6 +- enums/v3.ClientType.html | 6 +- enums/v3.ErrorCode.html | 6 +- enums/v3.MetricsTime.html | 6 +- enums/v3.ParentCommand.html | 6 +- enums/v4.ChildCommand.html | 14 +- enums/v4.ClientType.html | 12 +- enums/v4.ErrorCode.html | 20 +-- enums/v4.MetricsTime.html | 24 ++-- enums/v4.ParentCommand.html | 24 ++-- functions/v1.array2obj.html | 6 +- functions/v1.asyncSend.html | 6 +- functions/v1.childSend.html | 6 +- functions/v1.delay.html | 6 +- functions/v1.getNextMillis.html | 6 +- functions/v1.getParentKey.html | 6 +- functions/v1.isEmpty.html | 6 +- functions/v1.isNotConnectionError.html | 6 +- functions/v1.isRedisCluster.html | 6 +- functions/v1.isRedisInstance.html | 6 +- functions/v1.isRedisVersionLowerThan.html | 6 +- functions/v1.jobIdForGroup.html | 6 +- functions/v1.killAsync.html | 6 +- functions/v1.lengthInUtf8Bytes.html | 6 +- functions/v1.parentSend.html | 6 +- functions/v1.raw2jobData.html | 6 +- functions/v1.removeAllQueueData.html | 6 +- functions/v1.tryCatch.html | 6 +- functions/v2.array2obj.html | 6 +- functions/v2.asyncSend.html | 6 +- functions/v2.childSend.html | 6 +- functions/v2.delay.html | 6 +- functions/v2.getNextMillis.html | 6 +- functions/v2.getParentKey.html | 6 +- functions/v2.isEmpty.html | 6 +- functions/v2.isNotConnectionError.html | 6 +- functions/v2.isRedisCluster.html | 6 +- functions/v2.isRedisInstance.html | 6 +- functions/v2.isRedisVersionLowerThan.html | 6 +- functions/v2.jobIdForGroup.html | 6 +- functions/v2.killAsync.html | 6 +- functions/v2.lengthInUtf8Bytes.html | 6 +- functions/v2.parentSend.html | 6 +- functions/v2.raw2jobData.html | 6 +- functions/v2.removeAllQueueData.html | 6 +- functions/v2.tryCatch.html | 6 +- functions/v3.array2obj.html | 6 +- functions/v3.asyncSend.html | 6 +- functions/v3.childSend.html | 6 +- functions/v3.delay.html | 6 +- functions/v3.errorToJSON.html | 6 +- functions/v3.getNextMillis.html | 6 +- functions/v3.getParentKey.html | 6 +- functions/v3.isEmpty.html | 6 +- functions/v3.isNotConnectionError.html | 6 +- functions/v3.isRedisCluster.html | 6 +- functions/v3.isRedisInstance.html | 6 +- functions/v3.isRedisVersionLowerThan.html | 6 +- functions/v3.lengthInUtf8Bytes.html | 6 +- functions/v3.parseObjectValues.html | 6 +- functions/v3.raw2NextJobData.html | 6 +- functions/v3.removeAllQueueData.html | 6 +- functions/v3.tryCatch.html | 6 +- functions/v4.array2obj.html | 8 +- functions/v4.asyncSend.html | 8 +- functions/v4.childSend.html | 8 +- functions/v4.delay.html | 8 +- functions/v4.errorToJSON.html | 8 +- functions/v4.getNextMillis.html | 8 +- functions/v4.getParentKey.html | 8 +- functions/v4.isEmpty.html | 8 +- functions/v4.isNotConnectionError.html | 8 +- functions/v4.isRedisCluster.html | 8 +- functions/v4.isRedisInstance.html | 8 +- functions/v4.isRedisVersionLowerThan.html | 8 +- functions/v4.lengthInUtf8Bytes.html | 8 +- functions/v4.parseObjectValues.html | 8 +- functions/v4.raw2NextJobData.html | 8 +- functions/v4.removeAllQueueData.html | 8 +- functions/v4.tryCatch.html | 8 +- index.html | 8 +- interfaces/v1.AddChildrenOpts.html | 6 +- interfaces/v1.AddNodeOpts.html | 6 +- interfaces/v1.AdvancedOptions.html | 6 +- interfaces/v1.AdvancedRepeatOptions.html | 6 +- interfaces/v1.BackoffOptions.html | 6 +- interfaces/v1.BaseJobOptions.html | 6 +- interfaces/v1.ChildMessage.html | 6 +- interfaces/v1.ChildProcessExt.html | 6 +- interfaces/v1.Command.html | 6 +- interfaces/v1.DependenciesOpts.html | 6 +- interfaces/v1.FlowJob.html | 6 +- interfaces/v1.FlowOpts.html | 6 +- interfaces/v1.FlowProducerListener.html | 6 +- interfaces/v1.GetNextJobOptions.html | 6 +- interfaces/v1.IConnection.html | 6 +- interfaces/v1.IoredisListener.html | 6 +- interfaces/v1.JobInformation3.html | 6 +- interfaces/v1.JobJson.html | 6 +- interfaces/v1.JobJsonRaw.html | 6 +- interfaces/v1.JobNode.html | 6 +- interfaces/v1.JobPromise3.html | 6 +- interfaces/v1.JobsOptions.html | 6 +- interfaces/v1.KeepJobs.html | 6 +- interfaces/v1.Metrics.html | 6 +- interfaces/v1.MetricsOptions.html | 6 +- interfaces/v1.MoveToWaitingChildrenOpts.html | 6 +- interfaces/v1.NodeOpts.html | 6 +- interfaces/v1.ObliterateOpts.html | 6 +- interfaces/v1.Parent.html | 6 +- interfaces/v1.ParentKeys.html | 6 +- interfaces/v1.ParentMessage.html | 6 +- interfaces/v1.QueueBaseOptions.html | 6 +- interfaces/v1.QueueEventsListener.html | 6 +- interfaces/v1.QueueEventsOptions.html | 6 +- interfaces/v1.QueueListener.html | 6 +- interfaces/v1.QueueOptions.html | 6 +- interfaces/v1.QueueSchedulerListener.html | 6 +- interfaces/v1.QueueSchedulerOptions.html | 6 +- interfaces/v1.RateLimiterOptions.html | 6 +- interfaces/v1.RepeatBaseOptions.html | 6 +- interfaces/v1.RepeatOptions.html | 6 +- interfaces/v1.SandboxedJob.html | 6 +- interfaces/v1.ScriptMetadata.html | 6 +- interfaces/v1.Strategies.html | 6 +- interfaces/v1.WorkerListener.html | 6 +- interfaces/v1.WorkerOptions.html | 6 +- interfaces/v2.AddChildrenOpts.html | 6 +- interfaces/v2.AddNodeOpts.html | 6 +- interfaces/v2.AdvancedOptions.html | 6 +- interfaces/v2.AdvancedRepeatOptions.html | 6 +- interfaces/v2.BackoffOptions.html | 6 +- interfaces/v2.BaseJobOptions.html | 6 +- interfaces/v2.ChildMessage.html | 6 +- interfaces/v2.ChildProcessExt.html | 6 +- interfaces/v2.Command.html | 6 +- interfaces/v2.DefaultJobOptions.html | 6 +- interfaces/v2.DependenciesOpts.html | 6 +- interfaces/v2.FlowOpts.html | 6 +- interfaces/v2.FlowProducerListener.html | 6 +- interfaces/v2.GetNextJobOptions.html | 6 +- interfaces/v2.IConnection.html | 6 +- interfaces/v2.IoredisListener.html | 6 +- interfaces/v2.JobJson.html | 6 +- interfaces/v2.JobJsonRaw.html | 6 +- interfaces/v2.JobNode.html | 6 +- interfaces/v2.KeepJobs.html | 6 +- interfaces/v2.Metrics.html | 6 +- interfaces/v2.MetricsOptions.html | 6 +- interfaces/v2.MoveToWaitingChildrenOpts.html | 6 +- interfaces/v2.NodeOpts.html | 6 +- interfaces/v2.ObliterateOpts.html | 6 +- interfaces/v2.Parent.html | 6 +- interfaces/v2.ParentKeys.html | 6 +- interfaces/v2.ParentMessage.html | 6 +- interfaces/v2.QueueBaseOptions.html | 6 +- interfaces/v2.QueueEventsListener.html | 6 +- interfaces/v2.QueueEventsOptions.html | 6 +- interfaces/v2.QueueListener.html | 6 +- interfaces/v2.QueueOptions.html | 6 +- interfaces/v2.RateLimiterOptions.html | 6 +- interfaces/v2.RawCommand.html | 6 +- interfaces/v2.RepeatBaseOptions.html | 6 +- interfaces/v2.RepeatOptions.html | 6 +- interfaces/v2.SandboxedJob.html | 6 +- interfaces/v2.ScriptMetadata.html | 6 +- interfaces/v2.Strategies.html | 6 +- interfaces/v2.WorkerListener.html | 6 +- interfaces/v2.WorkerOptions.html | 6 +- interfaces/v3.AddChildrenOpts.html | 6 +- interfaces/v3.AddNodeOpts.html | 6 +- interfaces/v3.AdvancedOptions.html | 6 +- interfaces/v3.AdvancedRepeatOptions.html | 6 +- interfaces/v3.BackoffOptions.html | 6 +- interfaces/v3.BaseJobOptions.html | 6 +- interfaces/v3.BaseOptions.html | 6 +- interfaces/v3.BuiltInStrategies.html | 6 +- interfaces/v3.ChildMessage.html | 6 +- interfaces/v3.Command.html | 6 +- interfaces/v3.DefaultJobOptions.html | 6 +- interfaces/v3.DependenciesOpts.html | 6 +- interfaces/v3.FlowJobBase.html | 6 +- interfaces/v3.FlowOpts.html | 6 +- interfaces/v3.FlowProducerListener.html | 6 +- interfaces/v3.GetNextJobOptions.html | 6 +- interfaces/v3.IConnection.html | 6 +- interfaces/v3.IoredisListener.html | 6 +- interfaces/v3.JobJson.html | 6 +- interfaces/v3.JobJsonRaw.html | 6 +- interfaces/v3.JobNode.html | 6 +- interfaces/v3.KeepJobs.html | 6 +- interfaces/v3.Metrics.html | 6 +- interfaces/v3.MetricsOptions.html | 6 +- interfaces/v3.MinimalJob.html | 6 +- interfaces/v3.MoveToWaitingChildrenOpts.html | 6 +- interfaces/v3.NodeOpts.html | 6 +- interfaces/v3.ObliterateOpts.html | 6 +- interfaces/v3.Parent.html | 6 +- interfaces/v3.ParentKeys.html | 6 +- interfaces/v3.ParentMessage.html | 6 +- interfaces/v3.QueueBaseOptions.html | 6 +- interfaces/v3.QueueEventsListener.html | 6 +- interfaces/v3.QueueEventsOptions.html | 6 +- interfaces/v3.QueueListener.html | 6 +- interfaces/v3.QueueOptions.html | 6 +- interfaces/v3.RateLimiterOptions.html | 6 +- interfaces/v3.RawCommand.html | 6 +- interfaces/v3.RepeatBaseOptions.html | 6 +- interfaces/v3.RepeatOptions.html | 6 +- interfaces/v3.SandboxedJob.html | 6 +- interfaces/v3.ScriptMetadata.html | 6 +- interfaces/v3.WorkerListener.html | 6 +- interfaces/v3.WorkerOptions.html | 6 +- interfaces/v4.AddChildrenOpts.html | 16 +-- interfaces/v4.AddNodeOpts.html | 16 +-- interfaces/v4.AdvancedOptions.html | 14 +- interfaces/v4.AdvancedRepeatOptions.html | 12 +- interfaces/v4.BackoffOptions.html | 12 +- interfaces/v4.BaseJobOptions.html | 40 +++--- interfaces/v4.BaseOptions.html | 10 +- interfaces/v4.BuiltInStrategies.html | 8 +- interfaces/v4.ChildMessage.html | 14 +- interfaces/v4.Command.html | 12 +- interfaces/v4.DefaultJobOptions.html | 30 ++--- interfaces/v4.DependenciesOpts.html | 12 +- interfaces/v4.FlowJobBase.html | 20 +-- interfaces/v4.FlowOpts.html | 10 +- interfaces/v4.FlowProducerListener.html | 12 +- interfaces/v4.GetNextJobOptions.html | 10 +- interfaces/v4.IConnection.html | 12 +- interfaces/v4.IoredisListener.html | 10 +- interfaces/v4.JobJson.html | 38 +++--- interfaces/v4.JobJsonRaw.html | 40 +++--- interfaces/v4.JobNode.html | 12 +- interfaces/v4.KeepJobs.html | 12 +- interfaces/v4.Metrics.html | 14 +- interfaces/v4.MetricsOptions.html | 10 +- interfaces/v4.MinimalJob.html | 56 ++++---- interfaces/v4.MoveToWaitingChildrenOpts.html | 10 +- interfaces/v4.NodeOpts.html | 18 +-- interfaces/v4.ObliterateOpts.html | 12 +- interfaces/v4.Parent.html | 18 +-- interfaces/v4.ParentKeys.html | 12 +- interfaces/v4.ParentMessage.html | 16 +-- interfaces/v4.QueueBaseOptions.html | 16 +-- interfaces/v4.QueueEventsListener.html | 44 +++---- interfaces/v4.QueueEventsOptions.html | 22 ++-- interfaces/v4.QueueListener.html | 24 ++-- interfaces/v4.QueueOptions.html | 22 ++-- interfaces/v4.RateLimiterOptions.html | 12 +- interfaces/v4.RawCommand.html | 14 +- interfaces/v4.RepeatBaseOptions.html | 18 +-- interfaces/v4.RepeatOptions.html | 24 ++-- interfaces/v4.SandboxedJob.html | 44 +++---- interfaces/v4.ScriptMetadata.html | 20 +-- interfaces/v4.WorkerListener.html | 34 ++--- interfaces/v4.WorkerOptions.html | 48 +++---- modules/v1.html | 6 +- modules/v2.html | 6 +- modules/v3.html | 6 +- modules/v4.html | 6 +- types/v1.ActiveEventCallback3.html | 6 +- types/v1.BackoffFunction.html | 6 +- types/v1.BulkJobOptions.html | 6 +- types/v1.CleanedEventCallback3.html | 6 +- types/v1.ClusterOptions.html | 6 +- types/v1.CompletedEventCallback3.html | 6 +- types/v1.ConnectionOptions.html | 6 +- types/v1.EntryId.html | 6 +- types/v1.EntryRaw.html | 6 +- types/v1.ErrorEventCallback3.html | 6 +- types/v1.EventCallback3.html | 6 +- types/v1.FailedEventCallback3.html | 6 +- types/v1.FinishedPropValAttribute.html | 6 +- types/v1.FinishedStatus.html | 6 +- types/v1.FlowQueuesOpts.html | 6 +- types/v1.JobData.html | 6 +- types/v1.JobJsonSandbox.html | 6 +- types/v1.JobState.html | 6 +- types/v1.JobStatusClean3.html | 6 +- types/v1.JobType.html | 6 +- types/v1.KeysMap.html | 6 +- types/v1.MinimalQueue.html | 6 +- types/v1.ParentOpts.html | 6 +- types/v1.Processor.html | 6 +- types/v1.ProgressEventCallback3.html | 6 +- types/v1.RedisClient.html | 6 +- types/v1.RedisOptions.html | 6 +- types/v1.RemovedEventCallback3.html | 6 +- types/v1.RepeatStrategy.html | 6 +- types/v1.SandboxedJobProcessor.html | 6 +- types/v1.StalledEventCallback3.html | 6 +- types/v1.StreamName.html | 6 +- types/v1.StreamReadRaw.html | 6 +- types/v1.WaitingEventCallback3.html | 6 +- types/v2.BackoffFunction.html | 6 +- types/v2.BulkJobOptions.html | 6 +- types/v2.ClusterOptions.html | 6 +- types/v2.ConnectionOptions.html | 6 +- types/v2.EntryId.html | 6 +- types/v2.EntryRaw.html | 6 +- types/v2.FinishedPropValAttribute.html | 6 +- types/v2.FinishedStatus.html | 6 +- types/v2.FlowChildJob.html | 6 +- types/v2.FlowJob.html | 6 +- types/v2.FlowQueuesOpts.html | 6 +- types/v2.JobData.html | 6 +- types/v2.JobJsonSandbox.html | 6 +- types/v2.JobState.html | 6 +- types/v2.JobType.html | 6 +- types/v2.JobsOptions.html | 6 +- types/v2.KeysMap.html | 6 +- types/v2.MinimalQueue.html | 6 +- types/v2.ParentOpts.html | 6 +- types/v2.Processor.html | 6 +- types/v2.RedisClient.html | 6 +- types/v2.RedisJobOptions.html | 6 +- types/v2.RedisOptions.html | 6 +- types/v2.RepeatStrategy.html | 6 +- types/v2.SandboxedJobProcessor.html | 6 +- types/v2.StreamName.html | 6 +- types/v2.StreamReadRaw.html | 6 +- types/v3.BackoffStrategy.html | 6 +- types/v3.BulkJobOptions.html | 6 +- types/v3.ClusterOptions.html | 6 +- types/v3.ConnectionOptions.html | 6 +- types/v3.EntryId.html | 6 +- types/v3.EntryRaw.html | 6 +- types/v3.FinishedPropValAttribute.html | 6 +- types/v3.FinishedStatus.html | 6 +- types/v3.FlowChildJob.html | 6 +- types/v3.FlowJob.html | 6 +- types/v3.FlowQueuesOpts.html | 6 +- types/v3.JobData.html | 6 +- types/v3.JobJsonSandbox.html | 6 +- types/v3.JobState.html | 6 +- types/v3.JobType.html | 6 +- types/v3.JobsOptions.html | 6 +- types/v3.KeysMap.html | 6 +- types/v3.MinimalQueue.html | 6 +- types/v3.ParentOpts.html | 6 +- types/v3.Processor.html | 6 +- types/v3.RedisClient.html | 6 +- types/v3.RedisJobOptions.html | 6 +- types/v3.RedisOptions.html | 6 +- types/v3.RepeatStrategy.html | 6 +- types/v3.SandboxedJobProcessor.html | 6 +- types/v3.StreamName.html | 6 +- types/v3.StreamReadRaw.html | 6 +- types/v4.BackoffStrategy.html | 8 +- types/v4.BulkJobOptions.html | 8 +- types/v4.ClusterOptions.html | 8 +- types/v4.ConnectionOptions.html | 8 +- types/v4.EntryId.html | 8 +- types/v4.EntryRaw.html | 8 +- types/v4.FinishedPropValAttribute.html | 8 +- types/v4.FinishedStatus.html | 8 +- types/v4.FlowChildJob.html | 8 +- types/v4.FlowJob.html | 8 +- types/v4.FlowQueuesOpts.html | 8 +- types/v4.JobData.html | 8 +- types/v4.JobJsonSandbox.html | 8 +- types/v4.JobState.html | 8 +- types/v4.JobType.html | 8 +- types/v4.JobsOptions.html | 8 +- types/v4.KeysMap.html | 8 +- types/v4.MinimalQueue.html | 8 +- types/v4.ParentOpts.html | 8 +- types/v4.Processor.html | 8 +- types/v4.RedisClient.html | 8 +- types/v4.RedisJobOptions.html | 8 +- types/v4.RedisOptions.html | 8 +- types/v4.RepeatStrategy.html | 8 +- types/v4.SandboxedJobProcessor.html | 8 +- types/v4.StreamName.html | 8 +- types/v4.StreamReadRaw.html | 8 +- variables/v1.DELAY_TIME_1.html | 6 +- variables/v1.DELAY_TIME_5.html | 6 +- variables/v1.QUEUE_EVENT_SUFFIX.html | 6 +- variables/v1.QUEUE_SCHEDULER_SUFFIX.html | 6 +- variables/v1.WORKER_SUFFIX.html | 6 +- variables/v1.clientCommandMessageReg.html | 6 +- variables/v1.errorObject.html | 6 +- variables/v1.scriptLoader-1.html | 6 +- variables/v2.DELAY_TIME_1.html | 6 +- variables/v2.DELAY_TIME_5.html | 6 +- variables/v2.QUEUE_EVENT_SUFFIX.html | 6 +- variables/v2.QUEUE_SCHEDULER_SUFFIX.html | 6 +- variables/v2.WORKER_SUFFIX.html | 6 +- variables/v2.clientCommandMessageReg.html | 6 +- variables/v2.errorObject.html | 6 +- variables/v2.scriptLoader-1.html | 6 +- variables/v3.DELAY_TIME_1.html | 6 +- variables/v3.DELAY_TIME_5.html | 6 +- variables/v3.QUEUE_EVENT_SUFFIX.html | 6 +- variables/v3.WORKER_SUFFIX.html | 6 +- variables/v3.clientCommandMessageReg.html | 6 +- variables/v3.errorObject.html | 6 +- variables/v3.scriptLoader-1.html | 6 +- variables/v4.DELAY_TIME_1.html | 8 +- variables/v4.DELAY_TIME_5.html | 8 +- variables/v4.QUEUE_EVENT_SUFFIX.html | 8 +- variables/v4.WORKER_SUFFIX.html | 8 +- variables/v4.clientCommandMessageReg.html | 8 +- variables/v4.errorObject.html | 8 +- variables/v4.scriptLoader-1.html | 8 +- 494 files changed, 2231 insertions(+), 2231 deletions(-) diff --git a/classes/v1.Backoffs.html b/classes/v1.Backoffs.html index 23ec7530cd..8a16a87e03 100644 --- a/classes/v1.Backoffs.html +++ b/classes/v1.Backoffs.html @@ -1,4 +1,4 @@ -Backoffs | bullmq - v4.5.0
+Backoffs | bullmq - v4.6.0
  • Preparing search index...
  • -
  • The search index is not available
bullmq - v4.5.0
+
  • The search index is not available
  • bullmq - v4.6.0
    @@ -112,7 +112,7 @@

    calculate
  • normalize
  • @@ -195,7 +195,7 @@

    remove
  • retain
  • @@ -144,7 +144,7 @@

    stop
  • waitForCurrentJobAndExit
  • @@ -343,7 +343,7 @@

    on
  • once
  • @@ -996,7 +996,7 @@

    fromId
  • fromJSON
  • @@ -1225,7 +1225,7 @@

    trimEvents
  • waitUntilReady
  • @@ -1165,7 +1165,7 @@

    retryJob
  • setWorkerName
  • @@ -251,7 +251,7 @@

    emit
  • waitUntilReady
  • @@ -330,7 +330,7 @@

    run
  • waitUntilReady
  • @@ -751,7 +751,7 @@

    getWorkers
  • waitUntilReady
  • @@ -128,7 +128,7 @@

    getPrefixedQueueName
  • toKey
  • @@ -355,7 +355,7 @@

    run
  • waitUntilReady
  • @@ -161,7 +161,7 @@

    reconnect
  • waitUntilReady
  • @@ -333,7 +333,7 @@

    removeRepeatableByKey
  • waitUntilReady
  • @@ -262,7 +262,7 @@

    parseScript
  • resolvePath
  • @@ -111,7 +111,7 @@

    path
  • position
  • @@ -653,7 +653,7 @@

    updateDelaySet
  • updateProgress
  • @@ -123,7 +123,7 @@

    clearTimer
  • setTimer
  • @@ -73,7 +73,7 @@

    constructor

    @@ -507,7 +507,7 @@

    run
  • waitUntilReady
  • @@ -112,7 +112,7 @@

    calculate
  • normalize
  • @@ -195,7 +195,7 @@

    remove
  • retain
  • @@ -144,7 +144,7 @@

    stop
  • waitForCurrentJobAndExit
  • @@ -343,7 +343,7 @@

    on
  • once
  • @@ -1012,7 +1012,7 @@

    fromId
  • fromJSON
  • @@ -1225,7 +1225,7 @@

    trimEvents
  • waitUntilReady
  • @@ -249,7 +249,7 @@

    emit
  • waitUntilReady
  • @@ -330,7 +330,7 @@

    run
  • waitUntilReady
  • @@ -751,7 +751,7 @@

    getWorkers
  • waitUntilReady
  • @@ -128,7 +128,7 @@

    getPrefixedQueueName
  • toKey
  • @@ -175,7 +175,7 @@

    reconnect
  • waitUntilReady
  • @@ -333,7 +333,7 @@

    removeRepeatableByKey
  • waitUntilReady
  • @@ -262,7 +262,7 @@

    parseScript
  • resolvePath
  • @@ -111,7 +111,7 @@

    path
  • position
  • @@ -634,7 +634,7 @@

    updateData
  • updateProgress
  • @@ -123,7 +123,7 @@

    clearTimer
  • setTimer
  • @@ -73,7 +73,7 @@

    constructor

    @@ -514,7 +514,7 @@

    run
  • waitUntilReady
  • @@ -155,7 +155,7 @@

    numTotal
  • waitAll
  • @@ -112,7 +112,7 @@

    calculate
  • normalize
  • @@ -195,7 +195,7 @@

    remove
  • retain
  • @@ -162,7 +162,7 @@

    stop
  • waitForCurrentJobAndExit
  • @@ -73,7 +73,7 @@

    constructor

    @@ -343,7 +343,7 @@

    on
  • once
  • @@ -1095,7 +1095,7 @@

    fromId
  • fromJSON
  • @@ -1219,7 +1219,7 @@

    trimEvents
  • waitUntilReady
  • @@ -262,7 +262,7 @@

    emit
  • waitUntilReady
  • @@ -330,7 +330,7 @@

    run
  • waitUntilReady
  • @@ -757,7 +757,7 @@

    getWorkers
  • waitUntilReady
  • @@ -128,7 +128,7 @@

    getPrefixedQueueName
  • toKey
  • @@ -175,7 +175,7 @@

    reconnect
  • waitUntilReady
  • @@ -333,7 +333,7 @@

    removeRepeatableByKey
  • waitUntilReady
  • @@ -262,7 +262,7 @@

    parseScript
  • resolvePath
  • @@ -104,7 +104,7 @@

    line
  • position
  • @@ -764,7 +764,7 @@

    updateData
  • updateProgress
  • @@ -73,7 +73,7 @@

    constructor

    @@ -73,7 +73,7 @@

    constructor

    @@ -573,7 +573,7 @@

    waitUntilReady
  • RateLimitError
  • @@ -37,7 +37,7 @@

    Hierarchy

    • AsyncFifoQueue
    +
  • Defined in classes/async-fifo-queue.ts:13
  • @@ -75,7 +75,7 @@

    Parameters

    ignoreErrors: boolean = false

    Returns AsyncFifoQueue<T>

    +
  • Defined in classes/async-fifo-queue.ts:21
  • Methods

    @@ -90,7 +90,7 @@

    Parameters

    promise: Promise<T>

    Returns void

    +
  • Defined in classes/async-fifo-queue.ts:25
  • +
  • Defined in classes/async-fifo-queue.ts:84
  • +
  • Defined in classes/async-fifo-queue.ts:55
  • +
  • Defined in classes/async-fifo-queue.ts:59
  • +
  • Defined in classes/async-fifo-queue.ts:51
  • +
  • Defined in classes/async-fifo-queue.ts:47
  • @@ -21,7 +21,7 @@

    Hierarchy

    • Backoffs
    +
  • Defined in classes/backoffs.ts:8
  • @@ -54,7 +54,7 @@

    Properties

    builtinStrategies: BuiltInStrategies = ...
    +
  • Defined in classes/backoffs.ts:9
  • Methods

    @@ -77,7 +77,7 @@
    job: Optional customStrategy: BackoffStrategy

    Returns number | Promise<number>

    +
  • Defined in classes/backoffs.ts:36
  • Returns BackoffOptions

    +
  • Defined in classes/backoffs.ts:23
  • @@ -21,7 +21,7 @@

    Hierarchy

    • ChildPool
    +
  • Defined in classes/child-pool.ts:11
  • @@ -60,7 +60,7 @@

    Parameters

    __namedParameters: ChildPoolOpts

    Returns ChildPool

    +
  • Defined in classes/child-pool.ts:16
  • Properties

    @@ -72,7 +72,7 @@

    Type declaration

  • [key: string]: Child[]
  • +
  • Defined in classes/child-pool.ts:13
  • retained: {
        [key: number]: Child;
    } = {}
    @@ -82,7 +82,7 @@

    Type declaration

  • [key: number]: Child
  • +
  • Defined in classes/child-pool.ts:12
  • Methods

    @@ -92,7 +92,7 @@
    +
  • Defined in classes/child-pool.ts:72
  • +
  • Defined in classes/child-pool.ts:84
  • Returns Child[]

    +
  • Defined in classes/child-pool.ts:80
  • Returns Promise<void>

    +
  • Defined in classes/child-pool.ts:64
  • Returns void

    +
  • Defined in classes/child-pool.ts:48
  • Returns void

    +
  • Defined in classes/child-pool.ts:53
  • Returns Promise<Child>

    +
  • Defined in classes/child-pool.ts:23
  • @@ -27,7 +27,7 @@

    Hierarchy

    • ChildProcessor
    +
  • Defined in classes/child-processor.ts:19
  • @@ -75,24 +75,24 @@
    msg: Returns Promise<void>

    Returns ChildProcessor

    +
  • Defined in classes/child-processor.ts:24
  • Properties

    currentJobPromise: Promise<unknown>
    +
  • Defined in classes/child-processor.ts:22
  • processor: any
    +
  • Defined in classes/child-processor.ts:21
  • status?: ChildStatus
    +
  • Defined in classes/child-processor.ts:20
  • Methods

    @@ -107,7 +107,7 @@

    Parameters

    processorFile: string

    Returns Promise<void>

    +
  • Defined in classes/child-processor.ts:26
  • Returns Promise<void>

    +
  • Defined in classes/child-processor.ts:66
  • +
  • Defined in classes/child-processor.ts:94
  • +
  • Defined in classes/child-processor.ts:96
  • @@ -29,7 +29,7 @@

    Hierarchy

    • DelayedError
    +
  • Defined in classes/delayed-error.ts:8
  • @@ -54,7 +54,7 @@
    Optional Returns DelayedError
    +
  • Defined in classes/delayed-error.ts:9
  • @@ -32,7 +32,7 @@

    Hierarchy

    • FlowProducer
    +
  • Defined in classes/flow-producer.ts:92
  • @@ -83,29 +83,29 @@
    Connection: Returns FlowProducer
    +
  • Defined in classes/flow-producer.ts:100
  • Properties

    closing: Promise<void>
    +
  • Defined in classes/flow-producer.ts:95
  • keys: KeysMap
    +
  • Defined in classes/flow-producer.ts:94
  • opts: QueueBaseOptions = {}
    +
  • Defined in classes/flow-producer.ts:101
  • queueKeys: QueueKeys
    +
  • Defined in classes/flow-producer.ts:96
  • toKey: ((name, type) => string)
    @@ -125,7 +125,7 @@
    name: type: string

    Returns string

    +
  • Defined in classes/flow-producer.ts:93
  • Accessors

    @@ -135,7 +135,7 @@
    +
  • Defined in classes/flow-producer.ts:210
  • Methods

    @@ -164,7 +164,7 @@
    Optional Returns Promise<JobNode>
    +
  • Defined in classes/flow-producer.ts:159
  • +
  • Defined in classes/flow-producer.ts:235
  • +
  • Defined in classes/flow-producer.ts:445
  • +
  • Defined in classes/flow-producer.ts:452
  • +
  • Defined in classes/flow-producer.ts:118
  • +
  • Defined in classes/flow-producer.ts:192
  • +
  • Defined in classes/flow-producer.ts:125
  • +
  • Defined in classes/flow-producer.ts:133
  • +
  • Defined in classes/flow-producer.ts:141
  • @@ -41,7 +41,7 @@

    Implements

    +
  • Defined in classes/job.ts:58
  • @@ -154,7 +154,7 @@
    opts: Optional id: string

    Returns Job<DataType, ReturnType, NameType>

    +
  • Defined in classes/job.ts:140
  • Properties

    @@ -167,7 +167,7 @@

    Default Value

    0

    +
  • Defined in classes/job.ts:97
  • data: DataType
    @@ -176,7 +176,7 @@
    +
  • Defined in classes/job.ts:150
  • delay: number
    @@ -187,7 +187,7 @@

    Default Value

    0

    +
  • Defined in classes/job.ts:86
  • failedReason: string
    @@ -196,7 +196,7 @@
    +
  • Defined in classes/job.ts:102
  • finishedOn?: number
    @@ -205,13 +205,13 @@
    +
  • Defined in classes/job.ts:107
  • id?: string
    +
  • Defined in classes/job.ts:156
  • name: NameType
    @@ -220,7 +220,7 @@
    +
  • Defined in classes/job.ts:145
  • opts: JobsOptions = {}
    @@ -229,7 +229,7 @@
    +
  • Defined in classes/job.ts:155
  • parent?: ParentKeys
    @@ -238,7 +238,7 @@
    +
  • Defined in classes/job.ts:122
  • parentKey?: string
    @@ -247,7 +247,7 @@
    +
  • Defined in classes/job.ts:117
  • processedOn?: number
    @@ -256,7 +256,7 @@
    +
  • Defined in classes/job.ts:112
  • progress: number | object = 0
    @@ -267,7 +267,7 @@

    Default Value

    0

    +
  • Defined in classes/job.ts:68
  • repeatJobKey?: string
    @@ -276,7 +276,7 @@
    +
  • Defined in classes/job.ts:127
  • returnvalue: ReturnType = null
    @@ -287,7 +287,7 @@

    Default Value

    null

    +
  • Defined in classes/job.ts:74
  • stacktrace: string[] = null
    @@ -298,7 +298,7 @@

    Default Value

    null

    +
  • Defined in classes/job.ts:80
  • timestamp: number
    @@ -307,7 +307,7 @@
    +
  • Defined in classes/job.ts:91
  • token?: string
    @@ -315,7 +315,7 @@
    +
  • Defined in classes/job.ts:132
  • Accessors

    @@ -328,7 +328,7 @@

    Returns string

    +
  • Defined in classes/job.ts:712
  • +
  • Defined in classes/job.ts:705
  • +
  • Defined in classes/job.ts:720
  • Methods

    @@ -372,7 +372,7 @@
    Optional Returns Promise<string>
    +
  • Defined in classes/job.ts:1067
  • +
  • Defined in classes/job.ts:378
  • +
  • Defined in classes/job.ts:420
  • +
  • Defined in classes/job.ts:740
  • +
  • Defined in classes/job.ts:750
  • +
  • Defined in classes/job.ts:481
  • +
  • Defined in classes/job.ts:1045
  • +
  • Defined in classes/job.ts:519
  • +
  • Defined in classes/job.ts:762
  • +
  • Defined in classes/job.ts:779
  • +
  • Defined in classes/job.ts:871
  • +
  • Defined in classes/job.ts:730
  • +
  • Defined in classes/job.ts:691
  • +
  • Defined in classes/job.ts:663
  • +
  • Defined in classes/job.ts:677
  • +
  • Defined in classes/job.ts:670
  • +
  • Defined in classes/job.ts:698
  • +
  • Defined in classes/job.ts:684
  • +
  • Defined in classes/job.ts:454
  • +
  • Defined in classes/job.ts:532
  • +
  • Defined in classes/job.ts:995
  • +
  • Defined in classes/job.ts:570
  • +
  • Defined in classes/job.ts:1006
  • +
  • Defined in classes/job.ts:1016
  • +
  • Defined in classes/job.ts:499
  • +
  • Defined in classes/job.ts:1033
  • +
  • Defined in classes/job.ts:369
  • +
  • Defined in classes/job.ts:433
  • +
  • Defined in classes/job.ts:444
  • +
  • Defined in classes/job.ts:923
  • +
  • Defined in classes/job.ts:195
  • +
  • Defined in classes/job.ts:222
  • +
  • Defined in classes/job.ts:351
  • +
  • Defined in classes/job.ts:269
  • @@ -38,7 +38,7 @@

    Hierarchy

    • Queue
    +
  • Defined in classes/queue.ts:92
  • @@ -144,7 +144,7 @@
    Optional Returns Queue<DataType, ResultType, NameType>
    +
  • Defined in classes/queue.ts:101
  • Properties

    @@ -152,18 +152,18 @@
    +
  • Defined in classes/queue-base.ts:21
  • jobsOpts: BaseJobOptions
    +
  • Defined in classes/queue.ts:98
  • keys: KeysMap
    +
  • Defined in classes/queue-base.ts:20
  • name: string
    @@ -172,7 +172,7 @@
    +
  • Defined in classes/queue-base.ts:34
  • opts: QueueBaseOptions = {}
    @@ -181,7 +181,7 @@
    +
  • Defined in classes/queue-base.ts:35
  • toKey: ((type) => string)
    @@ -200,12 +200,12 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • token: string = ...
    +
  • Defined in classes/queue.ts:97
  • Accessors

    @@ -219,7 +219,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:77
  • +
  • Defined in classes/queue.ts:168
  • +
  • Defined in classes/queue-base.ts:84
  • +
  • Defined in classes/queue.ts:172
  • Methods

    @@ -281,7 +281,7 @@
    Optional Returns Promise<Job<DataType, ResultType, NameType>>
    +
  • Defined in classes/queue.ts:192
  • +
  • Defined in classes/queue.ts:232
  • +
  • Defined in classes/queue.ts:384
  • +
  • Defined in classes/queue.ts:269
  • +
  • Defined in classes/queue-getters.ts:96
  • +
  • Defined in classes/queue-base.ts:144
  • +
  • Defined in classes/queue.ts:370
  • +
  • Defined in classes/queue.ts:134
  • +
  • Defined in classes/queue-getters.ts:229
  • +
  • Defined in classes/queue-getters.ts:175
  • +
  • Defined in classes/queue-getters.ts:265
  • +
  • Defined in classes/queue-getters.ts:154
  • +
  • Defined in classes/queue-getters.ts:241
  • +
  • Defined in classes/queue-getters.ts:168
  • +
  • Defined in classes/queue-getters.ts:277
  • +
  • Defined in classes/queue-getters.ts:161
  • +
  • Defined in classes/queue-getters.ts:26
  • +
  • Defined in classes/queue-getters.ts:116
  • +
  • Defined in classes/queue-getters.ts:126
  • +
  • Defined in classes/queue-getters.ts:354
  • +
  • Defined in classes/queue-getters.ts:147
  • +
  • Defined in classes/queue-getters.ts:327
  • +
  • Defined in classes/queue-getters.ts:442
  • +
  • Defined in classes/queue-getters.ts:253
  • +
  • Defined in classes/queue-getters.ts:182
  • +
  • Defined in classes/queue-getters.ts:420
  • +
  • Defined in classes/queue-getters.ts:284
  • +
  • Defined in classes/queue.ts:305
  • +
  • Defined in classes/queue-getters.ts:205
  • +
  • Defined in classes/queue-getters.ts:217
  • +
  • Defined in classes/queue-getters.ts:196
  • +
  • Defined in classes/queue-getters.ts:189
  • +
  • Defined in classes/queue-getters.ts:406
  • +
  • Defined in classes/queue.ts:291
  • +
  • Defined in classes/queue.ts:417
  • +
  • Defined in classes/queue.ts:141
  • +
  • Defined in classes/queue.ts:149
  • +
  • Defined in classes/queue.ts:157
  • +
  • Defined in classes/queue.ts:260
  • +
  • Defined in classes/queue.ts:461
  • +
  • Defined in classes/queue.ts:359
  • +
  • Defined in classes/queue.ts:481
  • +
  • Defined in classes/queue.ts:322
  • +
  • Defined in classes/queue.ts:343
  • +
  • Defined in classes/queue.ts:283
  • +
  • Defined in classes/queue.ts:440
  • +
  • Defined in classes/queue.ts:473
  • +
  • Defined in classes/queue-base.ts:116
  • @@ -41,7 +41,7 @@

    Implements

    +
  • Defined in classes/queue-base.ts:18
  • @@ -100,7 +100,7 @@
    Connection: Returns QueueBase
    +
  • Defined in classes/queue-base.ts:33
  • Properties

    @@ -108,13 +108,13 @@
    +
  • Defined in classes/queue-base.ts:21
  • keys: KeysMap
    +
  • Defined in classes/queue-base.ts:20
  • name: string
    @@ -123,7 +123,7 @@
    +
  • Defined in classes/queue-base.ts:34
  • opts: QueueBaseOptions = {}
    @@ -132,7 +132,7 @@
    +
  • Defined in classes/queue-base.ts:35
  • toKey: ((type) => string)
    @@ -151,7 +151,7 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • Accessors

    @@ -165,7 +165,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:77
  • +
  • Defined in classes/queue-base.ts:84
  • Methods

    @@ -189,7 +189,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:133
  • +
  • Defined in classes/queue-base.ts:144
  • +
  • Defined in classes/queue-base.ts:102
  • +
  • Defined in classes/queue-base.ts:116
  • @@ -29,7 +29,7 @@

    Hierarchy

    • QueueEvents
    +
  • Defined in classes/queue-events.ts:164
  • @@ -82,7 +82,7 @@
    Optional Returns QueueEvents
    +
  • Defined in classes/queue-events.ts:167
  • Properties

    @@ -90,13 +90,13 @@
    +
  • Defined in classes/queue-base.ts:21
  • keys: KeysMap
    +
  • Defined in classes/queue-base.ts:20
  • name: string
    @@ -105,7 +105,7 @@
    +
  • Defined in classes/queue-base.ts:34
  • opts: QueueBaseOptions = {}
    @@ -114,7 +114,7 @@
    +
  • Defined in classes/queue-base.ts:35
  • toKey: ((type) => string)
    @@ -133,7 +133,7 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • Accessors

    @@ -147,7 +147,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:77
  • +
  • Defined in classes/queue-base.ts:84
  • Methods

    @@ -173,7 +173,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-events.ts:304
  • +
  • Defined in classes/queue-base.ts:144
  • +
  • Defined in classes/queue-events.ts:196
  • +
  • Defined in classes/queue-events.ts:203
  • +
  • Defined in classes/queue-events.ts:211
  • +
  • Defined in classes/queue-events.ts:219
  • +
  • Defined in classes/queue-events.ts:231
  • +
  • Defined in classes/queue-base.ts:116
  • @@ -39,7 +39,7 @@

    Hierarchy

  • Queue
  • Queue
  • +
  • Defined in classes/queue-getters.ts:21
  • @@ -132,7 +132,7 @@
    Connection: Returns QueueGetters<DataType, ResultType, NameType>
    +
  • Defined in classes/queue-base.ts:33
  • Properties

    @@ -140,13 +140,13 @@
    +
  • Defined in classes/queue-base.ts:21
  • keys: KeysMap
    +
  • Defined in classes/queue-base.ts:20
  • name: string
    @@ -155,7 +155,7 @@
    +
  • Defined in classes/queue-base.ts:34
  • opts: QueueBaseOptions = {}
    @@ -164,7 +164,7 @@
    +
  • Defined in classes/queue-base.ts:35
  • toKey: ((type) => string)
    @@ -183,7 +183,7 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • Accessors

    @@ -197,7 +197,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:77
  • +
  • Defined in classes/queue-base.ts:84
  • Methods

    @@ -222,7 +222,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:133
  • +
  • Defined in classes/queue-getters.ts:96
  • +
  • Defined in classes/queue-base.ts:144
  • +
  • Defined in classes/queue-base.ts:102
  • +
  • Defined in classes/queue-getters.ts:229
  • +
  • Defined in classes/queue-getters.ts:175
  • +
  • Defined in classes/queue-getters.ts:265
  • +
  • Defined in classes/queue-getters.ts:154
  • +
  • Defined in classes/queue-getters.ts:241
  • +
  • Defined in classes/queue-getters.ts:168
  • +
  • Defined in classes/queue-getters.ts:277
  • +
  • Defined in classes/queue-getters.ts:161
  • Returns Promise<Job<DataType, ResultType, NameType>>

    +
  • Defined in classes/queue-getters.ts:26
  • +
  • Defined in classes/queue-getters.ts:116
  • +
  • Defined in classes/queue-getters.ts:126
  • +
  • Defined in classes/queue-getters.ts:354
  • +
  • Defined in classes/queue-getters.ts:147
  • +
  • Defined in classes/queue-getters.ts:327
  • +
  • Defined in classes/queue-getters.ts:442
  • +
  • Defined in classes/queue-getters.ts:253
  • +
  • Defined in classes/queue-getters.ts:182
  • +
  • Defined in classes/queue-getters.ts:420
  • Returns Promise<string[]>

    +
  • Defined in classes/queue-getters.ts:284
  • +
  • Defined in classes/queue-getters.ts:205
  • +
  • Defined in classes/queue-getters.ts:217
  • +
  • Defined in classes/queue-getters.ts:196
  • +
  • Defined in classes/queue-getters.ts:189
  • +
  • Defined in classes/queue-getters.ts:406
  • +
  • Defined in classes/queue-base.ts:116
  • @@ -21,7 +21,7 @@

    Hierarchy

    • QueueKeys
    +
  • Defined in classes/queue-keys.ts:3
  • @@ -55,14 +55,14 @@

    Parameters

    prefix: string = 'bull'

    Returns QueueKeys

    +
  • Defined in classes/queue-keys.ts:4
  • Properties

    prefix: string = 'bull'
    +
  • Defined in classes/queue-keys.ts:4
  • Methods

    @@ -77,7 +77,7 @@

    Parameters

    name: string

    Returns KeysMap

    +
  • Defined in classes/queue-keys.ts:6
  • Returns string

    +
  • Defined in classes/queue-keys.ts:41
  • Returns string

    +
  • Defined in classes/queue-keys.ts:37
  • @@ -23,7 +23,7 @@

    Hierarchy

    • RedisConnection
    +
  • Defined in classes/redis-connection.ts:31
  • @@ -70,24 +70,24 @@
    blocking: Returns RedisConnection
    +
  • Defined in classes/redis-connection.ts:47
  • Properties

    closing: boolean
    +
  • Defined in classes/redis-connection.ts:35
  • minimumVersion: string = '5.0.0'
    +
  • Defined in classes/redis-connection.ts:32
  • recommendedMinimumVersion: string = '6.2.0'
    +
  • Defined in classes/redis-connection.ts:33
  • Accessors

    @@ -97,7 +97,7 @@
    +
  • Defined in classes/redis-connection.ts:152
  • +
  • Defined in classes/redis-connection.ts:282
  • Methods

    @@ -115,7 +115,7 @@
    +
  • Defined in classes/redis-connection.ts:237
  • +
  • Defined in classes/redis-connection.ts:209
  • +
  • Defined in classes/redis-connection.ts:232
  • +
  • Defined in classes/redis-connection.ts:115
  • @@ -28,7 +28,7 @@

    Hierarchy

    • Repeat
    +
  • Defined in classes/repeat.ts:9
  • @@ -82,7 +82,7 @@
    Optional Returns Repeat
    +
  • Defined in classes/repeat.ts:13
  • Properties

    @@ -90,13 +90,13 @@
    +
  • Defined in classes/queue-base.ts:21
  • keys: KeysMap
    +
  • Defined in classes/queue-base.ts:20
  • name: string
    @@ -105,7 +105,7 @@
    +
  • Defined in classes/queue-base.ts:34
  • opts: QueueBaseOptions = {}
    @@ -114,7 +114,7 @@
    +
  • Defined in classes/queue-base.ts:35
  • toKey: ((type) => string)
    @@ -133,7 +133,7 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • Accessors

    @@ -147,7 +147,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:77
  • +
  • Defined in classes/queue-base.ts:84
  • Methods

    @@ -189,7 +189,7 @@
    opts: Optional skipCheckExists: boolean

    Returns Promise<Job<T, R, N>>

    +
  • Defined in classes/repeat.ts:27
  • +
  • Defined in classes/queue-base.ts:133
  • +
  • Defined in classes/queue-base.ts:144
  • +
  • Defined in classes/queue-base.ts:102
  • +
  • Defined in classes/repeat.ts:202
  • Returns Promise<{
        endDate: number;
        id: string;
        key: string;
        name: string;
        next: number;
        pattern: string;
        tz: string;
    }[]>

    +
  • Defined in classes/repeat.ts:187
  • Returns Promise<number>

    +
  • Defined in classes/repeat.ts:143
  • Returns Promise<number>

    +
  • Defined in classes/repeat.ts:159
  • +
  • Defined in classes/queue-base.ts:116
  • @@ -25,7 +25,7 @@

    Hierarchy

    • ScriptLoader
    +
  • Defined in commands/script-loader.ts:84
  • @@ -55,7 +55,7 @@
    +
  • Defined in commands/script-loader.ts:96
  • Methods

    @@ -83,7 +83,7 @@
    mappedPath: Returns void
    +
  • Defined in commands/script-loader.ts:110
  • +
  • Defined in commands/script-loader.ts:463
  • +
  • Defined in commands/script-loader.ts:333
  • +
  • Defined in commands/script-loader.ts:435
    • @@ -159,7 +159,7 @@
      filename: Optional cache: Map<string, ScriptMetadata>

    Returns Promise<Command>

    +
  • Defined in commands/script-loader.ts:356
  • +
  • Defined in commands/script-loader.ts:390
  • +
  • Defined in commands/script-loader.ts:305
  • +
  • Defined in commands/script-loader.ts:134
  • @@ -23,7 +23,7 @@

    Hierarchy

    • ScriptLoaderError
    +
  • Defined in commands/script-loader.ts:52
  • @@ -62,7 +62,7 @@
    position: Returns ScriptLoaderError
    +
  • Defined in commands/script-loader.ts:60
  • Properties

    @@ -72,17 +72,17 @@
    +
  • Defined in commands/script-loader.ts:56
  • line: number
    +
  • Defined in commands/script-loader.ts:57
  • position: number
    +
  • Defined in commands/script-loader.ts:58
  • @@ -21,7 +21,7 @@

    Hierarchy

    • Scripts
    +
  • Defined in classes/scripts.ts:40
  • @@ -86,14 +86,14 @@

    Parameters

    queue: MinimalQueue

    Returns Scripts

    +
  • Defined in classes/scripts.ts:43
  • Properties

    moveToFinishedKeys: string[]
    +
  • Defined in classes/scripts.ts:41
  • Methods

    @@ -116,7 +116,7 @@
    jobId: parentOpts: ParentOpts = {}

    Returns Promise<string>

    +
  • Defined in classes/scripts.ts:74
  • Returns Promise<void>

    +
  • Defined in classes/scripts.ts:505
  • Returns Promise<void>

    +
  • Defined in classes/scripts.ts:537
  • +
  • Defined in classes/scripts.ts:703
  • Returns Promise<void>

    +
  • Defined in classes/scripts.ts:371
  • Returns Promise<number>

    +
  • Defined in classes/scripts.ts:193
  • Returns Error

    +
  • Defined in classes/scripts.ts:328
  • Returns Promise<number[]>

    +
  • Defined in classes/scripts.ts:421
  • Returns Promise<[string][]>

    +
  • Defined in classes/scripts.ts:396
  • Returns Promise<"unknown" | JobState>

    +
  • Defined in classes/scripts.ts:483
  • Returns Promise<number | [number, string]>

    +
  • Defined in classes/scripts.ts:468
  • Returns Promise<boolean>

    +
  • Defined in classes/scripts.ts:63
  • +
  • Defined in classes/scripts.ts:932
  • +
  • Defined in classes/scripts.ts:900
  • Returns Promise<any[]>

    +
  • Defined in classes/scripts.ts:837
  • Returns (string | number | boolean | Buffer)[]

    +
  • Defined in classes/scripts.ts:428
  • Returns Promise<void>

    +
  • Defined in classes/scripts.ts:648
  • Returns (string | number)[]

    +
  • Defined in classes/scripts.ts:573
  • Returns (string | number | boolean | Buffer)[]

    +
  • Defined in classes/scripts.ts:448
  • Returns Promise<any[]>

    +
  • Defined in classes/scripts.ts:312
  • +
  • Defined in classes/scripts.ts:673
  • Returns string[]

    +
  • Defined in classes/scripts.ts:625
  • Returns Promise<number>

    +
  • Defined in classes/scripts.ts:955
  • Returns Promise<void>

    +
  • Defined in classes/scripts.ts:142
  • Returns Promise<number>

    +
  • Defined in classes/scripts.ts:873
  • Returns Promise<number>

    +
  • Defined in classes/scripts.ts:784
  • Returns Promise<number>

    +
  • Defined in classes/scripts.ts:184
  • Returns Promise<number>

    +
  • Defined in classes/scripts.ts:174
  • +
  • Defined in classes/scripts.ts:805
  • Returns (string | number)[]

    +
  • Defined in classes/scripts.ts:720
  • Returns Promise<number>

    +
  • Defined in classes/scripts.ts:772
  • Returns string[]

    +
  • Defined in classes/scripts.ts:615
  • Returns Promise<void>

    +
  • Defined in classes/scripts.ts:210
  • Returns Promise<void>

    +
  • Defined in classes/scripts.ts:226
  • @@ -29,7 +29,7 @@

    Hierarchy

    • UnrecoverableError
    +
  • Defined in classes/unrecoverable-error.ts:8
  • @@ -54,7 +54,7 @@
    Optional Returns UnrecoverableError
    +
  • Defined in classes/unrecoverable-error.ts:9
  • @@ -29,7 +29,7 @@

    Hierarchy

    • WaitingChildrenError
    +
  • Defined in classes/waiting-children-error.ts:8
  • @@ -54,7 +54,7 @@
    Optional Returns WaitingChildrenError
    +
  • Defined in classes/waiting-children-error.ts:9
  • @@ -38,7 +38,7 @@

    Hierarchy

    • Worker
    +
  • Defined in classes/worker.ts:156
  • @@ -115,7 +115,7 @@
    Optional Returns Worker<DataType, ResultType, NameType>
    +
  • Defined in classes/worker.ts:193
  • Properties

    @@ -123,18 +123,18 @@
    +
  • Defined in classes/queue-base.ts:21
  • id: string
    +
  • Defined in classes/worker.ts:162
  • keys: KeysMap
    +
  • Defined in classes/queue-base.ts:20
  • name: string
    @@ -143,7 +143,7 @@
    +
  • Defined in classes/queue-base.ts:34
  • @@ -152,7 +152,7 @@
    +
  • Defined in classes/worker.ts:161
  • toKey: ((type) => string)
    @@ -171,7 +171,7 @@
    type: Returns string
    +
  • Defined in classes/queue-base.ts:19
  • Accessors

    @@ -185,7 +185,7 @@

    Returns Promise<

    +
  • Defined in classes/queue-base.ts:77
  • Returns void

    +
  • Defined in classes/worker.ts:347
  • +
  • Defined in classes/queue-base.ts:84
  • +
  • Defined in classes/worker.ts:354
  • Methods

    @@ -243,7 +243,7 @@

    Returns Promise<

    +
  • Defined in classes/worker.ts:738
  • +
  • Defined in classes/worker.ts:570
  • +
  • Defined in classes/queue-base.ts:144
  • +
  • Defined in classes/worker.ts:287
  • +
  • Defined in classes/worker.ts:441
  • +
  • Defined in classes/worker.ts:713
  • +
  • Defined in classes/worker.ts:723
  • +
  • Defined in classes/worker.ts:294
  • +
  • Defined in classes/worker.ts:302
  • +
  • Defined in classes/worker.ts:310
  • +
  • Defined in classes/worker.ts:682
  • Returns Promise<void | Job<DataType, ResultType, NameType>>

    +
  • Defined in classes/worker.ts:606
  • +
  • Defined in classes/worker.ts:489
  • +
  • Defined in classes/worker.ts:700
  • +
  • Defined in classes/worker.ts:368
  • +
  • Defined in classes/worker.ts:786
  • +
  • Defined in classes/worker.ts:342
  • +
  • Defined in classes/worker.ts:189
  • @@ -66,7 +66,7 @@

    Start
  • Stop
  • @@ -59,7 +59,7 @@

    blocking
  • normal
  • @@ -80,7 +80,7 @@

    JobPendingDependencies
  • ParentJobNotExist
  • @@ -101,7 +101,7 @@

    THIRTY_MINUTES
  • TWO_WEEKS
  • @@ -101,7 +101,7 @@

    Progress
  • Update
  • @@ -66,7 +66,7 @@

    Start
  • Stop
  • @@ -59,7 +59,7 @@

    blocking
  • normal
  • @@ -80,7 +80,7 @@

    JobPendingDependencies
  • ParentJobNotExist
  • @@ -101,7 +101,7 @@

    THIRTY_MINUTES
  • TWO_WEEKS
  • @@ -101,7 +101,7 @@

    Progress
  • Update
  • @@ -66,7 +66,7 @@

    Start
  • Stop
  • @@ -59,7 +59,7 @@

    blocking
  • normal
  • @@ -87,7 +87,7 @@

    JobPendingDependencies
  • ParentJobNotExist
  • @@ -101,7 +101,7 @@

    THIRTY_MINUTES
  • TWO_WEEKS
  • @@ -101,7 +101,7 @@

    Progress
  • Update
  • @@ -17,7 +17,7 @@
  • ChildCommand
  • Enumeration ChildCommand

    +
  • Defined in interfaces/child-command.ts:1
  • @@ -35,17 +35,17 @@

    Enumeration Members

    Init: 0
    +
  • Defined in interfaces/child-command.ts:2
  • Start: 1
    +
  • Defined in interfaces/child-command.ts:3
  • Stop: 2
    +
  • Defined in interfaces/child-command.ts:4
  • @@ -17,7 +17,7 @@
  • ClientType
  • Enumeration ClientType

    +
  • Defined in interfaces/queue-options.ts:5
  • @@ -34,12 +34,12 @@

    Enumeration Members

    blocking: "blocking"
    +
  • Defined in interfaces/queue-options.ts:6
  • normal: "normal"
    +
  • Defined in interfaces/queue-options.ts:7
  • @@ -17,7 +17,7 @@
  • ErrorCode
  • Enumeration ErrorCode

    +
  • Defined in enums/error-code.enum.ts:1
  • @@ -38,32 +38,32 @@

    Enumeration Members

    JobLockMismatch: -6
    +
  • Defined in enums/error-code.enum.ts:7
  • JobLockNotExist: -2
    +
  • Defined in enums/error-code.enum.ts:3
  • JobNotExist: -1
    +
  • Defined in enums/error-code.enum.ts:2
  • JobNotInState: -3
    +
  • Defined in enums/error-code.enum.ts:4
  • JobPendingDependencies: -4
    +
  • Defined in enums/error-code.enum.ts:5
  • ParentJobNotExist: -5
    +
  • Defined in enums/error-code.enum.ts:6
  • @@ -17,7 +17,7 @@
  • MetricsTime
  • Enumeration MetricsTime

    +
  • Defined in enums/metrics-time.ts:1
  • @@ -40,42 +40,42 @@

    Enumeration Members

    FIFTEEN_MINUTES: 15
    +
  • Defined in enums/metrics-time.ts:4
  • FIVE_MINUTES: 5
    +
  • Defined in enums/metrics-time.ts:3
  • ONE_HOUR: 60
    +
  • Defined in enums/metrics-time.ts:6
  • ONE_MINUTE: 1
    +
  • Defined in enums/metrics-time.ts:2
  • ONE_MONTH: 80640
    +
  • Defined in enums/metrics-time.ts:9
  • ONE_WEEK: 10080
    +
  • Defined in enums/metrics-time.ts:7
  • THIRTY_MINUTES: 30
    +
  • Defined in enums/metrics-time.ts:5
  • TWO_WEEKS: 20160
    +
  • Defined in enums/metrics-time.ts:8
  • @@ -17,7 +17,7 @@
  • ParentCommand
  • Enumeration ParentCommand

    +
  • Defined in interfaces/parent-command.ts:1
  • @@ -40,42 +40,42 @@

    Enumeration Members

    Completed: 0
    +
  • Defined in interfaces/parent-command.ts:2
  • Error: 1
    +
  • Defined in interfaces/parent-command.ts:3
  • Failed: 2
    +
  • Defined in interfaces/parent-command.ts:4
  • InitCompleted: 4
    +
  • Defined in interfaces/parent-command.ts:6
  • InitFailed: 3
    +
  • Defined in interfaces/parent-command.ts:5
  • Log: 5
    +
  • Defined in interfaces/parent-command.ts:7
  • Progress: 6
    +
  • Defined in interfaces/parent-command.ts:8
  • Update: 7
    +
  • Defined in interfaces/parent-command.ts:9
  • @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -48,7 +48,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -46,7 +46,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -45,7 +45,7 @@

    Member Visibility

    Theme

    @@ -49,7 +49,7 @@

    Member Visibility

    Theme

    @@ -46,7 +46,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -45,7 +45,7 @@

    Member Visibility

    Theme

    @@ -56,7 +56,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -48,7 +48,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -46,7 +46,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -45,7 +45,7 @@

    Member Visibility

    Theme

    @@ -49,7 +49,7 @@

    Member Visibility

    Theme

    @@ -46,7 +46,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -45,7 +45,7 @@

    Member Visibility

    Theme

    @@ -56,7 +56,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -48,7 +48,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -46,7 +46,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -46,7 +46,7 @@

    Member Visibility

    Theme

    @@ -44,7 +44,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -45,7 +45,7 @@

    Member Visibility

    Theme

    @@ -56,7 +56,7 @@

    Member Visibility

    Theme

    @@ -27,7 +27,7 @@

    Parameters

    arr: string[]

    Returns Record<string, string>

    +
  • Defined in utils.ts:41
  • @@ -34,7 +34,7 @@
    proc: msg: any

    Returns Promise<void>

    +
  • Defined in utils.ts:127
  • @@ -29,7 +29,7 @@
    proc: msg: ChildMessage

    Returns Promise<void>

    +
  • Defined in utils.ts:148
  • @@ -27,7 +27,7 @@

    Parameters

    ms: number

    Returns Promise<void>

    +
  • Defined in utils.ts:49
  • @@ -27,7 +27,7 @@

    Parameters

    value: any

    Returns Record<string, any>

    +
  • Defined in utils.ts:173
  • @@ -29,7 +29,7 @@
    millis: opts: RepeatOptions

    Returns number

    +
  • Defined in classes/repeat.ts:234
  • @@ -32,7 +32,7 @@
    id
    queue: string

    Returns string | undefined

    +
  • Defined in utils.ts:98
  • @@ -27,7 +27,7 @@

    Parameters

    obj: object

    Returns boolean

    +
  • Defined in utils.ts:32
  • @@ -27,7 +27,7 @@

    Parameters

    error: Error

    Returns boolean

    +
  • Defined in utils.ts:114
  • @@ -27,7 +27,7 @@

    Parameters

    obj: unknown

    Returns obj is Cluster

    +
  • Defined in utils.ts:63
  • @@ -27,7 +27,7 @@

    Parameters

    obj: any

    Returns obj is Cluster | Redis

    +
  • Defined in utils.ts:55
  • @@ -29,7 +29,7 @@
    currentVersion: minimumVersion: string

    Returns boolean

    +
  • Defined in utils.ts:153
  • @@ -32,7 +32,7 @@

    Returns numberSee

    https://stackoverflow.com/a/23318053/1347170

    +
  • Defined in utils.ts:28
  • @@ -30,7 +30,7 @@
    obj: [key: string]: string

    Returns Record<string, any>

    +
  • Defined in utils.ts:162
  • @@ -27,7 +27,7 @@

    Parameters

    raw: any[]

    Returns any[]

    +
  • Defined in classes/scripts.ts:977
  • @@ -31,7 +31,7 @@
    queueName: prefix: string = 'bull'

    Returns Promise<void | boolean>

    +
  • Defined in utils.ts:67
  • @@ -42,7 +42,7 @@
    ctx: args: any[]

    Returns any

    +
  • Defined in utils.ts:10
  • -

    bullmq - v4.5.0

    +

    bullmq - v4.6.0


    @@ -356,7 +356,7 @@

    Contributing
  • Thanks
  • @@ -89,7 +89,7 @@

    parent
  • queuesOpts
  • @@ -92,7 +92,7 @@

    parent
  • queuesOpts
  • @@ -75,7 +75,7 @@

    backoffStrategies
  • repeatStrategy
  • @@ -62,7 +62,7 @@

    repeatStrategy

    @@ -75,7 +75,7 @@

    delay
  • type
  • @@ -183,7 +183,7 @@

    stackTraceLimit
  • timestamp
  • @@ -70,7 +70,7 @@

    err
  • value
  • @@ -58,7 +58,7 @@

    processFile

    @@ -70,7 +70,7 @@

    name
  • options
  • @@ -77,7 +77,7 @@

    processed
  • unprocessed
  • @@ -91,7 +91,7 @@

    prefix
  • queueName
  • @@ -59,7 +59,7 @@

    queuesOptions

    @@ -95,7 +95,7 @@

    error
  • ioredis:close
  • @@ -56,7 +56,7 @@

    block

    @@ -73,7 +73,7 @@

    client
  • waitUntilReady
  • @@ -79,7 +79,7 @@

    ioredis:close

    @@ -98,7 +98,7 @@

    next
  • tz
  • @@ -154,7 +154,7 @@

    stacktrace
  • timestamp
  • @@ -161,7 +161,7 @@

    stacktrace
  • timestamp
  • @@ -63,7 +63,7 @@

    children
  • job
  • @@ -62,7 +62,7 @@

    cancel

    @@ -251,7 +251,7 @@

    stackTraceLimit
  • timestamp
  • @@ -76,7 +76,7 @@

    age
  • count
  • @@ -79,7 +79,7 @@

    data
  • meta
  • @@ -61,7 +61,7 @@

    maxDataPoints

    @@ -63,7 +63,7 @@

    child

    @@ -99,7 +99,7 @@

    prefix
  • queueName
  • @@ -73,7 +73,7 @@

    count
  • force
  • @@ -93,7 +93,7 @@

    prefix
  • queue
  • @@ -63,7 +63,7 @@

    id
  • queueKey
  • @@ -77,7 +77,7 @@

    job
  • value
  • @@ -104,7 +104,7 @@

    prefix
  • sharedConnection
  • @@ -555,7 +555,7 @@

    waiting
  • waiting-children
  • @@ -131,7 +131,7 @@

    prefix
  • sharedConnection
  • @@ -242,7 +242,7 @@

    resumed
  • waiting
  • @@ -156,7 +156,7 @@

    sharedConnection
  • streams
  • @@ -149,7 +149,7 @@

    ioredis:close
  • stalled
  • @@ -136,7 +136,7 @@

    sharedConnection
  • stalledInterval
  • @@ -101,7 +101,7 @@

    max
  • workerDelay
  • @@ -106,7 +106,7 @@

    settings
  • sharedConnection
  • @@ -141,7 +141,7 @@

    pattern
  • prevMillis
  • @@ -267,7 +267,7 @@

    update
  • updateProgress
  • @@ -111,7 +111,7 @@

    path
  • token
  • @@ -38,7 +38,7 @@

    Member Visibility

    Theme

    @@ -317,7 +317,7 @@

    progress
  • resumed
  • @@ -188,7 +188,7 @@

    sharedConnection
  • skipDelayCheck
  • @@ -89,7 +89,7 @@

    parent
  • queuesOpts
  • @@ -92,7 +92,7 @@

    parent
  • queuesOpts
  • @@ -75,7 +75,7 @@

    backoffStrategies
  • repeatStrategy
  • @@ -62,7 +62,7 @@

    repeatStrategy

    @@ -75,7 +75,7 @@

    delay
  • type
  • @@ -251,7 +251,7 @@

    stackTraceLimit
  • timestamp
  • @@ -70,7 +70,7 @@

    err
  • value
  • @@ -58,7 +58,7 @@

    processFile

    @@ -70,7 +70,7 @@

    name
  • options
  • @@ -183,7 +183,7 @@

    stackTraceLimit
  • timestamp
  • @@ -77,7 +77,7 @@

    processed
  • unprocessed
  • @@ -59,7 +59,7 @@

    queuesOptions

    @@ -95,7 +95,7 @@

    error
  • ioredis:close
  • @@ -56,7 +56,7 @@

    block

    @@ -73,7 +73,7 @@

    client
  • waitUntilReady
  • @@ -77,7 +77,7 @@

    ioredis:close

    @@ -154,7 +154,7 @@

    stacktrace
  • timestamp
  • @@ -161,7 +161,7 @@

    stacktrace
  • timestamp
  • @@ -63,7 +63,7 @@

    children
  • job
  • @@ -76,7 +76,7 @@

    age
  • count
  • @@ -79,7 +79,7 @@

    data
  • meta
  • @@ -61,7 +61,7 @@

    maxDataPoints

    @@ -63,7 +63,7 @@

    child

    @@ -99,7 +99,7 @@

    prefix
  • queueName
  • @@ -73,7 +73,7 @@

    count
  • force
  • @@ -93,7 +93,7 @@

    prefix
  • queue
  • @@ -63,7 +63,7 @@

    id
  • queueKey
  • @@ -77,7 +77,7 @@

    job
  • value
  • @@ -102,7 +102,7 @@

    prefix
  • sharedConnection
  • @@ -551,7 +551,7 @@

    waiting
  • waiting-children
  • @@ -131,7 +131,7 @@

    prefix
  • sharedConnection
  • @@ -242,7 +242,7 @@

    resumed
  • waiting
  • @@ -156,7 +156,7 @@

    sharedConnection
  • streams
  • @@ -101,7 +101,7 @@

    max
  • workerDelay
  • @@ -70,7 +70,7 @@

    keys
  • name
  • @@ -106,7 +106,7 @@

    settings
  • sharedConnection
  • @@ -141,7 +141,7 @@

    pattern
  • prevMillis
  • @@ -239,7 +239,7 @@

    update
  • updateProgress
  • @@ -111,7 +111,7 @@

    path
  • token
  • @@ -38,7 +38,7 @@

    Member Visibility

    Theme

    @@ -344,7 +344,7 @@

    resumed
  • stalled
  • @@ -210,7 +210,7 @@

    skipDelayCheck
  • stalledInterval
  • @@ -89,7 +89,7 @@

    parent
  • queuesOpts
  • @@ -92,7 +92,7 @@

    parent
  • queuesOpts
  • @@ -72,7 +72,7 @@

    backoffStrategy
  • repeatStrategy
  • @@ -62,7 +62,7 @@

    repeatStrategy

    @@ -75,7 +75,7 @@

    delay
  • type
  • @@ -255,7 +255,7 @@

    stackTraceLimit
  • timestamp
  • @@ -56,7 +56,7 @@

    skipVersionCheck

    @@ -49,7 +49,7 @@

    Member Visibility

    Theme

    @@ -70,7 +70,7 @@

    err
  • value
  • @@ -70,7 +70,7 @@

    name
  • options
  • @@ -182,7 +182,7 @@

    stackTraceLimit
  • timestamp
  • @@ -77,7 +77,7 @@

    processed
  • unprocessed
  • @@ -96,7 +96,7 @@

    prefix
  • queueName
  • @@ -59,7 +59,7 @@

    queuesOptions

    @@ -95,7 +95,7 @@

    error
  • ioredis:close
  • @@ -56,7 +56,7 @@

    block

    @@ -73,7 +73,7 @@

    client
  • waitUntilReady
  • @@ -77,7 +77,7 @@

    ioredis:close

    @@ -154,7 +154,7 @@

    stacktrace
  • timestamp
  • @@ -161,7 +161,7 @@

    stacktrace
  • timestamp
  • @@ -63,7 +63,7 @@

    children
  • job
  • @@ -76,7 +76,7 @@

    age
  • count
  • @@ -79,7 +79,7 @@

    data
  • meta
  • @@ -61,7 +61,7 @@

    maxDataPoints

    @@ -369,7 +369,7 @@

    update
  • updateProgress
  • @@ -63,7 +63,7 @@

    child

    @@ -99,7 +99,7 @@

    prefix
  • queueName
  • @@ -73,7 +73,7 @@

    count
  • force
  • @@ -93,7 +93,7 @@

    prefix
  • queue
  • @@ -63,7 +63,7 @@

    id
  • queueKey
  • @@ -77,7 +77,7 @@

    job
  • value
  • @@ -102,7 +102,7 @@

    prefix
  • sharedConnection
  • @@ -580,7 +580,7 @@

    waiting
  • waiting-children
  • @@ -131,7 +131,7 @@

    prefix
  • sharedConnection
  • @@ -242,7 +242,7 @@

    resumed
  • waiting
  • @@ -137,7 +137,7 @@

    sharedConnection
  • streams
  • @@ -71,7 +71,7 @@

    duration
  • max
  • @@ -70,7 +70,7 @@

    keys
  • name
  • @@ -106,7 +106,7 @@

    settings
  • sharedConnection
  • @@ -130,7 +130,7 @@

    pattern
  • prevMillis
  • @@ -239,7 +239,7 @@

    update
  • updateProgress
  • @@ -111,7 +111,7 @@

    path
  • token
  • @@ -365,7 +365,7 @@

    resumed
  • stalled
  • @@ -313,7 +313,7 @@

    stalledInterval
  • useWorkerThreads
  • @@ -21,7 +21,7 @@

    Hierarchy

    • AddChildrenOpts
    +
  • Defined in classes/flow-producer.ts:34
  • @@ -40,12 +40,12 @@

    Properties

    multi: ChainableCommander
    +
  • Defined in classes/flow-producer.ts:35
  • nodes: FlowJob[]
    +
  • Defined in classes/flow-producer.ts:36
  • parent: {
        parentDependenciesKey: string;
        parentOpts: {
            id: string;
            queue: string;
        };
    }
    @@ -62,12 +62,12 @@
    id
  • queue: string
  • +
  • Defined in classes/flow-producer.ts:37
  • queuesOpts?: FlowQueuesOpts
    +
  • Defined in classes/flow-producer.ts:44
  • @@ -21,7 +21,7 @@

    Hierarchy

    • AddNodeOpts
    +
  • Defined in classes/flow-producer.ts:18
  • @@ -40,12 +40,12 @@

    Properties

    multi: ChainableCommander
    +
  • Defined in classes/flow-producer.ts:19
  • node: FlowJob
    +
  • Defined in classes/flow-producer.ts:20
  • parent?: {
        parentDependenciesKey: string;
        parentOpts: {
            id: string;
            queue: string;
        };
    }
    @@ -62,7 +62,7 @@
    id
  • queue: string
  • +
  • Defined in classes/flow-producer.ts:21
  • queuesOpts?: FlowQueuesOpts
    @@ -70,7 +70,7 @@
    +
  • Defined in classes/flow-producer.ts:31
  • @@ -23,7 +23,7 @@

    Hierarchy

    • AdvancedOptions
    +
  • Defined in interfaces/advanced-options.ts:16
  • @@ -44,7 +44,7 @@
    +
  • Defined in interfaces/advanced-options.ts:20
  • repeatKeyHashAlgorithm?: string
    @@ -54,7 +54,7 @@
    +
  • Defined in interfaces/advanced-options.ts:13
  • repeatStrategy?: RepeatStrategy
    @@ -63,7 +63,7 @@
    +
  • Defined in interfaces/advanced-options.ts:7
  • @@ -24,7 +24,7 @@

    Hierarchy

  • AdvancedOptions
  • AdvancedOptions
  • +
  • Defined in interfaces/advanced-options.ts:3
  • @@ -45,7 +45,7 @@
    +
  • Defined in interfaces/advanced-options.ts:13
  • repeatStrategy?: RepeatStrategy
    @@ -53,7 +53,7 @@
    +
  • Defined in interfaces/advanced-options.ts:7
  • @@ -27,7 +27,7 @@

    Hierarchy

    • BackoffOptions
    +
  • Defined in interfaces/backoff-options.ts:6
  • @@ -47,7 +47,7 @@
    +
  • Defined in interfaces/backoff-options.ts:14
  • type: "fixed" | string & {} | "exponential"
    @@ -55,7 +55,7 @@
    +
  • Defined in interfaces/backoff-options.ts:10
  • @@ -23,7 +23,7 @@

    Hierarchy

    • BaseJobOptions
    +
  • Defined in interfaces/base-job-options.ts:77
  • @@ -60,7 +60,7 @@

    Default Value

    0

    +
  • Defined in interfaces/base-job-options.ts:29
  • backoff?: number | BackoffOptions
    @@ -69,7 +69,7 @@
    +
  • Defined in interfaces/base-job-options.ts:34
  • delay?: number
    @@ -82,7 +82,7 @@

    Default Value

    0

    +
  • Defined in interfaces/base-job-options.ts:23
  • jobId?: string
    @@ -94,7 +94,7 @@
    +
  • Defined in interfaces/base-job-options.ts:95
  • keepLogs?: number
    @@ -103,7 +103,7 @@
    +
  • Defined in interfaces/base-job-options.ts:64
  • lifo?: boolean
    @@ -114,7 +114,7 @@

    See

    https://docs.bul

    +
  • Defined in interfaces/base-job-options.ts:41
  • parent?: {
        id: string;
        queue: string;
    }
    @@ -131,7 +131,7 @@
    queuehttps://www.gnu.org/software/gawk/manual/html_node/Qualified-Names.html

    +
  • Defined in interfaces/base-job-options.ts:100
  • prevMillis?: number
    @@ -139,7 +139,7 @@
    +
  • Defined in interfaces/base-job-options.ts:113
  • priority?: number
    @@ -150,7 +150,7 @@
    +
  • Defined in interfaces/base-job-options.ts:15
  • removeOnComplete?: number | boolean | KeepJobs
    @@ -163,7 +163,7 @@
    +
  • Defined in interfaces/base-job-options.ts:50
  • removeOnFail?: number | boolean | KeepJobs
    @@ -176,7 +176,7 @@
    +
  • Defined in interfaces/base-job-options.ts:59
  • repeat?: RepeatOptions
    @@ -184,7 +184,7 @@
    +
  • Defined in interfaces/base-job-options.ts:81
  • repeatJobKey?: string
    @@ -192,7 +192,7 @@
    +
  • Defined in interfaces/base-job-options.ts:86
  • sizeLimit?: number
    @@ -201,7 +201,7 @@
    +
  • Defined in interfaces/base-job-options.ts:74
  • stackTraceLimit?: number
    @@ -210,7 +210,7 @@
    +
  • Defined in interfaces/base-job-options.ts:69
  • timestamp?: number
    @@ -221,7 +221,7 @@

    Default Value

    Date.now()

    +
  • Defined in interfaces/base-job-options.ts:8
  • @@ -21,7 +21,7 @@

    Hierarchy

    • BaseOptions
    +
  • Defined in interfaces/redis-options.ts:3
  • @@ -37,7 +37,7 @@

    Properties

    skipVersionCheck?: boolean
    +
  • Defined in interfaces/redis-options.ts:4
  • @@ -35,7 +35,7 @@

    Parameters

    delay: number

    Returns BackoffStrategy

    +
  • Defined in classes/backoffs.ts:4
  • @@ -21,7 +21,7 @@

    Hierarchy

    • ChildMessage
    +
  • Defined in interfaces/child-message.ts:3
  • @@ -39,17 +39,17 @@

    Properties

    +
  • Defined in interfaces/child-message.ts:4
  • err?: Record<string, any>
    +
  • Defined in interfaces/child-message.ts:6
  • value?: any
    +
  • Defined in interfaces/child-message.ts:5
  • @@ -21,7 +21,7 @@

    Hierarchy

    • Command
    +
  • Defined in commands/script-loader.ts:15
  • @@ -38,7 +38,7 @@

    Properties

    name: string
    +
  • Defined in commands/script-loader.ts:16
  • options: {
        lua: string;
        numberOfKeys: number;
    }
    @@ -50,7 +50,7 @@
    lua
    numberOfKeys: number
    +
  • Defined in commands/script-loader.ts:17
  • @@ -24,7 +24,7 @@

    Hierarchy

  • BaseJobOptions
  • BaseJobOptions
  • +
  • Defined in interfaces/base-job-options.ts:3
  • @@ -55,7 +55,7 @@

    0

    +
  • Defined in interfaces/base-job-options.ts:29
  • backoff?: number | BackoffOptions
    @@ -63,7 +63,7 @@
    +
  • Defined in interfaces/base-job-options.ts:34
  • delay?: number
    @@ -75,7 +75,7 @@

    0

    +
  • Defined in interfaces/base-job-options.ts:23
  • keepLogs?: number
    @@ -83,7 +83,7 @@
    +
  • Defined in interfaces/base-job-options.ts:64
  • lifo?: boolean
    @@ -93,7 +93,7 @@

    https://docs.bullmq.io/guide/jobs/lifo

    +
  • Defined in interfaces/base-job-options.ts:41
  • priority?: number
    @@ -103,7 +103,7 @@
    +
  • Defined in interfaces/base-job-options.ts:15
  • removeOnComplete?: number | boolean | KeepJobs
    @@ -115,7 +115,7 @@
    +
  • Defined in interfaces/base-job-options.ts:50
  • removeOnFail?: number | boolean | KeepJobs
    @@ -127,7 +127,7 @@
    +
  • Defined in interfaces/base-job-options.ts:59
  • sizeLimit?: number
    @@ -135,7 +135,7 @@
    +
  • Defined in interfaces/base-job-options.ts:74
  • stackTraceLimit?: number
    @@ -143,7 +143,7 @@
    +
  • Defined in interfaces/base-job-options.ts:69
  • timestamp?: number
    @@ -153,7 +153,7 @@

    Date.now()

    +
  • Defined in interfaces/base-job-options.ts:8
  • @@ -21,7 +21,7 @@

    Hierarchy

    • DependenciesOpts
    +
  • Defined in interfaces/minimal-job.ts:14
  • @@ -45,7 +45,7 @@
    Optional
    Optional cursor?: number
    +
  • Defined in interfaces/minimal-job.ts:15
  • unprocessed?: {
        count?: number;
        cursor?: number;
    }
    @@ -57,7 +57,7 @@
    Optional
    Optional cursor?: number
    +
  • Defined in interfaces/minimal-job.ts:19
  • @@ -26,7 +26,7 @@

    Hierarchy

    • FlowJobBase
    +
  • Defined in interfaces/flow-job.ts:4
  • @@ -47,32 +47,32 @@

    Properties

    children?: FlowChildJob[]
    +
  • Defined in interfaces/flow-job.ts:10
  • data?: any
    +
  • Defined in interfaces/flow-job.ts:7
  • name: string
    +
  • Defined in interfaces/flow-job.ts:5
  • opts?: Omit<T, "repeat">
    +
  • Defined in interfaces/flow-job.ts:9
  • prefix?: string
    +
  • Defined in interfaces/flow-job.ts:8
  • queueName: string
    +
  • Defined in interfaces/flow-job.ts:6
  • @@ -21,7 +21,7 @@

    Hierarchy

    • FlowOpts
    +
  • Defined in interfaces/flow-job.ts:22
  • @@ -40,7 +40,7 @@
    +
  • Defined in interfaces/flow-job.ts:26
  • @@ -23,7 +23,7 @@

    Hierarchy

    • FlowProducerListener
    +
  • Defined in classes/flow-producer.ts:75
  • @@ -57,7 +57,7 @@
    failedReason: Returns void
    +
  • Defined in classes/flow-producer.ts:81
  • ioredis:close: (() => void)
    @@ -75,7 +75,7 @@

    Returns void

    +
  • Defined in interfaces/ioredis-events.ts:7
  • @@ -21,7 +21,7 @@

    Hierarchy

    • GetNextJobOptions
    +
  • Defined in interfaces/worker-options.ts:142
  • @@ -37,7 +37,7 @@

    Properties

    block?: boolean
    +
  • Defined in interfaces/worker-options.ts:143
  • @@ -23,7 +23,7 @@

    Hierarchy

    • IConnection
    +
  • Defined in interfaces/connection.ts:6
  • @@ -43,7 +43,7 @@

    Properties

    client: Promise<RedisClient>
    +
  • Defined in interfaces/connection.ts:8
  • Methods

    @@ -53,7 +53,7 @@
    +
  • Defined in interfaces/connection.ts:7
  • @@ -30,7 +30,7 @@

    Hierarchy

  • QueueListener
  • WorkerListener
  • +
  • Defined in interfaces/ioredis-events.ts:1
  • @@ -58,7 +58,7 @@

    Type declaration

    Returns void

    +
  • Defined in interfaces/ioredis-events.ts:7
  • @@ -21,7 +21,7 @@

    Hierarchy

    • JobJson
    +
  • Defined in interfaces/job-json.ts:4
  • @@ -51,77 +51,77 @@

    Properties

    attemptsMade: number
    +
  • Defined in interfaces/job-json.ts:10
  • data: string
    +
  • Defined in interfaces/job-json.ts:7
  • failedReason: string
    +
  • Defined in interfaces/job-json.ts:14
  • finishedOn?: number
    +
  • Defined in interfaces/job-json.ts:11
  • id: string
    +
  • Defined in interfaces/job-json.ts:5
  • name: string
    +
  • Defined in interfaces/job-json.ts:6
  • +
  • Defined in interfaces/job-json.ts:8
  • parent?: ParentKeys
    +
  • Defined in interfaces/job-json.ts:17
  • parentKey?: string
    +
  • Defined in interfaces/job-json.ts:18
  • processedOn?: number
    +
  • Defined in interfaces/job-json.ts:12
  • progress: number | object
    +
  • Defined in interfaces/job-json.ts:9
  • repeatJobKey?: string
    +
  • Defined in interfaces/job-json.ts:19
  • returnvalue: string
    +
  • Defined in interfaces/job-json.ts:16
  • stacktrace: string
    +
  • Defined in interfaces/job-json.ts:15
  • timestamp: number
    +
  • Defined in interfaces/job-json.ts:13
  • @@ -21,7 +21,7 @@

    Hierarchy

    • JobJsonRaw
    +
  • Defined in interfaces/job-json.ts:22
  • @@ -52,82 +52,82 @@

    Properties

    attemptsMade: string
    +
  • Defined in interfaces/job-json.ts:29
  • data: string
    +
  • Defined in interfaces/job-json.ts:25
  • delay: string
    +
  • Defined in interfaces/job-json.ts:26
  • failedReason: string
    +
  • Defined in interfaces/job-json.ts:33
  • finishedOn?: string
    +
  • Defined in interfaces/job-json.ts:30
  • id: string
    +
  • Defined in interfaces/job-json.ts:23
  • name: string
    +
  • Defined in interfaces/job-json.ts:24
  • opts: string
    +
  • Defined in interfaces/job-json.ts:27
  • parent?: string
    +
  • Defined in interfaces/job-json.ts:37
  • parentKey?: string
    +
  • Defined in interfaces/job-json.ts:36
  • processedOn?: string
    +
  • Defined in interfaces/job-json.ts:31
  • progress: string
    +
  • Defined in interfaces/job-json.ts:28
  • returnvalue: string
    +
  • Defined in interfaces/job-json.ts:35
  • rjk?: string
    +
  • Defined in interfaces/job-json.ts:38
  • stacktrace: string[]
    +
  • Defined in interfaces/job-json.ts:34
  • timestamp: string
    +
  • Defined in interfaces/job-json.ts:32
  • @@ -21,7 +21,7 @@

    Hierarchy

    • JobNode
    +
  • Defined in classes/flow-producer.ts:70
  • @@ -38,12 +38,12 @@

    Properties

    children?: JobNode[]
    +
  • Defined in classes/flow-producer.ts:72
  • job: Job<any, any, string>
    +
  • Defined in classes/flow-producer.ts:71
  • @@ -28,7 +28,7 @@

    Hierarchy

    • KeepJobs
    +
  • Defined in interfaces/keep-jobs.ts:8
  • @@ -48,7 +48,7 @@
    +
  • Defined in interfaces/keep-jobs.ts:12
  • count?: number
    @@ -56,7 +56,7 @@
    +
  • Defined in interfaces/keep-jobs.ts:17
  • @@ -21,7 +21,7 @@

    Hierarchy

    • Metrics
    +
  • Defined in interfaces/metrics.ts:1
  • @@ -39,12 +39,12 @@

    Properties

    count: number
    +
  • Defined in interfaces/metrics.ts:8
  • data: number[]
    +
  • Defined in interfaces/metrics.ts:7
  • meta: {
        count: number;
        prevCount: number;
        prevTS: number;
    }
    @@ -58,7 +58,7 @@
    prevCount
    prevTS: number
    +
  • Defined in interfaces/metrics.ts:2
  • @@ -21,7 +21,7 @@

    Hierarchy

    • MetricsOptions
    +
  • Defined in interfaces/metrics-options.ts:5
  • @@ -42,7 +42,7 @@
    +
  • Defined in interfaces/metrics-options.ts:11
  • @@ -39,7 +39,7 @@

    Implemented by

  • Job
  • Job
  • +
  • Defined in interfaces/minimal-job.ts:28
  • @@ -89,7 +89,7 @@
    +
  • Defined in interfaces/minimal-job.ts:74
  • data: DataType
    @@ -97,7 +97,7 @@
    +
  • Defined in interfaces/minimal-job.ts:40
  • delay: number
    @@ -107,7 +107,7 @@
    +
  • Defined in interfaces/minimal-job.ts:65
  • failedReason: string
    @@ -115,7 +115,7 @@
    +
  • Defined in interfaces/minimal-job.ts:78
  • finishedOn?: number
    @@ -123,12 +123,12 @@
    +
  • Defined in interfaces/minimal-job.ts:82
  • id?: string
    +
  • Defined in interfaces/minimal-job.ts:45
  • name: NameType
    @@ -136,7 +136,7 @@
    +
  • Defined in interfaces/minimal-job.ts:36
  • @@ -144,7 +144,7 @@
    +
  • Defined in interfaces/minimal-job.ts:44
  • parent?: ParentKeys
    @@ -152,7 +152,7 @@
    +
  • Defined in interfaces/minimal-job.ts:94
  • parentKey?: string
    @@ -160,7 +160,7 @@
    +
  • Defined in interfaces/minimal-job.ts:90
  • processedOn?: number
    @@ -168,7 +168,7 @@
    +
  • Defined in interfaces/minimal-job.ts:86
  • progress: number | object
    @@ -178,7 +178,7 @@

    0

    +
  • Defined in interfaces/minimal-job.ts:50
  • repeatJobKey?: string
    @@ -186,7 +186,7 @@
    +
  • Defined in interfaces/minimal-job.ts:98
  • returnvalue: ReturnType
    @@ -196,7 +196,7 @@

    null

    +
  • Defined in interfaces/minimal-job.ts:55
  • stacktrace: string[]
    @@ -206,7 +206,7 @@

    null

    +
  • Defined in interfaces/minimal-job.ts:60
  • timestamp: number
    @@ -214,7 +214,7 @@
    +
  • Defined in interfaces/minimal-job.ts:69
  • Accessors

    @@ -226,7 +226,7 @@

    Returns string

    +
  • Defined in interfaces/minimal-job.ts:131
  • +
  • Defined in interfaces/minimal-job.ts:127
  • +
  • Defined in interfaces/minimal-job.ts:136
  • Methods

    @@ -259,7 +259,7 @@
    +
  • Defined in interfaces/minimal-job.ts:103
  • +
  • Defined in interfaces/minimal-job.ts:108
  • +
  • Defined in interfaces/minimal-job.ts:126
  • +
  • Defined in interfaces/minimal-job.ts:114
  • +
  • Defined in interfaces/minimal-job.ts:120
  • @@ -21,7 +21,7 @@

    Hierarchy

    • MoveToWaitingChildrenOpts
    +
  • Defined in interfaces/minimal-job.ts:7
  • @@ -44,7 +44,7 @@
    id
  • queue: string
  • +
  • Defined in interfaces/minimal-job.ts:8
  • @@ -21,7 +21,7 @@

    Hierarchy

    • NodeOpts
    +
  • Defined in classes/flow-producer.ts:47
  • @@ -44,7 +44,7 @@
    +
  • Defined in classes/flow-producer.ts:63
  • id: string
    @@ -52,7 +52,7 @@
    +
  • Defined in classes/flow-producer.ts:59
  • maxChildren?: number
    @@ -60,7 +60,7 @@
    +
  • Defined in classes/flow-producer.ts:67
  • prefix?: string
    @@ -68,7 +68,7 @@
    +
  • Defined in classes/flow-producer.ts:55
  • queueName: string
    @@ -76,7 +76,7 @@
    +
  • Defined in classes/flow-producer.ts:51
  • @@ -21,7 +21,7 @@

    Hierarchy

    • ObliterateOpts
    +
  • Defined in classes/queue.ts:17
  • @@ -43,7 +43,7 @@

    1000

    +
  • Defined in classes/queue.ts:27
  • force?: boolean
    @@ -53,7 +53,7 @@

    false

    +
  • Defined in classes/queue.ts:22
  • @@ -30,7 +30,7 @@

    Hierarchy

    • Parent
    +
  • Defined in interfaces/parent.ts:5
  • @@ -50,27 +50,27 @@

    Properties

    data?: T
    +
  • Defined in interfaces/parent.ts:9
  • name: string
    +
  • Defined in interfaces/parent.ts:6
  • +
  • Defined in interfaces/parent.ts:10
  • prefix?: string
    +
  • Defined in interfaces/parent.ts:7
  • queue?: string
    +
  • Defined in interfaces/parent.ts:8
  • @@ -21,7 +21,7 @@

    Hierarchy

    • ParentKeys
    +
  • Defined in interfaces/parent.ts:13
  • @@ -38,12 +38,12 @@

    Properties

    id: string
    +
  • Defined in interfaces/parent.ts:14
  • queueKey: string
    +
  • Defined in interfaces/parent.ts:15
  • @@ -21,7 +21,7 @@

    Hierarchy

    • ParentMessage
    +
  • Defined in interfaces/parent-message.ts:4
  • @@ -40,22 +40,22 @@

    Properties

    +
  • Defined in interfaces/parent-message.ts:5
  • err?: Error
    +
  • Defined in interfaces/parent-message.ts:7
  • job?: JobJson
    +
  • Defined in interfaces/parent-message.ts:8
  • value?: any
    +
  • Defined in interfaces/parent-message.ts:6
  • @@ -34,7 +34,7 @@

    Hierarchy

  • RepeatBaseOptions
  • WorkerOptions
  • +
  • Defined in interfaces/queue-options.ts:13
  • @@ -56,7 +56,7 @@
    +
  • Defined in interfaces/queue-options.ts:27
  • connection?: ConnectionOptions
    @@ -64,7 +64,7 @@
    +
  • Defined in interfaces/queue-options.ts:17
  • prefix?: string
    @@ -72,7 +72,7 @@
    +
  • Defined in interfaces/queue-options.ts:32
  • sharedConnection?: boolean
    @@ -80,7 +80,7 @@
    +
  • Defined in interfaces/queue-options.ts:22
  • @@ -23,7 +23,7 @@

    Hierarchy

    • QueueEventsListener
    +
  • Defined in classes/queue-events.ts:16
  • @@ -80,7 +80,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:22
  • added: ((args, id) => void)
    @@ -109,7 +109,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:29
  • cleaned: ((args, id) => void)
    @@ -136,7 +136,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:36
  • completed: ((args, id) => void)
    @@ -167,7 +167,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:43
  • delayed: ((args, id) => void)
    @@ -196,7 +196,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:53
  • drained: ((id) => void)
    @@ -220,7 +220,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:62
  • duplicated: ((args, id) => void)
    @@ -247,7 +247,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:69
  • error: ((args) => void)
    @@ -269,7 +269,7 @@
    args: Returns void
    +
  • Defined in classes/queue-events.ts:76
  • failed: ((args, id) => void)
    @@ -300,7 +300,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:83
  • ioredis:close: (() => void)
    @@ -318,7 +318,7 @@

    Returns void

    +
  • Defined in interfaces/ioredis-events.ts:7
  • paused: ((args, id) => void)
    @@ -343,7 +343,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:93
  • progress: ((args, id) => void)
    @@ -375,7 +375,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:103
  • removed: ((args, id) => void)
    @@ -405,7 +405,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:114
  • resumed: ((args, id) => void)
    @@ -430,7 +430,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:121
  • retries-exhausted: ((args, id) => void)
    @@ -459,7 +459,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:128
  • stalled: ((args, id) => void)
    @@ -488,7 +488,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:140
  • waiting: ((args, id) => void)
    @@ -517,7 +517,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:147
  • waiting-children: ((args, id) => void)
    @@ -544,7 +544,7 @@
    id: Returns void
    +
  • Defined in classes/queue-events.ts:154
  • @@ -27,7 +27,7 @@

    Hierarchy

    • QueueEventsOptions
    +
  • Defined in interfaces/queue-options.ts:69
  • @@ -52,7 +52,7 @@
    +
  • Defined in interfaces/queue-options.ts:73
  • blockingConnection?: boolean
    @@ -61,7 +61,7 @@
    +
  • Defined in interfaces/queue-options.ts:27
  • blockingTimeout?: number
    @@ -69,7 +69,7 @@
    +
  • Defined in interfaces/queue-options.ts:84
  • connection?: ConnectionOptions
    @@ -78,7 +78,7 @@
    +
  • Defined in interfaces/queue-options.ts:17
  • lastEventId?: string
    @@ -88,7 +88,7 @@
    +
  • Defined in interfaces/queue-options.ts:79
  • prefix?: string
    @@ -97,7 +97,7 @@
    +
  • Defined in interfaces/queue-options.ts:32
  • sharedConnection?: boolean
    @@ -106,7 +106,7 @@
    +
  • Defined in interfaces/queue-options.ts:22
  • @@ -32,7 +32,7 @@

    Hierarchy

    • QueueListener
    +
  • Defined in classes/queue.ts:30
  • @@ -74,7 +74,7 @@
    type: Returns void
    +
  • Defined in classes/queue.ts:37
  • error: ((err) => void)
    @@ -96,7 +96,7 @@
    err: Returns void
    +
  • Defined in classes/queue.ts:44
  • ioredis:close: (() => void)
    @@ -114,7 +114,7 @@

    Returns void

    +
  • Defined in interfaces/ioredis-events.ts:7
  • paused: (() => void)
    @@ -131,7 +131,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/queue.ts:51
  • progress: ((job, progress) => void)
    @@ -155,7 +155,7 @@
    progress: Returns void
    +
  • Defined in classes/queue.ts:58
  • removed: ((job) => void)
    @@ -177,7 +177,7 @@
    job: Returns void
    +
  • Defined in classes/queue.ts:68
  • resumed: (() => void)
    @@ -194,7 +194,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/queue.ts:75
  • waiting: ((job) => void)
    @@ -216,7 +216,7 @@
    job: Returns void
    +
  • Defined in classes/queue.ts:82
  • @@ -27,7 +27,7 @@

    Hierarchy

    • QueueOptions
    +
  • Defined in interfaces/queue-options.ts:38
  • @@ -53,7 +53,7 @@
    +
  • Defined in interfaces/queue-options.ts:27
  • connection?: ConnectionOptions
    @@ -62,12 +62,12 @@
    +
  • Defined in interfaces/queue-options.ts:17
  • defaultJobOptions?: DefaultJobOptions
    +
  • Defined in interfaces/queue-options.ts:39
  • prefix?: string
    @@ -76,12 +76,12 @@
    +
  • Defined in interfaces/queue-options.ts:32
  • +
  • Defined in interfaces/queue-options.ts:56
  • sharedConnection?: boolean
    @@ -90,7 +90,7 @@
    +
  • Defined in interfaces/queue-options.ts:22
  • streams?: {
        events: {
            maxLen: number;
        };
    }
    @@ -112,7 +112,7 @@
    maxLen
    +
  • Defined in interfaces/queue-options.ts:44
  • @@ -21,7 +21,7 @@

    Hierarchy

    • RateLimiterOptions
    +
  • Defined in interfaces/rate-limiter-options.ts:1
  • @@ -42,7 +42,7 @@
    +
  • Defined in interfaces/rate-limiter-options.ts:12
  • max: number
    @@ -51,7 +51,7 @@
    +
  • Defined in interfaces/rate-limiter-options.ts:6
  • @@ -21,7 +21,7 @@

    Hierarchy

    • RawCommand
    +
  • Defined in classes/redis-connection.ts:25
  • @@ -39,17 +39,17 @@

    Properties

    content: string
    +
  • Defined in classes/redis-connection.ts:26
  • keys: number
    +
  • Defined in classes/redis-connection.ts:28
  • name: string
    +
  • Defined in classes/redis-connection.ts:27
  • @@ -27,7 +27,7 @@

    Hierarchy

    • RepeatBaseOptions
    +
  • Defined in interfaces/queue-options.ts:62
  • @@ -51,7 +51,7 @@
    +
  • Defined in interfaces/queue-options.ts:27
  • connection?: ConnectionOptions
    @@ -60,7 +60,7 @@
    +
  • Defined in interfaces/queue-options.ts:17
  • prefix?: string
    @@ -69,12 +69,12 @@
    +
  • Defined in interfaces/queue-options.ts:32
  • +
  • Defined in interfaces/queue-options.ts:63
  • sharedConnection?: boolean
    @@ -83,7 +83,7 @@
    +
  • Defined in interfaces/queue-options.ts:22
  • @@ -29,7 +29,7 @@

    Hierarchy

    • RepeatOptions
    +
  • Defined in interfaces/repeat-options.ts:8
  • @@ -55,7 +55,7 @@
    +
  • Defined in interfaces/repeat-options.ts:30
  • every?: number
    @@ -64,7 +64,7 @@
    +
  • Defined in interfaces/repeat-options.ts:21
  • immediately?: boolean
    @@ -73,12 +73,12 @@
    +
  • Defined in interfaces/repeat-options.ts:26
  • jobId?: string
    +
  • Defined in interfaces/repeat-options.ts:33
  • limit?: number
    @@ -86,12 +86,12 @@
    +
  • Defined in interfaces/repeat-options.ts:16
  • offset?: number
    +
  • Defined in interfaces/repeat-options.ts:32
  • pattern?: string
    @@ -99,12 +99,12 @@
    +
  • Defined in interfaces/repeat-options.ts:12
  • prevMillis?: number
    +
  • Defined in interfaces/repeat-options.ts:31
  • @@ -34,7 +34,7 @@

    Hierarchy

    • SandboxedJob
    +
  • Defined in interfaces/sandboxed-job.ts:7
  • @@ -68,30 +68,30 @@
    +
  • Defined in interfaces/job-json.ts:10
  • data: T
    +
  • Defined in interfaces/sandboxed-job.ts:9
  • failedReason: string
    +
  • Defined in interfaces/job-json.ts:14
  • finishedOn?: number
    +
  • Defined in interfaces/job-json.ts:11
  • id: string
    +
  • Defined in interfaces/job-json.ts:5
  • log: ((row) => void)
    @@ -109,65 +109,65 @@

    Parameters

    row: any

    Returns void

    +
  • Defined in interfaces/sandboxed-job.ts:12
  • name: string
    +
  • Defined in interfaces/job-json.ts:6
  • +
  • Defined in interfaces/sandboxed-job.ts:10
  • parent?: ParentKeys
    +
  • Defined in interfaces/job-json.ts:17
  • parentKey?: string
    +
  • Defined in interfaces/job-json.ts:18
  • processedOn?: number
    +
  • Defined in interfaces/job-json.ts:12
  • repeatJobKey?: string
    +
  • Defined in interfaces/job-json.ts:19
  • returnValue: R
    +
  • Defined in interfaces/sandboxed-job.ts:14
  • returnvalue: string
    +
  • Defined in interfaces/job-json.ts:16
  • stacktrace: string
    +
  • Defined in interfaces/job-json.ts:15
  • timestamp: number
    +
  • Defined in interfaces/job-json.ts:13
  • updateData: ((data) => Promise<void>)
    @@ -185,7 +185,7 @@

    Parameters

    data: any

    Returns Promise<void>

    +
  • Defined in interfaces/sandboxed-job.ts:13
  • updateProgress: ((value) => Promise<void>)
    @@ -203,7 +203,7 @@

    Parameters

    value: number | object

    Returns Promise<void>

    +
  • Defined in interfaces/sandboxed-job.ts:11
  • @@ -25,7 +25,7 @@

    Hierarchy

    • ScriptMetadata
    +
  • Defined in commands/script-loader.ts:26
  • @@ -49,7 +49,7 @@
    +
  • Defined in commands/script-loader.ts:41
  • includes: ScriptMetadata[]
    @@ -57,7 +57,7 @@
    +
  • Defined in commands/script-loader.ts:49
  • name: string
    @@ -65,12 +65,12 @@
    +
  • Defined in commands/script-loader.ts:30
  • numberOfKeys?: number
    +
  • Defined in commands/script-loader.ts:32
  • path: string
    @@ -79,7 +79,7 @@
    +
  • Defined in commands/script-loader.ts:37
  • token: string
    @@ -87,7 +87,7 @@
    +
  • Defined in commands/script-loader.ts:45
  • @@ -32,7 +32,7 @@

    Hierarchy

    • WorkerListener
    +
  • Defined in classes/worker.ts:38
  • @@ -79,7 +79,7 @@
    prev: Returns void
    +
  • Defined in classes/worker.ts:48
  • closed: (() => void)
    @@ -96,7 +96,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/worker.ts:55
  • closing: ((msg) => void)
    @@ -118,7 +118,7 @@
    msg: Returns void
    +
  • Defined in classes/worker.ts:62
  • completed: ((job, result, prev) => void)
    @@ -144,7 +144,7 @@
    prev: Returns void
    +
  • Defined in classes/worker.ts:69
  • drained: (() => void)
    @@ -163,7 +163,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/worker.ts:82
  • error: ((failedReason) => void)
    @@ -185,7 +185,7 @@
    failedReason: Returns void
    +
  • Defined in classes/worker.ts:89
  • failed: ((job, error, prev) => void)
    @@ -213,7 +213,7 @@
    prev: Returns void
    +
  • Defined in classes/worker.ts:98
  • ioredis:close: (() => void)
    @@ -231,7 +231,7 @@

    Returns void

    +
  • Defined in interfaces/ioredis-events.ts:7
  • paused: (() => void)
    @@ -248,7 +248,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/worker.ts:109
  • progress: ((job, progress) => void)
    @@ -275,7 +275,7 @@
    progress: Returns void
    +
  • Defined in classes/worker.ts:119
  • ready: (() => void)
    @@ -292,7 +292,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/worker.ts:129
  • resumed: (() => void)
    @@ -309,7 +309,7 @@

    Type declaration

    Returns void

    +
  • Defined in classes/worker.ts:136
  • stalled: ((jobId, prev) => void)
    @@ -334,7 +334,7 @@
    prev: Returns void
    +
  • Defined in classes/worker.ts:144
  • @@ -27,7 +27,7 @@

    Hierarchy

    • WorkerOptions
    +
  • Defined in interfaces/worker-options.ts:16
  • @@ -68,7 +68,7 @@

    Default

    true
     
    +
  • Defined in interfaces/worker-options.ts:22
  • blockingConnection?: boolean
    @@ -77,7 +77,7 @@
    +
  • Defined in interfaces/queue-options.ts:27
  • concurrency?: number
    @@ -91,7 +91,7 @@

    Default

    1
     

    See

    https://docs.bullmq.io/guide/workers/concurrency

    +
  • Defined in interfaces/worker-options.ts:31
  • connection?: ConnectionOptions
    @@ -100,7 +100,7 @@
    +
  • Defined in interfaces/queue-options.ts:17
  • drainDelay?: number
    @@ -111,7 +111,7 @@

    Default

    5
     
    +
  • Defined in interfaces/worker-options.ts:99
  • @@ -121,7 +121,7 @@

    https://docs.bullmq.io/guide/rate-limiting

    +
  • Defined in interfaces/worker-options.ts:37
  • lockDuration?: number
    @@ -135,7 +135,7 @@

    Default

    30000
     
    +
  • Defined in interfaces/worker-options.ts:110
  • lockRenewTime?: number
    @@ -145,7 +145,7 @@
    +
  • Defined in interfaces/worker-options.ts:118
  • maxStalledCount?: number
    @@ -158,7 +158,7 @@

    Default

    1
     
    +
  • Defined in interfaces/worker-options.ts:52
  • metrics?: MetricsOptions
    @@ -168,7 +168,7 @@

    https://docs.bullmq.io/guide/metrics

    +
  • Defined in interfaces/worker-options.ts:43
  • prefix?: string
    @@ -177,7 +177,7 @@
    +
  • Defined in interfaces/queue-options.ts:32
  • removeOnComplete?: KeepJobs
    @@ -187,7 +187,7 @@
    +
  • Defined in interfaces/worker-options.ts:66
  • removeOnFail?: KeepJobs
    @@ -197,7 +197,7 @@
    +
  • Defined in interfaces/worker-options.ts:73
  • runRetryDelay?: number
    @@ -208,7 +208,7 @@

    Default

    15000
     
    +
  • Defined in interfaces/worker-options.ts:125
  • settings?: AdvancedOptions
    @@ -216,7 +216,7 @@
    +
  • Defined in interfaces/worker-options.ts:130
  • sharedConnection?: boolean
    @@ -225,7 +225,7 @@
    +
  • Defined in interfaces/queue-options.ts:22
  • skipLockRenewal?: boolean
    @@ -238,7 +238,7 @@

    Default

    false
     
    +
  • Defined in interfaces/worker-options.ts:91
  • skipStalledCheck?: boolean
    @@ -251,7 +251,7 @@

    Default

    false
     
    +
  • Defined in interfaces/worker-options.ts:82
  • stalledInterval?: number
    @@ -262,7 +262,7 @@

    Default

    30000
     
    +
  • Defined in interfaces/worker-options.ts:59
  • useWorkerThreads?: boolean
    @@ -275,7 +275,7 @@

    Default

    false
     
    +
  • Defined in interfaces/worker-options.ts:139
  • @@ -180,7 +180,7 @@

    Member Visibility

    Theme

    @@ -167,7 +167,7 @@

    Member Visibility

    Theme

    @@ -169,7 +169,7 @@

    Member Visibility

    Theme

    @@ -169,7 +169,7 @@

    Member Visibility

    Theme

    @@ -52,7 +52,7 @@

    Member Visibility

    Theme

    @@ -49,7 +49,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -52,7 +52,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -52,7 +52,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -45,7 +45,7 @@

    Member Visibility

    Theme

    @@ -40,7 +40,7 @@

    Member Visibility

    Theme

    @@ -52,7 +52,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -39,7 +39,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -59,7 +59,7 @@

    Member Visibility

    Theme

    @@ -52,7 +52,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -50,7 +50,7 @@

    Member Visibility

    Theme

    @@ -49,7 +49,7 @@

    Member Visibility

    Theme

    @@ -83,7 +83,7 @@

    Member Visibility

    Theme

    @@ -50,7 +50,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -45,7 +45,7 @@

    Member Visibility

    Theme

    @@ -49,7 +49,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -39,7 +39,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -40,7 +40,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -59,7 +59,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -43,7 +43,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -49,7 +49,7 @@

    Member Visibility

    Theme

    @@ -83,7 +83,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -51,7 +51,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -39,7 +39,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -40,7 +40,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -41,7 +41,7 @@

    Member Visibility

    Theme

    @@ -59,7 +59,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -48,7 +48,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -49,7 +49,7 @@

    Member Visibility

    Theme

    @@ -83,7 +83,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -37,7 +37,7 @@
    Optional Optional job: MinimalJob

    Returns Promise<number> | number

    +
  • Defined in types/backoff-strategy.ts:3
  • @@ -18,7 +18,7 @@

    Type alias BulkJobOptions

    BulkJobOptions: Omit<JobsOptions, "repeat">
    +
  • Defined in interfaces/minimal-job.ts:5
  • @@ -18,7 +18,7 @@

    Type alias ClusterOptions

    ClusterOptions: IORedis.ClusterOptions & BaseOptions
    +
  • Defined in interfaces/redis-options.ts:9
  • @@ -18,7 +18,7 @@

    Type alias ConnectionOptions

    ConnectionOptions: RedisOptions | ClusterOptions | IORedis.Redis | IORedis.Cluster
    +
  • Defined in interfaces/redis-options.ts:11
  • @@ -18,7 +18,7 @@

    Type alias EntryId

    EntryId: string
    +
  • Defined in interfaces/redis-streams.ts:6
  • @@ -18,7 +18,7 @@

    Type alias EntryRaw

    EntryRaw: [EntryId, string[]]
    +
  • Defined in interfaces/redis-streams.ts:7
  • @@ -18,7 +18,7 @@

    Type alias FinishedPropValAttribute

    FinishedPropValAttribute: "returnvalue" | "failedReason"
    +
  • Defined in types/finished-status.ts:3
  • @@ -18,7 +18,7 @@

    Type alias FinishedStatus

    FinishedStatus: "completed" | "failed"
    +
  • Defined in types/finished-status.ts:1
  • @@ -18,7 +18,7 @@

    Type alias FlowChildJob

    FlowChildJob: FlowJobBase<Omit<JobsOptions, "parent">>
    +
  • Defined in interfaces/flow-job.ts:13
  • @@ -18,7 +18,7 @@

    Type alias FlowJob

    +
  • Defined in interfaces/flow-job.ts:15
  • @@ -18,7 +18,7 @@

    Type alias FlowQueuesOpts

    FlowQueuesOpts: Record<string, Omit<QueueOptions, "connection" | "prefix">>
    +
  • Defined in interfaces/flow-job.ts:17
  • @@ -18,7 +18,7 @@

    Type alias JobData

    JobData: [JobJsonRaw | number, string?]
    +
  • Defined in classes/scripts.ts:38
  • @@ -25,7 +25,7 @@
    prefix
    queueName: string
    +
  • Defined in types/job-json-sandbox.ts:3
  • @@ -18,7 +18,7 @@

    Type alias JobState

    JobState: FinishedStatus | "active" | "delayed" | "prioritized" | "waiting" | "waiting-children"
    +
  • Defined in types/job-type.ts:3
  • @@ -18,7 +18,7 @@

    Type alias JobType

    JobType: JobState | "paused" | "repeat" | "wait"
    +
  • Defined in types/job-type.ts:11
  • @@ -31,7 +31,7 @@
    Optional
    +
  • Defined in types/job-options.ts:3
  • @@ -18,7 +18,7 @@

    Type alias KeysMap

    KeysMap: {
        [index in string]: string
    }
    +
  • Defined in classes/queue-keys.ts:1
  • @@ -18,7 +18,7 @@

    Type alias MinimalQueue

    MinimalQueue: Pick<QueueBase, "name" | "client" | "toKey" | "keys" | "opts" | "closing" | "waitUntilReady" | "removeListener" | "emit" | "on" | "redisVersion">
    +
  • Defined in types/minimal-queue.ts:3
  • @@ -27,7 +27,7 @@
    Optional
    Optional waitChildrenKey?: string
    +
  • Defined in interfaces/parent.ts:18
  • @@ -45,7 +45,7 @@
    Optional Returns Promise<R>
    +
  • Defined in interfaces/worker-options.ts:11
  • @@ -18,7 +18,7 @@

    Type alias RedisClient

    RedisClient: Redis | Cluster
    +
  • Defined in interfaces/connection.ts:4
  • @@ -39,7 +39,7 @@
    Optional
    +
  • Defined in types/job-options.ts:18
  • @@ -18,7 +18,7 @@

    Type alias RedisOptions

    RedisOptions: IORedis.RedisOptions & BaseOptions
    +
  • Defined in interfaces/redis-options.ts:7
  • @@ -35,7 +35,7 @@
    opts: Optional name: string

    Returns number

    +
  • Defined in types/repeat-strategy.ts:3
  • +
  • Defined in interfaces/sandboxed-job-processor.ts:6
  • @@ -18,7 +18,7 @@

    Type alias StreamName

    StreamName: string
    +
  • Defined in interfaces/redis-streams.ts:5
  • @@ -18,7 +18,7 @@

    Type alias StreamReadRaw

    StreamReadRaw: [StreamName, EntryRaw[]][] | null | undefined
    +
  • Defined in interfaces/redis-streams.ts:8
  • @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -37,7 +37,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -37,7 +37,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -37,7 +37,7 @@

    Member Visibility

    Theme

    @@ -32,7 +32,7 @@

    Member Visibility

    Theme

    @@ -18,7 +18,7 @@

    Variable DELAY_TIME_1Const

    DELAY_TIME_1: 100 = 100
    +
  • Defined in utils.ts:112
  • @@ -18,7 +18,7 @@

    Variable DELAY_TIME_5Const

    DELAY_TIME_5: 5000 = 5000
    +
  • Defined in utils.ts:110
  • @@ -18,7 +18,7 @@

    Variable QUEUE_EVENT_SUFFIXConst

    QUEUE_EVENT_SUFFIX: ":qe" = ':qe'
    +
  • Defined in utils.ts:185
  • @@ -18,7 +18,7 @@

    Variable WORKER_SUFFIXConst

    WORKER_SUFFIX: "" = ''
    +
  • Defined in utils.ts:183
  • @@ -18,7 +18,7 @@

    Variable clientCommandMessageRegConst

    clientCommandMessageReg: RegExp = ...
    +
  • Defined in utils.ts:107
  • @@ -23,7 +23,7 @@

    Type declaration

  • [index: string]: any
  • +
  • Defined in utils.ts:8
  • @@ -18,7 +18,7 @@

    Variable scriptLoaderConst

    scriptLoader: ScriptLoader = ...
    +
  • Defined in commands/index.ts:4