Skip to content
GitLab
Switch branch/tag
Find file Normal viewHistoryPermalink
observation_pb2_grpc.py 5.18 KB
Newer Older
Wei Shoulin's avatar
leve0  
Wei Shoulin committed
1
2
3 
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
Wei Shoulin's avatar
c3    
Wei Shoulin committed
4 
from ...facility.observation import observation_pb2 as facility_dot_observation_dot_observation__pb2
Wei Shoulin's avatar
leve0  
Wei Shoulin committed
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26 


class ObservationSrvStub(object):
  # missing associated documentation comment in .proto file
  pass

  def __init__(self, channel):
    """Constructor.

    Args:
      channel: A grpc.Channel.
    """
    self.Find = channel.unary_unary(
        '/observation.ObservationSrv/Find',
        request_serializer=facility_dot_observation_dot_observation__pb2.FindObservationReq.SerializeToString,
        response_deserializer=facility_dot_observation_dot_observation__pb2.FindObservationResp.FromString,
        )
    self.Get = channel.unary_unary(
        '/observation.ObservationSrv/Get',
        request_serializer=facility_dot_observation_dot_observation__pb2.GetObservationReq.SerializeToString,
        response_deserializer=facility_dot_observation_dot_observation__pb2.GetObservationResp.FromString,
        )
Wei Shoulin's avatar
c3    
Wei Shoulin committed
27 
    self.Write = channel.unary_unary(
Wei Shoulin's avatar
leve0  
Wei Shoulin committed
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
56
57
58
59
60
61 
        '/observation.ObservationSrv/Write',
        request_serializer=facility_dot_observation_dot_observation__pb2.WriteObservationReq.SerializeToString,
        response_deserializer=facility_dot_observation_dot_observation__pb2.WriteObservationResp.FromString,
        )
    self.UpdateQc0Status = channel.unary_unary(
        '/observation.ObservationSrv/UpdateQc0Status',
        request_serializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusReq.SerializeToString,
        response_deserializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusResp.FromString,
        )
    self.UpdateProcStatus = channel.unary_unary(
        '/observation.ObservationSrv/UpdateProcStatus',
        request_serializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusReq.SerializeToString,
        response_deserializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusResp.FromString,
        )


class ObservationSrvServicer(object):
  # missing associated documentation comment in .proto file
  pass

  def Find(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def Get(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')
Wei Shoulin's avatar
c3    
Wei Shoulin committed
62 
  def Write(self, request, context):
Wei Shoulin's avatar
leve0  
Wei Shoulin committed
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95 
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def UpdateQc0Status(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def UpdateProcStatus(self, request, context):
    # missing associated documentation comment in .proto file
    pass
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')


def add_ObservationSrvServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'Find': grpc.unary_unary_rpc_method_handler(
          servicer.Find,
          request_deserializer=facility_dot_observation_dot_observation__pb2.FindObservationReq.FromString,
          response_serializer=facility_dot_observation_dot_observation__pb2.FindObservationResp.SerializeToString,
      ),
      'Get': grpc.unary_unary_rpc_method_handler(
          servicer.Get,
          request_deserializer=facility_dot_observation_dot_observation__pb2.GetObservationReq.FromString,
          response_serializer=facility_dot_observation_dot_observation__pb2.GetObservationResp.SerializeToString,
      ),
Wei Shoulin's avatar
c3    
Wei Shoulin committed
96 
      'Write': grpc.unary_unary_rpc_method_handler(
Wei Shoulin's avatar
leve0  
Wei Shoulin committed
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114 
          servicer.Write,
          request_deserializer=facility_dot_observation_dot_observation__pb2.WriteObservationReq.FromString,
          response_serializer=facility_dot_observation_dot_observation__pb2.WriteObservationResp.SerializeToString,
      ),
      'UpdateQc0Status': grpc.unary_unary_rpc_method_handler(
          servicer.UpdateQc0Status,
          request_deserializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusReq.FromString,
          response_serializer=facility_dot_observation_dot_observation__pb2.UpdateQc0StatusResp.SerializeToString,
      ),
      'UpdateProcStatus': grpc.unary_unary_rpc_method_handler(
          servicer.UpdateProcStatus,
          request_deserializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusReq.FromString,
          response_serializer=facility_dot_observation_dot_observation__pb2.UpdateProcStatusResp.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'observation.ObservationSrv', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))