diff options
Diffstat (limited to '.venv/lib/python3.12/site-packages/hatchet_sdk/contracts/events_pb2_grpc.py')
| -rw-r--r-- | .venv/lib/python3.12/site-packages/hatchet_sdk/contracts/events_pb2_grpc.py | 274 |
1 files changed, 274 insertions, 0 deletions
diff --git a/.venv/lib/python3.12/site-packages/hatchet_sdk/contracts/events_pb2_grpc.py b/.venv/lib/python3.12/site-packages/hatchet_sdk/contracts/events_pb2_grpc.py new file mode 100644 index 00000000..ddea5aa4 --- /dev/null +++ b/.venv/lib/python3.12/site-packages/hatchet_sdk/contracts/events_pb2_grpc.py @@ -0,0 +1,274 @@ +# 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.""" + + def __init__(self, channel): + """Constructor. + + Args: + channel: A grpc.Channel. + """ + self.Push = channel.unary_unary( + '/EventsService/Push', + request_serializer=events__pb2.PushEventRequest.SerializeToString, + response_deserializer=events__pb2.Event.FromString, + _registered_method=True) + self.BulkPush = channel.unary_unary( + '/EventsService/BulkPush', + request_serializer=events__pb2.BulkPushEventRequest.SerializeToString, + response_deserializer=events__pb2.Events.FromString, + _registered_method=True) + self.ReplaySingleEvent = channel.unary_unary( + '/EventsService/ReplaySingleEvent', + request_serializer=events__pb2.ReplayEventRequest.SerializeToString, + response_deserializer=events__pb2.Event.FromString, + _registered_method=True) + self.PutLog = channel.unary_unary( + '/EventsService/PutLog', + request_serializer=events__pb2.PutLogRequest.SerializeToString, + response_deserializer=events__pb2.PutLogResponse.FromString, + _registered_method=True) + self.PutStreamEvent = channel.unary_unary( + '/EventsService/PutStreamEvent', + request_serializer=events__pb2.PutStreamEventRequest.SerializeToString, + response_deserializer=events__pb2.PutStreamEventResponse.FromString, + _registered_method=True) + + +class EventsServiceServicer(object): + """Missing associated documentation comment in .proto file.""" + + def Push(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 BulkPush(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 ReplaySingleEvent(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 PutLog(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 PutStreamEvent(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_EventsServiceServicer_to_server(servicer, server): + rpc_method_handlers = { + 'Push': grpc.unary_unary_rpc_method_handler( + servicer.Push, + request_deserializer=events__pb2.PushEventRequest.FromString, + response_serializer=events__pb2.Event.SerializeToString, + ), + 'BulkPush': grpc.unary_unary_rpc_method_handler( + servicer.BulkPush, + request_deserializer=events__pb2.BulkPushEventRequest.FromString, + response_serializer=events__pb2.Events.SerializeToString, + ), + 'ReplaySingleEvent': grpc.unary_unary_rpc_method_handler( + servicer.ReplaySingleEvent, + request_deserializer=events__pb2.ReplayEventRequest.FromString, + response_serializer=events__pb2.Event.SerializeToString, + ), + 'PutLog': grpc.unary_unary_rpc_method_handler( + servicer.PutLog, + request_deserializer=events__pb2.PutLogRequest.FromString, + response_serializer=events__pb2.PutLogResponse.SerializeToString, + ), + 'PutStreamEvent': grpc.unary_unary_rpc_method_handler( + servicer.PutStreamEvent, + request_deserializer=events__pb2.PutStreamEventRequest.FromString, + response_serializer=events__pb2.PutStreamEventResponse.SerializeToString, + ), + } + generic_handler = grpc.method_handlers_generic_handler( + 'EventsService', rpc_method_handlers) + server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('EventsService', rpc_method_handlers) + + + # This class is part of an EXPERIMENTAL API. +class EventsService(object): + """Missing associated documentation comment in .proto file.""" + + @staticmethod + def Push(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, + '/EventsService/Push', + events__pb2.PushEventRequest.SerializeToString, + events__pb2.Event.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def BulkPush(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, + '/EventsService/BulkPush', + events__pb2.BulkPushEventRequest.SerializeToString, + events__pb2.Events.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def ReplaySingleEvent(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, + '/EventsService/ReplaySingleEvent', + events__pb2.ReplayEventRequest.SerializeToString, + events__pb2.Event.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def PutLog(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, + '/EventsService/PutLog', + events__pb2.PutLogRequest.SerializeToString, + events__pb2.PutLogResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def PutStreamEvent(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, + '/EventsService/PutStreamEvent', + events__pb2.PutStreamEventRequest.SerializeToString, + events__pb2.PutStreamEventResponse.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) |