(params, endpoint, request, *, rs_type=None)
| 777 | |
| 778 | |
| 779 | def execute_router(params, endpoint, request, *, rs_type=None): |
| 780 | logger = logging.getLogger('keeper.router') |
| 781 | if logger.level <= logging.DEBUG: |
| 782 | js = google.protobuf.json_format.MessageToJson(request) if request else '' |
| 783 | logger.debug('>>> [ROUTER RQ] \"%s\": %s', endpoint, js) |
| 784 | |
| 785 | payload = request.SerializeToString() if request else None |
| 786 | rs_bytes = execute_router_rest(params, endpoint, payload) |
| 787 | if rs_type and rs_bytes: |
| 788 | response = rs_type() |
| 789 | response.ParseFromString(rs_bytes) |
| 790 | if logger.level <= logging.DEBUG: |
| 791 | js = google.protobuf.json_format.MessageToJson(response) |
| 792 | logger.debug('>>> [ROUTER RS] \"%s\": %s', endpoint, js) |
| 793 | return response |
| 794 | return None |
| 795 | |
| 796 | |
| 797 | def execute_router_json(params, endpoint, request): |
nothing calls this directly
no test coverage detected