OLD | NEW |
1 # Copyright 2015 The Chromium Authors. All rights reserved. | 1 # Copyright 2015 The Chromium Authors. All rights reserved. |
2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
4 | 4 |
5 import logging | 5 import logging |
6 | 6 |
7 from google.protobuf.message import DecodeError | 7 from google.protobuf.message import DecodeError |
8 from infra_libs.event_mon.protos.chrome_infra_log_pb2 import ( | 8 from infra_libs.event_mon.protos.chrome_infra_log_pb2 import ( |
9 ChromeInfraEvent, ServiceEvent, BuildEvent) | 9 ChromeInfraEvent, ServiceEvent, BuildEvent) |
10 from infra_libs.event_mon.protos.goma_stats_pb2 import GomaStats | 10 from infra_libs.event_mon.protos.goma_stats_pb2 import GomaStats |
(...skipping 495 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
506 def send_events(events): | 506 def send_events(events): |
507 """Send several events at once to the endpoint. | 507 """Send several events at once to the endpoint. |
508 | 508 |
509 Args: | 509 Args: |
510 events (iterable of Event): events to send | 510 events (iterable of Event): events to send |
511 | 511 |
512 Return: | 512 Return: |
513 success (bool): True if data was successfully received by the endpoint. | 513 success (bool): True if data was successfully received by the endpoint. |
514 """ | 514 """ |
515 return config._router.push_event(tuple(e.log_event() for e in events)) | 515 return config._router.push_event(tuple(e.log_event() for e in events)) |
OLD | NEW |