| docs / docs_src / confluent / security / custom_config.py |
(no class) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / asyncapi / asyncapi_customization / payload_info.py |
(no class) |
|
86% |
7 |
1 |
5 |
|
100% |
0 |
0 |
|
86% |
| docs / docs_src / getting_started / asyncapi / serve.py |
(no class) |
|
0% |
5 |
5 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / config / settings_base_1.py |
(no class) |
|
0% |
4 |
4 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / confluent / basic.py |
(no class) |
|
0% |
9 |
9 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / kafka / basic.py |
(no class) |
|
0% |
9 |
9 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / nats / basic.py |
(no class) |
|
0% |
9 |
9 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / rabbit / basic.py |
(no class) |
|
0% |
9 |
9 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / redis / basic.py |
(no class) |
|
0% |
9 |
9 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / confluent_base_run.py |
(no class) |
|
0% |
4 |
4 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / kafka_base_run.py |
(no class) |
|
0% |
4 |
4 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / nats_base_run.py |
(no class) |
|
0% |
4 |
4 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / rabbit_base_run.py |
(no class) |
|
0% |
4 |
4 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / redis_base_run.py |
(no class) |
|
0% |
4 |
4 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / confluent_telemetry.py |
(no class) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / kafka_telemetry.py |
(no class) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / mqtt_telemetry.py |
(no class) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / nats_telemetry.py |
(no class) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / rabbit_telemetry.py |
(no class) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / redis_telemetry.py |
(no class) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / confluent.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / confluent_asgi.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / kafka.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / kafka_asgi.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / mqtt.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / mqtt_asgi.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / nats.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / nats_asgi.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / rabbit.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / rabbit_asgi.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / redis.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / redis_asgi.py |
(no class) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / confluent / delay_equal.py |
(no class) |
|
69% |
13 |
4 |
2 |
|
100% |
0 |
0 |
|
69% |
| docs / docs_src / getting_started / routers / kafka / delay_equal.py |
(no class) |
|
69% |
13 |
4 |
2 |
|
100% |
0 |
0 |
|
69% |
| docs / docs_src / getting_started / routers / nats / delay_equal.py |
(no class) |
|
69% |
13 |
4 |
2 |
|
100% |
0 |
0 |
|
69% |
| docs / docs_src / getting_started / routers / rabbit / delay_equal.py |
(no class) |
|
69% |
13 |
4 |
2 |
|
100% |
0 |
0 |
|
69% |
| docs / docs_src / getting_started / routers / redis / delay_equal.py |
(no class) |
|
69% |
13 |
4 |
3 |
|
100% |
0 |
0 |
|
69% |
| docs / docs_src / getting_started / subscription / confluent / dynamic.py |
(no class) |
|
0% |
7 |
7 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / dynamic_iter.py |
(no class) |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / msgspec_fields.py |
(no class) |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / msgspec_struct.py |
(no class) |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / dynamic.py |
(no class) |
|
0% |
7 |
7 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / dynamic_iter.py |
(no class) |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / msgspec_fields.py |
(no class) |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / msgspec_struct.py |
(no class) |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / dynamic.py |
(no class) |
|
0% |
7 |
7 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / dynamic_iter.py |
(no class) |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / msgspec_fields.py |
(no class) |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / msgspec_struct.py |
(no class) |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / dynamic.py |
(no class) |
|
0% |
7 |
7 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / dynamic_iter.py |
(no class) |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / msgspec_fields.py |
(no class) |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / msgspec_struct.py |
(no class) |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / dynamic.py |
(no class) |
|
0% |
7 |
7 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / dynamic_iter.py |
(no class) |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / msgspec_fields.py |
(no class) |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / msgspec_struct.py |
(no class) |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / index / dependencies_annotated.py |
(no class) |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / integrations / no_http_frameworks_integrations / aiogram.py |
(no class) |
|
0% |
14 |
14 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / kafka / security / sasl_oauthbearer.py |
(no class) |
|
0% |
2 |
2 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / redis / stream / claiming_manual_ack.py |
(no class) |
|
90% |
10 |
1 |
4 |
|
100% |
0 |
0 |
|
90% |
| examples / fastapi_integration / testing.py |
(no class) |
|
86% |
14 |
2 |
5 |
|
100% |
0 |
0 |
|
86% |
| examples / nats / e07_object_storage.py |
(no class) |
|
80% |
10 |
2 |
5 |
|
100% |
0 |
0 |
|
80% |
| faststream / _internal / _compat.py |
(no class) |
|
61% |
66 |
26 |
91 |
|
50% |
2 |
1 |
|
60% |
| faststream / _internal / application.py |
StartAbleApplication |
|
91% |
22 |
2 |
0 |
|
88% |
8 |
1 |
|
90% |
| faststream / _internal / application.py |
(no class) |
|
80% |
46 |
9 |
30 |
|
0% |
2 |
0 |
|
77% |
| faststream / _internal / basic_types.py |
(no class) |
|
73% |
33 |
9 |
20 |
|
17% |
6 |
1 |
|
64% |
| faststream / _internal / broker / broker.py |
BrokerUsecase |
|
96% |
28 |
1 |
5 |
|
100% |
8 |
0 |
|
97% |
| faststream / _internal / broker / pub_base.py |
BrokerPublishMixin |
|
89% |
19 |
2 |
4 |
|
100% |
6 |
0 |
|
92% |
| faststream / _internal / broker / registrator.py |
Registrator |
|
96% |
28 |
1 |
8 |
|
100% |
8 |
0 |
|
97% |
| faststream / _internal / cli / docs.py |
(no class) |
|
8% |
52 |
48 |
87 |
|
9% |
22 |
0 |
|
8% |
| faststream / _internal / cli / main.py |
(no class) |
|
59% |
87 |
36 |
83 |
|
53% |
30 |
10 |
|
57% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
UvicornExtraConfig |
|
0% |
4 |
4 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
UvicornMultiprocess |
|
0% |
5 |
5 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
ASGIMultiprocess |
|
0% |
11 |
11 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
(no class) |
|
0% |
10 |
10 |
10 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / basereload.py |
BaseReload |
|
95% |
22 |
1 |
4 |
|
100% |
4 |
0 |
|
96% |
| faststream / _internal / cli / supervisors / multiprocess.py |
Multiprocess |
|
45% |
22 |
12 |
6 |
|
33% |
6 |
0 |
|
43% |
| faststream / _internal / cli / utils / errors.py |
(no class) |
|
0% |
10 |
10 |
4 |
|
0% |
4 |
0 |
|
0% |
| faststream / _internal / cli / utils / imports.py |
(no class) |
|
69% |
65 |
20 |
17 |
|
67% |
18 |
4 |
|
69% |
| faststream / _internal / cli / utils / logs.py |
(no class) |
|
48% |
60 |
31 |
21 |
|
36% |
14 |
1 |
|
46% |
| faststream / _internal / configs / broker.py |
BrokerConfig |
|
67% |
3 |
1 |
1 |
|
100% |
0 |
0 |
|
67% |
| faststream / _internal / configs / broker.py |
ConfigComposition |
|
97% |
37 |
1 |
2 |
|
100% |
18 |
0 |
|
98% |
| faststream / _internal / endpoint / call_wrapper.py |
HandlerCallWrapper |
|
95% |
39 |
2 |
0 |
|
93% |
14 |
1 |
|
94% |
| faststream / _internal / endpoint / publisher / fake.py |
FakePublisher |
|
75% |
8 |
2 |
4 |
|
100% |
2 |
0 |
|
80% |
| faststream / _internal / endpoint / publisher / specification.py |
PublisherSpecification |
|
95% |
19 |
1 |
4 |
|
75% |
8 |
2 |
|
89% |
| faststream / _internal / endpoint / subscriber / call_item.py |
HandlerItem |
|
87% |
31 |
4 |
11 |
|
75% |
12 |
3 |
|
84% |
| faststream / _internal / endpoint / subscriber / specification.py |
SubscriberSpecification |
|
88% |
17 |
2 |
2 |
|
83% |
6 |
1 |
|
87% |
| faststream / _internal / endpoint / subscriber / supervisor.py |
_SupervisorCache |
|
94% |
17 |
1 |
0 |
|
90% |
10 |
1 |
|
93% |
| faststream / _internal / endpoint / subscriber / usecase.py |
SubscriberUsecase |
|
94% |
101 |
6 |
41 |
|
89% |
36 |
2 |
|
93% |
| faststream / _internal / fastapi / _compat.py |
(no class) |
|
66% |
38 |
13 |
16 |
|
100% |
0 |
0 |
|
66% |
| faststream / _internal / fastapi / get_dependant.py |
(no class) |
|
90% |
29 |
3 |
83 |
|
100% |
8 |
0 |
|
92% |
| faststream / _internal / fastapi / route.py |
(no class) |
|
97% |
63 |
2 |
25 |
|
85% |
20 |
3 |
|
94% |
| faststream / _internal / fastapi / router.py |
StreamRouter |
|
97% |
66 |
2 |
29 |
|
89% |
18 |
2 |
|
95% |
| faststream / _internal / logger / formatter.py |
ColourizedFormatter |
|
100% |
7 |
0 |
0 |
|
75% |
4 |
1 |
|
91% |
| faststream / _internal / logger / logger_proxy.py |
NotSetLoggerObject |
|
33% |
3 |
2 |
2 |
|
100% |
0 |
0 |
|
33% |
| faststream / _internal / logger / logger_proxy.py |
EmptyLoggerObject |
|
0% |
1 |
1 |
3 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / logger / logging.py |
ExtendedFilter |
|
100% |
11 |
0 |
0 |
|
75% |
4 |
1 |
|
93% |
| faststream / _internal / logger / params_storage.py |
ManualLoggerStorage |
|
67% |
3 |
1 |
2 |
|
100% |
0 |
0 |
|
67% |
| faststream / _internal / logger / params_storage.py |
DefaultLoggerStorage |
|
67% |
6 |
2 |
3 |
|
50% |
2 |
1 |
|
62% |
| faststream / _internal / parser.py |
DefaultCodec |
|
50% |
2 |
1 |
0 |
|
100% |
0 |
0 |
|
50% |
| faststream / _internal / producer.py |
ProducerUnset |
|
0% |
8 |
8 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / proto.py |
NameRequired |
|
88% |
8 |
1 |
3 |
|
75% |
4 |
1 |
|
83% |
| faststream / _internal / utils / functions.py |
FakeContext |
|
50% |
6 |
3 |
1 |
|
50% |
4 |
0 |
|
50% |
| faststream / _internal / utils / nuid.py |
NUID |
|
81% |
21 |
4 |
0 |
|
75% |
4 |
1 |
|
80% |
| faststream / _internal / utils / path.py |
(no class) |
|
84% |
32 |
5 |
5 |
|
80% |
10 |
2 |
|
83% |
| faststream / asgi / app.py |
CliRunState |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / asgi / app.py |
AsgiFastStream |
|
83% |
92 |
16 |
3 |
|
86% |
22 |
1 |
|
83% |
| faststream / asgi / app.py |
(no class) |
|
78% |
32 |
7 |
34 |
|
0% |
6 |
0 |
|
66% |
| faststream / asgi / factories / asyncapi / docs.py |
(no class) |
|
100% |
8 |
0 |
10 |
|
50% |
2 |
1 |
|
90% |
| faststream / asgi / factories / asyncapi / try_it_out.py |
TryItOutProcessor |
|
86% |
29 |
4 |
0 |
|
75% |
8 |
2 |
|
84% |
| faststream / asgi / factories / asyncapi / try_it_out.py |
(no class) |
|
95% |
40 |
2 |
20 |
|
100% |
0 |
0 |
|
95% |
| faststream / asgi / handlers.py |
HttpHandler |
|
92% |
13 |
1 |
14 |
|
100% |
0 |
0 |
|
92% |
| faststream / asgi / handlers.py |
(no class) |
|
96% |
23 |
1 |
50 |
|
100% |
4 |
0 |
|
96% |
| faststream / asgi / request.py |
AsgiRequest |
|
79% |
43 |
9 |
0 |
|
59% |
22 |
9 |
|
72% |
| faststream / asgi / response.py |
(no class) |
|
100% |
18 |
0 |
7 |
|
83% |
6 |
1 |
|
96% |
| faststream / cli.py |
(no class) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / helpers / admin.py |
AdminService |
|
94% |
18 |
1 |
0 |
|
67% |
6 |
2 |
|
88% |
| faststream / confluent / helpers / client.py |
AsyncConfluentProducer |
|
83% |
47 |
8 |
2 |
|
64% |
22 |
8 |
|
77% |
| faststream / confluent / helpers / client.py |
AsyncConfluentConsumer |
|
84% |
31 |
5 |
67 |
|
71% |
14 |
4 |
|
80% |
| faststream / confluent / helpers / client.py |
BatchBuilder |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / confluent / helpers / config.py |
ConfluentFastConfig |
|
85% |
13 |
2 |
1 |
|
50% |
4 |
2 |
|
76% |
| faststream / confluent / helpers / config.py |
(no class) |
|
100% |
94 |
0 |
11 |
|
83% |
6 |
1 |
|
99% |
| faststream / confluent / opentelemetry / provider.py |
BaseConfluentTelemetrySettingsProvider |
|
75% |
8 |
2 |
0 |
|
50% |
4 |
2 |
|
67% |
| faststream / confluent / opentelemetry / provider.py |
ConfluentTelemetrySettingsProvider |
|
80% |
5 |
1 |
0 |
|
50% |
2 |
1 |
|
71% |
| faststream / confluent / parser.py |
(no class) |
|
90% |
10 |
1 |
18 |
|
50% |
2 |
1 |
|
83% |
| faststream / confluent / publisher / producer.py |
AsyncConfluentFastProducer |
|
0% |
5 |
5 |
4 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / producer.py |
AsyncConfluentFastProducerImpl |
|
92% |
24 |
2 |
0 |
|
75% |
4 |
1 |
|
89% |
| faststream / confluent / publisher / state.py |
EmptyProducerState |
|
0% |
4 |
4 |
2 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / state.py |
RealProducer |
|
80% |
5 |
1 |
0 |
|
100% |
0 |
0 |
|
80% |
| faststream / confluent / publisher / usecase.py |
LogicPublisher |
|
82% |
11 |
2 |
0 |
|
100% |
0 |
0 |
|
82% |
| faststream / confluent / response.py |
KafkaPublishCommand |
|
100% |
21 |
0 |
0 |
|
88% |
8 |
1 |
|
97% |
| faststream / confluent / schemas / partition.py |
TopicPartition |
|
83% |
12 |
2 |
0 |
|
50% |
4 |
2 |
|
75% |
| faststream / confluent / security.py |
(no class) |
|
96% |
28 |
1 |
7 |
|
94% |
16 |
1 |
|
95% |
| faststream / confluent / subscriber / specification.py |
KafkaSubscriberSpecification |
|
77% |
13 |
3 |
0 |
|
50% |
4 |
0 |
|
71% |
| faststream / confluent / subscriber / usecase.py |
LogicSubscriber |
|
98% |
49 |
1 |
8 |
|
90% |
10 |
1 |
|
97% |
| faststream / confluent / testing.py |
TestKafkaBroker |
|
89% |
19 |
2 |
2 |
|
88% |
8 |
1 |
|
89% |
| faststream / confluent / testing.py |
FakeProducer |
|
83% |
24 |
4 |
0 |
|
70% |
10 |
1 |
|
79% |
| faststream / confluent / testing.py |
MockConfluentMessage |
|
79% |
19 |
4 |
0 |
|
50% |
2 |
1 |
|
76% |
| faststream / confluent / testing.py |
(no class) |
|
92% |
49 |
4 |
30 |
|
100% |
8 |
0 |
|
93% |
| faststream / exceptions.py |
StopApplication |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / exceptions.py |
StartupValidationError |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / exceptions.py |
ContextError |
|
67% |
3 |
1 |
0 |
|
100% |
0 |
0 |
|
67% |
| faststream / kafka / configs / broker.py |
KafkaBrokerConfig |
|
87% |
15 |
2 |
0 |
|
75% |
4 |
1 |
|
84% |
| faststream / kafka / exceptions.py |
BatchBufferOverflowException |
|
50% |
2 |
1 |
0 |
|
100% |
0 |
0 |
|
50% |
| faststream / kafka / helpers / rebalance_listener.py |
_LoggingListener |
|
78% |
9 |
2 |
5 |
|
50% |
2 |
1 |
|
73% |
| faststream / kafka / helpers / rebalance_listener.py |
(no class) |
|
94% |
18 |
1 |
9 |
|
75% |
4 |
1 |
|
91% |
| faststream / kafka / message.py |
KafkaAckableMessage |
|
100% |
11 |
0 |
0 |
|
75% |
4 |
1 |
|
93% |
| faststream / kafka / opentelemetry / provider.py |
BaseKafkaTelemetrySettingsProvider |
|
75% |
8 |
2 |
0 |
|
50% |
4 |
2 |
|
67% |
| faststream / kafka / opentelemetry / provider.py |
KafkaTelemetrySettingsProvider |
|
80% |
5 |
1 |
0 |
|
50% |
2 |
1 |
|
71% |
| faststream / kafka / publisher / producer.py |
AioKafkaFastProducer |
|
0% |
5 |
5 |
4 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / producer.py |
AioKafkaFastProducerImpl |
|
88% |
33 |
4 |
0 |
|
90% |
10 |
1 |
|
88% |
| faststream / kafka / publisher / producer.py |
FakeAioKafkaFastProducer |
|
0% |
1 |
1 |
6 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / state.py |
EmptyProducerState |
|
0% |
3 |
3 |
2 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / state.py |
RealProducer |
|
40% |
5 |
3 |
0 |
|
100% |
0 |
0 |
|
40% |
| faststream / kafka / publisher / usecase.py |
LogicPublisher |
|
82% |
11 |
2 |
1 |
|
100% |
0 |
0 |
|
82% |
| faststream / kafka / response.py |
KafkaPublishCommand |
|
100% |
21 |
0 |
0 |
|
88% |
8 |
1 |
|
97% |
| faststream / kafka / security.py |
(no class) |
|
96% |
25 |
1 |
6 |
|
93% |
14 |
1 |
|
95% |
| faststream / kafka / subscriber / specification.py |
KafkaSubscriberSpecification |
|
80% |
15 |
3 |
0 |
|
67% |
6 |
0 |
|
76% |
| faststream / kafka / subscriber / usecase.py |
LogicSubscriber |
|
92% |
71 |
6 |
5 |
|
77% |
22 |
3 |
|
88% |
| faststream / kafka / subscriber / usecase.py |
ConcurrentBetweenPartitionsSubscriber |
|
92% |
25 |
2 |
1 |
|
70% |
10 |
3 |
|
86% |
| faststream / kafka / testing.py |
TestKafkaBroker |
|
89% |
19 |
2 |
6 |
|
88% |
8 |
1 |
|
89% |
| faststream / kafka / testing.py |
FakeProducer |
|
83% |
24 |
4 |
0 |
|
70% |
10 |
1 |
|
79% |
| faststream / kafka / testing.py |
(no class) |
|
91% |
45 |
4 |
33 |
|
100% |
10 |
0 |
|
93% |
| faststream / message / message.py |
StreamMessage |
|
96% |
26 |
1 |
18 |
|
88% |
8 |
1 |
|
94% |
| faststream / middlewares / acknowledgement / middleware.py |
_AcknowledgementMiddleware |
|
92% |
39 |
3 |
7 |
|
85% |
26 |
4 |
|
89% |
| faststream / middlewares / exception.py |
_BaseExceptionMiddleware |
|
95% |
21 |
1 |
2 |
|
90% |
10 |
1 |
|
94% |
| faststream / middlewares / logging.py |
_LoggingMiddleware |
|
100% |
11 |
0 |
5 |
|
50% |
2 |
1 |
|
92% |
| faststream / mqtt / broker / broker.py |
MQTTBroker |
|
92% |
36 |
3 |
1 |
|
92% |
12 |
1 |
|
92% |
| faststream / mqtt / broker / config.py |
MQTTBrokerConfig |
|
76% |
17 |
4 |
0 |
|
83% |
6 |
1 |
|
78% |
| faststream / mqtt / broker / logging.py |
MQTTParamsStorage |
|
100% |
9 |
0 |
3 |
|
50% |
2 |
1 |
|
91% |
| faststream / mqtt / broker / registrator.py |
MQTTRegistrator |
|
83% |
12 |
2 |
0 |
|
75% |
4 |
1 |
|
81% |
| faststream / mqtt / message.py |
MQTTMessage |
|
75% |
4 |
1 |
1 |
|
50% |
2 |
1 |
|
67% |
| faststream / mqtt / parser.py |
MQTTParserV311 |
|
88% |
8 |
1 |
0 |
|
100% |
0 |
0 |
|
88% |
| faststream / mqtt / parser.py |
MQTTParserV5 |
|
100% |
12 |
0 |
0 |
|
50% |
4 |
2 |
|
88% |
| faststream / mqtt / publisher / producer.py |
ZmqttBaseProducer |
|
71% |
14 |
4 |
2 |
|
50% |
2 |
1 |
|
69% |
| faststream / mqtt / publisher / producer.py |
ZmqttProducerV311 |
|
56% |
16 |
7 |
0 |
|
75% |
4 |
1 |
|
60% |
| faststream / mqtt / publisher / producer.py |
ZmqttFakeProducer |
|
0% |
1 |
1 |
3 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / response.py |
MQTTResponse |
|
0% |
4 |
4 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / response.py |
MQTTPublishCommand |
|
88% |
8 |
1 |
14 |
|
50% |
2 |
1 |
|
80% |
| faststream / mqtt / security.py |
(no class) |
|
62% |
13 |
5 |
4 |
|
38% |
8 |
1 |
|
52% |
| faststream / mqtt / subscriber / factory.py |
(no class) |
|
89% |
9 |
1 |
10 |
|
50% |
2 |
1 |
|
82% |
| faststream / mqtt / subscriber / specification.py |
MQTTSubscriberSpecification |
|
90% |
10 |
1 |
0 |
|
75% |
4 |
1 |
|
86% |
| faststream / mqtt / subscriber / usecase.py |
MQTTBaseSubscriber |
|
98% |
54 |
1 |
1 |
|
75% |
16 |
4 |
|
93% |
| faststream / mqtt / subscriber / usecase.py |
MQTTConcurrentSubscriber |
|
0% |
5 |
5 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / mqtt / testing.py |
_BlockingSubscription |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / testing.py |
FakeProducer |
|
93% |
27 |
2 |
0 |
|
83% |
12 |
2 |
|
90% |
| faststream / nats / broker / broker.py |
NatsBroker |
|
85% |
74 |
11 |
10 |
|
64% |
22 |
4 |
|
80% |
| faststream / nats / broker / logging.py |
NatsParamsStorage |
|
100% |
11 |
0 |
3 |
|
50% |
2 |
1 |
|
92% |
| faststream / nats / broker / state.py |
BrokerState |
|
78% |
18 |
4 |
0 |
|
50% |
4 |
2 |
|
73% |
| faststream / nats / helpers / bucket_declarer.py |
KVBucketDeclarer |
|
90% |
10 |
1 |
0 |
|
75% |
4 |
1 |
|
86% |
| faststream / nats / helpers / obj_storage_declarer.py |
OSBucketDeclarer |
|
90% |
10 |
1 |
0 |
|
75% |
4 |
1 |
|
86% |
| faststream / nats / helpers / state.py |
EmptyConnectionState |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / helpers / stream_builder.py |
StreamBuilder |
|
71% |
14 |
4 |
0 |
|
62% |
8 |
1 |
|
68% |
| faststream / nats / message.py |
NatsMessage |
|
79% |
14 |
3 |
0 |
|
60% |
10 |
2 |
|
71% |
| faststream / nats / message.py |
NatsBatchMessage |
|
27% |
11 |
8 |
0 |
|
25% |
8 |
0 |
|
26% |
| faststream / nats / parser.py |
NatsParser |
|
100% |
7 |
0 |
0 |
|
50% |
2 |
1 |
|
89% |
| faststream / nats / parser.py |
BatchParser |
|
93% |
15 |
1 |
0 |
|
83% |
6 |
1 |
|
90% |
| faststream / nats / publisher / producer.py |
NatsFastProducer |
|
0% |
2 |
2 |
4 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / publisher / producer.py |
FakeNatsFastProducer |
|
0% |
2 |
2 |
4 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / publisher / usecase.py |
LogicPublisher |
|
81% |
31 |
6 |
2 |
|
62% |
8 |
3 |
|
77% |
| faststream / nats / response.py |
NatsPublishCommand |
|
94% |
16 |
1 |
11 |
|
75% |
8 |
2 |
|
88% |
| faststream / nats / schemas / obj_watch.py |
ObjWatch |
|
90% |
10 |
1 |
4 |
|
75% |
4 |
1 |
|
86% |
| faststream / nats / schemas / pull_sub.py |
PullSub |
|
88% |
8 |
1 |
4 |
|
75% |
4 |
1 |
|
83% |
| faststream / nats / security.py |
(no class) |
|
45% |
11 |
6 |
4 |
|
17% |
6 |
1 |
|
35% |
| faststream / nats / subscriber / factory.py |
(no class) |
|
70% |
112 |
34 |
18 |
|
64% |
92 |
31 |
|
67% |
| faststream / nats / subscriber / state.py |
EmptySubscriberState |
|
0% |
12 |
12 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
ConnectedSubscriberState |
|
0% |
5 |
5 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
(no class) |
|
0% |
22 |
22 |
10 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / usecases / core_subscriber.py |
CoreSubscriber |
|
90% |
30 |
3 |
0 |
|
50% |
8 |
4 |
|
82% |
| faststream / nats / subscriber / usecases / core_subscriber.py |
ConcurrentCoreSubscriber |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / nats / subscriber / usecases / key_value_subscriber.py |
KeyValueWatchSubscriber |
|
90% |
49 |
5 |
0 |
|
69% |
16 |
5 |
|
85% |
| faststream / nats / subscriber / usecases / object_storage_subscriber.py |
ObjStoreWatchSubscriber |
|
91% |
53 |
5 |
0 |
|
69% |
16 |
5 |
|
86% |
| faststream / nats / subscriber / usecases / stream_basic.py |
StreamSubscriber |
|
100% |
33 |
0 |
0 |
|
75% |
8 |
2 |
|
95% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
PullStreamSubscriber |
|
93% |
15 |
1 |
0 |
|
75% |
8 |
2 |
|
87% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
ConcurrentPullStreamSubscriber |
|
0% |
5 |
5 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
BatchPullStreamSubscriber |
|
92% |
36 |
3 |
0 |
|
60% |
10 |
4 |
|
85% |
| faststream / nats / subscriber / usecases / stream_push_subscriber.py |
PushStreamSubscriber |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / nats / subscriber / usecases / stream_push_subscriber.py |
ConcurrentPushStreamSubscriber |
|
0% |
4 |
4 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / testing.py |
(no class) |
|
98% |
51 |
1 |
28 |
|
95% |
20 |
1 |
|
97% |
| faststream / opentelemetry / baggage.py |
Baggage |
|
100% |
26 |
0 |
4 |
|
88% |
8 |
1 |
|
97% |
| faststream / opentelemetry / middleware.py |
BaseTelemetryMiddleware |
|
96% |
76 |
3 |
2 |
|
94% |
18 |
1 |
|
96% |
| faststream / opentelemetry / middleware.py |
(no class) |
|
98% |
52 |
1 |
26 |
|
94% |
16 |
1 |
|
97% |
| faststream / prometheus / middleware.py |
PrometheusMiddleware |
|
100% |
12 |
0 |
0 |
|
83% |
6 |
1 |
|
94% |
| faststream / rabbit / broker / broker.py |
RabbitBroker |
|
92% |
49 |
4 |
4 |
|
72% |
18 |
5 |
|
87% |
| faststream / rabbit / broker / logging.py |
RabbitParamsStorage |
|
100% |
9 |
0 |
1 |
|
50% |
2 |
1 |
|
91% |
| faststream / rabbit / helpers / declarer.py |
RabbitDeclarerImpl |
|
100% |
20 |
0 |
3 |
|
90% |
10 |
1 |
|
97% |
| faststream / rabbit / helpers / state.py |
EmptyConnectionState |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / rabbit / message.py |
RabbitMessage |
|
93% |
15 |
1 |
0 |
|
83% |
6 |
1 |
|
90% |
| faststream / rabbit / publisher / fake.py |
RabbitFakePublisher |
|
100% |
11 |
0 |
0 |
|
50% |
2 |
1 |
|
92% |
| faststream / rabbit / publisher / producer.py |
LockUnset |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / rabbit / publisher / producer.py |
AioPikaFastProducer |
|
0% |
2 |
2 |
4 |
|
100% |
0 |
0 |
|
0% |
| faststream / rabbit / publisher / producer.py |
FakeAioPikaFastProducer |
|
0% |
1 |
1 |
4 |
|
100% |
0 |
0 |
|
0% |
| faststream / rabbit / publisher / usecase.py |
RabbitPublisher |
|
94% |
48 |
3 |
0 |
|
67% |
12 |
4 |
|
88% |
| faststream / rabbit / response.py |
RabbitPublishCommand |
|
93% |
15 |
1 |
0 |
|
75% |
4 |
1 |
|
89% |
| faststream / rabbit / schemas / queue.py |
RabbitQueue |
|
89% |
27 |
3 |
13 |
|
80% |
10 |
2 |
|
86% |
| faststream / rabbit / security.py |
(no class) |
|
91% |
11 |
1 |
4 |
|
83% |
6 |
1 |
|
88% |
| faststream / rabbit / subscriber / usecase.py |
RabbitSubscriber |
|
100% |
54 |
0 |
3 |
|
93% |
14 |
1 |
|
99% |
| faststream / rabbit / testing.py |
(no class) |
|
96% |
79 |
3 |
29 |
|
92% |
36 |
3 |
|
95% |
| faststream / rabbit / types.py |
(no class) |
|
0% |
1 |
1 |
3 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / broker / broker.py |
RedisBroker |
|
95% |
38 |
2 |
4 |
|
70% |
10 |
3 |
|
90% |
| faststream / redis / configs / broker.py |
RedisRouterConfig |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / configs / state.py |
ConnectionState |
|
82% |
17 |
3 |
0 |
|
75% |
4 |
1 |
|
81% |
| faststream / redis / message.py |
_RedisStreamMessageMixin |
|
91% |
11 |
1 |
0 |
|
75% |
4 |
1 |
|
87% |
| faststream / redis / parser / binary.py |
BinaryWriter |
|
92% |
12 |
1 |
0 |
|
50% |
2 |
1 |
|
86% |
| faststream / redis / publisher / factory.py |
(no class) |
|
94% |
17 |
1 |
11 |
|
88% |
8 |
1 |
|
92% |
| faststream / redis / publisher / producer.py |
RedisFastProducer |
|
94% |
35 |
2 |
1 |
|
75% |
8 |
2 |
|
91% |
| faststream / redis / publisher / specification.py |
ListPublisherSpecification |
|
86% |
7 |
1 |
0 |
|
50% |
2 |
1 |
|
78% |
| faststream / redis / publisher / specification.py |
StreamPublisherSpecification |
|
86% |
7 |
1 |
0 |
|
50% |
2 |
1 |
|
78% |
| faststream / redis / publisher / usecase.py |
ListPublisher |
|
80% |
15 |
3 |
0 |
|
100% |
0 |
0 |
|
80% |
| faststream / redis / publisher / usecase.py |
ListBatchPublisher |
|
62% |
8 |
3 |
0 |
|
100% |
0 |
0 |
|
62% |
| faststream / redis / publisher / usecase.py |
StreamPublisher |
|
81% |
16 |
3 |
0 |
|
100% |
0 |
0 |
|
81% |
| faststream / redis / schemas / list_sub.py |
ListSub |
|
88% |
8 |
1 |
0 |
|
100% |
0 |
0 |
|
88% |
| faststream / redis / schemas / proto.py |
(no class) |
|
40% |
10 |
6 |
4 |
|
50% |
6 |
3 |
|
44% |
| faststream / redis / schemas / stream_sub.py |
StreamSub |
|
92% |
26 |
2 |
0 |
|
86% |
14 |
2 |
|
90% |
| faststream / redis / security.py |
(no class) |
|
94% |
16 |
1 |
5 |
|
88% |
8 |
1 |
|
92% |
| faststream / redis / subscriber / factory.py |
(no class) |
|
86% |
37 |
5 |
15 |
|
83% |
24 |
4 |
|
85% |
| faststream / redis / subscriber / specification.py |
ListSubscriberSpecification |
|
86% |
7 |
1 |
0 |
|
50% |
2 |
1 |
|
78% |
| faststream / redis / subscriber / specification.py |
StreamSubscriberSpecification |
|
86% |
7 |
1 |
0 |
|
50% |
2 |
1 |
|
78% |
| faststream / redis / subscriber / usecases / basic.py |
LogicSubscriber |
|
82% |
28 |
5 |
1 |
|
70% |
10 |
1 |
|
79% |
| faststream / redis / subscriber / usecases / basic.py |
ConcurrentSubscriber |
|
0% |
4 |
4 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / subscriber / usecases / channel_subscriber.py |
ChannelSubscriber |
|
96% |
53 |
2 |
0 |
|
88% |
16 |
2 |
|
94% |
| faststream / redis / subscriber / usecases / list_subscriber.py |
_ListHandlerMixin |
|
95% |
41 |
2 |
0 |
|
70% |
10 |
3 |
|
90% |
| faststream / redis / subscriber / usecases / stream_subscriber.py |
_StreamHandlerMixin |
|
87% |
94 |
12 |
3 |
|
69% |
32 |
6 |
|
83% |
| faststream / redis / testing.py |
FakeProducer |
|
100% |
37 |
0 |
0 |
|
94% |
18 |
1 |
|
98% |
| faststream / redis / testing.py |
(no class) |
|
98% |
44 |
1 |
33 |
|
88% |
8 |
1 |
|
96% |
| faststream / response / response.py |
Response |
|
80% |
5 |
1 |
0 |
|
100% |
0 |
0 |
|
80% |
| faststream / response / response.py |
(no class) |
|
97% |
29 |
1 |
51 |
|
50% |
2 |
1 |
|
94% |
| faststream / specification / asyncapi / factory.py |
AsyncAPI |
|
96% |
24 |
1 |
3 |
|
100% |
4 |
0 |
|
96% |
| faststream / specification / asyncapi / message.py |
(no class) |
|
96% |
50 |
2 |
24 |
|
96% |
26 |
1 |
|
96% |
| faststream / specification / asyncapi / site.py |
_Handler |
|
0% |
12 |
12 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / site.py |
(no class) |
|
78% |
18 |
4 |
11 |
|
50% |
2 |
1 |
|
75% |
| faststream / specification / asyncapi / v2_6_0 / generate.py |
(no class) |
|
96% |
85 |
3 |
16 |
|
92% |
48 |
4 |
|
95% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / channel.py |
Queue |
|
67% |
3 |
1 |
2 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / channel.py |
Exchange |
|
67% |
3 |
1 |
2 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / channel.py |
ChannelBinding |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / operation.py |
OperationBinding |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / kafka / channel.py |
ChannelBinding |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / kafka / operation.py |
OperationBinding |
|
0% |
6 |
6 |
0 |
|
0% |
4 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / channel.py |
ChannelBinding |
|
73% |
30 |
8 |
4 |
|
71% |
28 |
4 |
|
72% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / channel.py |
(no class) |
|
87% |
15 |
2 |
14 |
|
50% |
2 |
1 |
|
82% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / operation.py |
OperationBinding |
|
47% |
30 |
16 |
4 |
|
43% |
28 |
4 |
|
45% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / operation.py |
(no class) |
|
88% |
16 |
2 |
14 |
|
50% |
2 |
1 |
|
83% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / mqtt / channel.py |
ChannelBinding |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / mqtt / operation.py |
OperationBinding |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / nats / channel.py |
ChannelBinding |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / nats / operation.py |
OperationBinding |
|
0% |
6 |
6 |
0 |
|
0% |
4 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / redis / channel.py |
ChannelBinding |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / redis / operation.py |
OperationBinding |
|
0% |
6 |
6 |
0 |
|
0% |
4 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / sqs / channel.py |
ChannelBinding |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / sqs / operation.py |
OperationBinding |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / channels.py |
(no class) |
|
86% |
14 |
2 |
6 |
|
50% |
2 |
1 |
|
81% |
| faststream / specification / asyncapi / v2_6_0 / schema / components.py |
(no class) |
|
75% |
8 |
2 |
4 |
|
50% |
2 |
1 |
|
70% |
| faststream / specification / asyncapi / v2_6_0 / schema / contact.py |
(no class) |
|
80% |
10 |
2 |
15 |
|
50% |
2 |
1 |
|
75% |
| faststream / specification / asyncapi / v2_6_0 / schema / docs.py |
(no class) |
|
78% |
9 |
2 |
15 |
|
50% |
2 |
1 |
|
73% |
| faststream / specification / asyncapi / v2_6_0 / schema / license.py |
(no class) |
|
78% |
9 |
2 |
15 |
|
50% |
2 |
1 |
|
73% |
| faststream / specification / asyncapi / v2_6_0 / schema / message.py |
(no class) |
|
83% |
23 |
4 |
6 |
|
50% |
4 |
2 |
|
78% |
| faststream / specification / asyncapi / v2_6_0 / schema / operations.py |
(no class) |
|
88% |
16 |
2 |
9 |
|
50% |
2 |
1 |
|
83% |
| faststream / specification / asyncapi / v2_6_0 / schema / servers.py |
(no class) |
|
82% |
22 |
4 |
5 |
|
50% |
4 |
2 |
|
77% |
| faststream / specification / asyncapi / v2_6_0 / schema / tag.py |
(no class) |
|
80% |
10 |
2 |
14 |
|
50% |
2 |
1 |
|
75% |
| faststream / specification / asyncapi / v3_0_0 / generate.py |
(no class) |
|
97% |
103 |
3 |
19 |
|
93% |
42 |
3 |
|
96% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / amqp / channel.py |
ChannelBinding |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / amqp / operation.py |
OperationBinding |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / channel.py |
ChannelBinding |
|
73% |
30 |
8 |
0 |
|
71% |
28 |
4 |
|
72% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / channel.py |
(no class) |
|
87% |
15 |
2 |
5 |
|
50% |
2 |
1 |
|
82% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / operation.py |
OperationBinding |
|
47% |
30 |
16 |
0 |
|
43% |
28 |
4 |
|
45% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / operation.py |
(no class) |
|
88% |
16 |
2 |
5 |
|
50% |
2 |
1 |
|
83% |
| faststream / specification / asyncapi / v3_0_0 / schema / channels.py |
(no class) |
|
86% |
14 |
2 |
7 |
|
50% |
2 |
1 |
|
81% |
| faststream / specification / asyncapi / v3_0_0 / schema / components.py |
(no class) |
|
75% |
8 |
2 |
4 |
|
50% |
2 |
1 |
|
70% |
| faststream / specification / asyncapi / v3_0_0 / schema / operations.py |
(no class) |
|
90% |
20 |
2 |
10 |
|
50% |
2 |
1 |
|
86% |
| faststream / specification / asyncapi / v3_0_0 / schema / servers.py |
(no class) |
|
87% |
15 |
2 |
5 |
|
50% |
2 |
1 |
|
82% |
| faststream / specification / base / info.py |
(no class) |
|
75% |
8 |
2 |
2 |
|
50% |
2 |
1 |
|
70% |
| tests / asgi / testcase.py |
AsgiTestcase |
|
99% |
186 |
1 |
46 |
|
100% |
2 |
0 |
|
99% |
| tests / asyncapi / base / basic.py |
(no class) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| tests / asyncapi / base / v2_6_0 / arguments.py |
FastAPICompatible |
|
98% |
216 |
4 |
55 |
|
94% |
32 |
2 |
|
98% |
| tests / asyncapi / base / v3_0_0 / arguments.py |
FastAPICompatible |
|
98% |
207 |
4 |
53 |
|
96% |
28 |
1 |
|
98% |
| tests / asyncapi / confluent / v2_6_0 / base.py |
AsyncAPI26Mixin |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / asyncapi / confluent / v3_0_0 / base.py |
AsyncAPI30Mixin |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / basic.py |
BaseTestcaseConfig |
|
0% |
1 |
1 |
3 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / codec.py |
CodecTestcase |
|
97% |
36 |
1 |
5 |
|
100% |
0 |
0 |
|
97% |
| tests / brokers / base / connection.py |
BrokerConnectionTestcase |
|
91% |
11 |
1 |
0 |
|
100% |
0 |
0 |
|
91% |
| tests / brokers / base / consume.py |
BrokerRealConsumeTestcase |
|
100% |
58 |
0 |
0 |
|
83% |
6 |
1 |
|
98% |
| tests / brokers / base / fastapi.py |
FastAPILocalTestcase |
|
98% |
261 |
5 |
38 |
|
100% |
2 |
0 |
|
98% |
| tests / brokers / base / middlewares.py |
ExceptionMiddlewareTestcase |
|
96% |
160 |
7 |
2 |
|
100% |
2 |
0 |
|
96% |
| tests / brokers / base / parser.py |
LocalCustomParserTestcase |
|
100% |
131 |
0 |
0 |
|
75% |
4 |
1 |
|
99% |
| tests / brokers / base / publish.py |
BrokerPublishTestcase |
|
99% |
191 |
1 |
5 |
|
100% |
2 |
0 |
|
99% |
| tests / brokers / confluent / conftest.py |
(no class) |
|
89% |
9 |
1 |
3 |
|
100% |
0 |
0 |
|
89% |
| tests / brokers / confluent / test_security.py |
(no class) |
|
33% |
6 |
4 |
21 |
|
100% |
0 |
0 |
|
33% |
| tests / brokers / confluent / test_test_client.py |
TestTestclient |
|
98% |
116 |
2 |
27 |
|
100% |
0 |
0 |
|
98% |
| tests / brokers / kafka / conftest.py |
(no class) |
|
89% |
9 |
1 |
3 |
|
100% |
0 |
0 |
|
89% |
| tests / brokers / kafka / test_test_client.py |
TestTestclient |
|
99% |
134 |
2 |
30 |
|
100% |
0 |
0 |
|
99% |
| tests / brokers / mqtt / conftest.py |
(no class) |
|
92% |
13 |
1 |
3 |
|
100% |
0 |
0 |
|
92% |
| tests / brokers / mqtt / test_consume.py |
TestConsume |
|
100% |
23 |
0 |
0 |
|
88% |
8 |
1 |
|
97% |
| tests / brokers / mqtt / test_testclient.py |
TestTestclient |
|
92% |
13 |
1 |
0 |
|
100% |
6 |
0 |
|
95% |
| tests / brokers / nats / test_consume.py |
TestConsume |
|
100% |
387 |
0 |
0 |
|
83% |
36 |
6 |
|
99% |
| tests / brokers / nats / test_test_client.py |
TestTestclient |
|
96% |
93 |
4 |
23 |
|
100% |
0 |
0 |
|
96% |
| tests / brokers / rabbit / conftest.py |
(no class) |
|
94% |
16 |
1 |
4 |
|
100% |
0 |
0 |
|
94% |
| tests / brokers / rabbit / test_test_client.py |
TestTestclient |
|
96% |
74 |
3 |
8 |
|
100% |
0 |
0 |
|
96% |
| tests / brokers / redis / conftest.py |
(no class) |
|
91% |
11 |
1 |
3 |
|
100% |
0 |
0 |
|
91% |
| tests / brokers / redis / test_autoclaim.py |
TestAutoClaim |
|
100% |
117 |
0 |
13 |
|
75% |
8 |
2 |
|
98% |
| tests / brokers / redis / test_consume.py |
TestConsumeList |
|
100% |
128 |
0 |
1 |
|
90% |
10 |
1 |
|
99% |
| tests / brokers / redis / test_consume.py |
TestConsumeStream |
|
99% |
207 |
1 |
10 |
|
79% |
14 |
3 |
|
98% |
| tests / brokers / redis / test_test_client.py |
TestTestclient |
|
94% |
108 |
6 |
11 |
|
100% |
0 |
0 |
|
94% |
| tests / brokers / supervisor / test_supervisor.py |
(no class) |
|
95% |
43 |
2 |
6 |
|
100% |
0 |
0 |
|
95% |
| tests / cli / conftest.py |
CLIThread |
|
89% |
35 |
4 |
14 |
|
90% |
20 |
2 |
|
89% |
| tests / cli / conftest.py |
(no class) |
|
98% |
54 |
1 |
21 |
|
83% |
6 |
1 |
|
97% |
| tests / cli / supervisors / test_watchfiles.py |
(no class) |
|
89% |
27 |
3 |
12 |
|
100% |
0 |
0 |
|
89% |
| tests / cli / test_asyncapi_docs.py |
(no class) |
|
96% |
53 |
2 |
11 |
|
100% |
0 |
0 |
|
96% |
| tests / conftest.py |
(no class) |
|
97% |
37 |
1 |
14 |
|
100% |
2 |
0 |
|
97% |
| tests / docs / confluent / publish_with_partition_key / test_app.py |
(no class) |
|
73% |
15 |
4 |
3 |
|
100% |
0 |
0 |
|
73% |
| tests / docs / getting_started / config / test_settings_base_1.py |
(no class) |
|
67% |
3 |
1 |
2 |
|
100% |
0 |
0 |
|
67% |
| tests / docs / kafka / publish_with_partition_key / test_app.py |
(no class) |
|
73% |
15 |
4 |
3 |
|
100% |
0 |
0 |
|
73% |
| tests / examples / nats / test_e07_object_storage.py |
(no class) |
|
84% |
19 |
3 |
5 |
|
67% |
6 |
2 |
|
80% |
| tests / marks.py |
(no class) |
|
66% |
29 |
10 |
7 |
|
100% |
0 |
0 |
|
66% |
| tests / opentelemetry / basic.py |
LocalTelemetryTestcase |
|
99% |
254 |
1 |
2 |
|
100% |
16 |
0 |
|
99% |
| tests / prometheus / basic.py |
LocalPrometheusTestcase |
|
100% |
47 |
0 |
2 |
|
93% |
14 |
1 |
|
98% |
| tests / utils / context / test_main.py |
test_context_with_custom_object_implementing_comparison.User |
|
75% |
4 |
1 |
1 |
|
100% |
0 |
0 |
|
75% |