feat: added ack_first (#1917)

* feat: added ack_first * docs: generate API References * feat: ack_first added deprecated and docstrings to Ack_Policy * docs: generate API References * feat: ack_first refactored ack_first check * chore: merge 0.6 * docs: generate API References --------- Co-authored-by: Rusich90 <[email protected]> Co-authored-by: Nikita Pastukhov <[email protected]>
airtai · Nov 26, 2024 · d13624c · d13624c
1 parent de1bca8
commit d13624c
Show file tree

Hide file tree

Showing 130 changed files with 548 additions and 715 deletions.
diff --git a/docs/docs/SUMMARY.md b/docs/docs/SUMMARY.md
diff --git a/...ststream/kafka/subscriber/specified/SpecificationConcurrentDefaultSubscriber.md b/...ststream/kafka/subscriber/specified/SpecificationConcurrentDefaultSubscriber.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.kafka.subscriber.specified.SpecificationConcurrentDefaultSubscriber
diff --git a/...aststream/specification/schema/tag/Tag.md → docs/docs/en/api/faststream/nats/PubAck.md b/...aststream/specification/schema/tag/Tag.md → docs/docs/en/api/faststream/nats/PubAck.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.specification.schema.tag.Tag
+::: nats.js.api.PubAck
diff --git a/...tstream/specification/schema/info/Info.md → .../en/api/faststream/nats/schemas/PubAck.md b/...tstream/specification/schema/info/Info.md → .../en/api/faststream/nats/schemas/PubAck.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.specification.schema.info.Info
+::: nats.js.api.PubAck
diff --git a/...scriber/usecase/PushStreamSubscription.md → ...us/middleware/BasePrometheusMiddleware.md b/...scriber/usecase/PushStreamSubscription.md → ...us/middleware/BasePrometheusMiddleware.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.PushStreamSubscription
+::: faststream.prometheus.middleware.BasePrometheusMiddleware
diff --git a/...criber/usecase/ObjStoreWatchSubscriber.md → ...tion/asyncapi/utils/move_pydantic_refs.md b/...criber/usecase/ObjStoreWatchSubscriber.md → ...tion/asyncapi/utils/move_pydantic_refs.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.ObjStoreWatchSubscriber
+::: faststream.specification.asyncapi.utils.move_pydantic_refs
diff --git a/.../en/api/faststream/specification/asyncapi/v2_6_0/generate/move_pydantic_refs.md b/.../en/api/faststream/specification/asyncapi/v2_6_0/generate/move_pydantic_refs.md
diff --git a/...riber/usecase/ConcurrentCoreSubscriber.md → ...asyncapi/v2_6_0/schema/ApplicationInfo.md b/...riber/usecase/ConcurrentCoreSubscriber.md → ...asyncapi/v2_6_0/schema/ApplicationInfo.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.ConcurrentCoreSubscriber
+::: faststream.specification.asyncapi.v2_6_0.schema.ApplicationInfo
diff --git a/...usecase/ConcurrentPullStreamSubscriber.md → ...yncapi/v2_6_0/schema/ApplicationSchema.md b/...usecase/ConcurrentPullStreamSubscriber.md → ...yncapi/v2_6_0/schema/ApplicationSchema.md
@@ -8,4 +8,4 @@ search:
   boost: 0.5
 ---
 
-::: faststream.nats.subscriber.usecase.ConcurrentPullStreamSubscriber
+::: faststream.specification.asyncapi.v2_6_0.schema.ApplicationSchema
diff --git a/...tstream/specification/asyncapi/v2_6_0/schema/bindings/amqp/channel/from_spec.md b/...tstream/specification/asyncapi/v2_6_0/schema/bindings/amqp/channel/from_spec.md
diff --git a/...specification/asyncapi/v2_6_0/schema/bindings/amqp/channel_binding_from_spec.md b/...specification/asyncapi/v2_6_0/schema/bindings/amqp/channel_binding_from_spec.md
diff --git a/...tream/specification/asyncapi/v2_6_0/schema/bindings/amqp/operation/from_spec.md b/...tream/specification/asyncapi/v2_6_0/schema/bindings/amqp/operation/from_spec.md
diff --git a/...ecification/asyncapi/v2_6_0/schema/bindings/amqp/operation_binding_from_spec.md b/...ecification/asyncapi/v2_6_0/schema/bindings/amqp/operation_binding_from_spec.md
diff --git a/...ream/specification/asyncapi/v2_6_0/schema/bindings/channel_binding_from_spec.md b/...ream/specification/asyncapi/v2_6_0/schema/bindings/channel_binding_from_spec.md
diff --git a/...ream/specification/asyncapi/v2_6_0/schema/bindings/kafka/operation/from_spec.md b/...ream/specification/asyncapi/v2_6_0/schema/bindings/kafka/operation/from_spec.md
diff --git a/...cification/asyncapi/v2_6_0/schema/bindings/kafka/operation_binding_from_spec.md b/...cification/asyncapi/v2_6_0/schema/bindings/kafka/operation_binding_from_spec.md
diff --git a/...tstream/specification/asyncapi/v2_6_0/schema/bindings/main/channel/from_spec.md b/...tstream/specification/asyncapi/v2_6_0/schema/bindings/main/channel/from_spec.md
diff --git a/...specification/asyncapi/v2_6_0/schema/bindings/main/channel_binding_from_spec.md b/...specification/asyncapi/v2_6_0/schema/bindings/main/channel_binding_from_spec.md
diff --git a/...tream/specification/asyncapi/v2_6_0/schema/bindings/main/operation/from_spec.md b/...tream/specification/asyncapi/v2_6_0/schema/bindings/main/operation/from_spec.md
diff --git a/...ecification/asyncapi/v2_6_0/schema/bindings/main/operation_binding_from_spec.md b/...ecification/asyncapi/v2_6_0/schema/bindings/main/operation_binding_from_spec.md
diff --git a/...tream/specification/asyncapi/v2_6_0/schema/bindings/nats/operation/from_spec.md b/...tream/specification/asyncapi/v2_6_0/schema/bindings/nats/operation/from_spec.md
diff --git a/...ecification/asyncapi/v2_6_0/schema/bindings/nats/operation_binding_from_spec.md b/...ecification/asyncapi/v2_6_0/schema/bindings/nats/operation_binding_from_spec.md
diff --git a/...am/specification/asyncapi/v2_6_0/schema/bindings/operation_binding_from_spec.md b/...am/specification/asyncapi/v2_6_0/schema/bindings/operation_binding_from_spec.md
diff --git a/...ream/specification/asyncapi/v2_6_0/schema/bindings/redis/operation/from_spec.md b/...ream/specification/asyncapi/v2_6_0/schema/bindings/redis/operation/from_spec.md
diff --git a/...cification/asyncapi/v2_6_0/schema/bindings/redis/operation_binding_from_spec.md b/...cification/asyncapi/v2_6_0/schema/bindings/redis/operation_binding_from_spec.md
diff --git a/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/channel_from_spec.md b/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/channel_from_spec.md
diff --git a/...cs/en/api/faststream/specification/asyncapi/v2_6_0/schema/channels/from_spec.md b/...cs/en/api/faststream/specification/asyncapi/v2_6_0/schema/channels/from_spec.md
diff --git a/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/contact/from_spec.md b/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/contact/from_spec.md
diff --git a/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/contact_from_spec.md b/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/contact_from_spec.md
diff --git a/docs/docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/docs/from_spec.md b/docs/docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/docs/from_spec.md
diff --git a/docs/docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/docs_from_spec.md b/docs/docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/docs_from_spec.md
diff --git a/.../en/api/faststream/specification/asyncapi/v2_6_0/schema/info/ApplicationInfo.md b/.../en/api/faststream/specification/asyncapi/v2_6_0/schema/info/ApplicationInfo.md
@@ -0,0 +1,11 @@
+---
+# 0.5 - API
+# 2 - Release
+# 3 - Contributing
+# 5 - Template Page
+# 10 - Default
+search:
+  boost: 0.5
+---
+
+::: faststream.specification.asyncapi.v2_6_0.schema.info.ApplicationInfo
diff --git a/docs/docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/info/Info.md b/docs/docs/en/api/faststream/specification/asyncapi/v2_6_0/schema/info/Info.md
diff --git a/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/license/from_spec.md b/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/license/from_spec.md
diff --git a/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/license_from_spec.md b/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/license_from_spec.md
diff --git a/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/message/from_spec.md b/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/message/from_spec.md
diff --git a/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/message_from_spec.md b/...ocs/en/api/faststream/specification/asyncapi/v2_6_0/schema/message_from_spec.md