perxis.environments.environments_pb2_grpc

Client and server classes corresponding to protobuf-defined services.

  1# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
  2"""Client and server classes corresponding to protobuf-defined services."""
  3import grpc
  4import warnings
  5
  6from perxis.environments import environments_pb2 as environments_dot_environments__pb2
  7from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2
  8
  9GRPC_GENERATED_VERSION = '1.67.1'
 10GRPC_VERSION = grpc.__version__
 11_version_not_supported = False
 12
 13try:
 14    from grpc._utilities import first_version_is_lower
 15    _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
 16except ImportError:
 17    _version_not_supported = True
 18
 19if _version_not_supported:
 20    raise RuntimeError(
 21        f'The grpc package installed is at version {GRPC_VERSION},'
 22        + f' but the generated code in environments/environments_pb2_grpc.py depends on'
 23        + f' grpcio>={GRPC_GENERATED_VERSION}.'
 24        + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
 25        + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
 26    )
 27
 28
 29class EnvironmentsStub(object):
 30    """Missing associated documentation comment in .proto file."""
 31
 32    def __init__(self, channel):
 33        """Constructor.
 34
 35        Args:
 36            channel: A grpc.Channel.
 37        """
 38        self.Create = channel.unary_unary(
 39                '/content.environments.Environments/Create',
 40                request_serializer=environments_dot_environments__pb2.CreateRequest.SerializeToString,
 41                response_deserializer=environments_dot_environments__pb2.CreateResponse.FromString,
 42                _registered_method=True)
 43        self.Get = channel.unary_unary(
 44                '/content.environments.Environments/Get',
 45                request_serializer=environments_dot_environments__pb2.GetRequest.SerializeToString,
 46                response_deserializer=environments_dot_environments__pb2.GetResponse.FromString,
 47                _registered_method=True)
 48        self.List = channel.unary_unary(
 49                '/content.environments.Environments/List',
 50                request_serializer=environments_dot_environments__pb2.ListRequest.SerializeToString,
 51                response_deserializer=environments_dot_environments__pb2.ListResponse.FromString,
 52                _registered_method=True)
 53        self.Update = channel.unary_unary(
 54                '/content.environments.Environments/Update',
 55                request_serializer=environments_dot_environments__pb2.UpdateRequest.SerializeToString,
 56                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
 57                _registered_method=True)
 58        self.SetAlias = channel.unary_unary(
 59                '/content.environments.Environments/SetAlias',
 60                request_serializer=environments_dot_environments__pb2.SetAliasRequest.SerializeToString,
 61                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
 62                _registered_method=True)
 63        self.RemoveAlias = channel.unary_unary(
 64                '/content.environments.Environments/RemoveAlias',
 65                request_serializer=environments_dot_environments__pb2.RemoveAliasRequest.SerializeToString,
 66                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
 67                _registered_method=True)
 68        self.Delete = channel.unary_unary(
 69                '/content.environments.Environments/Delete',
 70                request_serializer=environments_dot_environments__pb2.DeleteRequest.SerializeToString,
 71                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
 72                _registered_method=True)
 73        self.Migrate = channel.unary_unary(
 74                '/content.environments.Environments/Migrate',
 75                request_serializer=environments_dot_environments__pb2.MigrateRequest.SerializeToString,
 76                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
 77                _registered_method=True)
 78
 79
 80class EnvironmentsServicer(object):
 81    """Missing associated documentation comment in .proto file."""
 82
 83    def Create(self, request, context):
 84        """Missing associated documentation comment in .proto file."""
 85        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 86        context.set_details('Method not implemented!')
 87        raise NotImplementedError('Method not implemented!')
 88
 89    def Get(self, request, context):
 90        """Missing associated documentation comment in .proto file."""
 91        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 92        context.set_details('Method not implemented!')
 93        raise NotImplementedError('Method not implemented!')
 94
 95    def List(self, request, context):
 96        """Missing associated documentation comment in .proto file."""
 97        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 98        context.set_details('Method not implemented!')
 99        raise NotImplementedError('Method not implemented!')
100
101    def Update(self, request, context):
102        """Missing associated documentation comment in .proto file."""
103        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
104        context.set_details('Method not implemented!')
105        raise NotImplementedError('Method not implemented!')
106
107    def SetAlias(self, request, context):
108        """Missing associated documentation comment in .proto file."""
109        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
110        context.set_details('Method not implemented!')
111        raise NotImplementedError('Method not implemented!')
112
113    def RemoveAlias(self, request, context):
114        """Missing associated documentation comment in .proto file."""
115        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
116        context.set_details('Method not implemented!')
117        raise NotImplementedError('Method not implemented!')
118
119    def Delete(self, request, context):
120        """Missing associated documentation comment in .proto file."""
121        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
122        context.set_details('Method not implemented!')
123        raise NotImplementedError('Method not implemented!')
124
125    def Migrate(self, request, context):
126        """Выполнить миграцию окружения. По умолчанию выполняется в синхронном режиме, для асинхронного выполнения можно
127        передать соответствующую настройку в опциях `MigrateRequest.options`
128
129        При вызове миграции:
130        - выполняются миграции для всех коллекций окружения
131
132        В случае возникновения ошибок миграции они записываются в поле `Environment.state`
133        """
134        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
135        context.set_details('Method not implemented!')
136        raise NotImplementedError('Method not implemented!')
137
138
139def add_EnvironmentsServicer_to_server(servicer, server):
140    rpc_method_handlers = {
141            'Create': grpc.unary_unary_rpc_method_handler(
142                    servicer.Create,
143                    request_deserializer=environments_dot_environments__pb2.CreateRequest.FromString,
144                    response_serializer=environments_dot_environments__pb2.CreateResponse.SerializeToString,
145            ),
146            'Get': grpc.unary_unary_rpc_method_handler(
147                    servicer.Get,
148                    request_deserializer=environments_dot_environments__pb2.GetRequest.FromString,
149                    response_serializer=environments_dot_environments__pb2.GetResponse.SerializeToString,
150            ),
151            'List': grpc.unary_unary_rpc_method_handler(
152                    servicer.List,
153                    request_deserializer=environments_dot_environments__pb2.ListRequest.FromString,
154                    response_serializer=environments_dot_environments__pb2.ListResponse.SerializeToString,
155            ),
156            'Update': grpc.unary_unary_rpc_method_handler(
157                    servicer.Update,
158                    request_deserializer=environments_dot_environments__pb2.UpdateRequest.FromString,
159                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
160            ),
161            'SetAlias': grpc.unary_unary_rpc_method_handler(
162                    servicer.SetAlias,
163                    request_deserializer=environments_dot_environments__pb2.SetAliasRequest.FromString,
164                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
165            ),
166            'RemoveAlias': grpc.unary_unary_rpc_method_handler(
167                    servicer.RemoveAlias,
168                    request_deserializer=environments_dot_environments__pb2.RemoveAliasRequest.FromString,
169                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
170            ),
171            'Delete': grpc.unary_unary_rpc_method_handler(
172                    servicer.Delete,
173                    request_deserializer=environments_dot_environments__pb2.DeleteRequest.FromString,
174                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
175            ),
176            'Migrate': grpc.unary_unary_rpc_method_handler(
177                    servicer.Migrate,
178                    request_deserializer=environments_dot_environments__pb2.MigrateRequest.FromString,
179                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
180            ),
181    }
182    generic_handler = grpc.method_handlers_generic_handler(
183            'content.environments.Environments', rpc_method_handlers)
184    server.add_generic_rpc_handlers((generic_handler,))
185    server.add_registered_method_handlers('content.environments.Environments', rpc_method_handlers)
186
187
188 # This class is part of an EXPERIMENTAL API.
189class Environments(object):
190    """Missing associated documentation comment in .proto file."""
191
192    @staticmethod
193    def Create(request,
194            target,
195            options=(),
196            channel_credentials=None,
197            call_credentials=None,
198            insecure=False,
199            compression=None,
200            wait_for_ready=None,
201            timeout=None,
202            metadata=None):
203        return grpc.experimental.unary_unary(
204            request,
205            target,
206            '/content.environments.Environments/Create',
207            environments_dot_environments__pb2.CreateRequest.SerializeToString,
208            environments_dot_environments__pb2.CreateResponse.FromString,
209            options,
210            channel_credentials,
211            insecure,
212            call_credentials,
213            compression,
214            wait_for_ready,
215            timeout,
216            metadata,
217            _registered_method=True)
218
219    @staticmethod
220    def Get(request,
221            target,
222            options=(),
223            channel_credentials=None,
224            call_credentials=None,
225            insecure=False,
226            compression=None,
227            wait_for_ready=None,
228            timeout=None,
229            metadata=None):
230        return grpc.experimental.unary_unary(
231            request,
232            target,
233            '/content.environments.Environments/Get',
234            environments_dot_environments__pb2.GetRequest.SerializeToString,
235            environments_dot_environments__pb2.GetResponse.FromString,
236            options,
237            channel_credentials,
238            insecure,
239            call_credentials,
240            compression,
241            wait_for_ready,
242            timeout,
243            metadata,
244            _registered_method=True)
245
246    @staticmethod
247    def List(request,
248            target,
249            options=(),
250            channel_credentials=None,
251            call_credentials=None,
252            insecure=False,
253            compression=None,
254            wait_for_ready=None,
255            timeout=None,
256            metadata=None):
257        return grpc.experimental.unary_unary(
258            request,
259            target,
260            '/content.environments.Environments/List',
261            environments_dot_environments__pb2.ListRequest.SerializeToString,
262            environments_dot_environments__pb2.ListResponse.FromString,
263            options,
264            channel_credentials,
265            insecure,
266            call_credentials,
267            compression,
268            wait_for_ready,
269            timeout,
270            metadata,
271            _registered_method=True)
272
273    @staticmethod
274    def Update(request,
275            target,
276            options=(),
277            channel_credentials=None,
278            call_credentials=None,
279            insecure=False,
280            compression=None,
281            wait_for_ready=None,
282            timeout=None,
283            metadata=None):
284        return grpc.experimental.unary_unary(
285            request,
286            target,
287            '/content.environments.Environments/Update',
288            environments_dot_environments__pb2.UpdateRequest.SerializeToString,
289            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
290            options,
291            channel_credentials,
292            insecure,
293            call_credentials,
294            compression,
295            wait_for_ready,
296            timeout,
297            metadata,
298            _registered_method=True)
299
300    @staticmethod
301    def SetAlias(request,
302            target,
303            options=(),
304            channel_credentials=None,
305            call_credentials=None,
306            insecure=False,
307            compression=None,
308            wait_for_ready=None,
309            timeout=None,
310            metadata=None):
311        return grpc.experimental.unary_unary(
312            request,
313            target,
314            '/content.environments.Environments/SetAlias',
315            environments_dot_environments__pb2.SetAliasRequest.SerializeToString,
316            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
317            options,
318            channel_credentials,
319            insecure,
320            call_credentials,
321            compression,
322            wait_for_ready,
323            timeout,
324            metadata,
325            _registered_method=True)
326
327    @staticmethod
328    def RemoveAlias(request,
329            target,
330            options=(),
331            channel_credentials=None,
332            call_credentials=None,
333            insecure=False,
334            compression=None,
335            wait_for_ready=None,
336            timeout=None,
337            metadata=None):
338        return grpc.experimental.unary_unary(
339            request,
340            target,
341            '/content.environments.Environments/RemoveAlias',
342            environments_dot_environments__pb2.RemoveAliasRequest.SerializeToString,
343            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
344            options,
345            channel_credentials,
346            insecure,
347            call_credentials,
348            compression,
349            wait_for_ready,
350            timeout,
351            metadata,
352            _registered_method=True)
353
354    @staticmethod
355    def Delete(request,
356            target,
357            options=(),
358            channel_credentials=None,
359            call_credentials=None,
360            insecure=False,
361            compression=None,
362            wait_for_ready=None,
363            timeout=None,
364            metadata=None):
365        return grpc.experimental.unary_unary(
366            request,
367            target,
368            '/content.environments.Environments/Delete',
369            environments_dot_environments__pb2.DeleteRequest.SerializeToString,
370            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
371            options,
372            channel_credentials,
373            insecure,
374            call_credentials,
375            compression,
376            wait_for_ready,
377            timeout,
378            metadata,
379            _registered_method=True)
380
381    @staticmethod
382    def Migrate(request,
383            target,
384            options=(),
385            channel_credentials=None,
386            call_credentials=None,
387            insecure=False,
388            compression=None,
389            wait_for_ready=None,
390            timeout=None,
391            metadata=None):
392        return grpc.experimental.unary_unary(
393            request,
394            target,
395            '/content.environments.Environments/Migrate',
396            environments_dot_environments__pb2.MigrateRequest.SerializeToString,
397            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
398            options,
399            channel_credentials,
400            insecure,
401            call_credentials,
402            compression,
403            wait_for_ready,
404            timeout,
405            metadata,
406            _registered_method=True)
GRPC_GENERATED_VERSION = '1.67.1'
GRPC_VERSION = '1.67.1'
class EnvironmentsStub:
30class EnvironmentsStub(object):
31    """Missing associated documentation comment in .proto file."""
32
33    def __init__(self, channel):
34        """Constructor.
35
36        Args:
37            channel: A grpc.Channel.
38        """
39        self.Create = channel.unary_unary(
40                '/content.environments.Environments/Create',
41                request_serializer=environments_dot_environments__pb2.CreateRequest.SerializeToString,
42                response_deserializer=environments_dot_environments__pb2.CreateResponse.FromString,
43                _registered_method=True)
44        self.Get = channel.unary_unary(
45                '/content.environments.Environments/Get',
46                request_serializer=environments_dot_environments__pb2.GetRequest.SerializeToString,
47                response_deserializer=environments_dot_environments__pb2.GetResponse.FromString,
48                _registered_method=True)
49        self.List = channel.unary_unary(
50                '/content.environments.Environments/List',
51                request_serializer=environments_dot_environments__pb2.ListRequest.SerializeToString,
52                response_deserializer=environments_dot_environments__pb2.ListResponse.FromString,
53                _registered_method=True)
54        self.Update = channel.unary_unary(
55                '/content.environments.Environments/Update',
56                request_serializer=environments_dot_environments__pb2.UpdateRequest.SerializeToString,
57                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
58                _registered_method=True)
59        self.SetAlias = channel.unary_unary(
60                '/content.environments.Environments/SetAlias',
61                request_serializer=environments_dot_environments__pb2.SetAliasRequest.SerializeToString,
62                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
63                _registered_method=True)
64        self.RemoveAlias = channel.unary_unary(
65                '/content.environments.Environments/RemoveAlias',
66                request_serializer=environments_dot_environments__pb2.RemoveAliasRequest.SerializeToString,
67                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
68                _registered_method=True)
69        self.Delete = channel.unary_unary(
70                '/content.environments.Environments/Delete',
71                request_serializer=environments_dot_environments__pb2.DeleteRequest.SerializeToString,
72                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
73                _registered_method=True)
74        self.Migrate = channel.unary_unary(
75                '/content.environments.Environments/Migrate',
76                request_serializer=environments_dot_environments__pb2.MigrateRequest.SerializeToString,
77                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
78                _registered_method=True)

Missing associated documentation comment in .proto file.

EnvironmentsStub(channel)
33    def __init__(self, channel):
34        """Constructor.
35
36        Args:
37            channel: A grpc.Channel.
38        """
39        self.Create = channel.unary_unary(
40                '/content.environments.Environments/Create',
41                request_serializer=environments_dot_environments__pb2.CreateRequest.SerializeToString,
42                response_deserializer=environments_dot_environments__pb2.CreateResponse.FromString,
43                _registered_method=True)
44        self.Get = channel.unary_unary(
45                '/content.environments.Environments/Get',
46                request_serializer=environments_dot_environments__pb2.GetRequest.SerializeToString,
47                response_deserializer=environments_dot_environments__pb2.GetResponse.FromString,
48                _registered_method=True)
49        self.List = channel.unary_unary(
50                '/content.environments.Environments/List',
51                request_serializer=environments_dot_environments__pb2.ListRequest.SerializeToString,
52                response_deserializer=environments_dot_environments__pb2.ListResponse.FromString,
53                _registered_method=True)
54        self.Update = channel.unary_unary(
55                '/content.environments.Environments/Update',
56                request_serializer=environments_dot_environments__pb2.UpdateRequest.SerializeToString,
57                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
58                _registered_method=True)
59        self.SetAlias = channel.unary_unary(
60                '/content.environments.Environments/SetAlias',
61                request_serializer=environments_dot_environments__pb2.SetAliasRequest.SerializeToString,
62                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
63                _registered_method=True)
64        self.RemoveAlias = channel.unary_unary(
65                '/content.environments.Environments/RemoveAlias',
66                request_serializer=environments_dot_environments__pb2.RemoveAliasRequest.SerializeToString,
67                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
68                _registered_method=True)
69        self.Delete = channel.unary_unary(
70                '/content.environments.Environments/Delete',
71                request_serializer=environments_dot_environments__pb2.DeleteRequest.SerializeToString,
72                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
73                _registered_method=True)
74        self.Migrate = channel.unary_unary(
75                '/content.environments.Environments/Migrate',
76                request_serializer=environments_dot_environments__pb2.MigrateRequest.SerializeToString,
77                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
78                _registered_method=True)

Constructor.

Arguments:
  • channel: A grpc.Channel.
Create
Get
List
Update
SetAlias
RemoveAlias
Delete
Migrate
class EnvironmentsServicer:
 81class EnvironmentsServicer(object):
 82    """Missing associated documentation comment in .proto file."""
 83
 84    def Create(self, request, context):
 85        """Missing associated documentation comment in .proto file."""
 86        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 87        context.set_details('Method not implemented!')
 88        raise NotImplementedError('Method not implemented!')
 89
 90    def Get(self, request, context):
 91        """Missing associated documentation comment in .proto file."""
 92        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 93        context.set_details('Method not implemented!')
 94        raise NotImplementedError('Method not implemented!')
 95
 96    def List(self, request, context):
 97        """Missing associated documentation comment in .proto file."""
 98        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 99        context.set_details('Method not implemented!')
100        raise NotImplementedError('Method not implemented!')
101
102    def Update(self, request, context):
103        """Missing associated documentation comment in .proto file."""
104        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
105        context.set_details('Method not implemented!')
106        raise NotImplementedError('Method not implemented!')
107
108    def SetAlias(self, request, context):
109        """Missing associated documentation comment in .proto file."""
110        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
111        context.set_details('Method not implemented!')
112        raise NotImplementedError('Method not implemented!')
113
114    def RemoveAlias(self, request, context):
115        """Missing associated documentation comment in .proto file."""
116        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
117        context.set_details('Method not implemented!')
118        raise NotImplementedError('Method not implemented!')
119
120    def Delete(self, request, context):
121        """Missing associated documentation comment in .proto file."""
122        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
123        context.set_details('Method not implemented!')
124        raise NotImplementedError('Method not implemented!')
125
126    def Migrate(self, request, context):
127        """Выполнить миграцию окружения. По умолчанию выполняется в синхронном режиме, для асинхронного выполнения можно
128        передать соответствующую настройку в опциях `MigrateRequest.options`
129
130        При вызове миграции:
131        - выполняются миграции для всех коллекций окружения
132
133        В случае возникновения ошибок миграции они записываются в поле `Environment.state`
134        """
135        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
136        context.set_details('Method not implemented!')
137        raise NotImplementedError('Method not implemented!')

Missing associated documentation comment in .proto file.

def Create(self, request, context):
84    def Create(self, request, context):
85        """Missing associated documentation comment in .proto file."""
86        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
87        context.set_details('Method not implemented!')
88        raise NotImplementedError('Method not implemented!')

Missing associated documentation comment in .proto file.

def Get(self, request, context):
90    def Get(self, request, context):
91        """Missing associated documentation comment in .proto file."""
92        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
93        context.set_details('Method not implemented!')
94        raise NotImplementedError('Method not implemented!')

Missing associated documentation comment in .proto file.

def List(self, request, context):
 96    def List(self, request, context):
 97        """Missing associated documentation comment in .proto file."""
 98        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 99        context.set_details('Method not implemented!')
100        raise NotImplementedError('Method not implemented!')

Missing associated documentation comment in .proto file.

def Update(self, request, context):
102    def Update(self, request, context):
103        """Missing associated documentation comment in .proto file."""
104        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
105        context.set_details('Method not implemented!')
106        raise NotImplementedError('Method not implemented!')

Missing associated documentation comment in .proto file.

def SetAlias(self, request, context):
108    def SetAlias(self, request, context):
109        """Missing associated documentation comment in .proto file."""
110        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
111        context.set_details('Method not implemented!')
112        raise NotImplementedError('Method not implemented!')

Missing associated documentation comment in .proto file.

def RemoveAlias(self, request, context):
114    def RemoveAlias(self, request, context):
115        """Missing associated documentation comment in .proto file."""
116        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
117        context.set_details('Method not implemented!')
118        raise NotImplementedError('Method not implemented!')

Missing associated documentation comment in .proto file.

def Delete(self, request, context):
120    def Delete(self, request, context):
121        """Missing associated documentation comment in .proto file."""
122        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
123        context.set_details('Method not implemented!')
124        raise NotImplementedError('Method not implemented!')

Missing associated documentation comment in .proto file.

def Migrate(self, request, context):
126    def Migrate(self, request, context):
127        """Выполнить миграцию окружения. По умолчанию выполняется в синхронном режиме, для асинхронного выполнения можно
128        передать соответствующую настройку в опциях `MigrateRequest.options`
129
130        При вызове миграции:
131        - выполняются миграции для всех коллекций окружения
132
133        В случае возникновения ошибок миграции они записываются в поле `Environment.state`
134        """
135        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
136        context.set_details('Method not implemented!')
137        raise NotImplementedError('Method not implemented!')

Выполнить миграцию окружения. По умолчанию выполняется в синхронном режиме, для асинхронного выполнения можно передать соответствующую настройку в опциях MigrateRequest.options

При вызове миграции:

  • выполняются миграции для всех коллекций окружения

В случае возникновения ошибок миграции они записываются в поле Environment.state

def add_EnvironmentsServicer_to_server(servicer, server):
140def add_EnvironmentsServicer_to_server(servicer, server):
141    rpc_method_handlers = {
142            'Create': grpc.unary_unary_rpc_method_handler(
143                    servicer.Create,
144                    request_deserializer=environments_dot_environments__pb2.CreateRequest.FromString,
145                    response_serializer=environments_dot_environments__pb2.CreateResponse.SerializeToString,
146            ),
147            'Get': grpc.unary_unary_rpc_method_handler(
148                    servicer.Get,
149                    request_deserializer=environments_dot_environments__pb2.GetRequest.FromString,
150                    response_serializer=environments_dot_environments__pb2.GetResponse.SerializeToString,
151            ),
152            'List': grpc.unary_unary_rpc_method_handler(
153                    servicer.List,
154                    request_deserializer=environments_dot_environments__pb2.ListRequest.FromString,
155                    response_serializer=environments_dot_environments__pb2.ListResponse.SerializeToString,
156            ),
157            'Update': grpc.unary_unary_rpc_method_handler(
158                    servicer.Update,
159                    request_deserializer=environments_dot_environments__pb2.UpdateRequest.FromString,
160                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
161            ),
162            'SetAlias': grpc.unary_unary_rpc_method_handler(
163                    servicer.SetAlias,
164                    request_deserializer=environments_dot_environments__pb2.SetAliasRequest.FromString,
165                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
166            ),
167            'RemoveAlias': grpc.unary_unary_rpc_method_handler(
168                    servicer.RemoveAlias,
169                    request_deserializer=environments_dot_environments__pb2.RemoveAliasRequest.FromString,
170                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
171            ),
172            'Delete': grpc.unary_unary_rpc_method_handler(
173                    servicer.Delete,
174                    request_deserializer=environments_dot_environments__pb2.DeleteRequest.FromString,
175                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
176            ),
177            'Migrate': grpc.unary_unary_rpc_method_handler(
178                    servicer.Migrate,
179                    request_deserializer=environments_dot_environments__pb2.MigrateRequest.FromString,
180                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
181            ),
182    }
183    generic_handler = grpc.method_handlers_generic_handler(
184            'content.environments.Environments', rpc_method_handlers)
185    server.add_generic_rpc_handlers((generic_handler,))
186    server.add_registered_method_handlers('content.environments.Environments', rpc_method_handlers)
class Environments:
190class Environments(object):
191    """Missing associated documentation comment in .proto file."""
192
193    @staticmethod
194    def Create(request,
195            target,
196            options=(),
197            channel_credentials=None,
198            call_credentials=None,
199            insecure=False,
200            compression=None,
201            wait_for_ready=None,
202            timeout=None,
203            metadata=None):
204        return grpc.experimental.unary_unary(
205            request,
206            target,
207            '/content.environments.Environments/Create',
208            environments_dot_environments__pb2.CreateRequest.SerializeToString,
209            environments_dot_environments__pb2.CreateResponse.FromString,
210            options,
211            channel_credentials,
212            insecure,
213            call_credentials,
214            compression,
215            wait_for_ready,
216            timeout,
217            metadata,
218            _registered_method=True)
219
220    @staticmethod
221    def Get(request,
222            target,
223            options=(),
224            channel_credentials=None,
225            call_credentials=None,
226            insecure=False,
227            compression=None,
228            wait_for_ready=None,
229            timeout=None,
230            metadata=None):
231        return grpc.experimental.unary_unary(
232            request,
233            target,
234            '/content.environments.Environments/Get',
235            environments_dot_environments__pb2.GetRequest.SerializeToString,
236            environments_dot_environments__pb2.GetResponse.FromString,
237            options,
238            channel_credentials,
239            insecure,
240            call_credentials,
241            compression,
242            wait_for_ready,
243            timeout,
244            metadata,
245            _registered_method=True)
246
247    @staticmethod
248    def List(request,
249            target,
250            options=(),
251            channel_credentials=None,
252            call_credentials=None,
253            insecure=False,
254            compression=None,
255            wait_for_ready=None,
256            timeout=None,
257            metadata=None):
258        return grpc.experimental.unary_unary(
259            request,
260            target,
261            '/content.environments.Environments/List',
262            environments_dot_environments__pb2.ListRequest.SerializeToString,
263            environments_dot_environments__pb2.ListResponse.FromString,
264            options,
265            channel_credentials,
266            insecure,
267            call_credentials,
268            compression,
269            wait_for_ready,
270            timeout,
271            metadata,
272            _registered_method=True)
273
274    @staticmethod
275    def Update(request,
276            target,
277            options=(),
278            channel_credentials=None,
279            call_credentials=None,
280            insecure=False,
281            compression=None,
282            wait_for_ready=None,
283            timeout=None,
284            metadata=None):
285        return grpc.experimental.unary_unary(
286            request,
287            target,
288            '/content.environments.Environments/Update',
289            environments_dot_environments__pb2.UpdateRequest.SerializeToString,
290            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
291            options,
292            channel_credentials,
293            insecure,
294            call_credentials,
295            compression,
296            wait_for_ready,
297            timeout,
298            metadata,
299            _registered_method=True)
300
301    @staticmethod
302    def SetAlias(request,
303            target,
304            options=(),
305            channel_credentials=None,
306            call_credentials=None,
307            insecure=False,
308            compression=None,
309            wait_for_ready=None,
310            timeout=None,
311            metadata=None):
312        return grpc.experimental.unary_unary(
313            request,
314            target,
315            '/content.environments.Environments/SetAlias',
316            environments_dot_environments__pb2.SetAliasRequest.SerializeToString,
317            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
318            options,
319            channel_credentials,
320            insecure,
321            call_credentials,
322            compression,
323            wait_for_ready,
324            timeout,
325            metadata,
326            _registered_method=True)
327
328    @staticmethod
329    def RemoveAlias(request,
330            target,
331            options=(),
332            channel_credentials=None,
333            call_credentials=None,
334            insecure=False,
335            compression=None,
336            wait_for_ready=None,
337            timeout=None,
338            metadata=None):
339        return grpc.experimental.unary_unary(
340            request,
341            target,
342            '/content.environments.Environments/RemoveAlias',
343            environments_dot_environments__pb2.RemoveAliasRequest.SerializeToString,
344            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
345            options,
346            channel_credentials,
347            insecure,
348            call_credentials,
349            compression,
350            wait_for_ready,
351            timeout,
352            metadata,
353            _registered_method=True)
354
355    @staticmethod
356    def Delete(request,
357            target,
358            options=(),
359            channel_credentials=None,
360            call_credentials=None,
361            insecure=False,
362            compression=None,
363            wait_for_ready=None,
364            timeout=None,
365            metadata=None):
366        return grpc.experimental.unary_unary(
367            request,
368            target,
369            '/content.environments.Environments/Delete',
370            environments_dot_environments__pb2.DeleteRequest.SerializeToString,
371            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
372            options,
373            channel_credentials,
374            insecure,
375            call_credentials,
376            compression,
377            wait_for_ready,
378            timeout,
379            metadata,
380            _registered_method=True)
381
382    @staticmethod
383    def Migrate(request,
384            target,
385            options=(),
386            channel_credentials=None,
387            call_credentials=None,
388            insecure=False,
389            compression=None,
390            wait_for_ready=None,
391            timeout=None,
392            metadata=None):
393        return grpc.experimental.unary_unary(
394            request,
395            target,
396            '/content.environments.Environments/Migrate',
397            environments_dot_environments__pb2.MigrateRequest.SerializeToString,
398            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
399            options,
400            channel_credentials,
401            insecure,
402            call_credentials,
403            compression,
404            wait_for_ready,
405            timeout,
406            metadata,
407            _registered_method=True)

Missing associated documentation comment in .proto file.

@staticmethod
def Create( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
193    @staticmethod
194    def Create(request,
195            target,
196            options=(),
197            channel_credentials=None,
198            call_credentials=None,
199            insecure=False,
200            compression=None,
201            wait_for_ready=None,
202            timeout=None,
203            metadata=None):
204        return grpc.experimental.unary_unary(
205            request,
206            target,
207            '/content.environments.Environments/Create',
208            environments_dot_environments__pb2.CreateRequest.SerializeToString,
209            environments_dot_environments__pb2.CreateResponse.FromString,
210            options,
211            channel_credentials,
212            insecure,
213            call_credentials,
214            compression,
215            wait_for_ready,
216            timeout,
217            metadata,
218            _registered_method=True)
@staticmethod
def Get( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
220    @staticmethod
221    def Get(request,
222            target,
223            options=(),
224            channel_credentials=None,
225            call_credentials=None,
226            insecure=False,
227            compression=None,
228            wait_for_ready=None,
229            timeout=None,
230            metadata=None):
231        return grpc.experimental.unary_unary(
232            request,
233            target,
234            '/content.environments.Environments/Get',
235            environments_dot_environments__pb2.GetRequest.SerializeToString,
236            environments_dot_environments__pb2.GetResponse.FromString,
237            options,
238            channel_credentials,
239            insecure,
240            call_credentials,
241            compression,
242            wait_for_ready,
243            timeout,
244            metadata,
245            _registered_method=True)
@staticmethod
def List( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
247    @staticmethod
248    def List(request,
249            target,
250            options=(),
251            channel_credentials=None,
252            call_credentials=None,
253            insecure=False,
254            compression=None,
255            wait_for_ready=None,
256            timeout=None,
257            metadata=None):
258        return grpc.experimental.unary_unary(
259            request,
260            target,
261            '/content.environments.Environments/List',
262            environments_dot_environments__pb2.ListRequest.SerializeToString,
263            environments_dot_environments__pb2.ListResponse.FromString,
264            options,
265            channel_credentials,
266            insecure,
267            call_credentials,
268            compression,
269            wait_for_ready,
270            timeout,
271            metadata,
272            _registered_method=True)
@staticmethod
def Update( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
274    @staticmethod
275    def Update(request,
276            target,
277            options=(),
278            channel_credentials=None,
279            call_credentials=None,
280            insecure=False,
281            compression=None,
282            wait_for_ready=None,
283            timeout=None,
284            metadata=None):
285        return grpc.experimental.unary_unary(
286            request,
287            target,
288            '/content.environments.Environments/Update',
289            environments_dot_environments__pb2.UpdateRequest.SerializeToString,
290            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
291            options,
292            channel_credentials,
293            insecure,
294            call_credentials,
295            compression,
296            wait_for_ready,
297            timeout,
298            metadata,
299            _registered_method=True)
@staticmethod
def SetAlias( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
301    @staticmethod
302    def SetAlias(request,
303            target,
304            options=(),
305            channel_credentials=None,
306            call_credentials=None,
307            insecure=False,
308            compression=None,
309            wait_for_ready=None,
310            timeout=None,
311            metadata=None):
312        return grpc.experimental.unary_unary(
313            request,
314            target,
315            '/content.environments.Environments/SetAlias',
316            environments_dot_environments__pb2.SetAliasRequest.SerializeToString,
317            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
318            options,
319            channel_credentials,
320            insecure,
321            call_credentials,
322            compression,
323            wait_for_ready,
324            timeout,
325            metadata,
326            _registered_method=True)
@staticmethod
def RemoveAlias( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
328    @staticmethod
329    def RemoveAlias(request,
330            target,
331            options=(),
332            channel_credentials=None,
333            call_credentials=None,
334            insecure=False,
335            compression=None,
336            wait_for_ready=None,
337            timeout=None,
338            metadata=None):
339        return grpc.experimental.unary_unary(
340            request,
341            target,
342            '/content.environments.Environments/RemoveAlias',
343            environments_dot_environments__pb2.RemoveAliasRequest.SerializeToString,
344            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
345            options,
346            channel_credentials,
347            insecure,
348            call_credentials,
349            compression,
350            wait_for_ready,
351            timeout,
352            metadata,
353            _registered_method=True)
@staticmethod
def Delete( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
355    @staticmethod
356    def Delete(request,
357            target,
358            options=(),
359            channel_credentials=None,
360            call_credentials=None,
361            insecure=False,
362            compression=None,
363            wait_for_ready=None,
364            timeout=None,
365            metadata=None):
366        return grpc.experimental.unary_unary(
367            request,
368            target,
369            '/content.environments.Environments/Delete',
370            environments_dot_environments__pb2.DeleteRequest.SerializeToString,
371            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
372            options,
373            channel_credentials,
374            insecure,
375            call_credentials,
376            compression,
377            wait_for_ready,
378            timeout,
379            metadata,
380            _registered_method=True)
@staticmethod
def Migrate( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
382    @staticmethod
383    def Migrate(request,
384            target,
385            options=(),
386            channel_credentials=None,
387            call_credentials=None,
388            insecure=False,
389            compression=None,
390            wait_for_ready=None,
391            timeout=None,
392            metadata=None):
393        return grpc.experimental.unary_unary(
394            request,
395            target,
396            '/content.environments.Environments/Migrate',
397            environments_dot_environments__pb2.MigrateRequest.SerializeToString,
398            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
399            options,
400            channel_credentials,
401            insecure,
402            call_credentials,
403            compression,
404            wait_for_ready,
405            timeout,
406            metadata,
407            _registered_method=True)