Merge pull request #1283 from printify/master

makasim · web-flow · commit 58dc83a15c2e · 2023-03-01T17:18:29.000+02:00
MongoDB - Add combined index
diff --git a/pkg/mongodb/MongodbContext.php b/pkg/mongodb/MongodbContext.php
@@ -161,5 +161,6 @@ public function createCollection(): void
         $collection->createIndex(['queue' => 1], ['name' => 'enqueue_queue']);
         $collection->createIndex(['priority' => -1, 'published_at' => 1], ['name' => 'enqueue_priority']);
         $collection->createIndex(['delayed_until' => 1], ['name' => 'enqueue_delayed']);
+        $collection->createIndex(['queue' => 1, 'priority' => -1, 'published_at' => 1, 'delayed_until' => 1], ['name' => 'enqueue_combined']);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -161,5 +161,6 @@ public function createCollection(): void`
`161`	`161`	`$collection->createIndex(['queue' => 1], ['name' => 'enqueue_queue']);`
`162`	`162`	`$collection->createIndex(['priority' => -1, 'published_at' => 1], ['name' => 'enqueue_priority']);`
`163`	`163`	`$collection->createIndex(['delayed_until' => 1], ['name' => 'enqueue_delayed']);`
	`164`	`+ $collection->createIndex(['queue' => 1, 'priority' => -1, 'published_at' => 1, 'delayed_until' => 1], ['name' => 'enqueue_combined']);`
`164`	`165`	`}`
`165`	`166`	`}`