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)
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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
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)
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.
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)
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)
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)
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)
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)
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)
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)
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)