Skip to content

Commit 8634fd8

Browse files
caspervonbcaspervonb
committed
Format ./nats
1 parent cd9b716 commit 8634fd8

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

50 files changed

+712
-1708
lines changed

‎nats/benchmark/latency_perf.py‎

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -34,9 +34,7 @@ def show_usage_and_die():
3434

3535
async def main():
3636
parser = argparse.ArgumentParser()
37-
parser.add_argument(
38-
"-n", "--iterations", default=DEFAULT_ITERATIONS, type=int
39-
)
37+
parser.add_argument("-n", "--iterations", default=DEFAULT_ITERATIONS, type=int)
4038
parser.add_argument("-S", "--subject", default="test")
4139
parser.add_argument("--servers", default=[], action="append")
4240
args = parser.parse_args()
@@ -60,11 +58,7 @@ async def handler(msg):
6058
start = time.monotonic()
6159
to_send = args.iterations
6260

63-
print(
64-
"Sending {} request/responses on [{}]".format(
65-
args.iterations, args.subject
66-
)
67-
)
61+
print("Sending {} request/responses on [{}]".format(args.iterations, args.subject))
6862
while to_send > 0:
6963
to_send -= 1
7064
if to_send == 0:

‎nats/benchmark/parser_perf.py‎

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55

66

77
class DummyNatsClient:
8-
98
def __init__(self):
109
self._subs = {}
1110
self._pongs = []
@@ -40,9 +39,7 @@ async def _process_err(self, err=None):
4039

4140
def generate_msg(subject, nbytes, reply=""):
4241
msg = []
43-
protocol_line = "MSG {subject} 1 {reply} {nbytes}\r\n".format(
44-
subject=subject, reply=reply, nbytes=nbytes
45-
).encode()
42+
protocol_line = "MSG {subject} 1 {reply} {nbytes}\r\n".format(subject=subject, reply=reply, nbytes=nbytes).encode()
4643
msg.append(protocol_line)
4744
msg.append(b"A" * nbytes)
4845
msg.append(b"r\n")

‎nats/benchmark/pub_perf.py‎

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -68,11 +68,7 @@ async def main():
6868
start = time.time()
6969
to_send = args.count
7070

71-
print(
72-
"Sending {} messages of size {} bytes on [{}]".format(
73-
args.count, args.size, args.subject
74-
)
75-
)
71+
print("Sending {} messages of size {} bytes on [{}]".format(args.count, args.size, args.subject))
7672
while to_send > 0:
7773
for i in range(0, args.batch):
7874
to_send -= 1
@@ -94,11 +90,7 @@ async def main():
9490

9591
elapsed = time.time() - start
9692
mbytes = "%.1f" % (((args.size * args.count) / elapsed) / (1024 * 1024))
97-
print(
98-
"\nTest completed : {} msgs/sec ({}) MB/sec".format(
99-
args.count / elapsed, mbytes
100-
)
101-
)
93+
print("\nTest completed : {} msgs/sec ({}) MB/sec".format(args.count / elapsed, mbytes))
10294
await nc.close()
10395

10496

‎nats/benchmark/pub_sub_perf.py‎

Lines changed: 4 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -79,11 +79,7 @@ async def handler(msg):
7979
start = time.time()
8080
to_send = args.count
8181

82-
print(
83-
"Sending {} messages of size {} bytes on [{}]".format(
84-
args.count, args.size, args.subject
85-
)
86-
)
82+
print("Sending {} messages of size {} bytes on [{}]".format(args.count, args.size, args.subject))
8783
while to_send > 0:
8884
for i in range(0, args.batch):
8985
to_send -= 1
@@ -107,17 +103,9 @@ async def handler(msg):
107103

108104
elapsed = time.time() - start
109105
mbytes = "%.1f" % (((args.size * args.count) / elapsed) / (1024 * 1024))
110-
print(
111-
"\nTest completed : {} msgs/sec sent ({}) MB/sec".format(
112-
args.count / elapsed, mbytes
113-
)
114-
)
115-
116-
print(
117-
"Received {} messages ({} msgs/sec)".format(
118-
received, received / elapsed
119-
)
120-
)
106+
print("\nTest completed : {} msgs/sec sent ({}) MB/sec".format(args.count / elapsed, mbytes))
107+
108+
print("Received {} messages ({} msgs/sec)".format(received, received / elapsed))
121109
await nc.close()
122110

123111

‎nats/benchmark/sub_perf.py‎

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -77,11 +77,7 @@ async def handler(msg):
7777
elapsed = time.monotonic() - start
7878
print("\nTest completed : {} msgs/sec sent".format(args.count / elapsed))
7979

80-
print(
81-
"Received {} messages ({} msgs/sec)".format(
82-
received, received / elapsed
83-
)
84-
)
80+
print("Received {} messages ({} msgs/sec)".format(received, received / elapsed))
8581
await nc.close()
8682

8783

‎nats/examples/advanced.py‎

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55

66

77
async def main():
8-
98
async def disconnected_cb():
109
print("Got disconnected!")
1110

@@ -41,11 +40,7 @@ async def request_handler(msg):
4140
subject = msg.subject
4241
reply = msg.reply
4342
data = msg.data.decode()
44-
print(
45-
"Received a message on '{subject} {reply}': {data}".format(
46-
subject=subject, reply=reply, data=data
47-
)
48-
)
43+
print("Received a message on '{subject} {reply}': {data}".format(subject=subject, reply=reply, data=data))
4944

5045
# Signal the server to stop sending messages after we got 10 already.
5146
resp = await nc.request("help.please", b"help")

‎nats/examples/basic.py‎

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -31,17 +31,13 @@ async def message_handler(msg):
3131

3232
try:
3333
async for msg in sub.messages:
34-
print(
35-
f"Received a message on '{msg.subject} {msg.reply}': {msg.data.decode()}"
36-
)
34+
print(f"Received a message on '{msg.subject} {msg.reply}': {msg.data.decode()}")
3735
await sub.unsubscribe()
3836
except Exception as e:
3937
pass
4038

4139
async def help_request(msg):
42-
print(
43-
f"Received a message on '{msg.subject} {msg.reply}': {msg.data.decode()}"
44-
)
40+
print(f"Received a message on '{msg.subject} {msg.reply}': {msg.data.decode()}")
4541
await nc.publish(msg.reply, b"I can help")
4642

4743
# Use queue named 'workers' for distributing requests

‎nats/examples/client.py‎

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -7,19 +7,14 @@
77

88

99
class Client:
10-
1110
def __init__(self, nc):
1211
self.nc = nc
1312

1413
async def message_handler(self, msg):
1514
print(f"[Received on '{msg.subject}']: {msg.data.decode()}")
1615

1716
async def request_handler(self, msg):
18-
print(
19-
"[Request on '{} {}']: {}".format(
20-
msg.subject, msg.reply, msg.data.decode()
21-
)
22-
)
17+
print("[Request on '{} {}']: {}".format(msg.subject, msg.reply, msg.data.decode()))
2318
await self.nc.publish(msg.reply, b"I can help!")
2419

2520
async def start(self):

‎nats/examples/clustered.py‎

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -70,11 +70,7 @@ async def subscribe_handler(msg):
7070
print("Connection closed prematurely.")
7171
break
7272
except ErrTimeout as e:
73-
print(
74-
"Timeout occurred when publishing msg i={}: {}".format(
75-
i, e
76-
)
77-
)
73+
print("Timeout occurred when publishing msg i={}: {}".format(i, e))
7874

7975
end_time = datetime.now()
8076
await nc.drain()

‎nats/examples/component.py‎

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@
66

77

88
class Component:
9-
109
def __init__(self):
1110
self._nc = None
1211
self._done = asyncio.Future()
@@ -89,9 +88,7 @@ def signal_handler():
8988
asyncio.create_task(c.close())
9089

9190
for sig in ("SIGINT", "SIGTERM"):
92-
asyncio.get_running_loop().add_signal_handler(
93-
getattr(signal, sig), signal_handler
94-
)
91+
asyncio.get_running_loop().add_signal_handler(getattr(signal, sig), signal_handler)
9592

9693
await c.run_forever()
9794

0 commit comments

Comments
 (0)