1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
#!/usr/bin/env python
""" Example of using the Gerrit client class. """
import logging
import optparse
import sys
import time
from pygerrit.client import GerritClient
from pygerrit.stream import GerritStreamErrorEvent
def _main():
usage = "usage: %prog [options]"
parser = optparse.OptionParser(usage=usage)
parser.add_option('-g', '--gerrit-hostname', dest='hostname',
default='review',
help='gerrit server hostname (default: %default)')
parser.add_option('-b', '--blocking', dest='blocking',
action='store_true',
help='block on event get (default: False)')
parser.add_option('-t', '--timeout', dest='timeout',
default=None, type='int',
help='timeout (seconds) for blocking event get '
'(default: None)')
(options, _args) = parser.parse_args()
if options.timeout and not options.blocking:
parser.error('Can only use -t with -b')
logging.basicConfig(format='%(message)s', level=logging.INFO)
gerrit = GerritClient(host=options.hostname)
gerrit.start_event_stream()
try:
while True:
event = gerrit.get_event(block=options.blocking,
timeout=options.timeout)
if event:
logging.info("Event: %s", event.name)
if isinstance(event, GerritStreamErrorEvent):
logging.error(event.error)
break
else:
logging.info("No event")
if not options.blocking:
time.sleep(1)
except KeyboardInterrupt:
logging.info("Terminated by user")
gerrit.stop_event_stream()
if __name__ == "__main__":
sys.exit(_main())
|
