faust.web.apps.router

HTTP endpoint showing partition routing destinations.

class faust.web.apps.router.TableList(app: faust.types.app.AppT, web: faust.web.base.Web) → None[source]

List routes for all tables.

async get(request: faust.web.base.Request) → faust.web.base.Response[source]

Return JSON response with list of all table routes.

Return type

Response

class faust.web.apps.router.TableDetail(app: faust.types.app.AppT, web: faust.web.base.Web) → None[source]

List route for specific table.

async get(request: faust.web.base.Request, name: str) → faust.web.base.Response[source]

Return JSON response with table metadata.

Return type

Response

class faust.web.apps.router.TableKeyDetail(app: faust.types.app.AppT, web: faust.web.base.Web) → None[source]

List information about key.

async get(request: faust.web.base.Request, name: str, key: str) → faust.web.base.Response[source]

Return JSON response after looking up the route of a table key.

Parameters

  • name (str) – Name of table.

  • key (str) – Key to look up node for.

Raises

faust.web.exceptions.ServiceUnavailable – if broker metadata has not yet been received.

Return type

Response