faust.web.apps.router

HTTP endpoint showing partition routing destinations.

class faust.web.apps.router.TableList(app: AppT, web: Web)

— description: List routes for all tables. tags: - Faust produces: - application/json

async get(request: Request) → Response

Return JSON response with list of all table routes.

Return type:

Response

view_name: str

view_path: str

methods: Mapping[str, Callable[[Request], Awaitable]]

class faust.web.apps.router.TopicList(app: AppT, web: Web)

List routes for all external topics.

async get(request: Request) → Response

Return JSON response with list of all table routes.

Return type:

Response

view_name: str

view_path: str

methods: Mapping[str, Callable[[Request], Awaitable]]

class faust.web.apps.router.TableDetail(app: AppT, web: Web)

— description: List route for a specific table. tags: - Faust parameters: - in: path

name: name type: string required: true

produces: - application/json

async get(request: Request, name: str) → Response

Return JSON response with table metadata.

Return type:

Response

view_name: str

view_path: str

methods: Mapping[str, Callable[[Request], Awaitable]]

class faust.web.apps.router.TableKeyDetail(app: AppT, web: Web)

— description: List information about key. tags: - Faust parameters: - in: path

name: name type: string required: true

• in: path name: key type: string required: true

produces: - application/json

async get(request: Request, name: str, key: str) → Response

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

view_name: str

view_path: str

methods: Mapping[str, Callable[[Request], Awaitable]]