StrafesNET/python-grpc
3
Fork 0
Code Releases Activity

Update proto

Browse Source
This commit is contained in:
itzaname 2022-10-23 15:39:34 -04:00
parent 0dff08718b
commit f53aac64eb
4 changed files with 432 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

69
strafesnet/datastore_pb2.py Normal file
View File

@ -0,0 +1,69 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: datastore.proto
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
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()
from google.protobuf import struct_pb2 as google_dot_protobuf_dot_struct__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0f\x64\x61tastore.proto\x12\tdatastore\x1a\x1cgoogle/protobuf/struct.proto\"\x19\n\nKeyMessage\x12\x0b\n\x03Key\x18\x01 \x01(\t\"p\n\rUpdateMessage\x12\x0b\n\x03Key\x18\x01 \x01(\t\x12(\n\x07Updates\x18\x02 \x01(\x0b\x32\x17.google.protobuf.Struct\x12(\n\x07\x44\x65letes\x18\x03 \x01(\x0b\x32\x17.google.protobuf.Struct\"D\n\x0eObjectResponse\x12\x0b\n\x03Key\x18\x01 \x01(\t\x12%\n\x04\x44\x61ta\x18\x02 \x01(\x0b\x32\x17.google.protobuf.Struct\"\x0e\n\x0cNullResponse2\xc4\x01\n\x10\x44\x61tastoreService\x12\x37\n\x03Get\x12\x15.datastore.KeyMessage\x1a\x19.datastore.ObjectResponse\x12=\n\x06Update\x12\x18.datastore.UpdateMessage\x1a\x19.datastore.ObjectResponse\x12\x38\n\x06\x44\x65lete\x12\x15.datastore.KeyMessage\x1a\x17.datastore.NullResponseB,Z*git.itzana.me/strafesnet/go-grpc/datastoreb\x06proto3')
_KEYMESSAGE = DESCRIPTOR.message_types_by_name['KeyMessage']
_UPDATEMESSAGE = DESCRIPTOR.message_types_by_name['UpdateMessage']
_OBJECTRESPONSE = DESCRIPTOR.message_types_by_name['ObjectResponse']
_NULLRESPONSE = DESCRIPTOR.message_types_by_name['NullResponse']
KeyMessage = _reflection.GeneratedProtocolMessageType('KeyMessage', (_message.Message,), {
'DESCRIPTOR' : _KEYMESSAGE,
'__module__' : 'datastore_pb2'
# @@protoc_insertion_point(class_scope:datastore.KeyMessage)
})
_sym_db.RegisterMessage(KeyMessage)
UpdateMessage = _reflection.GeneratedProtocolMessageType('UpdateMessage', (_message.Message,), {
'DESCRIPTOR' : _UPDATEMESSAGE,
'__module__' : 'datastore_pb2'
# @@protoc_insertion_point(class_scope:datastore.UpdateMessage)
})
_sym_db.RegisterMessage(UpdateMessage)
ObjectResponse = _reflection.GeneratedProtocolMessageType('ObjectResponse', (_message.Message,), {
'DESCRIPTOR' : _OBJECTRESPONSE,
'__module__' : 'datastore_pb2'
# @@protoc_insertion_point(class_scope:datastore.ObjectResponse)
})
_sym_db.RegisterMessage(ObjectResponse)
NullResponse = _reflection.GeneratedProtocolMessageType('NullResponse', (_message.Message,), {
'DESCRIPTOR' : _NULLRESPONSE,
'__module__' : 'datastore_pb2'
# @@protoc_insertion_point(class_scope:datastore.NullResponse)
})
_sym_db.RegisterMessage(NullResponse)
_DATASTORESERVICE = DESCRIPTOR.services_by_name['DatastoreService']
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z*git.itzana.me/strafesnet/go-grpc/datastore'
_KEYMESSAGE._serialized_start=60
_KEYMESSAGE._serialized_end=85
_UPDATEMESSAGE._serialized_start=87
_UPDATEMESSAGE._serialized_end=199
_OBJECTRESPONSE._serialized_start=201
_OBJECTRESPONSE._serialized_end=269
_NULLRESPONSE._serialized_start=271
_NULLRESPONSE._serialized_end=285
_DATASTORESERVICE._serialized_start=288
_DATASTORESERVICE._serialized_end=484
# @@protoc_insertion_point(module_scope)

132
strafesnet/datastore_pb2_grpc.py Normal file
View File

@ -0,0 +1,132 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import datastore_pb2 as datastore__pb2
class DatastoreServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Get = channel.unary_unary(
'/datastore.DatastoreService/Get',
request_serializer=datastore__pb2.KeyMessage.SerializeToString,
response_deserializer=datastore__pb2.ObjectResponse.FromString,
)
self.Update = channel.unary_unary(
'/datastore.DatastoreService/Update',
request_serializer=datastore__pb2.UpdateMessage.SerializeToString,
response_deserializer=datastore__pb2.ObjectResponse.FromString,
)
self.Delete = channel.unary_unary(
'/datastore.DatastoreService/Delete',
request_serializer=datastore__pb2.KeyMessage.SerializeToString,
response_deserializer=datastore__pb2.NullResponse.FromString,
)
class DatastoreServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
def Get(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Update(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Delete(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def add_DatastoreServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=datastore__pb2.KeyMessage.FromString,
response_serializer=datastore__pb2.ObjectResponse.SerializeToString,
),
'Update': grpc.unary_unary_rpc_method_handler(
servicer.Update,
request_deserializer=datastore__pb2.UpdateMessage.FromString,
response_serializer=datastore__pb2.ObjectResponse.SerializeToString,
),
'Delete': grpc.unary_unary_rpc_method_handler(
servicer.Delete,
request_deserializer=datastore__pb2.KeyMessage.FromString,
response_serializer=datastore__pb2.NullResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'datastore.DatastoreService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class DatastoreService(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Get(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/datastore.DatastoreService/Get',
datastore__pb2.KeyMessage.SerializeToString,
datastore__pb2.ObjectResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Update(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/datastore.DatastoreService/Update',
datastore__pb2.UpdateMessage.SerializeToString,
datastore__pb2.ObjectResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Delete(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/datastore.DatastoreService/Delete',
datastore__pb2.KeyMessage.SerializeToString,
datastore__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

99
strafesnet/ranks_pb2.py Normal file
View File

@ -0,0 +1,99 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: ranks.proto
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
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()
import users_pb2 as users__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0branks.proto\x12\x05ranks\x1a\x0busers.proto\"\x17\n\tIdMessage\x12\n\n\x02ID\x18\x01 \x01(\x03\"M\n\nGetRequest\x12\x0e\n\x06UserID\x18\x01 \x01(\x03\x12\x0f\n\x07StyleID\x18\x02 \x01(\x05\x12\x0e\n\x06GameID\x18\x03 \x01(\x05\x12\x0e\n\x06ModeID\x18\x04 \x01(\x05\"m\n\x0bListRequest\x12\x0f\n\x07StyleID\x18\x01 \x01(\x05\x12\x0e\n\x06GameID\x18\x02 \x01(\x05\x12\x0e\n\x06ModeID\x18\x03 \x01(\x05\x12\x0c\n\x04Sort\x18\x04 \x01(\x03\x12\x1f\n\x04Page\x18\x05 \x01(\x0b\x32\x11.ranks.Pagination\"-\n\x08RankList\x12!\n\x05ranks\x18\x01 \x03(\x0b\x32\x12.ranks.RankMessage\"\x9d\x01\n\x0bRankMessage\x12\n\n\x02ID\x18\x01 \x01(\x03\x12!\n\x04User\x18\x02 \x01(\x0b\x32\x13.users.UserResponse\x12\x0f\n\x07StyleID\x18\x03 \x01(\x05\x12\x0e\n\x06ModeID\x18\x04 \x01(\x05\x12\x0e\n\x06GameID\x18\x05 \x01(\x05\x12\x0c\n\x04Rank\x18\x06 \x01(\x01\x12\r\n\x05Skill\x18\x07 \x01(\x01\x12\x11\n\tUpdatedAt\x18\x08 \x01(\x03\"*\n\nPagination\x12\x0c\n\x04Size\x18\x01 \x01(\x05\x12\x0e\n\x06Number\x18\x02 \x01(\x05\"\x0e\n\x0cNullResponse2\x97\x01\n\x0cRanksService\x12,\n\x03Get\x12\x11.ranks.GetRequest\x1a\x12.ranks.RankMessage\x12+\n\x04List\x12\x12.ranks.ListRequest\x1a\x0f.ranks.RankList\x12,\n\x06\x44\x65lete\x12\x10.ranks.IdMessage\x1a\x10.ranks.IdMessageB(Z&git.itzana.me/strafesnet/go-grpc/ranksb\x06proto3')
_IDMESSAGE = DESCRIPTOR.message_types_by_name['IdMessage']
_GETREQUEST = DESCRIPTOR.message_types_by_name['GetRequest']
_LISTREQUEST = DESCRIPTOR.message_types_by_name['ListRequest']
_RANKLIST = DESCRIPTOR.message_types_by_name['RankList']
_RANKMESSAGE = DESCRIPTOR.message_types_by_name['RankMessage']
_PAGINATION = DESCRIPTOR.message_types_by_name['Pagination']
_NULLRESPONSE = DESCRIPTOR.message_types_by_name['NullResponse']
IdMessage = _reflection.GeneratedProtocolMessageType('IdMessage', (_message.Message,), {
'DESCRIPTOR' : _IDMESSAGE,
'__module__' : 'ranks_pb2'
# @@protoc_insertion_point(class_scope:ranks.IdMessage)
})
_sym_db.RegisterMessage(IdMessage)
GetRequest = _reflection.GeneratedProtocolMessageType('GetRequest', (_message.Message,), {
'DESCRIPTOR' : _GETREQUEST,
'__module__' : 'ranks_pb2'
# @@protoc_insertion_point(class_scope:ranks.GetRequest)
})
_sym_db.RegisterMessage(GetRequest)
ListRequest = _reflection.GeneratedProtocolMessageType('ListRequest', (_message.Message,), {
'DESCRIPTOR' : _LISTREQUEST,
'__module__' : 'ranks_pb2'
# @@protoc_insertion_point(class_scope:ranks.ListRequest)
})
_sym_db.RegisterMessage(ListRequest)
RankList = _reflection.GeneratedProtocolMessageType('RankList', (_message.Message,), {
'DESCRIPTOR' : _RANKLIST,
'__module__' : 'ranks_pb2'
# @@protoc_insertion_point(class_scope:ranks.RankList)
})
_sym_db.RegisterMessage(RankList)
RankMessage = _reflection.GeneratedProtocolMessageType('RankMessage', (_message.Message,), {
'DESCRIPTOR' : _RANKMESSAGE,
'__module__' : 'ranks_pb2'
# @@protoc_insertion_point(class_scope:ranks.RankMessage)
})
_sym_db.RegisterMessage(RankMessage)
Pagination = _reflection.GeneratedProtocolMessageType('Pagination', (_message.Message,), {
'DESCRIPTOR' : _PAGINATION,
'__module__' : 'ranks_pb2'
# @@protoc_insertion_point(class_scope:ranks.Pagination)
})
_sym_db.RegisterMessage(Pagination)
NullResponse = _reflection.GeneratedProtocolMessageType('NullResponse', (_message.Message,), {
'DESCRIPTOR' : _NULLRESPONSE,
'__module__' : 'ranks_pb2'
# @@protoc_insertion_point(class_scope:ranks.NullResponse)
})
_sym_db.RegisterMessage(NullResponse)
_RANKSSERVICE = DESCRIPTOR.services_by_name['RanksService']
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z&git.itzana.me/strafesnet/go-grpc/ranks'
_IDMESSAGE._serialized_start=35
_IDMESSAGE._serialized_end=58
_GETREQUEST._serialized_start=60
_GETREQUEST._serialized_end=137
_LISTREQUEST._serialized_start=139
_LISTREQUEST._serialized_end=248
_RANKLIST._serialized_start=250
_RANKLIST._serialized_end=295
_RANKMESSAGE._serialized_start=298
_RANKMESSAGE._serialized_end=455
_PAGINATION._serialized_start=457
_PAGINATION._serialized_end=499
_NULLRESPONSE._serialized_start=501
_NULLRESPONSE._serialized_end=515
_RANKSSERVICE._serialized_start=518
_RANKSSERVICE._serialized_end=669
# @@protoc_insertion_point(module_scope)

132
strafesnet/ranks_pb2_grpc.py Normal file
View File

@ -0,0 +1,132 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import ranks_pb2 as ranks__pb2
class RanksServiceStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.Get = channel.unary_unary(
'/ranks.RanksService/Get',
request_serializer=ranks__pb2.GetRequest.SerializeToString,
response_deserializer=ranks__pb2.RankMessage.FromString,
)
self.List = channel.unary_unary(
'/ranks.RanksService/List',
request_serializer=ranks__pb2.ListRequest.SerializeToString,
response_deserializer=ranks__pb2.RankList.FromString,
)
self.Delete = channel.unary_unary(
'/ranks.RanksService/Delete',
request_serializer=ranks__pb2.IdMessage.SerializeToString,
response_deserializer=ranks__pb2.IdMessage.FromString,
)
class RanksServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
def Get(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def List(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Delete(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def add_RanksServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'Get': grpc.unary_unary_rpc_method_handler(
servicer.Get,
request_deserializer=ranks__pb2.GetRequest.FromString,
response_serializer=ranks__pb2.RankMessage.SerializeToString,
),
'List': grpc.unary_unary_rpc_method_handler(
servicer.List,
request_deserializer=ranks__pb2.ListRequest.FromString,
response_serializer=ranks__pb2.RankList.SerializeToString,
),
'Delete': grpc.unary_unary_rpc_method_handler(
servicer.Delete,
request_deserializer=ranks__pb2.IdMessage.FromString,
response_serializer=ranks__pb2.IdMessage.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'ranks.RanksService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
class RanksService(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def Get(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/ranks.RanksService/Get',
ranks__pb2.GetRequest.SerializeToString,
ranks__pb2.RankMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def List(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/ranks.RanksService/List',
ranks__pb2.ListRequest.SerializeToString,
ranks__pb2.RankList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Delete(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/ranks.RanksService/Delete',
ranks__pb2.IdMessage.SerializeToString,
ranks__pb2.IdMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)