faust.app.router
¶
Route messages to Faust nodes by partitioning.
-
class
faust.app.router.
Router
(app: faust.types.app.AppT) → None[source]¶ Router for
app.router
.-
key_store
(table_name: str, key: Union[bytes, faust.types.core.ModelT, typing.Any, NoneType]) → yarl.URL[source]¶ Return type: URL
-
table_metadata
(table_name: str) → MutableMapping[str, MutableMapping[str, List[int]]][source]¶ Return type: MutableMapping
[str
,MutableMapping
[str
,List
[int
]]]
-
tables_metadata
() → MutableMapping[str, MutableMapping[str, List[int]]][source]¶ Return type: MutableMapping
[str
,MutableMapping
[str
,List
[int
]]]
-