perxis.files.files_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.files import files_pb2 as files_dot_files__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 files/files_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 FilesStub(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.StartUpload = channel.unary_unary(
 39                '/files.Files/StartUpload',
 40                request_serializer=files_dot_files__pb2.StartUploadRequest.SerializeToString,
 41                response_deserializer=files_dot_files__pb2.StartUploadResponse.FromString,
 42                _registered_method=True)
 43        self.CompleteUpload = channel.unary_unary(
 44                '/files.Files/CompleteUpload',
 45                request_serializer=files_dot_files__pb2.CompleteUploadRequest.SerializeToString,
 46                response_deserializer=files_dot_files__pb2.CompleteUploadResponse.FromString,
 47                _registered_method=True)
 48        self.AbortUpload = channel.unary_unary(
 49                '/files.Files/AbortUpload',
 50                request_serializer=files_dot_files__pb2.AbortUploadRequest.SerializeToString,
 51                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
 52                _registered_method=True)
 53        self.MoveUpload = channel.unary_unary(
 54                '/files.Files/MoveUpload',
 55                request_serializer=files_dot_files__pb2.MoveUploadRequest.SerializeToString,
 56                response_deserializer=files_dot_files__pb2.MoveUploadResponse.FromString,
 57                _registered_method=True)
 58        self.Upload = channel.unary_unary(
 59                '/files.Files/Upload',
 60                request_serializer=files_dot_files__pb2.UploadRequest.SerializeToString,
 61                response_deserializer=files_dot_files__pb2.UploadResponse.FromString,
 62                _registered_method=True)
 63        self.GetFile = channel.unary_unary(
 64                '/files.Files/GetFile',
 65                request_serializer=files_dot_files__pb2.GetFileRequest.SerializeToString,
 66                response_deserializer=files_dot_files__pb2.GetFileResponse.FromString,
 67                _registered_method=True)
 68        self.DeleteFile = channel.unary_unary(
 69                '/files.Files/DeleteFile',
 70                request_serializer=files_dot_files__pb2.DeleteFileRequest.SerializeToString,
 71                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
 72                _registered_method=True)
 73
 74
 75class FilesServicer(object):
 76    """Missing associated documentation comment in .proto file."""
 77
 78    def StartUpload(self, request, context):
 79        """StartUpload - инициирует процедуру загрузки файла в файловое хранилище.
 80        Используется клиентским приложением для начала загрузки файла
 81        Требуемые параметры: объект `MultipartUpload` с вложенным объектом `File`, в котором
 82        обязательные поля  Name и Size.
 83        Возвращает объект с заполненными полями ID, PartSize, PartURLs, MimeType, Size, UploadID.
 84        """
 85        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 86        context.set_details('Method not implemented!')
 87        raise NotImplementedError('Method not implemented!')
 88
 89    def CompleteUpload(self, request, context):
 90        """CompleteUpload - завершает процедуру загрузку файла
 91        Предполагается, что в объекте, полученном из `StartUpload`, клиент должен заполнить поле
 92        Parts (идентификаторами загруженных блоков (S3 ETAGs)) и передать его в `CompleteUpload`
 93        """
 94        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 95        context.set_details('Method not implemented!')
 96        raise NotImplementedError('Method not implemented!')
 97
 98    def AbortUpload(self, request, context):
 99        """AbortUpload - прерывает процедуру загрузки файла, все загруженные части файла удаляются их хранилища
100        """
101        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
102        context.set_details('Method not implemented!')
103        raise NotImplementedError('Method not implemented!')
104
105    def MoveUpload(self, request, context):
106        """MoveUpload - перемещает загруженный файл из временного расположения в постоянное месторасположения.
107        После перемещение загрузки хранилище выдает новый идентификатор постоянного файла
108        """
109        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
110        context.set_details('Method not implemented!')
111        raise NotImplementedError('Method not implemented!')
112
113    def Upload(self, request, context):
114        """Upload - инициация загрузки файла в хранилище. Возвращает объект, содержащий подписанный URL.
115        Завершение загрузки файла осуществляется выполнением POST-запроса
116        """
117        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
118        context.set_details('Method not implemented!')
119        raise NotImplementedError('Method not implemented!')
120
121    def GetFile(self, request, context):
122        """GetFile - получить информацию о файле (ссылку) по ID
123        """
124        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
125        context.set_details('Method not implemented!')
126        raise NotImplementedError('Method not implemented!')
127
128    def DeleteFile(self, request, context):
129        """DeleteFile - удаляет файл. Если происходит удаление оригинала,
130        удаляются и все связанные структуры
131        Возможны следующие ситуации:
132        - Удаление оригинального файла. Удаляется файл и все связанные с ним файлы.
133        - Удаление связанного файла. Для удаления конкретного файла передается 'ID', 'Type' и 'Name'
134        - Удаления связанных файлов конкретного типа (например, все 'thumbnails'). Передается 'ID' и 'Type'
135        """
136        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
137        context.set_details('Method not implemented!')
138        raise NotImplementedError('Method not implemented!')
139
140
141def add_FilesServicer_to_server(servicer, server):
142    rpc_method_handlers = {
143            'StartUpload': grpc.unary_unary_rpc_method_handler(
144                    servicer.StartUpload,
145                    request_deserializer=files_dot_files__pb2.StartUploadRequest.FromString,
146                    response_serializer=files_dot_files__pb2.StartUploadResponse.SerializeToString,
147            ),
148            'CompleteUpload': grpc.unary_unary_rpc_method_handler(
149                    servicer.CompleteUpload,
150                    request_deserializer=files_dot_files__pb2.CompleteUploadRequest.FromString,
151                    response_serializer=files_dot_files__pb2.CompleteUploadResponse.SerializeToString,
152            ),
153            'AbortUpload': grpc.unary_unary_rpc_method_handler(
154                    servicer.AbortUpload,
155                    request_deserializer=files_dot_files__pb2.AbortUploadRequest.FromString,
156                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
157            ),
158            'MoveUpload': grpc.unary_unary_rpc_method_handler(
159                    servicer.MoveUpload,
160                    request_deserializer=files_dot_files__pb2.MoveUploadRequest.FromString,
161                    response_serializer=files_dot_files__pb2.MoveUploadResponse.SerializeToString,
162            ),
163            'Upload': grpc.unary_unary_rpc_method_handler(
164                    servicer.Upload,
165                    request_deserializer=files_dot_files__pb2.UploadRequest.FromString,
166                    response_serializer=files_dot_files__pb2.UploadResponse.SerializeToString,
167            ),
168            'GetFile': grpc.unary_unary_rpc_method_handler(
169                    servicer.GetFile,
170                    request_deserializer=files_dot_files__pb2.GetFileRequest.FromString,
171                    response_serializer=files_dot_files__pb2.GetFileResponse.SerializeToString,
172            ),
173            'DeleteFile': grpc.unary_unary_rpc_method_handler(
174                    servicer.DeleteFile,
175                    request_deserializer=files_dot_files__pb2.DeleteFileRequest.FromString,
176                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
177            ),
178    }
179    generic_handler = grpc.method_handlers_generic_handler(
180            'files.Files', rpc_method_handlers)
181    server.add_generic_rpc_handlers((generic_handler,))
182    server.add_registered_method_handlers('files.Files', rpc_method_handlers)
183
184
185 # This class is part of an EXPERIMENTAL API.
186class Files(object):
187    """Missing associated documentation comment in .proto file."""
188
189    @staticmethod
190    def StartUpload(request,
191            target,
192            options=(),
193            channel_credentials=None,
194            call_credentials=None,
195            insecure=False,
196            compression=None,
197            wait_for_ready=None,
198            timeout=None,
199            metadata=None):
200        return grpc.experimental.unary_unary(
201            request,
202            target,
203            '/files.Files/StartUpload',
204            files_dot_files__pb2.StartUploadRequest.SerializeToString,
205            files_dot_files__pb2.StartUploadResponse.FromString,
206            options,
207            channel_credentials,
208            insecure,
209            call_credentials,
210            compression,
211            wait_for_ready,
212            timeout,
213            metadata,
214            _registered_method=True)
215
216    @staticmethod
217    def CompleteUpload(request,
218            target,
219            options=(),
220            channel_credentials=None,
221            call_credentials=None,
222            insecure=False,
223            compression=None,
224            wait_for_ready=None,
225            timeout=None,
226            metadata=None):
227        return grpc.experimental.unary_unary(
228            request,
229            target,
230            '/files.Files/CompleteUpload',
231            files_dot_files__pb2.CompleteUploadRequest.SerializeToString,
232            files_dot_files__pb2.CompleteUploadResponse.FromString,
233            options,
234            channel_credentials,
235            insecure,
236            call_credentials,
237            compression,
238            wait_for_ready,
239            timeout,
240            metadata,
241            _registered_method=True)
242
243    @staticmethod
244    def AbortUpload(request,
245            target,
246            options=(),
247            channel_credentials=None,
248            call_credentials=None,
249            insecure=False,
250            compression=None,
251            wait_for_ready=None,
252            timeout=None,
253            metadata=None):
254        return grpc.experimental.unary_unary(
255            request,
256            target,
257            '/files.Files/AbortUpload',
258            files_dot_files__pb2.AbortUploadRequest.SerializeToString,
259            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
260            options,
261            channel_credentials,
262            insecure,
263            call_credentials,
264            compression,
265            wait_for_ready,
266            timeout,
267            metadata,
268            _registered_method=True)
269
270    @staticmethod
271    def MoveUpload(request,
272            target,
273            options=(),
274            channel_credentials=None,
275            call_credentials=None,
276            insecure=False,
277            compression=None,
278            wait_for_ready=None,
279            timeout=None,
280            metadata=None):
281        return grpc.experimental.unary_unary(
282            request,
283            target,
284            '/files.Files/MoveUpload',
285            files_dot_files__pb2.MoveUploadRequest.SerializeToString,
286            files_dot_files__pb2.MoveUploadResponse.FromString,
287            options,
288            channel_credentials,
289            insecure,
290            call_credentials,
291            compression,
292            wait_for_ready,
293            timeout,
294            metadata,
295            _registered_method=True)
296
297    @staticmethod
298    def Upload(request,
299            target,
300            options=(),
301            channel_credentials=None,
302            call_credentials=None,
303            insecure=False,
304            compression=None,
305            wait_for_ready=None,
306            timeout=None,
307            metadata=None):
308        return grpc.experimental.unary_unary(
309            request,
310            target,
311            '/files.Files/Upload',
312            files_dot_files__pb2.UploadRequest.SerializeToString,
313            files_dot_files__pb2.UploadResponse.FromString,
314            options,
315            channel_credentials,
316            insecure,
317            call_credentials,
318            compression,
319            wait_for_ready,
320            timeout,
321            metadata,
322            _registered_method=True)
323
324    @staticmethod
325    def GetFile(request,
326            target,
327            options=(),
328            channel_credentials=None,
329            call_credentials=None,
330            insecure=False,
331            compression=None,
332            wait_for_ready=None,
333            timeout=None,
334            metadata=None):
335        return grpc.experimental.unary_unary(
336            request,
337            target,
338            '/files.Files/GetFile',
339            files_dot_files__pb2.GetFileRequest.SerializeToString,
340            files_dot_files__pb2.GetFileResponse.FromString,
341            options,
342            channel_credentials,
343            insecure,
344            call_credentials,
345            compression,
346            wait_for_ready,
347            timeout,
348            metadata,
349            _registered_method=True)
350
351    @staticmethod
352    def DeleteFile(request,
353            target,
354            options=(),
355            channel_credentials=None,
356            call_credentials=None,
357            insecure=False,
358            compression=None,
359            wait_for_ready=None,
360            timeout=None,
361            metadata=None):
362        return grpc.experimental.unary_unary(
363            request,
364            target,
365            '/files.Files/DeleteFile',
366            files_dot_files__pb2.DeleteFileRequest.SerializeToString,
367            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
368            options,
369            channel_credentials,
370            insecure,
371            call_credentials,
372            compression,
373            wait_for_ready,
374            timeout,
375            metadata,
376            _registered_method=True)
GRPC_GENERATED_VERSION = '1.67.1'
GRPC_VERSION = '1.67.1'
class FilesStub:
30class FilesStub(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.StartUpload = channel.unary_unary(
40                '/files.Files/StartUpload',
41                request_serializer=files_dot_files__pb2.StartUploadRequest.SerializeToString,
42                response_deserializer=files_dot_files__pb2.StartUploadResponse.FromString,
43                _registered_method=True)
44        self.CompleteUpload = channel.unary_unary(
45                '/files.Files/CompleteUpload',
46                request_serializer=files_dot_files__pb2.CompleteUploadRequest.SerializeToString,
47                response_deserializer=files_dot_files__pb2.CompleteUploadResponse.FromString,
48                _registered_method=True)
49        self.AbortUpload = channel.unary_unary(
50                '/files.Files/AbortUpload',
51                request_serializer=files_dot_files__pb2.AbortUploadRequest.SerializeToString,
52                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
53                _registered_method=True)
54        self.MoveUpload = channel.unary_unary(
55                '/files.Files/MoveUpload',
56                request_serializer=files_dot_files__pb2.MoveUploadRequest.SerializeToString,
57                response_deserializer=files_dot_files__pb2.MoveUploadResponse.FromString,
58                _registered_method=True)
59        self.Upload = channel.unary_unary(
60                '/files.Files/Upload',
61                request_serializer=files_dot_files__pb2.UploadRequest.SerializeToString,
62                response_deserializer=files_dot_files__pb2.UploadResponse.FromString,
63                _registered_method=True)
64        self.GetFile = channel.unary_unary(
65                '/files.Files/GetFile',
66                request_serializer=files_dot_files__pb2.GetFileRequest.SerializeToString,
67                response_deserializer=files_dot_files__pb2.GetFileResponse.FromString,
68                _registered_method=True)
69        self.DeleteFile = channel.unary_unary(
70                '/files.Files/DeleteFile',
71                request_serializer=files_dot_files__pb2.DeleteFileRequest.SerializeToString,
72                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
73                _registered_method=True)

Missing associated documentation comment in .proto file.

FilesStub(channel)
33    def __init__(self, channel):
34        """Constructor.
35
36        Args:
37            channel: A grpc.Channel.
38        """
39        self.StartUpload = channel.unary_unary(
40                '/files.Files/StartUpload',
41                request_serializer=files_dot_files__pb2.StartUploadRequest.SerializeToString,
42                response_deserializer=files_dot_files__pb2.StartUploadResponse.FromString,
43                _registered_method=True)
44        self.CompleteUpload = channel.unary_unary(
45                '/files.Files/CompleteUpload',
46                request_serializer=files_dot_files__pb2.CompleteUploadRequest.SerializeToString,
47                response_deserializer=files_dot_files__pb2.CompleteUploadResponse.FromString,
48                _registered_method=True)
49        self.AbortUpload = channel.unary_unary(
50                '/files.Files/AbortUpload',
51                request_serializer=files_dot_files__pb2.AbortUploadRequest.SerializeToString,
52                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
53                _registered_method=True)
54        self.MoveUpload = channel.unary_unary(
55                '/files.Files/MoveUpload',
56                request_serializer=files_dot_files__pb2.MoveUploadRequest.SerializeToString,
57                response_deserializer=files_dot_files__pb2.MoveUploadResponse.FromString,
58                _registered_method=True)
59        self.Upload = channel.unary_unary(
60                '/files.Files/Upload',
61                request_serializer=files_dot_files__pb2.UploadRequest.SerializeToString,
62                response_deserializer=files_dot_files__pb2.UploadResponse.FromString,
63                _registered_method=True)
64        self.GetFile = channel.unary_unary(
65                '/files.Files/GetFile',
66                request_serializer=files_dot_files__pb2.GetFileRequest.SerializeToString,
67                response_deserializer=files_dot_files__pb2.GetFileResponse.FromString,
68                _registered_method=True)
69        self.DeleteFile = channel.unary_unary(
70                '/files.Files/DeleteFile',
71                request_serializer=files_dot_files__pb2.DeleteFileRequest.SerializeToString,
72                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
73                _registered_method=True)

Constructor.

Arguments:
  • channel: A grpc.Channel.
StartUpload
CompleteUpload
AbortUpload
MoveUpload
Upload
GetFile
DeleteFile
class FilesServicer:
 76class FilesServicer(object):
 77    """Missing associated documentation comment in .proto file."""
 78
 79    def StartUpload(self, request, context):
 80        """StartUpload - инициирует процедуру загрузки файла в файловое хранилище.
 81        Используется клиентским приложением для начала загрузки файла
 82        Требуемые параметры: объект `MultipartUpload` с вложенным объектом `File`, в котором
 83        обязательные поля  Name и Size.
 84        Возвращает объект с заполненными полями ID, PartSize, PartURLs, MimeType, Size, UploadID.
 85        """
 86        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 87        context.set_details('Method not implemented!')
 88        raise NotImplementedError('Method not implemented!')
 89
 90    def CompleteUpload(self, request, context):
 91        """CompleteUpload - завершает процедуру загрузку файла
 92        Предполагается, что в объекте, полученном из `StartUpload`, клиент должен заполнить поле
 93        Parts (идентификаторами загруженных блоков (S3 ETAGs)) и передать его в `CompleteUpload`
 94        """
 95        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 96        context.set_details('Method not implemented!')
 97        raise NotImplementedError('Method not implemented!')
 98
 99    def AbortUpload(self, request, context):
100        """AbortUpload - прерывает процедуру загрузки файла, все загруженные части файла удаляются их хранилища
101        """
102        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
103        context.set_details('Method not implemented!')
104        raise NotImplementedError('Method not implemented!')
105
106    def MoveUpload(self, request, context):
107        """MoveUpload - перемещает загруженный файл из временного расположения в постоянное месторасположения.
108        После перемещение загрузки хранилище выдает новый идентификатор постоянного файла
109        """
110        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
111        context.set_details('Method not implemented!')
112        raise NotImplementedError('Method not implemented!')
113
114    def Upload(self, request, context):
115        """Upload - инициация загрузки файла в хранилище. Возвращает объект, содержащий подписанный URL.
116        Завершение загрузки файла осуществляется выполнением POST-запроса
117        """
118        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
119        context.set_details('Method not implemented!')
120        raise NotImplementedError('Method not implemented!')
121
122    def GetFile(self, request, context):
123        """GetFile - получить информацию о файле (ссылку) по ID
124        """
125        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
126        context.set_details('Method not implemented!')
127        raise NotImplementedError('Method not implemented!')
128
129    def DeleteFile(self, request, context):
130        """DeleteFile - удаляет файл. Если происходит удаление оригинала,
131        удаляются и все связанные структуры
132        Возможны следующие ситуации:
133        - Удаление оригинального файла. Удаляется файл и все связанные с ним файлы.
134        - Удаление связанного файла. Для удаления конкретного файла передается 'ID', 'Type' и 'Name'
135        - Удаления связанных файлов конкретного типа (например, все 'thumbnails'). Передается 'ID' и 'Type'
136        """
137        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
138        context.set_details('Method not implemented!')
139        raise NotImplementedError('Method not implemented!')

Missing associated documentation comment in .proto file.

def StartUpload(self, request, context):
79    def StartUpload(self, request, context):
80        """StartUpload - инициирует процедуру загрузки файла в файловое хранилище.
81        Используется клиентским приложением для начала загрузки файла
82        Требуемые параметры: объект `MultipartUpload` с вложенным объектом `File`, в котором
83        обязательные поля  Name и Size.
84        Возвращает объект с заполненными полями ID, PartSize, PartURLs, MimeType, Size, UploadID.
85        """
86        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
87        context.set_details('Method not implemented!')
88        raise NotImplementedError('Method not implemented!')

StartUpload - инициирует процедуру загрузки файла в файловое хранилище. Используется клиентским приложением для начала загрузки файла Требуемые параметры: объект MultipartUpload с вложенным объектом File, в котором обязательные поля Name и Size. Возвращает объект с заполненными полями ID, PartSize, PartURLs, MimeType, Size, UploadID.

def CompleteUpload(self, request, context):
90    def CompleteUpload(self, request, context):
91        """CompleteUpload - завершает процедуру загрузку файла
92        Предполагается, что в объекте, полученном из `StartUpload`, клиент должен заполнить поле
93        Parts (идентификаторами загруженных блоков (S3 ETAGs)) и передать его в `CompleteUpload`
94        """
95        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
96        context.set_details('Method not implemented!')
97        raise NotImplementedError('Method not implemented!')

CompleteUpload - завершает процедуру загрузку файла Предполагается, что в объекте, полученном из StartUpload, клиент должен заполнить поле Parts (идентификаторами загруженных блоков (S3 ETAGs)) и передать его в CompleteUpload

def AbortUpload(self, request, context):
 99    def AbortUpload(self, request, context):
100        """AbortUpload - прерывает процедуру загрузки файла, все загруженные части файла удаляются их хранилища
101        """
102        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
103        context.set_details('Method not implemented!')
104        raise NotImplementedError('Method not implemented!')

AbortUpload - прерывает процедуру загрузки файла, все загруженные части файла удаляются их хранилища

def MoveUpload(self, request, context):
106    def MoveUpload(self, request, context):
107        """MoveUpload - перемещает загруженный файл из временного расположения в постоянное месторасположения.
108        После перемещение загрузки хранилище выдает новый идентификатор постоянного файла
109        """
110        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
111        context.set_details('Method not implemented!')
112        raise NotImplementedError('Method not implemented!')

MoveUpload - перемещает загруженный файл из временного расположения в постоянное месторасположения. После перемещение загрузки хранилище выдает новый идентификатор постоянного файла

def Upload(self, request, context):
114    def Upload(self, request, context):
115        """Upload - инициация загрузки файла в хранилище. Возвращает объект, содержащий подписанный URL.
116        Завершение загрузки файла осуществляется выполнением POST-запроса
117        """
118        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
119        context.set_details('Method not implemented!')
120        raise NotImplementedError('Method not implemented!')

Upload - инициация загрузки файла в хранилище. Возвращает объект, содержащий подписанный URL. Завершение загрузки файла осуществляется выполнением POST-запроса

def GetFile(self, request, context):
122    def GetFile(self, request, context):
123        """GetFile - получить информацию о файле (ссылку) по ID
124        """
125        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
126        context.set_details('Method not implemented!')
127        raise NotImplementedError('Method not implemented!')

GetFile - получить информацию о файле (ссылку) по ID

def DeleteFile(self, request, context):
129    def DeleteFile(self, request, context):
130        """DeleteFile - удаляет файл. Если происходит удаление оригинала,
131        удаляются и все связанные структуры
132        Возможны следующие ситуации:
133        - Удаление оригинального файла. Удаляется файл и все связанные с ним файлы.
134        - Удаление связанного файла. Для удаления конкретного файла передается 'ID', 'Type' и 'Name'
135        - Удаления связанных файлов конкретного типа (например, все 'thumbnails'). Передается 'ID' и 'Type'
136        """
137        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
138        context.set_details('Method not implemented!')
139        raise NotImplementedError('Method not implemented!')

DeleteFile - удаляет файл. Если происходит удаление оригинала, удаляются и все связанные структуры Возможны следующие ситуации:

  • Удаление оригинального файла. Удаляется файл и все связанные с ним файлы.
  • Удаление связанного файла. Для удаления конкретного файла передается 'ID', 'Type' и 'Name'
  • Удаления связанных файлов конкретного типа (например, все 'thumbnails'). Передается 'ID' и 'Type'
def add_FilesServicer_to_server(servicer, server):
142def add_FilesServicer_to_server(servicer, server):
143    rpc_method_handlers = {
144            'StartUpload': grpc.unary_unary_rpc_method_handler(
145                    servicer.StartUpload,
146                    request_deserializer=files_dot_files__pb2.StartUploadRequest.FromString,
147                    response_serializer=files_dot_files__pb2.StartUploadResponse.SerializeToString,
148            ),
149            'CompleteUpload': grpc.unary_unary_rpc_method_handler(
150                    servicer.CompleteUpload,
151                    request_deserializer=files_dot_files__pb2.CompleteUploadRequest.FromString,
152                    response_serializer=files_dot_files__pb2.CompleteUploadResponse.SerializeToString,
153            ),
154            'AbortUpload': grpc.unary_unary_rpc_method_handler(
155                    servicer.AbortUpload,
156                    request_deserializer=files_dot_files__pb2.AbortUploadRequest.FromString,
157                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
158            ),
159            'MoveUpload': grpc.unary_unary_rpc_method_handler(
160                    servicer.MoveUpload,
161                    request_deserializer=files_dot_files__pb2.MoveUploadRequest.FromString,
162                    response_serializer=files_dot_files__pb2.MoveUploadResponse.SerializeToString,
163            ),
164            'Upload': grpc.unary_unary_rpc_method_handler(
165                    servicer.Upload,
166                    request_deserializer=files_dot_files__pb2.UploadRequest.FromString,
167                    response_serializer=files_dot_files__pb2.UploadResponse.SerializeToString,
168            ),
169            'GetFile': grpc.unary_unary_rpc_method_handler(
170                    servicer.GetFile,
171                    request_deserializer=files_dot_files__pb2.GetFileRequest.FromString,
172                    response_serializer=files_dot_files__pb2.GetFileResponse.SerializeToString,
173            ),
174            'DeleteFile': grpc.unary_unary_rpc_method_handler(
175                    servicer.DeleteFile,
176                    request_deserializer=files_dot_files__pb2.DeleteFileRequest.FromString,
177                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
178            ),
179    }
180    generic_handler = grpc.method_handlers_generic_handler(
181            'files.Files', rpc_method_handlers)
182    server.add_generic_rpc_handlers((generic_handler,))
183    server.add_registered_method_handlers('files.Files', rpc_method_handlers)
class Files:
187class Files(object):
188    """Missing associated documentation comment in .proto file."""
189
190    @staticmethod
191    def StartUpload(request,
192            target,
193            options=(),
194            channel_credentials=None,
195            call_credentials=None,
196            insecure=False,
197            compression=None,
198            wait_for_ready=None,
199            timeout=None,
200            metadata=None):
201        return grpc.experimental.unary_unary(
202            request,
203            target,
204            '/files.Files/StartUpload',
205            files_dot_files__pb2.StartUploadRequest.SerializeToString,
206            files_dot_files__pb2.StartUploadResponse.FromString,
207            options,
208            channel_credentials,
209            insecure,
210            call_credentials,
211            compression,
212            wait_for_ready,
213            timeout,
214            metadata,
215            _registered_method=True)
216
217    @staticmethod
218    def CompleteUpload(request,
219            target,
220            options=(),
221            channel_credentials=None,
222            call_credentials=None,
223            insecure=False,
224            compression=None,
225            wait_for_ready=None,
226            timeout=None,
227            metadata=None):
228        return grpc.experimental.unary_unary(
229            request,
230            target,
231            '/files.Files/CompleteUpload',
232            files_dot_files__pb2.CompleteUploadRequest.SerializeToString,
233            files_dot_files__pb2.CompleteUploadResponse.FromString,
234            options,
235            channel_credentials,
236            insecure,
237            call_credentials,
238            compression,
239            wait_for_ready,
240            timeout,
241            metadata,
242            _registered_method=True)
243
244    @staticmethod
245    def AbortUpload(request,
246            target,
247            options=(),
248            channel_credentials=None,
249            call_credentials=None,
250            insecure=False,
251            compression=None,
252            wait_for_ready=None,
253            timeout=None,
254            metadata=None):
255        return grpc.experimental.unary_unary(
256            request,
257            target,
258            '/files.Files/AbortUpload',
259            files_dot_files__pb2.AbortUploadRequest.SerializeToString,
260            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
261            options,
262            channel_credentials,
263            insecure,
264            call_credentials,
265            compression,
266            wait_for_ready,
267            timeout,
268            metadata,
269            _registered_method=True)
270
271    @staticmethod
272    def MoveUpload(request,
273            target,
274            options=(),
275            channel_credentials=None,
276            call_credentials=None,
277            insecure=False,
278            compression=None,
279            wait_for_ready=None,
280            timeout=None,
281            metadata=None):
282        return grpc.experimental.unary_unary(
283            request,
284            target,
285            '/files.Files/MoveUpload',
286            files_dot_files__pb2.MoveUploadRequest.SerializeToString,
287            files_dot_files__pb2.MoveUploadResponse.FromString,
288            options,
289            channel_credentials,
290            insecure,
291            call_credentials,
292            compression,
293            wait_for_ready,
294            timeout,
295            metadata,
296            _registered_method=True)
297
298    @staticmethod
299    def Upload(request,
300            target,
301            options=(),
302            channel_credentials=None,
303            call_credentials=None,
304            insecure=False,
305            compression=None,
306            wait_for_ready=None,
307            timeout=None,
308            metadata=None):
309        return grpc.experimental.unary_unary(
310            request,
311            target,
312            '/files.Files/Upload',
313            files_dot_files__pb2.UploadRequest.SerializeToString,
314            files_dot_files__pb2.UploadResponse.FromString,
315            options,
316            channel_credentials,
317            insecure,
318            call_credentials,
319            compression,
320            wait_for_ready,
321            timeout,
322            metadata,
323            _registered_method=True)
324
325    @staticmethod
326    def GetFile(request,
327            target,
328            options=(),
329            channel_credentials=None,
330            call_credentials=None,
331            insecure=False,
332            compression=None,
333            wait_for_ready=None,
334            timeout=None,
335            metadata=None):
336        return grpc.experimental.unary_unary(
337            request,
338            target,
339            '/files.Files/GetFile',
340            files_dot_files__pb2.GetFileRequest.SerializeToString,
341            files_dot_files__pb2.GetFileResponse.FromString,
342            options,
343            channel_credentials,
344            insecure,
345            call_credentials,
346            compression,
347            wait_for_ready,
348            timeout,
349            metadata,
350            _registered_method=True)
351
352    @staticmethod
353    def DeleteFile(request,
354            target,
355            options=(),
356            channel_credentials=None,
357            call_credentials=None,
358            insecure=False,
359            compression=None,
360            wait_for_ready=None,
361            timeout=None,
362            metadata=None):
363        return grpc.experimental.unary_unary(
364            request,
365            target,
366            '/files.Files/DeleteFile',
367            files_dot_files__pb2.DeleteFileRequest.SerializeToString,
368            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
369            options,
370            channel_credentials,
371            insecure,
372            call_credentials,
373            compression,
374            wait_for_ready,
375            timeout,
376            metadata,
377            _registered_method=True)

Missing associated documentation comment in .proto file.

@staticmethod
def StartUpload( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
190    @staticmethod
191    def StartUpload(request,
192            target,
193            options=(),
194            channel_credentials=None,
195            call_credentials=None,
196            insecure=False,
197            compression=None,
198            wait_for_ready=None,
199            timeout=None,
200            metadata=None):
201        return grpc.experimental.unary_unary(
202            request,
203            target,
204            '/files.Files/StartUpload',
205            files_dot_files__pb2.StartUploadRequest.SerializeToString,
206            files_dot_files__pb2.StartUploadResponse.FromString,
207            options,
208            channel_credentials,
209            insecure,
210            call_credentials,
211            compression,
212            wait_for_ready,
213            timeout,
214            metadata,
215            _registered_method=True)
@staticmethod
def CompleteUpload( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
217    @staticmethod
218    def CompleteUpload(request,
219            target,
220            options=(),
221            channel_credentials=None,
222            call_credentials=None,
223            insecure=False,
224            compression=None,
225            wait_for_ready=None,
226            timeout=None,
227            metadata=None):
228        return grpc.experimental.unary_unary(
229            request,
230            target,
231            '/files.Files/CompleteUpload',
232            files_dot_files__pb2.CompleteUploadRequest.SerializeToString,
233            files_dot_files__pb2.CompleteUploadResponse.FromString,
234            options,
235            channel_credentials,
236            insecure,
237            call_credentials,
238            compression,
239            wait_for_ready,
240            timeout,
241            metadata,
242            _registered_method=True)
@staticmethod
def AbortUpload( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
244    @staticmethod
245    def AbortUpload(request,
246            target,
247            options=(),
248            channel_credentials=None,
249            call_credentials=None,
250            insecure=False,
251            compression=None,
252            wait_for_ready=None,
253            timeout=None,
254            metadata=None):
255        return grpc.experimental.unary_unary(
256            request,
257            target,
258            '/files.Files/AbortUpload',
259            files_dot_files__pb2.AbortUploadRequest.SerializeToString,
260            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
261            options,
262            channel_credentials,
263            insecure,
264            call_credentials,
265            compression,
266            wait_for_ready,
267            timeout,
268            metadata,
269            _registered_method=True)
@staticmethod
def MoveUpload( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
271    @staticmethod
272    def MoveUpload(request,
273            target,
274            options=(),
275            channel_credentials=None,
276            call_credentials=None,
277            insecure=False,
278            compression=None,
279            wait_for_ready=None,
280            timeout=None,
281            metadata=None):
282        return grpc.experimental.unary_unary(
283            request,
284            target,
285            '/files.Files/MoveUpload',
286            files_dot_files__pb2.MoveUploadRequest.SerializeToString,
287            files_dot_files__pb2.MoveUploadResponse.FromString,
288            options,
289            channel_credentials,
290            insecure,
291            call_credentials,
292            compression,
293            wait_for_ready,
294            timeout,
295            metadata,
296            _registered_method=True)
@staticmethod
def Upload( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
298    @staticmethod
299    def Upload(request,
300            target,
301            options=(),
302            channel_credentials=None,
303            call_credentials=None,
304            insecure=False,
305            compression=None,
306            wait_for_ready=None,
307            timeout=None,
308            metadata=None):
309        return grpc.experimental.unary_unary(
310            request,
311            target,
312            '/files.Files/Upload',
313            files_dot_files__pb2.UploadRequest.SerializeToString,
314            files_dot_files__pb2.UploadResponse.FromString,
315            options,
316            channel_credentials,
317            insecure,
318            call_credentials,
319            compression,
320            wait_for_ready,
321            timeout,
322            metadata,
323            _registered_method=True)
@staticmethod
def GetFile( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
325    @staticmethod
326    def GetFile(request,
327            target,
328            options=(),
329            channel_credentials=None,
330            call_credentials=None,
331            insecure=False,
332            compression=None,
333            wait_for_ready=None,
334            timeout=None,
335            metadata=None):
336        return grpc.experimental.unary_unary(
337            request,
338            target,
339            '/files.Files/GetFile',
340            files_dot_files__pb2.GetFileRequest.SerializeToString,
341            files_dot_files__pb2.GetFileResponse.FromString,
342            options,
343            channel_credentials,
344            insecure,
345            call_credentials,
346            compression,
347            wait_for_ready,
348            timeout,
349            metadata,
350            _registered_method=True)
@staticmethod
def DeleteFile( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
352    @staticmethod
353    def DeleteFile(request,
354            target,
355            options=(),
356            channel_credentials=None,
357            call_credentials=None,
358            insecure=False,
359            compression=None,
360            wait_for_ready=None,
361            timeout=None,
362            metadata=None):
363        return grpc.experimental.unary_unary(
364            request,
365            target,
366            '/files.Files/DeleteFile',
367            files_dot_files__pb2.DeleteFileRequest.SerializeToString,
368            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
369            options,
370            channel_credentials,
371            insecure,
372            call_credentials,
373            compression,
374            wait_for_ready,
375            timeout,
376            metadata,
377            _registered_method=True)