Acquires up to @num_chats pending chats for processing. Uses SKIP LOCKED to prevent multiple replicas from acquiring the same chat.
(ctx context.Context, arg AcquireChatsParams)
| 17 | // Acquires up to @num_chats pending chats for processing. Uses SKIP LOCKED |
| 18 | // to prevent multiple replicas from acquiring the same chat. |
| 19 | AcquireChats(ctx context.Context, arg AcquireChatsParams) ([]Chat, error) |
| 20 | // Blocks until the lock is acquired. |
| 21 | // |
| 22 | // This must be called from within a transaction. The lock will be automatically |
no outgoing calls