Doc of delayed queues

Tempest plugin
Depends-On: I0a15600a836f609e4b992f8a80ba887e312aa780

Implement blueprint delayed-queues
Change-Id: Iea7a68be8b20f3eb20ed035c33243cc843a22365
This commit is contained in:
yangzhenyu 2017-10-19 14:45:20 +08:00
parent ba244af502
commit 949d496263
6 changed files with 34 additions and 0 deletions

View File

@ -53,6 +53,8 @@ be between 60 and 1209600 seconds (14 days). Note that the server might not
actually delete the message until its age has reached up to (ttl + 60) seconds, actually delete the message until its age has reached up to (ttl + 60) seconds,
to allow for flexibility in storage implementations. to allow for flexibility in storage implementations.
The ``delay`` attribute specifies how long the message can be claimed.
The value of ``delay`` must be between 0 and 900 seconds (15 mins).
Normal response codes: 201 Normal response codes: 201
@ -133,6 +135,7 @@ Request Parameters
- limit: limit - limit: limit
- echo: echo - echo: echo
- include_claimed: include_claimed - include_claimed: include_claimed
- include_delayed: include_delayed
Response Parameters Response Parameters

View File

@ -103,6 +103,13 @@ include_claimed:
description: description:
Indicate if the messages list should include the claimed messages. Indicate if the messages list should include the claimed messages.
include_delayed:
type: boolean
in: query
required: false
description:
Indicate if the messages list should include the delayed messages.
limit: limit:
type: integer type: integer
in: query in: query
@ -155,6 +162,17 @@ _dead_letter_queue_messages_ttl:
not set, current TTL will be kept. It is one of the ``reserved attributes`` not set, current TTL will be kept. It is one of the ``reserved attributes``
of Zaqar queues. of Zaqar queues.
_default_message_delay:
type: string
in: body
required: False
description: |
The delay of messages defined for a queue. When the messages send to
the queue, it will be delayed for some times and means it can not be
claimed until the delay expired. And user can define a queue's level
value for delay, also can define a message's level. The latter has
a higher priority.
_default_message_ttl: _default_message_ttl:
type: integer type: integer
in: body in: body

View File

@ -76,6 +76,8 @@ When create queue, user can specify metadata for the queue. Currently, Zaqar
supports below metadata: _flavor, _max_claim_count, _dead_letter_queue and supports below metadata: _flavor, _max_claim_count, _dead_letter_queue and
_dead_letter_queue_messages_ttl. _dead_letter_queue_messages_ttl.
In order to support the delayed queues, now add a metadata
``_default_message_delay``.
Normal response codes: 201, 204 Normal response codes: 201, 204
@ -94,6 +96,7 @@ Request Parameters
- queue_name: queue_name - queue_name: queue_name
- _dead_letter_queue: _dead_letter_queue - _dead_letter_queue: _dead_letter_queue
- _dead_letter_queue_messages_ttl: _dead_letter_queue_messages_ttl - _dead_letter_queue_messages_ttl: _dead_letter_queue_messages_ttl
- _default_message_delay: _default_message_delay
- _default_message_ttl: _default_message_ttl - _default_message_ttl: _default_message_ttl
- _flavor: _flavor - _flavor: _flavor
- _max_claim_count: _max_claim_count - _max_claim_count: _max_claim_count
@ -189,6 +192,7 @@ Response Parameters
.. rest_parameters:: parameters.yaml .. rest_parameters:: parameters.yaml
- _max_messages_post_size: _max_messages_post_size - _max_messages_post_size: _max_messages_post_size
- _default_message_delay: _default_message_delay
- _default_message_ttl: _default_message_ttl - _default_message_ttl: _default_message_ttl
Response Example Response Example

View File

@ -2,6 +2,7 @@
"messages": [ "messages": [
{ {
"ttl": 300, "ttl": 300,
"delay": 20,
"body": { "body": {
"event": "BackupStarted", "event": "BackupStarted",
"backup_id": "c378813c-3f0b-11e2-ad92-7823d2b0f3ce" "backup_id": "c378813c-3f0b-11e2-ad92-7823d2b0f3ce"

View File

@ -1,5 +1,6 @@
{ {
"_max_messages_post_size": 262144, "_max_messages_post_size": 262144,
"_default_message_ttl": 3600, "_default_message_ttl": 3600,
"_default_message_delay": 30,
"description": "Queue for international traffic billing." "description": "Queue for international traffic billing."
} }

View File

@ -0,0 +1,7 @@
---
features:
- |
Support for delayed queues is added for MongoDB, Redis and Swift. With
this feature, if the queue is a delayed queue, its message will be
delayed some time to be claimed. New reseved metadata key of queue
is added: _default_message_delay.