# -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: proto/task.proto from google.protobuf.internal import enum_type_wrapper 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 # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() DESCRIPTOR = _descriptor.FileDescriptor( name='proto/task.proto', package='', syntax='proto3', serialized_options=None, serialized_pb=b'\n\x10proto/task.proto\"\xa5\x01\n\x03\x41rg\x12#\n\x05local\x18\x01 \x01(\x0e\x32\r.Arg.LocalityR\x05local\x12!\n\x0creference_id\x18\x02 \x01(\x0cR\x0breferenceId\x12\x12\n\x04\x64\x61ta\x18\x03 \x01(\x0cR\x04\x64\x61ta\x12\x19\n\x04type\x18\x04 \x01(\x0e\x32\x05.TypeR\x04type\"\'\n\x08Locality\x12\x0c\n\x08INTERNED\x10\x00\x12\r\n\tREFERENCE\x10\x01\"S\n\x04Task\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x1d\n\npayload_id\x18\x02 \x01(\x0cR\tpayloadId\x12\x18\n\x04\x61rgs\x18\x03 \x03(\x0b\x32\x04.ArgR\x04\x61rgs\")\n\nTaskTicket\x12\x1b\n\treturn_id\x18\x01 \x01(\x0cR\x08returnId\" \n\nPutRequest\x12\x12\n\x04\x64\x61ta\x18\x01 \x01(\x0cR\x04\x64\x61ta\"\x1d\n\x0bPutResponse\x12\x0e\n\x02id\x18\x01 \x01(\x0cR\x02id\"\x1c\n\nGetRequest\x12\x0e\n\x02id\x18\x01 \x01(\x0cR\x02id\"7\n\x0bGetResponse\x12\x14\n\x05valid\x18\x01 \x01(\x08R\x05valid\x12\x12\n\x04\x64\x61ta\x18\x02 \x01(\x0cR\x04\x64\x61ta*\x13\n\x04Type\x12\x0b\n\x07\x44\x45\x46\x41ULT\x10\x00\x32\x82\x01\n\nTaskServer\x12(\n\tGetObject\x12\x0b.GetRequest\x1a\x0c.GetResponse\"\x00\x12(\n\tPutObject\x12\x0b.PutRequest\x1a\x0c.PutResponse\"\x00\x12 \n\x08Schedule\x12\x05.Task\x1a\x0b.TaskTicket\"\x00\x32\x85\x01\n\nWorkServer\x12(\n\tGetObject\x12\x0b.GetRequest\x1a\x0c.GetResponse\"\x00\x12(\n\tPutObject\x12\x0b.PutRequest\x1a\x0c.PutResponse\"\x00\x12#\n\x07\x45xecute\x12\x0b.TaskTicket\x1a\x05.Task\"\x00(\x01\x30\x01\x62\x06proto3' ) _TYPE = _descriptor.EnumDescriptor( name='Type', full_name='Type', filename=None, file=DESCRIPTOR, values=[ _descriptor.EnumValueDescriptor( name='DEFAULT', index=0, number=0, serialized_options=None, type=None), ], containing_type=None, serialized_options=None, serialized_start=468, serialized_end=487, ) _sym_db.RegisterEnumDescriptor(_TYPE) Type = enum_type_wrapper.EnumTypeWrapper(_TYPE) DEFAULT = 0 _ARG_LOCALITY = _descriptor.EnumDescriptor( name='Locality', full_name='Arg.Locality', filename=None, file=DESCRIPTOR, values=[ _descriptor.EnumValueDescriptor( name='INTERNED', index=0, number=0, serialized_options=None, type=None), _descriptor.EnumValueDescriptor( name='REFERENCE', index=1, number=1, serialized_options=None, type=None), ], containing_type=None, serialized_options=None, serialized_start=147, serialized_end=186, ) _sym_db.RegisterEnumDescriptor(_ARG_LOCALITY) _ARG = _descriptor.Descriptor( name='Arg', full_name='Arg', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='local', full_name='Arg.local', index=0, number=1, 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, serialized_options=None, json_name='local', file=DESCRIPTOR), _descriptor.FieldDescriptor( name='reference_id', full_name='Arg.reference_id', index=1, number=2, 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, serialized_options=None, json_name='referenceId', file=DESCRIPTOR), _descriptor.FieldDescriptor( name='data', full_name='Arg.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, serialized_options=None, json_name='data', file=DESCRIPTOR), _descriptor.FieldDescriptor( name='type', full_name='Arg.type', index=3, number=4, 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, serialized_options=None, json_name='type', file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ _ARG_LOCALITY, ], serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=21, serialized_end=186, ) _TASK = _descriptor.Descriptor( name='Task', full_name='Task', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='name', full_name='Task.name', index=0, number=1, 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, serialized_options=None, json_name='name', file=DESCRIPTOR), _descriptor.FieldDescriptor( name='payload_id', full_name='Task.payload_id', index=1, number=2, 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, serialized_options=None, json_name='payloadId', file=DESCRIPTOR), _descriptor.FieldDescriptor( name='args', full_name='Task.args', index=2, number=3, 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, serialized_options=None, json_name='args', file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=188, serialized_end=271, ) _TASKTICKET = _descriptor.Descriptor( name='TaskTicket', full_name='TaskTicket', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='return_id', full_name='TaskTicket.return_id', 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, serialized_options=None, json_name='returnId', file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=273, serialized_end=314, ) _PUTREQUEST = _descriptor.Descriptor( name='PutRequest', full_name='PutRequest', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='data', full_name='PutRequest.data', 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, serialized_options=None, json_name='data', file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=316, serialized_end=348, ) _PUTRESPONSE = _descriptor.Descriptor( name='PutResponse', full_name='PutResponse', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='id', full_name='PutResponse.id', 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, serialized_options=None, json_name='id', file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=350, serialized_end=379, ) _GETREQUEST = _descriptor.Descriptor( name='GetRequest', full_name='GetRequest', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='id', full_name='GetRequest.id', 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, serialized_options=None, json_name='id', file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=381, serialized_end=409, ) _GETRESPONSE = _descriptor.Descriptor( name='GetResponse', full_name='GetResponse', filename=None, file=DESCRIPTOR, containing_type=None, fields=[ _descriptor.FieldDescriptor( name='valid', full_name='GetResponse.valid', 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, serialized_options=None, json_name='valid', file=DESCRIPTOR), _descriptor.FieldDescriptor( name='data', full_name='GetResponse.data', index=1, number=2, 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, serialized_options=None, json_name='data', file=DESCRIPTOR), ], extensions=[ ], nested_types=[], enum_types=[ ], serialized_options=None, is_extendable=False, syntax='proto3', extension_ranges=[], oneofs=[ ], serialized_start=411, serialized_end=466, ) _ARG.fields_by_name['local'].enum_type = _ARG_LOCALITY _ARG.fields_by_name['type'].enum_type = _TYPE _ARG_LOCALITY.containing_type = _ARG _TASK.fields_by_name['args'].message_type = _ARG DESCRIPTOR.message_types_by_name['Arg'] = _ARG DESCRIPTOR.message_types_by_name['Task'] = _TASK DESCRIPTOR.message_types_by_name['TaskTicket'] = _TASKTICKET DESCRIPTOR.message_types_by_name['PutRequest'] = _PUTREQUEST DESCRIPTOR.message_types_by_name['PutResponse'] = _PUTRESPONSE DESCRIPTOR.message_types_by_name['GetRequest'] = _GETREQUEST DESCRIPTOR.message_types_by_name['GetResponse'] = _GETRESPONSE DESCRIPTOR.enum_types_by_name['Type'] = _TYPE _sym_db.RegisterFileDescriptor(DESCRIPTOR) Arg = _reflection.GeneratedProtocolMessageType('Arg', (_message.Message,), { 'DESCRIPTOR' : _ARG, '__module__' : 'proto.task_pb2' # @@protoc_insertion_point(class_scope:Arg) }) _sym_db.RegisterMessage(Arg) Task = _reflection.GeneratedProtocolMessageType('Task', (_message.Message,), { 'DESCRIPTOR' : _TASK, '__module__' : 'proto.task_pb2' # @@protoc_insertion_point(class_scope:Task) }) _sym_db.RegisterMessage(Task) TaskTicket = _reflection.GeneratedProtocolMessageType('TaskTicket', (_message.Message,), { 'DESCRIPTOR' : _TASKTICKET, '__module__' : 'proto.task_pb2' # @@protoc_insertion_point(class_scope:TaskTicket) }) _sym_db.RegisterMessage(TaskTicket) PutRequest = _reflection.GeneratedProtocolMessageType('PutRequest', (_message.Message,), { 'DESCRIPTOR' : _PUTREQUEST, '__module__' : 'proto.task_pb2' # @@protoc_insertion_point(class_scope:PutRequest) }) _sym_db.RegisterMessage(PutRequest) PutResponse = _reflection.GeneratedProtocolMessageType('PutResponse', (_message.Message,), { 'DESCRIPTOR' : _PUTRESPONSE, '__module__' : 'proto.task_pb2' # @@protoc_insertion_point(class_scope:PutResponse) }) _sym_db.RegisterMessage(PutResponse) GetRequest = _reflection.GeneratedProtocolMessageType('GetRequest', (_message.Message,), { 'DESCRIPTOR' : _GETREQUEST, '__module__' : 'proto.task_pb2' # @@protoc_insertion_point(class_scope:GetRequest) }) _sym_db.RegisterMessage(GetRequest) GetResponse = _reflection.GeneratedProtocolMessageType('GetResponse', (_message.Message,), { 'DESCRIPTOR' : _GETRESPONSE, '__module__' : 'proto.task_pb2' # @@protoc_insertion_point(class_scope:GetResponse) }) _sym_db.RegisterMessage(GetResponse) _TASKSERVER = _descriptor.ServiceDescriptor( name='TaskServer', full_name='TaskServer', file=DESCRIPTOR, index=0, serialized_options=None, serialized_start=490, serialized_end=620, methods=[ _descriptor.MethodDescriptor( name='GetObject', full_name='TaskServer.GetObject', index=0, containing_service=None, input_type=_GETREQUEST, output_type=_GETRESPONSE, serialized_options=None, ), _descriptor.MethodDescriptor( name='PutObject', full_name='TaskServer.PutObject', index=1, containing_service=None, input_type=_PUTREQUEST, output_type=_PUTRESPONSE, serialized_options=None, ), _descriptor.MethodDescriptor( name='Schedule', full_name='TaskServer.Schedule', index=2, containing_service=None, input_type=_TASK, output_type=_TASKTICKET, serialized_options=None, ), ]) _sym_db.RegisterServiceDescriptor(_TASKSERVER) DESCRIPTOR.services_by_name['TaskServer'] = _TASKSERVER _WORKSERVER = _descriptor.ServiceDescriptor( name='WorkServer', full_name='WorkServer', file=DESCRIPTOR, index=1, serialized_options=None, serialized_start=623, serialized_end=756, methods=[ _descriptor.MethodDescriptor( name='GetObject', full_name='WorkServer.GetObject', index=0, containing_service=None, input_type=_GETREQUEST, output_type=_GETRESPONSE, serialized_options=None, ), _descriptor.MethodDescriptor( name='PutObject', full_name='WorkServer.PutObject', index=1, containing_service=None, input_type=_PUTREQUEST, output_type=_PUTRESPONSE, serialized_options=None, ), _descriptor.MethodDescriptor( name='Execute', full_name='WorkServer.Execute', index=2, containing_service=None, input_type=_TASKTICKET, output_type=_TASK, serialized_options=None, ), ]) _sym_db.RegisterServiceDescriptor(_WORKSERVER) DESCRIPTOR.services_by_name['WorkServer'] = _WORKSERVER # @@protoc_insertion_point(module_scope)