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, Any, None]) → yarl.URL[source]¶ Return the URL of web server that hosts key in table.
- Return type
-
table_metadata(table_name: str) → MutableMapping[str, MutableMapping[str, List[int]]][source]¶ Return metadata stored for table in the partition assignor.
- Return type
-
