Index: client/proto/isolate_bot_pb2.py |
diff --git a/client/proto/isolate_bot_pb2.py b/client/proto/isolate_bot_pb2.py |
deleted file mode 100644 |
index a34afb4d95eefe8818917308073102e1b9f0e36e..0000000000000000000000000000000000000000 |
--- a/client/proto/isolate_bot_pb2.py |
+++ /dev/null |
@@ -1,698 +0,0 @@ |
-# Generated by the protocol buffer compiler. DO NOT EDIT! |
-# source: isolate_bot.proto |
- |
-import sys |
-_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1')) |
-from google.protobuf import descriptor as _descriptor |
-from google.protobuf import message as _message |
-from google.protobuf import reflection as _reflection |
-from google.protobuf import symbol_database as _symbol_database |
-from google.protobuf import descriptor_pb2 |
-# @@protoc_insertion_point(imports) |
- |
-_sym_db = _symbol_database.Default() |
- |
- |
- |
- |
-DESCRIPTOR = _descriptor.FileDescriptor( |
- name='isolate_bot.proto', |
- package='luci.swarming.bot', |
- syntax='proto3', |
- serialized_pb=_b('\n\x11isolate_bot.proto\x12\x11luci.swarming.bot\"C\n\x0f\x43ontainsRequest\x12\x30\n\x06\x64igest\x18\x01 \x03(\x0b\x32 .luci.swarming.bot.ContentDigest\">\n\rContainsReply\x12-\n\x06status\x18\x01 \x01(\x0b\x32\x1d.luci.swarming.bot.BlobStatus\">\n\x10PushBlobsRequest\x12*\n\x04\x64\x61ta\x18\x01 \x01(\x0b\x32\x1c.luci.swarming.bot.BlobChunk\"?\n\x0ePushBlobsReply\x12-\n\x06status\x18\x01 \x01(\x0b\x32\x1d.luci.swarming.bot.BlobStatus\"E\n\x11\x46\x65tchBlobsRequest\x12\x30\n\x06\x64igest\x18\x01 \x03(\x0b\x32 .luci.swarming.bot.ContentDigest\"l\n\x0f\x46\x65tchBlobsReply\x12-\n\x06status\x18\x01 \x01(\x0b\x32\x1d.luci.swarming.bot.BlobStatus\x12*\n\x04\x64\x61ta\x18\x02 \x01(\x0b\x32\x1c.luci.swarming.bot.BlobChunk\"[\n\tBlobChunk\x12\x30\n\x06\x64igest\x18\x01 \x01(\x0b\x32 .luci.swarming.bot.ContentDigest\x12\x0e\n\x06offset\x18\x02 \x01(\x03\x12\x0c\n\x04\x64\x61ta\x18\x03 \x01(\x0c\"D\n\rContentDigest\x12\x0e\n\x06\x64igest\x18\x01 \x01(\x0c\x12\x12\n\nsize_bytes\x18\x02 \x01(\x03\x12\x0f\n\x07version\x18\x03 \x01(\x05\"\x80\x02\n\nBlobStatus\x12\x11\n\tsucceeded\x18\x01 \x01(\x08\x12\x36\n\x05\x65rror\x18\x02 \x01(\x0e\x32\'.luci.swarming.bot.BlobStatus.ErrorCode\x12\x14\n\x0c\x65rror_detail\x18\x03 \x01(\t\x12\x38\n\x0emissing_digest\x18\x04 \x03(\x0b\x32 .luci.swarming.bot.ContentDigest\"W\n\tErrorCode\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x14\n\x10INVALID_ARGUMENT\x10\x01\x12\x12\n\x0eMISSING_DIGEST\x10\x02\x12\x13\n\x0f\x44IGEST_MISMATCH\x10\x03\x32\x90\x02\n\x0b\x46ileService\x12P\n\x08\x43ontains\x12\".luci.swarming.bot.ContainsRequest\x1a .luci.swarming.bot.ContainsReply\x12U\n\tPushBlobs\x12#.luci.swarming.bot.PushBlobsRequest\x1a!.luci.swarming.bot.PushBlobsReply(\x01\x12X\n\nFetchBlobs\x12$.luci.swarming.bot.FetchBlobsRequest\x1a\".luci.swarming.bot.FetchBlobsReply0\x01\x62\x06proto3') |
-) |
-_sym_db.RegisterFileDescriptor(DESCRIPTOR) |
- |
- |
- |
-_BLOBSTATUS_ERRORCODE = _descriptor.EnumDescriptor( |
- name='ErrorCode', |
- full_name='luci.swarming.bot.BlobStatus.ErrorCode', |
- filename=None, |
- file=DESCRIPTOR, |
- values=[ |
- _descriptor.EnumValueDescriptor( |
- name='UNKNOWN', index=0, number=0, |
- options=None, |
- type=None), |
- _descriptor.EnumValueDescriptor( |
- name='INVALID_ARGUMENT', index=1, number=1, |
- options=None, |
- type=None), |
- _descriptor.EnumValueDescriptor( |
- name='MISSING_DIGEST', index=2, number=2, |
- options=None, |
- type=None), |
- _descriptor.EnumValueDescriptor( |
- name='DIGEST_MISMATCH', index=3, number=3, |
- options=None, |
- type=None), |
- ], |
- containing_type=None, |
- options=None, |
- serialized_start=816, |
- serialized_end=903, |
-) |
-_sym_db.RegisterEnumDescriptor(_BLOBSTATUS_ERRORCODE) |
- |
- |
-_CONTAINSREQUEST = _descriptor.Descriptor( |
- name='ContainsRequest', |
- full_name='luci.swarming.bot.ContainsRequest', |
- filename=None, |
- file=DESCRIPTOR, |
- containing_type=None, |
- fields=[ |
- _descriptor.FieldDescriptor( |
- name='digest', full_name='luci.swarming.bot.ContainsRequest.digest', index=0, |
- number=1, type=11, cpp_type=10, label=3, |
- has_default_value=False, default_value=[], |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- ], |
- extensions=[ |
- ], |
- nested_types=[], |
- enum_types=[ |
- ], |
- options=None, |
- is_extendable=False, |
- syntax='proto3', |
- extension_ranges=[], |
- oneofs=[ |
- ], |
- serialized_start=40, |
- serialized_end=107, |
-) |
- |
- |
-_CONTAINSREPLY = _descriptor.Descriptor( |
- name='ContainsReply', |
- full_name='luci.swarming.bot.ContainsReply', |
- filename=None, |
- file=DESCRIPTOR, |
- containing_type=None, |
- fields=[ |
- _descriptor.FieldDescriptor( |
- name='status', full_name='luci.swarming.bot.ContainsReply.status', index=0, |
- number=1, type=11, cpp_type=10, label=1, |
- has_default_value=False, default_value=None, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- ], |
- extensions=[ |
- ], |
- nested_types=[], |
- enum_types=[ |
- ], |
- options=None, |
- is_extendable=False, |
- syntax='proto3', |
- extension_ranges=[], |
- oneofs=[ |
- ], |
- serialized_start=109, |
- serialized_end=171, |
-) |
- |
- |
-_PUSHBLOBSREQUEST = _descriptor.Descriptor( |
- name='PushBlobsRequest', |
- full_name='luci.swarming.bot.PushBlobsRequest', |
- filename=None, |
- file=DESCRIPTOR, |
- containing_type=None, |
- fields=[ |
- _descriptor.FieldDescriptor( |
- name='data', full_name='luci.swarming.bot.PushBlobsRequest.data', index=0, |
- number=1, type=11, cpp_type=10, label=1, |
- has_default_value=False, default_value=None, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- ], |
- extensions=[ |
- ], |
- nested_types=[], |
- enum_types=[ |
- ], |
- options=None, |
- is_extendable=False, |
- syntax='proto3', |
- extension_ranges=[], |
- oneofs=[ |
- ], |
- serialized_start=173, |
- serialized_end=235, |
-) |
- |
- |
-_PUSHBLOBSREPLY = _descriptor.Descriptor( |
- name='PushBlobsReply', |
- full_name='luci.swarming.bot.PushBlobsReply', |
- filename=None, |
- file=DESCRIPTOR, |
- containing_type=None, |
- fields=[ |
- _descriptor.FieldDescriptor( |
- name='status', full_name='luci.swarming.bot.PushBlobsReply.status', index=0, |
- number=1, type=11, cpp_type=10, label=1, |
- has_default_value=False, default_value=None, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- ], |
- extensions=[ |
- ], |
- nested_types=[], |
- enum_types=[ |
- ], |
- options=None, |
- is_extendable=False, |
- syntax='proto3', |
- extension_ranges=[], |
- oneofs=[ |
- ], |
- serialized_start=237, |
- serialized_end=300, |
-) |
- |
- |
-_FETCHBLOBSREQUEST = _descriptor.Descriptor( |
- name='FetchBlobsRequest', |
- full_name='luci.swarming.bot.FetchBlobsRequest', |
- filename=None, |
- file=DESCRIPTOR, |
- containing_type=None, |
- fields=[ |
- _descriptor.FieldDescriptor( |
- name='digest', full_name='luci.swarming.bot.FetchBlobsRequest.digest', index=0, |
- number=1, type=11, cpp_type=10, label=3, |
- has_default_value=False, default_value=[], |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- ], |
- extensions=[ |
- ], |
- nested_types=[], |
- enum_types=[ |
- ], |
- options=None, |
- is_extendable=False, |
- syntax='proto3', |
- extension_ranges=[], |
- oneofs=[ |
- ], |
- serialized_start=302, |
- serialized_end=371, |
-) |
- |
- |
-_FETCHBLOBSREPLY = _descriptor.Descriptor( |
- name='FetchBlobsReply', |
- full_name='luci.swarming.bot.FetchBlobsReply', |
- filename=None, |
- file=DESCRIPTOR, |
- containing_type=None, |
- fields=[ |
- _descriptor.FieldDescriptor( |
- name='status', full_name='luci.swarming.bot.FetchBlobsReply.status', index=0, |
- number=1, type=11, cpp_type=10, label=1, |
- has_default_value=False, default_value=None, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- _descriptor.FieldDescriptor( |
- name='data', full_name='luci.swarming.bot.FetchBlobsReply.data', index=1, |
- number=2, type=11, cpp_type=10, label=1, |
- has_default_value=False, default_value=None, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- ], |
- extensions=[ |
- ], |
- nested_types=[], |
- enum_types=[ |
- ], |
- options=None, |
- is_extendable=False, |
- syntax='proto3', |
- extension_ranges=[], |
- oneofs=[ |
- ], |
- serialized_start=373, |
- serialized_end=481, |
-) |
- |
- |
-_BLOBCHUNK = _descriptor.Descriptor( |
- name='BlobChunk', |
- full_name='luci.swarming.bot.BlobChunk', |
- filename=None, |
- file=DESCRIPTOR, |
- containing_type=None, |
- fields=[ |
- _descriptor.FieldDescriptor( |
- name='digest', full_name='luci.swarming.bot.BlobChunk.digest', index=0, |
- number=1, type=11, cpp_type=10, label=1, |
- has_default_value=False, default_value=None, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- _descriptor.FieldDescriptor( |
- name='offset', full_name='luci.swarming.bot.BlobChunk.offset', index=1, |
- number=2, type=3, cpp_type=2, label=1, |
- has_default_value=False, default_value=0, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- _descriptor.FieldDescriptor( |
- name='data', full_name='luci.swarming.bot.BlobChunk.data', index=2, |
- number=3, type=12, cpp_type=9, label=1, |
- has_default_value=False, default_value=_b(""), |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- ], |
- extensions=[ |
- ], |
- nested_types=[], |
- enum_types=[ |
- ], |
- options=None, |
- is_extendable=False, |
- syntax='proto3', |
- extension_ranges=[], |
- oneofs=[ |
- ], |
- serialized_start=483, |
- serialized_end=574, |
-) |
- |
- |
-_CONTENTDIGEST = _descriptor.Descriptor( |
- name='ContentDigest', |
- full_name='luci.swarming.bot.ContentDigest', |
- filename=None, |
- file=DESCRIPTOR, |
- containing_type=None, |
- fields=[ |
- _descriptor.FieldDescriptor( |
- name='digest', full_name='luci.swarming.bot.ContentDigest.digest', index=0, |
- number=1, type=12, cpp_type=9, label=1, |
- has_default_value=False, default_value=_b(""), |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- _descriptor.FieldDescriptor( |
- name='size_bytes', full_name='luci.swarming.bot.ContentDigest.size_bytes', index=1, |
- number=2, type=3, cpp_type=2, label=1, |
- has_default_value=False, default_value=0, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- _descriptor.FieldDescriptor( |
- name='version', full_name='luci.swarming.bot.ContentDigest.version', index=2, |
- number=3, type=5, cpp_type=1, label=1, |
- has_default_value=False, default_value=0, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- ], |
- extensions=[ |
- ], |
- nested_types=[], |
- enum_types=[ |
- ], |
- options=None, |
- is_extendable=False, |
- syntax='proto3', |
- extension_ranges=[], |
- oneofs=[ |
- ], |
- serialized_start=576, |
- serialized_end=644, |
-) |
- |
- |
-_BLOBSTATUS = _descriptor.Descriptor( |
- name='BlobStatus', |
- full_name='luci.swarming.bot.BlobStatus', |
- filename=None, |
- file=DESCRIPTOR, |
- containing_type=None, |
- fields=[ |
- _descriptor.FieldDescriptor( |
- name='succeeded', full_name='luci.swarming.bot.BlobStatus.succeeded', index=0, |
- number=1, type=8, cpp_type=7, label=1, |
- has_default_value=False, default_value=False, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- _descriptor.FieldDescriptor( |
- name='error', full_name='luci.swarming.bot.BlobStatus.error', index=1, |
- number=2, type=14, cpp_type=8, label=1, |
- has_default_value=False, default_value=0, |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- _descriptor.FieldDescriptor( |
- name='error_detail', full_name='luci.swarming.bot.BlobStatus.error_detail', index=2, |
- number=3, type=9, cpp_type=9, label=1, |
- has_default_value=False, default_value=_b("").decode('utf-8'), |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- _descriptor.FieldDescriptor( |
- name='missing_digest', full_name='luci.swarming.bot.BlobStatus.missing_digest', index=3, |
- number=4, type=11, cpp_type=10, label=3, |
- has_default_value=False, default_value=[], |
- message_type=None, enum_type=None, containing_type=None, |
- is_extension=False, extension_scope=None, |
- options=None), |
- ], |
- extensions=[ |
- ], |
- nested_types=[], |
- enum_types=[ |
- _BLOBSTATUS_ERRORCODE, |
- ], |
- options=None, |
- is_extendable=False, |
- syntax='proto3', |
- extension_ranges=[], |
- oneofs=[ |
- ], |
- serialized_start=647, |
- serialized_end=903, |
-) |
- |
-_CONTAINSREQUEST.fields_by_name['digest'].message_type = _CONTENTDIGEST |
-_CONTAINSREPLY.fields_by_name['status'].message_type = _BLOBSTATUS |
-_PUSHBLOBSREQUEST.fields_by_name['data'].message_type = _BLOBCHUNK |
-_PUSHBLOBSREPLY.fields_by_name['status'].message_type = _BLOBSTATUS |
-_FETCHBLOBSREQUEST.fields_by_name['digest'].message_type = _CONTENTDIGEST |
-_FETCHBLOBSREPLY.fields_by_name['status'].message_type = _BLOBSTATUS |
-_FETCHBLOBSREPLY.fields_by_name['data'].message_type = _BLOBCHUNK |
-_BLOBCHUNK.fields_by_name['digest'].message_type = _CONTENTDIGEST |
-_BLOBSTATUS.fields_by_name['error'].enum_type = _BLOBSTATUS_ERRORCODE |
-_BLOBSTATUS.fields_by_name['missing_digest'].message_type = _CONTENTDIGEST |
-_BLOBSTATUS_ERRORCODE.containing_type = _BLOBSTATUS |
-DESCRIPTOR.message_types_by_name['ContainsRequest'] = _CONTAINSREQUEST |
-DESCRIPTOR.message_types_by_name['ContainsReply'] = _CONTAINSREPLY |
-DESCRIPTOR.message_types_by_name['PushBlobsRequest'] = _PUSHBLOBSREQUEST |
-DESCRIPTOR.message_types_by_name['PushBlobsReply'] = _PUSHBLOBSREPLY |
-DESCRIPTOR.message_types_by_name['FetchBlobsRequest'] = _FETCHBLOBSREQUEST |
-DESCRIPTOR.message_types_by_name['FetchBlobsReply'] = _FETCHBLOBSREPLY |
-DESCRIPTOR.message_types_by_name['BlobChunk'] = _BLOBCHUNK |
-DESCRIPTOR.message_types_by_name['ContentDigest'] = _CONTENTDIGEST |
-DESCRIPTOR.message_types_by_name['BlobStatus'] = _BLOBSTATUS |
- |
-ContainsRequest = _reflection.GeneratedProtocolMessageType('ContainsRequest', (_message.Message,), dict( |
- DESCRIPTOR = _CONTAINSREQUEST, |
- __module__ = 'isolate_bot_pb2' |
- # @@protoc_insertion_point(class_scope:luci.swarming.bot.ContainsRequest) |
- )) |
-_sym_db.RegisterMessage(ContainsRequest) |
- |
-ContainsReply = _reflection.GeneratedProtocolMessageType('ContainsReply', (_message.Message,), dict( |
- DESCRIPTOR = _CONTAINSREPLY, |
- __module__ = 'isolate_bot_pb2' |
- # @@protoc_insertion_point(class_scope:luci.swarming.bot.ContainsReply) |
- )) |
-_sym_db.RegisterMessage(ContainsReply) |
- |
-PushBlobsRequest = _reflection.GeneratedProtocolMessageType('PushBlobsRequest', (_message.Message,), dict( |
- DESCRIPTOR = _PUSHBLOBSREQUEST, |
- __module__ = 'isolate_bot_pb2' |
- # @@protoc_insertion_point(class_scope:luci.swarming.bot.PushBlobsRequest) |
- )) |
-_sym_db.RegisterMessage(PushBlobsRequest) |
- |
-PushBlobsReply = _reflection.GeneratedProtocolMessageType('PushBlobsReply', (_message.Message,), dict( |
- DESCRIPTOR = _PUSHBLOBSREPLY, |
- __module__ = 'isolate_bot_pb2' |
- # @@protoc_insertion_point(class_scope:luci.swarming.bot.PushBlobsReply) |
- )) |
-_sym_db.RegisterMessage(PushBlobsReply) |
- |
-FetchBlobsRequest = _reflection.GeneratedProtocolMessageType('FetchBlobsRequest', (_message.Message,), dict( |
- DESCRIPTOR = _FETCHBLOBSREQUEST, |
- __module__ = 'isolate_bot_pb2' |
- # @@protoc_insertion_point(class_scope:luci.swarming.bot.FetchBlobsRequest) |
- )) |
-_sym_db.RegisterMessage(FetchBlobsRequest) |
- |
-FetchBlobsReply = _reflection.GeneratedProtocolMessageType('FetchBlobsReply', (_message.Message,), dict( |
- DESCRIPTOR = _FETCHBLOBSREPLY, |
- __module__ = 'isolate_bot_pb2' |
- # @@protoc_insertion_point(class_scope:luci.swarming.bot.FetchBlobsReply) |
- )) |
-_sym_db.RegisterMessage(FetchBlobsReply) |
- |
-BlobChunk = _reflection.GeneratedProtocolMessageType('BlobChunk', (_message.Message,), dict( |
- DESCRIPTOR = _BLOBCHUNK, |
- __module__ = 'isolate_bot_pb2' |
- # @@protoc_insertion_point(class_scope:luci.swarming.bot.BlobChunk) |
- )) |
-_sym_db.RegisterMessage(BlobChunk) |
- |
-ContentDigest = _reflection.GeneratedProtocolMessageType('ContentDigest', (_message.Message,), dict( |
- DESCRIPTOR = _CONTENTDIGEST, |
- __module__ = 'isolate_bot_pb2' |
- # @@protoc_insertion_point(class_scope:luci.swarming.bot.ContentDigest) |
- )) |
-_sym_db.RegisterMessage(ContentDigest) |
- |
-BlobStatus = _reflection.GeneratedProtocolMessageType('BlobStatus', (_message.Message,), dict( |
- DESCRIPTOR = _BLOBSTATUS, |
- __module__ = 'isolate_bot_pb2' |
- # @@protoc_insertion_point(class_scope:luci.swarming.bot.BlobStatus) |
- )) |
-_sym_db.RegisterMessage(BlobStatus) |
- |
- |
-try: |
- # THESE ELEMENTS WILL BE DEPRECATED. |
- # Please use the generated *_pb2_grpc.py files instead. |
- import grpc |
- from grpc.framework.common import cardinality |
- from grpc.framework.interfaces.face import utilities as face_utilities |
- from grpc.beta import implementations as beta_implementations |
- from grpc.beta import interfaces as beta_interfaces |
- |
- |
- class FileServiceStub(object): |
- """FileService exposes the main operations of an Isolate server |
- to upload and download blobs. |
- """ |
- |
- def __init__(self, channel): |
- """Constructor. |
- |
- Args: |
- channel: A grpc.Channel. |
- """ |
- self.Contains = channel.unary_unary( |
- '/luci.swarming.bot.FileService/Contains', |
- request_serializer=ContainsRequest.SerializeToString, |
- response_deserializer=ContainsReply.FromString, |
- ) |
- self.PushBlobs = channel.stream_unary( |
- '/luci.swarming.bot.FileService/PushBlobs', |
- request_serializer=PushBlobsRequest.SerializeToString, |
- response_deserializer=PushBlobsReply.FromString, |
- ) |
- self.FetchBlobs = channel.unary_stream( |
- '/luci.swarming.bot.FileService/FetchBlobs', |
- request_serializer=FetchBlobsRequest.SerializeToString, |
- response_deserializer=FetchBlobsReply.FromString, |
- ) |
- |
- |
- class FileServiceServicer(object): |
- """FileService exposes the main operations of an Isolate server |
- to upload and download blobs. |
- """ |
- |
- def Contains(self, request, context): |
- """Unlike in the native Isolate API, it is not *necessary* to |
- call Contains prior to pushing a blob, as Contains does not |
- return "upload tickets." The BlobStatus returned by Contains |
- will have succeeded = True if all digests were found, and |
- false for any other reason (missing blobs, network error, |
- etc.) |
- """ |
- context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
- context.set_details('Method not implemented!') |
- raise NotImplementedError('Method not implemented!') |
- |
- def PushBlobs(self, request_iterator, context): |
- """PushBlobs can push one or more blobs at a time (serially), |
- with each blob transmitted as one or more chunks. At the |
- beginning of a new blob, the chunk offset should be zero |
- and the digest must be provided. The function returns true |
- only if all blobs are successfully received, and returns |
- as soon as an error occurs. |
- """ |
- context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
- context.set_details('Method not implemented!') |
- raise NotImplementedError('Method not implemented!') |
- |
- def FetchBlobs(self, request, context): |
- """FetchBlobs takes a list of digests and returns them all as |
- a stream of BlobChunks. |
- """ |
- context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
- context.set_details('Method not implemented!') |
- raise NotImplementedError('Method not implemented!') |
- |
- |
- def add_FileServiceServicer_to_server(servicer, server): |
- rpc_method_handlers = { |
- 'Contains': grpc.unary_unary_rpc_method_handler( |
- servicer.Contains, |
- request_deserializer=ContainsRequest.FromString, |
- response_serializer=ContainsReply.SerializeToString, |
- ), |
- 'PushBlobs': grpc.stream_unary_rpc_method_handler( |
- servicer.PushBlobs, |
- request_deserializer=PushBlobsRequest.FromString, |
- response_serializer=PushBlobsReply.SerializeToString, |
- ), |
- 'FetchBlobs': grpc.unary_stream_rpc_method_handler( |
- servicer.FetchBlobs, |
- request_deserializer=FetchBlobsRequest.FromString, |
- response_serializer=FetchBlobsReply.SerializeToString, |
- ), |
- } |
- generic_handler = grpc.method_handlers_generic_handler( |
- 'luci.swarming.bot.FileService', rpc_method_handlers) |
- server.add_generic_rpc_handlers((generic_handler,)) |
- |
- |
- class BetaFileServiceServicer(object): |
- """The Beta API is deprecated for 0.15.0 and later. |
- |
- It is recommended to use the GA API (classes and functions in this |
- file not marked beta) for all further purposes. This class was generated |
- only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0.""" |
- """FileService exposes the main operations of an Isolate server |
- to upload and download blobs. |
- """ |
- def Contains(self, request, context): |
- """Unlike in the native Isolate API, it is not *necessary* to |
- call Contains prior to pushing a blob, as Contains does not |
- return "upload tickets." The BlobStatus returned by Contains |
- will have succeeded = True if all digests were found, and |
- false for any other reason (missing blobs, network error, |
- etc.) |
- """ |
- context.code(beta_interfaces.StatusCode.UNIMPLEMENTED) |
- def PushBlobs(self, request_iterator, context): |
- """PushBlobs can push one or more blobs at a time (serially), |
- with each blob transmitted as one or more chunks. At the |
- beginning of a new blob, the chunk offset should be zero |
- and the digest must be provided. The function returns true |
- only if all blobs are successfully received, and returns |
- as soon as an error occurs. |
- """ |
- context.code(beta_interfaces.StatusCode.UNIMPLEMENTED) |
- def FetchBlobs(self, request, context): |
- """FetchBlobs takes a list of digests and returns them all as |
- a stream of BlobChunks. |
- """ |
- context.code(beta_interfaces.StatusCode.UNIMPLEMENTED) |
- |
- |
- class BetaFileServiceStub(object): |
- """The Beta API is deprecated for 0.15.0 and later. |
- |
- It is recommended to use the GA API (classes and functions in this |
- file not marked beta) for all further purposes. This class was generated |
- only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0.""" |
- """FileService exposes the main operations of an Isolate server |
- to upload and download blobs. |
- """ |
- def Contains(self, request, timeout, metadata=None, with_call=False, protocol_options=None): |
- """Unlike in the native Isolate API, it is not *necessary* to |
- call Contains prior to pushing a blob, as Contains does not |
- return "upload tickets." The BlobStatus returned by Contains |
- will have succeeded = True if all digests were found, and |
- false for any other reason (missing blobs, network error, |
- etc.) |
- """ |
- raise NotImplementedError() |
- Contains.future = None |
- def PushBlobs(self, request_iterator, timeout, metadata=None, with_call=False, protocol_options=None): |
- """PushBlobs can push one or more blobs at a time (serially), |
- with each blob transmitted as one or more chunks. At the |
- beginning of a new blob, the chunk offset should be zero |
- and the digest must be provided. The function returns true |
- only if all blobs are successfully received, and returns |
- as soon as an error occurs. |
- """ |
- raise NotImplementedError() |
- PushBlobs.future = None |
- def FetchBlobs(self, request, timeout, metadata=None, with_call=False, protocol_options=None): |
- """FetchBlobs takes a list of digests and returns them all as |
- a stream of BlobChunks. |
- """ |
- raise NotImplementedError() |
- |
- |
- def beta_create_FileService_server(servicer, pool=None, pool_size=None, default_timeout=None, maximum_timeout=None): |
- """The Beta API is deprecated for 0.15.0 and later. |
- |
- It is recommended to use the GA API (classes and functions in this |
- file not marked beta) for all further purposes. This function was |
- generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0""" |
- request_deserializers = { |
- ('luci.swarming.bot.FileService', 'Contains'): ContainsRequest.FromString, |
- ('luci.swarming.bot.FileService', 'FetchBlobs'): FetchBlobsRequest.FromString, |
- ('luci.swarming.bot.FileService', 'PushBlobs'): PushBlobsRequest.FromString, |
- } |
- response_serializers = { |
- ('luci.swarming.bot.FileService', 'Contains'): ContainsReply.SerializeToString, |
- ('luci.swarming.bot.FileService', 'FetchBlobs'): FetchBlobsReply.SerializeToString, |
- ('luci.swarming.bot.FileService', 'PushBlobs'): PushBlobsReply.SerializeToString, |
- } |
- method_implementations = { |
- ('luci.swarming.bot.FileService', 'Contains'): face_utilities.unary_unary_inline(servicer.Contains), |
- ('luci.swarming.bot.FileService', 'FetchBlobs'): face_utilities.unary_stream_inline(servicer.FetchBlobs), |
- ('luci.swarming.bot.FileService', 'PushBlobs'): face_utilities.stream_unary_inline(servicer.PushBlobs), |
- } |
- server_options = beta_implementations.server_options(request_deserializers=request_deserializers, response_serializers=response_serializers, thread_pool=pool, thread_pool_size=pool_size, default_timeout=default_timeout, maximum_timeout=maximum_timeout) |
- return beta_implementations.server(method_implementations, options=server_options) |
- |
- |
- def beta_create_FileService_stub(channel, host=None, metadata_transformer=None, pool=None, pool_size=None): |
- """The Beta API is deprecated for 0.15.0 and later. |
- |
- It is recommended to use the GA API (classes and functions in this |
- file not marked beta) for all further purposes. This function was |
- generated only to ease transition from grpcio<0.15.0 to grpcio>=0.15.0""" |
- request_serializers = { |
- ('luci.swarming.bot.FileService', 'Contains'): ContainsRequest.SerializeToString, |
- ('luci.swarming.bot.FileService', 'FetchBlobs'): FetchBlobsRequest.SerializeToString, |
- ('luci.swarming.bot.FileService', 'PushBlobs'): PushBlobsRequest.SerializeToString, |
- } |
- response_deserializers = { |
- ('luci.swarming.bot.FileService', 'Contains'): ContainsReply.FromString, |
- ('luci.swarming.bot.FileService', 'FetchBlobs'): FetchBlobsReply.FromString, |
- ('luci.swarming.bot.FileService', 'PushBlobs'): PushBlobsReply.FromString, |
- } |
- cardinalities = { |
- 'Contains': cardinality.Cardinality.UNARY_UNARY, |
- 'FetchBlobs': cardinality.Cardinality.UNARY_STREAM, |
- 'PushBlobs': cardinality.Cardinality.STREAM_UNARY, |
- } |
- stub_options = beta_implementations.stub_options(host=host, metadata_transformer=metadata_transformer, request_serializers=request_serializers, response_deserializers=response_deserializers, thread_pool=pool, thread_pool_size=pool_size) |
- return beta_implementations.dynamic_stub(channel, 'luci.swarming.bot.FileService', cardinalities, options=stub_options) |
-except ImportError: |
- pass |
-# @@protoc_insertion_point(module_scope) |