Add HttpsMonitor

infra_libs/ts_mon/config.py

 # Copyright 2015 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 import json
 import logging
 import os
 import socket
 import sys
 import urlparse
@@ skipping 65 matching lines @@
   parser.add_argument(
       '--ts-mon-config-file',
       default=default_config_file,
       help='path to a JSON config file that contains suitable values for '
            '"endpoint" and "credentials" for this machine. This config file is '
            'intended to be shared by all processes on the machine, as the '
            'values depend on the machine\'s position in the network, IP '
            'whitelisting and deployment of credentials. (default: %(default)s)')
   parser.add_argument(
       '--ts-mon-endpoint',
-      help='url (including file://, pubsub://project/topic) to post monitoring '
-           'metrics to. If set, overrides the value in --ts-mon-config-file')
+      help='url (including file://, pubsub://project/topic, https://) to post '
+           'monitoring metrics to. If set, overrides the value in '
+           '--ts-mon-config-file')
   parser.add_argument(
       '--ts-mon-credentials',
       help='path to a pkcs8 json credential file. If set, overrides the value '
            'in --ts-mon-config-file')
   parser.add_argument(
       '--ts-mon-flush',
       choices=('manual', 'auto'), default='auto',
       help=('metric push behavior: manual (only send when flush() is called), '
             'or auto (send automatically every --ts-mon-flush-interval-secs '
             'seconds). (default: %(default)s)'))
@@ skipping 127 matching lines @@
   elif endpoint.startswith('pubsub://'):
     if credentials:
       url = urlparse.urlparse(endpoint)
       project = url.netloc
       topic = url.path.strip('/')
       interface.state.global_monitor = monitors.PubSubMonitor(
           credentials, project, topic, use_instrumented_http=True)
     else:
       logging.error('ts_mon monitoring is disabled because credentials are not '
                     'available')
+  elif endpoint.startswith('https://'):
+    interface.state.global_monitor = monitors.HttpsMonitor(endpoint,
+                                                           credentials)
   elif endpoint.lower() == 'none':
     logging.info('ts_mon monitoring has been explicitly disabled')
   else:
     logging.error('ts_mon monitoring is disabled because the endpoint provided'
                   ' is invalid or not supported: %s', endpoint)
 
   interface.state.flush_mode = args.ts_mon_flush
 
   if args.ts_mon_flush == 'auto':
     interface.state.flush_thread = interface._FlushThread(
         args.ts_mon_flush_interval_secs)
     interface.state.flush_thread.start()
 
   standard_metrics.init()