Skip to content

Commit a47174f

Browse files
committed
Update [vald sha: 8d9830dbf64f32726e87b506a3fd05c9c5d0f0e2]
Signed-off-by: Vdaas CI <vald@vdaas.org>
1 parent 77226a3 commit a47174f

File tree

4 files changed

+177
-45
lines changed

4 files changed

+177
-45
lines changed

VALD_SHA

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
fa163d6fd52b09014b72852f3bee00eca359b127
1+
8d9830dbf64f32726e87b506a3fd05c9c5d0f0e2

src/vald/v1/payload/payload_pb2.py

Lines changed: 50 additions & 44 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/vald/v1/rpc/stats/stats_pb2.py

Lines changed: 41 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Lines changed: 85 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,85 @@
1+
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
2+
"""Client and server classes corresponding to protobuf-defined services."""
3+
import grpc
4+
5+
from vald.v1.payload import payload_pb2 as vald_dot_v1_dot_payload_dot_payload__pb2
6+
7+
8+
class StatsStub(object):
9+
"""Overview
10+
Represent the resource stats service.
11+
"""
12+
13+
def __init__(self, channel):
14+
"""Constructor.
15+
16+
Args:
17+
channel: A grpc.Channel.
18+
"""
19+
self.ResourceStats = channel.unary_unary(
20+
'/rpc.v1.Stats/ResourceStats',
21+
request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString,
22+
response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Info.ResourceStats.FromString,
23+
_registered_method=True)
24+
25+
26+
class StatsServicer(object):
27+
"""Overview
28+
Represent the resource stats service.
29+
"""
30+
31+
def ResourceStats(self, request, context):
32+
"""Overview
33+
Represent the RPC to get the resource stats.
34+
"""
35+
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
36+
context.set_details('Method not implemented!')
37+
raise NotImplementedError('Method not implemented!')
38+
39+
40+
def add_StatsServicer_to_server(servicer, server):
41+
rpc_method_handlers = {
42+
'ResourceStats': grpc.unary_unary_rpc_method_handler(
43+
servicer.ResourceStats,
44+
request_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString,
45+
response_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Info.ResourceStats.SerializeToString,
46+
),
47+
}
48+
generic_handler = grpc.method_handlers_generic_handler(
49+
'rpc.v1.Stats', rpc_method_handlers)
50+
server.add_generic_rpc_handlers((generic_handler,))
51+
server.add_registered_method_handlers('rpc.v1.Stats', rpc_method_handlers)
52+
53+
54+
# This class is part of an EXPERIMENTAL API.
55+
class Stats(object):
56+
"""Overview
57+
Represent the resource stats service.
58+
"""
59+
60+
@staticmethod
61+
def ResourceStats(request,
62+
target,
63+
options=(),
64+
channel_credentials=None,
65+
call_credentials=None,
66+
insecure=False,
67+
compression=None,
68+
wait_for_ready=None,
69+
timeout=None,
70+
metadata=None):
71+
return grpc.experimental.unary_unary(
72+
request,
73+
target,
74+
'/rpc.v1.Stats/ResourceStats',
75+
vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString,
76+
vald_dot_v1_dot_payload_dot_payload__pb2.Info.ResourceStats.FromString,
77+
options,
78+
channel_credentials,
79+
insecure,
80+
call_credentials,
81+
compression,
82+
wait_for_ready,
83+
timeout,
84+
metadata,
85+
_registered_method=True)

0 commit comments

Comments
 (0)