0.6.0 #1779
Draft
0.6.0 #1779
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Asyncapi 3.0.0 / support
* feat: refactor logging with FSM * refactor: delete subscribers without dict * refactor: new kafka logging * refactor: new confluent logging * docs: generate API References * tests: fix tests * tests: fix in-memory mocks * confluent: fix self.logger usage * confluent: fix logger usage * confluent: fix logger usage * confluent: make laze logging * confluent: check producer before setup * confluent: fix producer * tests: correct setup call order * fix: remove Confluent producer logger * fix: remove useless option * tests: fix confluent * fix confluent --------- Co-authored-by: Lancetnik <Lancetnik@users.noreply.github.com>
* Feat: add process msg to broker.request methods * Fix: add correct way to use process_msg * Fix: typo * Fix: lint * Fix: rename message vars, avoid overwrite * fix nats types * lint: fix RMQ types * lint: fix Kafka types * lint: fix Redis types * lint: fix Confluent types --------- Co-authored-by: Daniil Dumchenko <dumchenko.de@sibvaleo.com> Co-authored-by: Nikita Pastukhov <diementros@yandex.ru>
* init * AsyncAPI2 * AsyncAPI3 * AsyncAPI facade * AsyncAPI facade refactoring to factory * Rename facade to factory * Remove specs interface from Faststream and AsgiFaststream * Tests update * fixes * tests fixes * tests fix * tests fix * fixes * fixes * docs: generate API References * asyncapi.py rename to facade.py * tests fix * docs: generate API References * merge conflict fix * docs: generate API References * Separation of AMQP bindings creation for AsyncAPI 3.0.0 and 2.6.0 * docs: generate API References * Correct cc for AMQP in AsyncAPI 3.0.0 * docs: generate API References --------- Co-authored-by: KrySeyt <KrySeyt@users.noreply.github.com>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Description
Please include a summary of the change and specify which issue is being addressed. Additionally, provide relevant motivation and context.
fixes #1742, close #1308, close #1228, close #980
Breaking changes:
@broker.subscriber(..., filters=...)removedmessage.decoded_bodyremovedpublish(..., rpc=True)removed@broker.subscriber(..., reply_config=...)removedContext("broker")andContext("logger")moved to local context. They can not be accessed in lifespan hooks anymoreFastStream(broker)is positional-only argument now (preparing toFastStream(*brokers)support)