StrafesNET/python-grpc
3
Fork 0
Code Releases Activity

Autogenerated update for 65a9abe6d3...f7f9376b4e

Browse Source
This commit is contained in:
itzaname 2024-07-14 00:40:26 +00:00
parent 54e2609f85
commit b5397065d3
18 changed files with 877 additions and 203 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
strafesnet/bots_pb2.py
View File

@ -1,7 +1,7 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: bots.proto
# Protobuf Python Version: 4.25.0
# Protobuf Python Version: 5.26.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
@ -19,8 +19,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\nbots.proto\x12\x
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'bots_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
_globals['DESCRIPTOR']._options = None
if not _descriptor._USE_C_DESCRIPTORS:
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'Z%git.itzana.me/strafesnet/go-grpc/bots'
_globals['_IDLIST']._serialized_start=20
_globals['_IDLIST']._serialized_end=40

134
strafesnet/bots_pb2_grpc.py
View File

@ -1,9 +1,34 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
from . import bots_pb2 as bots__pb2
GRPC_GENERATED_VERSION = '1.64.1'
GRPC_VERSION = grpc.__version__
EXPECTED_ERROR_RELEASE = '1.65.0'
SCHEDULED_RELEASE_DATE = 'June 25, 2024'
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
warnings.warn(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in bots_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
+ f' This warning will become an error in {EXPECTED_ERROR_RELEASE},'
+ f' scheduled for release on {SCHEDULED_RELEASE_DATE}.',
RuntimeWarning
)
class BotsServiceStub(object):
"""Missing associated documentation comment in .proto file."""
@ -18,32 +43,32 @@ class BotsServiceStub(object):
'/bots.BotsService/Get',
request_serializer=bots__pb2.IdMessage.SerializeToString,
response_deserializer=bots__pb2.BotResponse.FromString,
)
_registered_method=True)
self.GetList = channel.unary_unary(
'/bots.BotsService/GetList',
request_serializer=bots__pb2.IdList.SerializeToString,
response_deserializer=bots__pb2.BotList.FromString,
)
_registered_method=True)
self.Update = channel.unary_unary(
'/bots.BotsService/Update',
request_serializer=bots__pb2.BotRequest.SerializeToString,
response_deserializer=bots__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Create = channel.unary_unary(
'/bots.BotsService/Create',
request_serializer=bots__pb2.BotRequest.SerializeToString,
response_deserializer=bots__pb2.IdMessage.FromString,
)
_registered_method=True)
self.Delete = channel.unary_unary(
'/bots.BotsService/Delete',
request_serializer=bots__pb2.IdMessage.SerializeToString,
response_deserializer=bots__pb2.NullResponse.FromString,
)
_registered_method=True)
self.List = channel.unary_unary(
'/bots.BotsService/List',
request_serializer=bots__pb2.ListRequest.SerializeToString,
response_deserializer=bots__pb2.BotList.FromString,
)
_registered_method=True)
class BotsServiceServicer(object):
@ -122,6 +147,7 @@ def add_BotsServiceServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'bots.BotsService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('bots.BotsService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
@ -139,11 +165,21 @@ class BotsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/bots.BotsService/Get',
return grpc.experimental.unary_unary(
request,
target,
'/bots.BotsService/Get',
bots__pb2.IdMessage.SerializeToString,
bots__pb2.BotResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def GetList(request,
@ -156,11 +192,21 @@ class BotsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/bots.BotsService/GetList',
return grpc.experimental.unary_unary(
request,
target,
'/bots.BotsService/GetList',
bots__pb2.IdList.SerializeToString,
bots__pb2.BotList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Update(request,
@ -173,11 +219,21 @@ class BotsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/bots.BotsService/Update',
return grpc.experimental.unary_unary(
request,
target,
'/bots.BotsService/Update',
bots__pb2.BotRequest.SerializeToString,
bots__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Create(request,
@ -190,11 +246,21 @@ class BotsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/bots.BotsService/Create',
return grpc.experimental.unary_unary(
request,
target,
'/bots.BotsService/Create',
bots__pb2.BotRequest.SerializeToString,
bots__pb2.IdMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Delete(request,
@ -207,11 +273,21 @@ class BotsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/bots.BotsService/Delete',
return grpc.experimental.unary_unary(
request,
target,
'/bots.BotsService/Delete',
bots__pb2.IdMessage.SerializeToString,
bots__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def List(request,
@ -224,8 +300,18 @@ class BotsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/bots.BotsService/List',
return grpc.experimental.unary_unary(
request,
target,
'/bots.BotsService/List',
bots__pb2.ListRequest.SerializeToString,
bots__pb2.BotList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

6
strafesnet/datastore_pb2.py
View File

@ -1,7 +1,7 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: datastore.proto
# Protobuf Python Version: 4.25.0
# Protobuf Python Version: 5.26.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
@ -20,8 +20,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0f\x64\x61tastor
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'datastore_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
_globals['DESCRIPTOR']._options = None
if not _descriptor._USE_C_DESCRIPTORS:
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'Z*git.itzana.me/strafesnet/go-grpc/datastore'
_globals['_KEYMESSAGE']._serialized_start=60
_globals['_KEYMESSAGE']._serialized_end=85

80
strafesnet/datastore_pb2_grpc.py
View File

@ -1,9 +1,34 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
from . import datastore_pb2 as datastore__pb2
GRPC_GENERATED_VERSION = '1.64.1'
GRPC_VERSION = grpc.__version__
EXPECTED_ERROR_RELEASE = '1.65.0'
SCHEDULED_RELEASE_DATE = 'June 25, 2024'
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
warnings.warn(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in datastore_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
+ f' This warning will become an error in {EXPECTED_ERROR_RELEASE},'
+ f' scheduled for release on {SCHEDULED_RELEASE_DATE}.',
RuntimeWarning
)
class DatastoreServiceStub(object):
"""Missing associated documentation comment in .proto file."""
@ -18,17 +43,17 @@ class DatastoreServiceStub(object):
'/datastore.DatastoreService/Get',
request_serializer=datastore__pb2.KeyMessage.SerializeToString,
response_deserializer=datastore__pb2.ObjectResponse.FromString,
)
_registered_method=True)
self.Update = channel.unary_unary(
'/datastore.DatastoreService/Update',
request_serializer=datastore__pb2.UpdateMessage.SerializeToString,
response_deserializer=datastore__pb2.ObjectResponse.FromString,
)
_registered_method=True)
self.Delete = channel.unary_unary(
'/datastore.DatastoreService/Delete',
request_serializer=datastore__pb2.KeyMessage.SerializeToString,
response_deserializer=datastore__pb2.NullResponse.FromString,
)
_registered_method=True)
class DatastoreServiceServicer(object):
@ -74,6 +99,7 @@ def add_DatastoreServiceServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'datastore.DatastoreService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('datastore.DatastoreService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
@ -91,11 +117,21 @@ class DatastoreService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/datastore.DatastoreService/Get',
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)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Update(request,
@ -108,11 +144,21 @@ class DatastoreService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/datastore.DatastoreService/Update',
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)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Delete(request,
@ -125,8 +171,18 @@ class DatastoreService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/datastore.DatastoreService/Delete',
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)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

6
strafesnet/events_pb2.py
View File

@ -1,7 +1,7 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: events.proto
# Protobuf Python Version: 4.25.0
# Protobuf Python Version: 5.26.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
@ -20,8 +20,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0c\x65vents.prot
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'events_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
_globals['DESCRIPTOR']._options = None
if not _descriptor._USE_C_DESCRIPTORS:
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'Z\'git.itzana.me/strafesnet/go-grpc/events'
_globals['_EVENTCREATE']._serialized_start=54
_globals['_EVENTCREATE']._serialized_end=167

80
strafesnet/events_pb2_grpc.py
View File

@ -1,9 +1,34 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
from . import events_pb2 as events__pb2
GRPC_GENERATED_VERSION = '1.64.1'
GRPC_VERSION = grpc.__version__
EXPECTED_ERROR_RELEASE = '1.65.0'
SCHEDULED_RELEASE_DATE = 'June 25, 2024'
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
warnings.warn(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in events_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
+ f' This warning will become an error in {EXPECTED_ERROR_RELEASE},'
+ f' scheduled for release on {SCHEDULED_RELEASE_DATE}.',
RuntimeWarning
)
class EventsServiceStub(object):
"""Missing associated documentation comment in .proto file."""
@ -18,17 +43,17 @@ class EventsServiceStub(object):
'/events.EventsService/Latest',
request_serializer=events__pb2.LatestRequest.SerializeToString,
response_deserializer=events__pb2.LatestResponse.FromString,
)
_registered_method=True)
self.Create = channel.unary_unary(
'/events.EventsService/Create',
request_serializer=events__pb2.EventCreate.SerializeToString,
response_deserializer=events__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Clean = channel.unary_unary(
'/events.EventsService/Clean',
request_serializer=events__pb2.NullResponse.SerializeToString,
response_deserializer=events__pb2.NullResponse.FromString,
)
_registered_method=True)
class EventsServiceServicer(object):
@ -74,6 +99,7 @@ def add_EventsServiceServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'events.EventsService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('events.EventsService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
@ -91,11 +117,21 @@ class EventsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/events.EventsService/Latest',
return grpc.experimental.unary_unary(
request,
target,
'/events.EventsService/Latest',
events__pb2.LatestRequest.SerializeToString,
events__pb2.LatestResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Create(request,
@ -108,11 +144,21 @@ class EventsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/events.EventsService/Create',
return grpc.experimental.unary_unary(
request,
target,
'/events.EventsService/Create',
events__pb2.EventCreate.SerializeToString,
events__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Clean(request,
@ -125,8 +171,18 @@ class EventsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/events.EventsService/Clean',
return grpc.experimental.unary_unary(
request,
target,
'/events.EventsService/Clean',
events__pb2.NullResponse.SerializeToString,
events__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

6
strafesnet/maps_pb2.py
View File

@ -1,7 +1,7 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: maps.proto
# Protobuf Python Version: 4.25.0
# Protobuf Python Version: 5.26.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
@ -19,8 +19,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\nmaps.proto\x12\x
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'maps_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
_globals['DESCRIPTOR']._options = None
if not _descriptor._USE_C_DESCRIPTORS:
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'Z%git.itzana.me/strafesnet/go-grpc/maps'
_globals['_IDLIST']._serialized_start=20
_globals['_IDLIST']._serialized_end=40

134
strafesnet/maps_pb2_grpc.py
View File

@ -1,9 +1,34 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
from . import maps_pb2 as maps__pb2
GRPC_GENERATED_VERSION = '1.64.1'
GRPC_VERSION = grpc.__version__
EXPECTED_ERROR_RELEASE = '1.65.0'
SCHEDULED_RELEASE_DATE = 'June 25, 2024'
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
warnings.warn(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in maps_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
+ f' This warning will become an error in {EXPECTED_ERROR_RELEASE},'
+ f' scheduled for release on {SCHEDULED_RELEASE_DATE}.',
RuntimeWarning
)
class MapsServiceStub(object):
"""Missing associated documentation comment in .proto file."""
@ -18,32 +43,32 @@ class MapsServiceStub(object):
'/maps.MapsService/Get',
request_serializer=maps__pb2.IdMessage.SerializeToString,
response_deserializer=maps__pb2.MapResponse.FromString,
)
_registered_method=True)
self.GetList = channel.unary_unary(
'/maps.MapsService/GetList',
request_serializer=maps__pb2.IdList.SerializeToString,
response_deserializer=maps__pb2.MapList.FromString,
)
_registered_method=True)
self.Update = channel.unary_unary(
'/maps.MapsService/Update',
request_serializer=maps__pb2.MapRequest.SerializeToString,
response_deserializer=maps__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Create = channel.unary_unary(
'/maps.MapsService/Create',
request_serializer=maps__pb2.MapRequest.SerializeToString,
response_deserializer=maps__pb2.IdMessage.FromString,
)
_registered_method=True)
self.Delete = channel.unary_unary(
'/maps.MapsService/Delete',
request_serializer=maps__pb2.IdMessage.SerializeToString,
response_deserializer=maps__pb2.NullResponse.FromString,
)
_registered_method=True)
self.List = channel.unary_unary(
'/maps.MapsService/List',
request_serializer=maps__pb2.ListRequest.SerializeToString,
response_deserializer=maps__pb2.MapList.FromString,
)
_registered_method=True)
class MapsServiceServicer(object):
@ -122,6 +147,7 @@ def add_MapsServiceServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'maps.MapsService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('maps.MapsService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
@ -139,11 +165,21 @@ class MapsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/maps.MapsService/Get',
return grpc.experimental.unary_unary(
request,
target,
'/maps.MapsService/Get',
maps__pb2.IdMessage.SerializeToString,
maps__pb2.MapResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def GetList(request,
@ -156,11 +192,21 @@ class MapsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/maps.MapsService/GetList',
return grpc.experimental.unary_unary(
request,
target,
'/maps.MapsService/GetList',
maps__pb2.IdList.SerializeToString,
maps__pb2.MapList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Update(request,
@ -173,11 +219,21 @@ class MapsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/maps.MapsService/Update',
return grpc.experimental.unary_unary(
request,
target,
'/maps.MapsService/Update',
maps__pb2.MapRequest.SerializeToString,
maps__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Create(request,
@ -190,11 +246,21 @@ class MapsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/maps.MapsService/Create',
return grpc.experimental.unary_unary(
request,
target,
'/maps.MapsService/Create',
maps__pb2.MapRequest.SerializeToString,
maps__pb2.IdMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Delete(request,
@ -207,11 +273,21 @@ class MapsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/maps.MapsService/Delete',
return grpc.experimental.unary_unary(
request,
target,
'/maps.MapsService/Delete',
maps__pb2.IdMessage.SerializeToString,
maps__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def List(request,
@ -224,8 +300,18 @@ class MapsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/maps.MapsService/List',
return grpc.experimental.unary_unary(
request,
target,
'/maps.MapsService/List',
maps__pb2.ListRequest.SerializeToString,
maps__pb2.MapList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

6
strafesnet/ranks_pb2.py
View File

@ -1,7 +1,7 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: ranks.proto
# Protobuf Python Version: 4.25.0
# Protobuf Python Version: 5.26.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
@ -20,8 +20,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0branks.proto\x1
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'ranks_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
_globals['DESCRIPTOR']._options = None
if not _descriptor._USE_C_DESCRIPTORS:
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'Z&git.itzana.me/strafesnet/go-grpc/ranks'
_globals['_IDMESSAGE']._serialized_start=35
_globals['_IDMESSAGE']._serialized_end=58

80
strafesnet/ranks_pb2_grpc.py
View File

@ -1,9 +1,34 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
from . import ranks_pb2 as ranks__pb2
GRPC_GENERATED_VERSION = '1.64.1'
GRPC_VERSION = grpc.__version__
EXPECTED_ERROR_RELEASE = '1.65.0'
SCHEDULED_RELEASE_DATE = 'June 25, 2024'
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
warnings.warn(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in ranks_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
+ f' This warning will become an error in {EXPECTED_ERROR_RELEASE},'
+ f' scheduled for release on {SCHEDULED_RELEASE_DATE}.',
RuntimeWarning
)
class RanksServiceStub(object):
"""Missing associated documentation comment in .proto file."""
@ -18,17 +43,17 @@ class RanksServiceStub(object):
'/ranks.RanksService/Get',
request_serializer=ranks__pb2.GetRequest.SerializeToString,
response_deserializer=ranks__pb2.RankMessage.FromString,
)
_registered_method=True)
self.List = channel.unary_unary(
'/ranks.RanksService/List',
request_serializer=ranks__pb2.ListRequest.SerializeToString,
response_deserializer=ranks__pb2.RankList.FromString,
)
_registered_method=True)
self.Delete = channel.unary_unary(
'/ranks.RanksService/Delete',
request_serializer=ranks__pb2.IdMessage.SerializeToString,
response_deserializer=ranks__pb2.IdMessage.FromString,
)
_registered_method=True)
class RanksServiceServicer(object):
@ -74,6 +99,7 @@ def add_RanksServiceServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'ranks.RanksService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('ranks.RanksService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
@ -91,11 +117,21 @@ class RanksService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/ranks.RanksService/Get',
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)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def List(request,
@ -108,11 +144,21 @@ class RanksService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/ranks.RanksService/List',
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)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Delete(request,
@ -125,8 +171,18 @@ class RanksService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/ranks.RanksService/Delete',
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)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

6
strafesnet/servers_pb2.py
View File

@ -1,7 +1,7 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: servers.proto
# Protobuf Python Version: 4.25.0
# Protobuf Python Version: 5.26.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
@ -21,8 +21,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rservers.proto\x1
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'servers_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
_globals['DESCRIPTOR']._options = None
if not _descriptor._USE_C_DESCRIPTORS:
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'Z(git.itzana.me/strafesnet/go-grpc/servers'
_globals['_SERVERLIST']._serialized_start=51
_globals['_SERVERLIST']._serialized_end=101

116
strafesnet/servers_pb2_grpc.py
View File

@ -1,9 +1,34 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
from . import servers_pb2 as servers__pb2
GRPC_GENERATED_VERSION = '1.64.1'
GRPC_VERSION = grpc.__version__
EXPECTED_ERROR_RELEASE = '1.65.0'
SCHEDULED_RELEASE_DATE = 'June 25, 2024'
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
warnings.warn(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in servers_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
+ f' This warning will become an error in {EXPECTED_ERROR_RELEASE},'
+ f' scheduled for release on {SCHEDULED_RELEASE_DATE}.',
RuntimeWarning
)
class ServerServiceStub(object):
"""Missing associated documentation comment in .proto file."""
@ -18,27 +43,27 @@ class ServerServiceStub(object):
'/servers.ServerService/Create',
request_serializer=servers__pb2.ServerCreate.SerializeToString,
response_deserializer=servers__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Update = channel.unary_unary(
'/servers.ServerService/Update',
request_serializer=servers__pb2.ServerUpdate.SerializeToString,
response_deserializer=servers__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Delete = channel.unary_unary(
'/servers.ServerService/Delete',
request_serializer=servers__pb2.IdMessage.SerializeToString,
response_deserializer=servers__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Get = channel.unary_unary(
'/servers.ServerService/Get',
request_serializer=servers__pb2.IdMessage.SerializeToString,
response_deserializer=servers__pb2.ServerItem.FromString,
)
_registered_method=True)
self.List = channel.unary_unary(
'/servers.ServerService/List',
request_serializer=servers__pb2.ServerListRequest.SerializeToString,
response_deserializer=servers__pb2.ServerList.FromString,
)
_registered_method=True)
class ServerServiceServicer(object):
@ -106,6 +131,7 @@ def add_ServerServiceServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'servers.ServerService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('servers.ServerService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
@ -123,11 +149,21 @@ class ServerService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/servers.ServerService/Create',
return grpc.experimental.unary_unary(
request,
target,
'/servers.ServerService/Create',
servers__pb2.ServerCreate.SerializeToString,
servers__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Update(request,
@ -140,11 +176,21 @@ class ServerService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/servers.ServerService/Update',
return grpc.experimental.unary_unary(
request,
target,
'/servers.ServerService/Update',
servers__pb2.ServerUpdate.SerializeToString,
servers__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Delete(request,
@ -157,11 +203,21 @@ class ServerService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/servers.ServerService/Delete',
return grpc.experimental.unary_unary(
request,
target,
'/servers.ServerService/Delete',
servers__pb2.IdMessage.SerializeToString,
servers__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Get(request,
@ -174,11 +230,21 @@ class ServerService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/servers.ServerService/Get',
return grpc.experimental.unary_unary(
request,
target,
'/servers.ServerService/Get',
servers__pb2.IdMessage.SerializeToString,
servers__pb2.ServerItem.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def List(request,
@ -191,8 +257,18 @@ class ServerService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/servers.ServerService/List',
return grpc.experimental.unary_unary(
request,
target,
'/servers.ServerService/List',
servers__pb2.ServerListRequest.SerializeToString,
servers__pb2.ServerList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

6
strafesnet/times_pb2.py
View File

@ -1,7 +1,7 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: times.proto
# Protobuf Python Version: 4.25.0
# Protobuf Python Version: 5.26.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
@ -22,8 +22,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0btimes.proto\x1
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'times_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
_globals['DESCRIPTOR']._options = None
if not _descriptor._USE_C_DESCRIPTORS:
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'Z&git.itzana.me/strafesnet/go-grpc/times'
_globals['_TIMEREQUEST']._serialized_start=60
_globals['_TIMEREQUEST']._serialized_end=301

134
strafesnet/times_pb2_grpc.py
View File

@ -1,9 +1,34 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
from . import times_pb2 as times__pb2
GRPC_GENERATED_VERSION = '1.64.1'
GRPC_VERSION = grpc.__version__
EXPECTED_ERROR_RELEASE = '1.65.0'
SCHEDULED_RELEASE_DATE = 'June 25, 2024'
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
warnings.warn(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in times_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
+ f' This warning will become an error in {EXPECTED_ERROR_RELEASE},'
+ f' scheduled for release on {SCHEDULED_RELEASE_DATE}.',
RuntimeWarning
)
class TimesServiceStub(object):
"""Missing associated documentation comment in .proto file."""
@ -18,32 +43,32 @@ class TimesServiceStub(object):
'/times.TimesService/Create',
request_serializer=times__pb2.TimeRequest.SerializeToString,
response_deserializer=times__pb2.IdMessage.FromString,
)
_registered_method=True)
self.Update = channel.unary_unary(
'/times.TimesService/Update',
request_serializer=times__pb2.TimeRequest.SerializeToString,
response_deserializer=times__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Delete = channel.unary_unary(
'/times.TimesService/Delete',
request_serializer=times__pb2.IdMessage.SerializeToString,
response_deserializer=times__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Get = channel.unary_unary(
'/times.TimesService/Get',
request_serializer=times__pb2.IdMessage.SerializeToString,
response_deserializer=times__pb2.TimeResponse.FromString,
)
_registered_method=True)
self.List = channel.unary_unary(
'/times.TimesService/List',
request_serializer=times__pb2.ListRequest.SerializeToString,
response_deserializer=times__pb2.TimeList.FromString,
)
_registered_method=True)
self.Rank = channel.unary_unary(
'/times.TimesService/Rank',
request_serializer=times__pb2.IdMessage.SerializeToString,
response_deserializer=times__pb2.RankResponse.FromString,
)
_registered_method=True)
class TimesServiceServicer(object):
@ -122,6 +147,7 @@ def add_TimesServiceServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'times.TimesService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('times.TimesService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
@ -139,11 +165,21 @@ class TimesService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/times.TimesService/Create',
return grpc.experimental.unary_unary(
request,
target,
'/times.TimesService/Create',
times__pb2.TimeRequest.SerializeToString,
times__pb2.IdMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Update(request,
@ -156,11 +192,21 @@ class TimesService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/times.TimesService/Update',
return grpc.experimental.unary_unary(
request,
target,
'/times.TimesService/Update',
times__pb2.TimeRequest.SerializeToString,
times__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Delete(request,
@ -173,11 +219,21 @@ class TimesService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/times.TimesService/Delete',
return grpc.experimental.unary_unary(
request,
target,
'/times.TimesService/Delete',
times__pb2.IdMessage.SerializeToString,
times__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Get(request,
@ -190,11 +246,21 @@ class TimesService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/times.TimesService/Get',
return grpc.experimental.unary_unary(
request,
target,
'/times.TimesService/Get',
times__pb2.IdMessage.SerializeToString,
times__pb2.TimeResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def List(request,
@ -207,11 +273,21 @@ class TimesService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/times.TimesService/List',
return grpc.experimental.unary_unary(
request,
target,
'/times.TimesService/List',
times__pb2.ListRequest.SerializeToString,
times__pb2.TimeList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Rank(request,
@ -224,8 +300,18 @@ class TimesService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/times.TimesService/Rank',
return grpc.experimental.unary_unary(
request,
target,
'/times.TimesService/Rank',
times__pb2.IdMessage.SerializeToString,
times__pb2.RankResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

6
strafesnet/transactions_pb2.py
View File

@ -1,7 +1,7 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: transactions.proto
# Protobuf Python Version: 4.25.0
# Protobuf Python Version: 5.26.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
@ -21,8 +21,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x12transactions.p
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'transactions_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
_globals['DESCRIPTOR']._options = None
if not _descriptor._USE_C_DESCRIPTORS:
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'Z-git.itzana.me/strafesnet/go-grpc/transactions'
_globals['_TRANSACTIONCREATE']._serialized_start=79
_globals['_TRANSACTIONCREATE']._serialized_end=197

134
strafesnet/transactions_pb2_grpc.py
View File

@ -1,9 +1,34 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
from . import transactions_pb2 as transactions__pb2
GRPC_GENERATED_VERSION = '1.64.1'
GRPC_VERSION = grpc.__version__
EXPECTED_ERROR_RELEASE = '1.65.0'
SCHEDULED_RELEASE_DATE = 'June 25, 2024'
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
warnings.warn(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in transactions_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
+ f' This warning will become an error in {EXPECTED_ERROR_RELEASE},'
+ f' scheduled for release on {SCHEDULED_RELEASE_DATE}.',
RuntimeWarning
)
class TransactionsServiceStub(object):
"""Missing associated documentation comment in .proto file."""
@ -18,32 +43,32 @@ class TransactionsServiceStub(object):
'/transactions.TransactionsService/Create',
request_serializer=transactions__pb2.TransactionCreate.SerializeToString,
response_deserializer=transactions__pb2.IdMessage.FromString,
)
_registered_method=True)
self.Update = channel.unary_unary(
'/transactions.TransactionsService/Update',
request_serializer=transactions__pb2.TransactionUpdate.SerializeToString,
response_deserializer=transactions__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Delete = channel.unary_unary(
'/transactions.TransactionsService/Delete',
request_serializer=transactions__pb2.IdMessage.SerializeToString,
response_deserializer=transactions__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Balance = channel.unary_unary(
'/transactions.TransactionsService/Balance',
request_serializer=transactions__pb2.UserIdMessage.SerializeToString,
response_deserializer=transactions__pb2.BalanceResponse.FromString,
)
_registered_method=True)
self.Get = channel.unary_unary(
'/transactions.TransactionsService/Get',
request_serializer=transactions__pb2.IdMessage.SerializeToString,
response_deserializer=transactions__pb2.TransactionItem.FromString,
)
_registered_method=True)
self.List = channel.unary_unary(
'/transactions.TransactionsService/List',
request_serializer=transactions__pb2.ListRequest.SerializeToString,
response_deserializer=transactions__pb2.TransactionList.FromString,
)
_registered_method=True)
class TransactionsServiceServicer(object):
@ -122,6 +147,7 @@ def add_TransactionsServiceServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'transactions.TransactionsService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('transactions.TransactionsService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
@ -139,11 +165,21 @@ class TransactionsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/Create',
return grpc.experimental.unary_unary(
request,
target,
'/transactions.TransactionsService/Create',
transactions__pb2.TransactionCreate.SerializeToString,
transactions__pb2.IdMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Update(request,
@ -156,11 +192,21 @@ class TransactionsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/Update',
return grpc.experimental.unary_unary(
request,
target,
'/transactions.TransactionsService/Update',
transactions__pb2.TransactionUpdate.SerializeToString,
transactions__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Delete(request,
@ -173,11 +219,21 @@ class TransactionsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/Delete',
return grpc.experimental.unary_unary(
request,
target,
'/transactions.TransactionsService/Delete',
transactions__pb2.IdMessage.SerializeToString,
transactions__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Balance(request,
@ -190,11 +246,21 @@ class TransactionsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/Balance',
return grpc.experimental.unary_unary(
request,
target,
'/transactions.TransactionsService/Balance',
transactions__pb2.UserIdMessage.SerializeToString,
transactions__pb2.BalanceResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Get(request,
@ -207,11 +273,21 @@ class TransactionsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/Get',
return grpc.experimental.unary_unary(
request,
target,
'/transactions.TransactionsService/Get',
transactions__pb2.IdMessage.SerializeToString,
transactions__pb2.TransactionItem.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def List(request,
@ -224,8 +300,18 @@ class TransactionsService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/List',
return grpc.experimental.unary_unary(
request,
target,
'/transactions.TransactionsService/List',
transactions__pb2.ListRequest.SerializeToString,
transactions__pb2.TransactionList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

6
strafesnet/users_pb2.py
View File

@ -1,7 +1,7 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: users.proto
# Protobuf Python Version: 4.25.0
# Protobuf Python Version: 5.26.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
@ -19,8 +19,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0busers.proto\x1
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'users_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
_globals['DESCRIPTOR']._options = None
if not _descriptor._USE_C_DESCRIPTORS:
_globals['DESCRIPTOR']._loaded_options = None
_globals['DESCRIPTOR']._serialized_options = b'Z&git.itzana.me/strafesnet/go-grpc/users'
_globals['_IDLIST']._serialized_start=22
_globals['_IDLIST']._serialized_end=42

134
strafesnet/users_pb2_grpc.py
View File

@ -1,9 +1,34 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
import warnings
from . import users_pb2 as users__pb2
GRPC_GENERATED_VERSION = '1.64.1'
GRPC_VERSION = grpc.__version__
EXPECTED_ERROR_RELEASE = '1.65.0'
SCHEDULED_RELEASE_DATE = 'June 25, 2024'
_version_not_supported = False
try:
from grpc._utilities import first_version_is_lower
_version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
except ImportError:
_version_not_supported = True
if _version_not_supported:
warnings.warn(
f'The grpc package installed is at version {GRPC_VERSION},'
+ f' but the generated code in users_pb2_grpc.py depends on'
+ f' grpcio>={GRPC_GENERATED_VERSION}.'
+ f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+ f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
+ f' This warning will become an error in {EXPECTED_ERROR_RELEASE},'
+ f' scheduled for release on {SCHEDULED_RELEASE_DATE}.',
RuntimeWarning
)
class UsersServiceStub(object):
"""Missing associated documentation comment in .proto file."""
@ -18,32 +43,32 @@ class UsersServiceStub(object):
'/users.UsersService/Get',
request_serializer=users__pb2.IdMessage.SerializeToString,
response_deserializer=users__pb2.UserResponse.FromString,
)
_registered_method=True)
self.GetList = channel.unary_unary(
'/users.UsersService/GetList',
request_serializer=users__pb2.IdList.SerializeToString,
response_deserializer=users__pb2.UserList.FromString,
)
_registered_method=True)
self.Update = channel.unary_unary(
'/users.UsersService/Update',
request_serializer=users__pb2.UserRequest.SerializeToString,
response_deserializer=users__pb2.NullResponse.FromString,
)
_registered_method=True)
self.Create = channel.unary_unary(
'/users.UsersService/Create',
request_serializer=users__pb2.UserRequest.SerializeToString,
response_deserializer=users__pb2.IdMessage.FromString,
)
_registered_method=True)
self.Delete = channel.unary_unary(
'/users.UsersService/Delete',
request_serializer=users__pb2.IdMessage.SerializeToString,
response_deserializer=users__pb2.NullResponse.FromString,
)
_registered_method=True)
self.List = channel.unary_unary(
'/users.UsersService/List',
request_serializer=users__pb2.ListRequest.SerializeToString,
response_deserializer=users__pb2.UserList.FromString,
)
_registered_method=True)
class UsersServiceServicer(object):
@ -122,6 +147,7 @@ def add_UsersServiceServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'users.UsersService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('users.UsersService', rpc_method_handlers)
# This class is part of an EXPERIMENTAL API.
@ -139,11 +165,21 @@ class UsersService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/users.UsersService/Get',
return grpc.experimental.unary_unary(
request,
target,
'/users.UsersService/Get',
users__pb2.IdMessage.SerializeToString,
users__pb2.UserResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def GetList(request,
@ -156,11 +192,21 @@ class UsersService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/users.UsersService/GetList',
return grpc.experimental.unary_unary(
request,
target,
'/users.UsersService/GetList',
users__pb2.IdList.SerializeToString,
users__pb2.UserList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Update(request,
@ -173,11 +219,21 @@ class UsersService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/users.UsersService/Update',
return grpc.experimental.unary_unary(
request,
target,
'/users.UsersService/Update',
users__pb2.UserRequest.SerializeToString,
users__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Create(request,
@ -190,11 +246,21 @@ class UsersService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/users.UsersService/Create',
return grpc.experimental.unary_unary(
request,
target,
'/users.UsersService/Create',
users__pb2.UserRequest.SerializeToString,
users__pb2.IdMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def Delete(request,
@ -207,11 +273,21 @@ class UsersService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/users.UsersService/Delete',
return grpc.experimental.unary_unary(
request,
target,
'/users.UsersService/Delete',
users__pb2.IdMessage.SerializeToString,
users__pb2.NullResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
@staticmethod
def List(request,
@ -224,8 +300,18 @@ class UsersService(object):
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/users.UsersService/List',
return grpc.experimental.unary_unary(
request,
target,
'/users.UsersService/List',
users__pb2.ListRequest.SerializeToString,
users__pb2.UserList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)