(subparsers)
| 1031 | |
| 1032 | |
| 1033 | def initialize_monitor_subcommand(subparsers): |
| 1034 | command_help = """Monitor given topology's throughput interactively.""" |
| 1035 | sub_parser = subparsers.add_parser("monitor", help=command_help, formatter_class=SortingHelpFormatter) |
| 1036 | |
| 1037 | sub_parser.add_argument("topology-name") |
| 1038 | sub_parser.add_argument( |
| 1039 | "-i", "--interval", type=check_positive, default=None, |
| 1040 | help="""By default, poll-interval is 4 seconds""" |
| 1041 | ) |
| 1042 | sub_parser.add_argument("-m", "--component", default=None) |
| 1043 | sub_parser.add_argument("-s", "--stream", default=None) |
| 1044 | sub_parser.add_argument("-w", "--watch", default=None) |
| 1045 | sub_parser.set_defaults(func=monitor) |
| 1046 | add_common_options(sub_parser) |
| 1047 | |
| 1048 | |
| 1049 | def jar(args): |
no test coverage detected