Commit e5a8f5a
File tree
839 files changed
+10414
-148
lines changed- .github/workflows
- docs/docs
- en
- api/faststream
- app
- asgi
- app
- factories
- handlers
- response
- websocket
- confluent
- broker
- broker
- logging
- registrator
- router
- configs
- broker
- fastapi
- fastapi
- helpers
- admin
- client
- config
- message
- opentelemetry
- middleware
- provider
- parser
- prometheus
- middleware
- provider
- publisher
- config
- factory
- fake
- producer
- specification
- state
- usecase
- response
- schemas
- partition
- security
- subscriber
- config
- factory
- specification
- usecase
- testing
- exceptions
- kafka
- broker
- broker
- logging
- registrator
- router
- configs
- broker
- exceptions
- fastapi
- fastapi
- helpers
- rebalance_listener
- listener
- message
- opentelemetry
- middleware
- provider
- parser
- prometheus
- middleware
- provider
- publisher
- config
- factory
- fake
- producer
- specification
- state
- usecase
- response
- schemas/params
- security
- subscriber
- config
- factory
- specification
- usecase
- testing
- message
- message
- source_type
- utils
- middlewares
- acknowledgement
- conf
- middleware
- exception
- logging
- nats
- broker
- broker
- logging
- registrator
- router
- state
- configs
- broker
- fastapi
- fastapi
- helpers
- bucket_declarer
- obj_storage_declarer
- object_builder
- state
- message
- opentelemetry
- middleware
- provider
- parser
- prometheus
- middleware
- provider
- publisher
- config
- factory
- fake
- producer
- specification
- usecase
- response
- schemas
- js_stream
- kv_watch
- obj_watch
- pull_sub
- security
- subscriber
- adapters
- config
- factory
- specification
- state
- usecases
- basic
- core_subscriber
- key_value_subscriber
- object_storage_subscriber
- stream_basic
- stream_pull_subscriber
- stream_push_subscriber
- testing
- opentelemetry
- baggage
- consts
- middleware
- provider
- params
- no_cast
- params
- prometheus
- container
- manager
- middleware
- provider
- types
- rabbit
- broker
- broker
- logging
- registrator
- router
- configs
- base
- broker
- fastapi
- fastapi
- helpers
- channel_manager
- declarer
- state
- message
- opentelemetry
- middleware
- provider
- parser
- prometheus
- middleware
- provider
- publisher
- config
- factory
- fake
- options
- producer
- specification
- usecase
- response
- schemas
- channel
- constants
- exchange
- proto
- queue
- security
- subscriber
- config
- factory
- specification
- usecase
- testing
- utils
- redis
- annotations
- broker
- broker
- logging
- registrator
- router
- configs
- broker
- state
- fastapi
- fastapi
- message
- opentelemetry
- middleware
- provider
- parser
- prometheus
- middleware
- provider
- publisher
- config
- factory
- fake
- producer
- specification
- usecase
- response
- schemas
- list_sub
- proto
- pub_sub
- stream_sub
- security
- subscriber
- config
- factory
- specification
- usecases
- basic
- channel_subscriber
- list_subscriber
- stream_subscriber
- testing
- response
- publish_type
- response
- utils
- security
- specification
- asyncapi
- factory
- message
- site
- utils
- v2_6_0
- generate
- schema
- bindings
- amqp
- channel
- operation
- kafka
- channel
- operation
- main
- channel
- operation
- nats
- channel
- operation
- redis
- channel
- operation
- sqs
- channel
- operation
- channels
- components
- contact
- docs
- info
- license
- message
- operations
- schema
- servers
- tag
- utils
- v3_0_0
- generate
- schema
- bindings
- amqp
- channel
- operation
- kafka
- main
- channel
- operation
- nats
- redis
- sqs
- channels
- components
- contact
- docs
- info
- license
- message
- operations
- schema
- servers
- tag
- utils
- base
- generator
- info
- schema
- specification
- schema
- bindings
- amqp
- http
- kafka
- main
- nats
- redis
- sqs
- broker
- extra
- contact
- external_docs
- license
- tag
- message
- model
- operation
- model
- publisher
- subscriber
- faststream/_internal/cli
- scripts
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
839 files changed
+10414
-148
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
7 | | - | |
| 7 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
24 | 24 | | |
25 | 25 | | |
26 | 26 | | |
27 | | - | |
28 | | - | |
29 | 27 | | |
30 | 28 | | |
31 | 29 | | |
| |||
295 | 293 | | |
296 | 294 | | |
297 | 295 | | |
298 | | - | |
| 296 | + | |
299 | 297 | | |
300 | 298 | | |
301 | 299 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
36 | 36 | | |
37 | 37 | | |
38 | 38 | | |
39 | | - | |
| 39 | + | |
40 | 40 | | |
41 | 41 | | |
42 | 42 | | |
43 | 43 | | |
| 44 | + | |
44 | 45 | | |
45 | 46 | | |
46 | 47 | | |
47 | 48 | | |
48 | 49 | | |
49 | | - | |
| 50 | + | |
50 | 51 | | |
51 | 52 | | |
52 | 53 | | |
53 | 54 | | |
54 | | - | |
55 | | - | |
56 | | - | |
57 | | - | |
58 | | - | |
59 | | - | |
60 | | - | |
61 | | - | |
62 | | - | |
63 | | - | |
| 55 | + | |
64 | 56 | | |
65 | 57 | | |
66 | 58 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
12 | | - | |
13 | | - | |
| 11 | + | |
14 | 12 | | |
15 | 13 | | |
16 | 14 | | |
17 | 15 | | |
18 | 16 | | |
19 | 17 | | |
20 | 18 | | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
21 | 24 | | |
22 | 25 | | |
23 | | - | |
| 26 | + | |
24 | 27 | | |
25 | 28 | | |
26 | 29 | | |
| |||
159 | 162 | | |
160 | 163 | | |
161 | 164 | | |
| 165 | + | |
| 166 | + | |
| 167 | + | |
| 168 | + | |
| 169 | + | |
| 170 | + | |
| 171 | + | |
| 172 | + | |
Large diffs are not rendered by default.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
0 commit comments