diff --git a/schema/druncschema/broadcast.proto b/schema/druncschema/broadcast.proto deleted file mode 100644 index 10cc580..0000000 --- a/schema/druncschema/broadcast.proto +++ /dev/null @@ -1,64 +0,0 @@ -syntax = "proto3"; - -package dunedaq.druncschema; - -import "druncschema/generic.proto"; -import "druncschema/request_response.proto"; -import "google/protobuf/any.proto"; - -service BroadcastReceiver { - rpc handle_broadcast (BroadcastMessage) returns (Empty) {} -} - -service BroadcastSender { - rpc add_to_broadcast_list (Request) returns (Response) {} - rpc remove_from_broadcast_list (Request) returns (Response) {} - rpc get_broadcast_list (Request) returns (Response) {} -} - - -message KafkaBroadcastHandlerConfiguration{ - string kafka_address = 1; - string topic = 2; -} - -enum BroadcastType { - ACK = 0; - RECEIVER_REMOVED = 1; - RECEIVER_ADDED = 2; - SERVER_READY = 3; - SERVER_SHUTDOWN = 4; - TEXT_MESSAGE = 15; - COMMAND_EXECUTION_START = 5; - COMMAND_RECEIVED = 16; - COMMAND_EXECUTION_SUCCESS = 6; - DRUNC_EXCEPTION_RAISED = 7; - UNHANDLED_EXCEPTION_RAISED = 8; - STATUS_UPDATE = 9; - SUBPROCESS_STATUS_UPDATE = 10; - DEBUG = 11; - CHILD_COMMAND_EXECUTION_START = 12; - CHILD_COMMAND_EXECUTION_SUCCESS = 13; - CHILD_COMMAND_EXECUTION_FAILED = 14; - FSM_STATUS_UPDATE = 17; -} - -message Emitter { - string process = 1; - string session = 2; -} - -message BroadcastMessage{ - Emitter emitter = 1; - BroadcastType type = 2; - google.protobuf.Any data = 3; -} - -message BroadcastRequest { - string broadcast_receiver_address = 1; -} - -message BroadcastResponse { - bool success = 1; -} - diff --git a/schema/druncschema/description.proto b/schema/druncschema/description.proto index f17a313..1340014 100644 --- a/schema/druncschema/description.proto +++ b/schema/druncschema/description.proto @@ -4,7 +4,6 @@ package dunedaq.druncschema; import "druncschema/request_response.proto"; import "druncschema/token.proto"; -import "google/protobuf/any.proto"; message CommandDescription { string name = 1; @@ -21,6 +20,5 @@ message Description { optional string info = 5; optional string session = 6; repeated CommandDescription commands = 7; - optional google.protobuf.Any broadcast = 8; - ResponseFlag flag = 9; + ResponseFlag flag = 8; } diff --git a/src/druncschema/broadcast_pb2.py b/src/druncschema/broadcast_pb2.py deleted file mode 100644 index 6357c5b..0000000 --- a/src/druncschema/broadcast_pb2.py +++ /dev/null @@ -1,53 +0,0 @@ -# -*- coding: utf-8 -*- -# Generated by the protocol buffer compiler. DO NOT EDIT! -# NO CHECKED-IN PROTOBUF GENCODE -# source: druncschema/broadcast.proto -# Protobuf Python Version: 6.31.1 -"""Generated protocol buffer code.""" -from google.protobuf import descriptor as _descriptor -from google.protobuf import descriptor_pool as _descriptor_pool -from google.protobuf import runtime_version as _runtime_version -from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder -_runtime_version.ValidateProtobufRuntimeVersion( - _runtime_version.Domain.PUBLIC, - 6, - 31, - 1, - '', - 'druncschema/broadcast.proto' -) -# @@protoc_insertion_point(imports) - -_sym_db = _symbol_database.Default() - - -from druncschema import generic_pb2 as druncschema_dot_generic__pb2 -from druncschema import request_response_pb2 as druncschema_dot_request__response__pb2 -from google.protobuf import any_pb2 as google_dot_protobuf_dot_any__pb2 - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1b\x64runcschema/broadcast.proto\x12\x13\x64unedaq.druncschema\x1a\x19\x64runcschema/generic.proto\x1a\"druncschema/request_response.proto\x1a\x19google/protobuf/any.proto\"J\n\"KafkaBroadcastHandlerConfiguration\x12\x15\n\rkafka_address\x18\x01 \x01(\t\x12\r\n\x05topic\x18\x02 \x01(\t\"+\n\x07\x45mitter\x12\x0f\n\x07process\x18\x01 \x01(\t\x12\x0f\n\x07session\x18\x02 \x01(\t\"\x97\x01\n\x10\x42roadcastMessage\x12-\n\x07\x65mitter\x18\x01 \x01(\x0b\x32\x1c.dunedaq.druncschema.Emitter\x12\x30\n\x04type\x18\x02 \x01(\x0e\x32\".dunedaq.druncschema.BroadcastType\x12\"\n\x04\x64\x61ta\x18\x03 \x01(\x0b\x32\x14.google.protobuf.Any\"6\n\x10\x42roadcastRequest\x12\"\n\x1a\x62roadcast_receiver_address\x18\x01 \x01(\t\"$\n\x11\x42roadcastResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08*\xc8\x03\n\rBroadcastType\x12\x07\n\x03\x41\x43K\x10\x00\x12\x14\n\x10RECEIVER_REMOVED\x10\x01\x12\x12\n\x0eRECEIVER_ADDED\x10\x02\x12\x10\n\x0cSERVER_READY\x10\x03\x12\x13\n\x0fSERVER_SHUTDOWN\x10\x04\x12\x10\n\x0cTEXT_MESSAGE\x10\x0f\x12\x1b\n\x17\x43OMMAND_EXECUTION_START\x10\x05\x12\x14\n\x10\x43OMMAND_RECEIVED\x10\x10\x12\x1d\n\x19\x43OMMAND_EXECUTION_SUCCESS\x10\x06\x12\x1a\n\x16\x44RUNC_EXCEPTION_RAISED\x10\x07\x12\x1e\n\x1aUNHANDLED_EXCEPTION_RAISED\x10\x08\x12\x11\n\rSTATUS_UPDATE\x10\t\x12\x1c\n\x18SUBPROCESS_STATUS_UPDATE\x10\n\x12\t\n\x05\x44\x45\x42UG\x10\x0b\x12!\n\x1d\x43HILD_COMMAND_EXECUTION_START\x10\x0c\x12#\n\x1f\x43HILD_COMMAND_EXECUTION_SUCCESS\x10\r\x12\"\n\x1e\x43HILD_COMMAND_EXECUTION_FAILED\x10\x0e\x12\x15\n\x11\x46SM_STATUS_UPDATE\x10\x11\x32l\n\x11\x42roadcastReceiver\x12W\n\x10handle_broadcast\x12%.dunedaq.druncschema.BroadcastMessage\x1a\x1a.dunedaq.druncschema.Empty\"\x00\x32\x9b\x02\n\x0f\x42roadcastSender\x12V\n\x15\x61\x64\x64_to_broadcast_list\x12\x1c.dunedaq.druncschema.Request\x1a\x1d.dunedaq.druncschema.Response\"\x00\x12[\n\x1aremove_from_broadcast_list\x12\x1c.dunedaq.druncschema.Request\x1a\x1d.dunedaq.druncschema.Response\"\x00\x12S\n\x12get_broadcast_list\x12\x1c.dunedaq.druncschema.Request\x1a\x1d.dunedaq.druncschema.Response\"\x00\x62\x06proto3') - -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'druncschema.broadcast_pb2', _globals) -if not _descriptor._USE_C_DESCRIPTORS: - DESCRIPTOR._loaded_options = None - _globals['_BROADCASTTYPE']._serialized_start=512 - _globals['_BROADCASTTYPE']._serialized_end=968 - _globals['_KAFKABROADCASTHANDLERCONFIGURATION']._serialized_start=142 - _globals['_KAFKABROADCASTHANDLERCONFIGURATION']._serialized_end=216 - _globals['_EMITTER']._serialized_start=218 - _globals['_EMITTER']._serialized_end=261 - _globals['_BROADCASTMESSAGE']._serialized_start=264 - _globals['_BROADCASTMESSAGE']._serialized_end=415 - _globals['_BROADCASTREQUEST']._serialized_start=417 - _globals['_BROADCASTREQUEST']._serialized_end=471 - _globals['_BROADCASTRESPONSE']._serialized_start=473 - _globals['_BROADCASTRESPONSE']._serialized_end=509 - _globals['_BROADCASTRECEIVER']._serialized_start=970 - _globals['_BROADCASTRECEIVER']._serialized_end=1078 - _globals['_BROADCASTSENDER']._serialized_start=1081 - _globals['_BROADCASTSENDER']._serialized_end=1364 -# @@protoc_insertion_point(module_scope) diff --git a/src/druncschema/broadcast_pb2.pyi b/src/druncschema/broadcast_pb2.pyi deleted file mode 100644 index 0a744e6..0000000 --- a/src/druncschema/broadcast_pb2.pyi +++ /dev/null @@ -1,175 +0,0 @@ -""" -@generated by mypy-protobuf. Do not edit manually! -isort:skip_file -""" - -from google.protobuf import any_pb2 as _any_pb2 -from google.protobuf import descriptor as _descriptor -from google.protobuf import message as _message -from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper -import builtins as _builtins -import sys -import typing as _typing - -if sys.version_info >= (3, 11): - from typing import TypeAlias as _TypeAlias, Never as _Never -else: - from typing_extensions import TypeAlias as _TypeAlias, Never as _Never - -DESCRIPTOR: _descriptor.FileDescriptor - -class _BroadcastType: - ValueType = _typing.NewType("ValueType", _builtins.int) - V: _TypeAlias = ValueType # noqa: Y015 - -class _BroadcastTypeEnumTypeWrapper(_enum_type_wrapper._EnumTypeWrapper[_BroadcastType.ValueType], _builtins.type): - DESCRIPTOR: _descriptor.EnumDescriptor - ACK: _BroadcastType.ValueType # 0 - RECEIVER_REMOVED: _BroadcastType.ValueType # 1 - RECEIVER_ADDED: _BroadcastType.ValueType # 2 - SERVER_READY: _BroadcastType.ValueType # 3 - SERVER_SHUTDOWN: _BroadcastType.ValueType # 4 - TEXT_MESSAGE: _BroadcastType.ValueType # 15 - COMMAND_EXECUTION_START: _BroadcastType.ValueType # 5 - COMMAND_RECEIVED: _BroadcastType.ValueType # 16 - COMMAND_EXECUTION_SUCCESS: _BroadcastType.ValueType # 6 - DRUNC_EXCEPTION_RAISED: _BroadcastType.ValueType # 7 - UNHANDLED_EXCEPTION_RAISED: _BroadcastType.ValueType # 8 - STATUS_UPDATE: _BroadcastType.ValueType # 9 - SUBPROCESS_STATUS_UPDATE: _BroadcastType.ValueType # 10 - DEBUG: _BroadcastType.ValueType # 11 - CHILD_COMMAND_EXECUTION_START: _BroadcastType.ValueType # 12 - CHILD_COMMAND_EXECUTION_SUCCESS: _BroadcastType.ValueType # 13 - CHILD_COMMAND_EXECUTION_FAILED: _BroadcastType.ValueType # 14 - FSM_STATUS_UPDATE: _BroadcastType.ValueType # 17 - -class BroadcastType(_BroadcastType, metaclass=_BroadcastTypeEnumTypeWrapper): ... - -ACK: BroadcastType.ValueType # 0 -RECEIVER_REMOVED: BroadcastType.ValueType # 1 -RECEIVER_ADDED: BroadcastType.ValueType # 2 -SERVER_READY: BroadcastType.ValueType # 3 -SERVER_SHUTDOWN: BroadcastType.ValueType # 4 -TEXT_MESSAGE: BroadcastType.ValueType # 15 -COMMAND_EXECUTION_START: BroadcastType.ValueType # 5 -COMMAND_RECEIVED: BroadcastType.ValueType # 16 -COMMAND_EXECUTION_SUCCESS: BroadcastType.ValueType # 6 -DRUNC_EXCEPTION_RAISED: BroadcastType.ValueType # 7 -UNHANDLED_EXCEPTION_RAISED: BroadcastType.ValueType # 8 -STATUS_UPDATE: BroadcastType.ValueType # 9 -SUBPROCESS_STATUS_UPDATE: BroadcastType.ValueType # 10 -DEBUG: BroadcastType.ValueType # 11 -CHILD_COMMAND_EXECUTION_START: BroadcastType.ValueType # 12 -CHILD_COMMAND_EXECUTION_SUCCESS: BroadcastType.ValueType # 13 -CHILD_COMMAND_EXECUTION_FAILED: BroadcastType.ValueType # 14 -FSM_STATUS_UPDATE: BroadcastType.ValueType # 17 -Global___BroadcastType: _TypeAlias = BroadcastType # noqa: Y015 - -@_typing.final -class KafkaBroadcastHandlerConfiguration(_message.Message): - DESCRIPTOR: _descriptor.Descriptor - - KAFKA_ADDRESS_FIELD_NUMBER: _builtins.int - TOPIC_FIELD_NUMBER: _builtins.int - kafka_address: _builtins.str - topic: _builtins.str - def __init__( - self, - *, - kafka_address: _builtins.str = ..., - topic: _builtins.str = ..., - ) -> None: ... - _HasFieldArgType: _TypeAlias = _Never # noqa: Y015 - def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ... - _ClearFieldArgType: _TypeAlias = _typing.Literal["kafka_address", b"kafka_address", "topic", b"topic"] # noqa: Y015 - def ClearField(self, field_name: _ClearFieldArgType) -> None: ... - def WhichOneof(self, oneof_group: _Never) -> None: ... - -Global___KafkaBroadcastHandlerConfiguration: _TypeAlias = KafkaBroadcastHandlerConfiguration # noqa: Y015 - -@_typing.final -class Emitter(_message.Message): - DESCRIPTOR: _descriptor.Descriptor - - PROCESS_FIELD_NUMBER: _builtins.int - SESSION_FIELD_NUMBER: _builtins.int - process: _builtins.str - session: _builtins.str - def __init__( - self, - *, - process: _builtins.str = ..., - session: _builtins.str = ..., - ) -> None: ... - _HasFieldArgType: _TypeAlias = _Never # noqa: Y015 - def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ... - _ClearFieldArgType: _TypeAlias = _typing.Literal["process", b"process", "session", b"session"] # noqa: Y015 - def ClearField(self, field_name: _ClearFieldArgType) -> None: ... - def WhichOneof(self, oneof_group: _Never) -> None: ... - -Global___Emitter: _TypeAlias = Emitter # noqa: Y015 - -@_typing.final -class BroadcastMessage(_message.Message): - DESCRIPTOR: _descriptor.Descriptor - - EMITTER_FIELD_NUMBER: _builtins.int - TYPE_FIELD_NUMBER: _builtins.int - DATA_FIELD_NUMBER: _builtins.int - type: Global___BroadcastType.ValueType - @_builtins.property - def emitter(self) -> Global___Emitter: ... - @_builtins.property - def data(self) -> _any_pb2.Any: ... - def __init__( - self, - *, - emitter: Global___Emitter | None = ..., - type: Global___BroadcastType.ValueType = ..., - data: _any_pb2.Any | None = ..., - ) -> None: ... - _HasFieldArgType: _TypeAlias = _typing.Literal["data", b"data", "emitter", b"emitter"] # noqa: Y015 - def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ... - _ClearFieldArgType: _TypeAlias = _typing.Literal["data", b"data", "emitter", b"emitter", "type", b"type"] # noqa: Y015 - def ClearField(self, field_name: _ClearFieldArgType) -> None: ... - def WhichOneof(self, oneof_group: _Never) -> None: ... - -Global___BroadcastMessage: _TypeAlias = BroadcastMessage # noqa: Y015 - -@_typing.final -class BroadcastRequest(_message.Message): - DESCRIPTOR: _descriptor.Descriptor - - BROADCAST_RECEIVER_ADDRESS_FIELD_NUMBER: _builtins.int - broadcast_receiver_address: _builtins.str - def __init__( - self, - *, - broadcast_receiver_address: _builtins.str = ..., - ) -> None: ... - _HasFieldArgType: _TypeAlias = _Never # noqa: Y015 - def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ... - _ClearFieldArgType: _TypeAlias = _typing.Literal["broadcast_receiver_address", b"broadcast_receiver_address"] # noqa: Y015 - def ClearField(self, field_name: _ClearFieldArgType) -> None: ... - def WhichOneof(self, oneof_group: _Never) -> None: ... - -Global___BroadcastRequest: _TypeAlias = BroadcastRequest # noqa: Y015 - -@_typing.final -class BroadcastResponse(_message.Message): - DESCRIPTOR: _descriptor.Descriptor - - SUCCESS_FIELD_NUMBER: _builtins.int - success: _builtins.bool - def __init__( - self, - *, - success: _builtins.bool = ..., - ) -> None: ... - _HasFieldArgType: _TypeAlias = _Never # noqa: Y015 - def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ... - _ClearFieldArgType: _TypeAlias = _typing.Literal["success", b"success"] # noqa: Y015 - def ClearField(self, field_name: _ClearFieldArgType) -> None: ... - def WhichOneof(self, oneof_group: _Never) -> None: ... - -Global___BroadcastResponse: _TypeAlias = BroadcastResponse # noqa: Y015 diff --git a/src/druncschema/broadcast_pb2_grpc.py b/src/druncschema/broadcast_pb2_grpc.py deleted file mode 100644 index f542f69..0000000 --- a/src/druncschema/broadcast_pb2_grpc.py +++ /dev/null @@ -1,257 +0,0 @@ -# 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 druncschema import broadcast_pb2 as druncschema_dot_broadcast__pb2 -from druncschema import generic_pb2 as druncschema_dot_generic__pb2 -from druncschema import request_response_pb2 as druncschema_dot_request__response__pb2 - -GRPC_GENERATED_VERSION = '1.75.0' -GRPC_VERSION = grpc.__version__ -_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: - raise RuntimeError( - f'The grpc package installed is at version {GRPC_VERSION},' - + f' but the generated code in druncschema/broadcast_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}.' - ) - - -class BroadcastReceiverStub(object): - """Missing associated documentation comment in .proto file.""" - - def __init__(self, channel): - """Constructor. - - Args: - channel: A grpc.Channel. - """ - self.handle_broadcast = channel.unary_unary( - '/dunedaq.druncschema.BroadcastReceiver/handle_broadcast', - request_serializer=druncschema_dot_broadcast__pb2.BroadcastMessage.SerializeToString, - response_deserializer=druncschema_dot_generic__pb2.Empty.FromString, - _registered_method=True) - - -class BroadcastReceiverServicer(object): - """Missing associated documentation comment in .proto file.""" - - def handle_broadcast(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_BroadcastReceiverServicer_to_server(servicer, server): - rpc_method_handlers = { - 'handle_broadcast': grpc.unary_unary_rpc_method_handler( - servicer.handle_broadcast, - request_deserializer=druncschema_dot_broadcast__pb2.BroadcastMessage.FromString, - response_serializer=druncschema_dot_generic__pb2.Empty.SerializeToString, - ), - } - generic_handler = grpc.method_handlers_generic_handler( - 'dunedaq.druncschema.BroadcastReceiver', rpc_method_handlers) - server.add_generic_rpc_handlers((generic_handler,)) - server.add_registered_method_handlers('dunedaq.druncschema.BroadcastReceiver', rpc_method_handlers) - - - # This class is part of an EXPERIMENTAL API. -class BroadcastReceiver(object): - """Missing associated documentation comment in .proto file.""" - - @staticmethod - def handle_broadcast(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, - '/dunedaq.druncschema.BroadcastReceiver/handle_broadcast', - druncschema_dot_broadcast__pb2.BroadcastMessage.SerializeToString, - druncschema_dot_generic__pb2.Empty.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - -class BroadcastSenderStub(object): - """Missing associated documentation comment in .proto file.""" - - def __init__(self, channel): - """Constructor. - - Args: - channel: A grpc.Channel. - """ - self.add_to_broadcast_list = channel.unary_unary( - '/dunedaq.druncschema.BroadcastSender/add_to_broadcast_list', - request_serializer=druncschema_dot_request__response__pb2.Request.SerializeToString, - response_deserializer=druncschema_dot_request__response__pb2.Response.FromString, - _registered_method=True) - self.remove_from_broadcast_list = channel.unary_unary( - '/dunedaq.druncschema.BroadcastSender/remove_from_broadcast_list', - request_serializer=druncschema_dot_request__response__pb2.Request.SerializeToString, - response_deserializer=druncschema_dot_request__response__pb2.Response.FromString, - _registered_method=True) - self.get_broadcast_list = channel.unary_unary( - '/dunedaq.druncschema.BroadcastSender/get_broadcast_list', - request_serializer=druncschema_dot_request__response__pb2.Request.SerializeToString, - response_deserializer=druncschema_dot_request__response__pb2.Response.FromString, - _registered_method=True) - - -class BroadcastSenderServicer(object): - """Missing associated documentation comment in .proto file.""" - - def add_to_broadcast_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 remove_from_broadcast_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 get_broadcast_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 add_BroadcastSenderServicer_to_server(servicer, server): - rpc_method_handlers = { - 'add_to_broadcast_list': grpc.unary_unary_rpc_method_handler( - servicer.add_to_broadcast_list, - request_deserializer=druncschema_dot_request__response__pb2.Request.FromString, - response_serializer=druncschema_dot_request__response__pb2.Response.SerializeToString, - ), - 'remove_from_broadcast_list': grpc.unary_unary_rpc_method_handler( - servicer.remove_from_broadcast_list, - request_deserializer=druncschema_dot_request__response__pb2.Request.FromString, - response_serializer=druncschema_dot_request__response__pb2.Response.SerializeToString, - ), - 'get_broadcast_list': grpc.unary_unary_rpc_method_handler( - servicer.get_broadcast_list, - request_deserializer=druncschema_dot_request__response__pb2.Request.FromString, - response_serializer=druncschema_dot_request__response__pb2.Response.SerializeToString, - ), - } - generic_handler = grpc.method_handlers_generic_handler( - 'dunedaq.druncschema.BroadcastSender', rpc_method_handlers) - server.add_generic_rpc_handlers((generic_handler,)) - server.add_registered_method_handlers('dunedaq.druncschema.BroadcastSender', rpc_method_handlers) - - - # This class is part of an EXPERIMENTAL API. -class BroadcastSender(object): - """Missing associated documentation comment in .proto file.""" - - @staticmethod - def add_to_broadcast_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, - '/dunedaq.druncschema.BroadcastSender/add_to_broadcast_list', - druncschema_dot_request__response__pb2.Request.SerializeToString, - druncschema_dot_request__response__pb2.Response.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def remove_from_broadcast_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, - '/dunedaq.druncschema.BroadcastSender/remove_from_broadcast_list', - druncschema_dot_request__response__pb2.Request.SerializeToString, - druncschema_dot_request__response__pb2.Response.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def get_broadcast_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, - '/dunedaq.druncschema.BroadcastSender/get_broadcast_list', - druncschema_dot_request__response__pb2.Request.SerializeToString, - druncschema_dot_request__response__pb2.Response.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) diff --git a/src/druncschema/description_pb2.py b/src/druncschema/description_pb2.py index bad9faa..553831e 100644 --- a/src/druncschema/description_pb2.py +++ b/src/druncschema/description_pb2.py @@ -24,18 +24,17 @@ from druncschema import request_response_pb2 as druncschema_dot_request__response__pb2 from druncschema import token_pb2 as druncschema_dot_token__pb2 -from google.protobuf import any_pb2 as google_dot_protobuf_dot_any__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1d\x64runcschema/description.proto\x12\x13\x64unedaq.druncschema\x1a\"druncschema/request_response.proto\x1a\x17\x64runcschema/token.proto\x1a\x19google/protobuf/any.proto\"X\n\x12\x43ommandDescription\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x11\n\tdata_type\x18\x02 \x03(\t\x12\x0c\n\x04help\x18\x03 \x01(\t\x12\x13\n\x0breturn_type\x18\x04 \x01(\t\"\xcc\x02\n\x0b\x44\x65scription\x12)\n\x05token\x18\x01 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12\x0c\n\x04type\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12\x10\n\x08\x65ndpoint\x18\x04 \x01(\t\x12\x11\n\x04info\x18\x05 \x01(\tH\x00\x88\x01\x01\x12\x14\n\x07session\x18\x06 \x01(\tH\x01\x88\x01\x01\x12\x39\n\x08\x63ommands\x18\x07 \x03(\x0b\x32\'.dunedaq.druncschema.CommandDescription\x12,\n\tbroadcast\x18\x08 \x01(\x0b\x32\x14.google.protobuf.AnyH\x02\x88\x01\x01\x12/\n\x04\x66lag\x18\t \x01(\x0e\x32!.dunedaq.druncschema.ResponseFlagB\x07\n\x05_infoB\n\n\x08_sessionB\x0c\n\n_broadcastb\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1d\x64runcschema/description.proto\x12\x13\x64unedaq.druncschema\x1a\"druncschema/request_response.proto\x1a\x17\x64runcschema/token.proto\"X\n\x12\x43ommandDescription\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x11\n\tdata_type\x18\x02 \x03(\t\x12\x0c\n\x04help\x18\x03 \x01(\t\x12\x13\n\x0breturn_type\x18\x04 \x01(\t\"\x90\x02\n\x0b\x44\x65scription\x12)\n\x05token\x18\x01 \x01(\x0b\x32\x1a.dunedaq.druncschema.Token\x12\x0c\n\x04type\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12\x10\n\x08\x65ndpoint\x18\x04 \x01(\t\x12\x11\n\x04info\x18\x05 \x01(\tH\x00\x88\x01\x01\x12\x14\n\x07session\x18\x06 \x01(\tH\x01\x88\x01\x01\x12\x39\n\x08\x63ommands\x18\x07 \x03(\x0b\x32\'.dunedaq.druncschema.CommandDescription\x12/\n\x04\x66lag\x18\x08 \x01(\x0e\x32!.dunedaq.druncschema.ResponseFlagB\x07\n\x05_infoB\n\n\x08_sessionb\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'druncschema.description_pb2', _globals) if not _descriptor._USE_C_DESCRIPTORS: DESCRIPTOR._loaded_options = None - _globals['_COMMANDDESCRIPTION']._serialized_start=142 - _globals['_COMMANDDESCRIPTION']._serialized_end=230 - _globals['_DESCRIPTION']._serialized_start=233 - _globals['_DESCRIPTION']._serialized_end=565 + _globals['_COMMANDDESCRIPTION']._serialized_start=115 + _globals['_COMMANDDESCRIPTION']._serialized_end=203 + _globals['_DESCRIPTION']._serialized_start=206 + _globals['_DESCRIPTION']._serialized_end=478 # @@protoc_insertion_point(module_scope) diff --git a/src/druncschema/description_pb2.pyi b/src/druncschema/description_pb2.pyi index 189a332..acf4896 100644 --- a/src/druncschema/description_pb2.pyi +++ b/src/druncschema/description_pb2.pyi @@ -6,7 +6,6 @@ isort:skip_file from collections import abc as _abc from druncschema import request_response_pb2 as _request_response_pb2 from druncschema import token_pb2 as _token_pb2 -from google.protobuf import any_pb2 as _any_pb2 from google.protobuf import descriptor as _descriptor from google.protobuf import message as _message from google.protobuf.internal import containers as _containers @@ -61,7 +60,6 @@ class Description(_message.Message): INFO_FIELD_NUMBER: _builtins.int SESSION_FIELD_NUMBER: _builtins.int COMMANDS_FIELD_NUMBER: _builtins.int - BROADCAST_FIELD_NUMBER: _builtins.int FLAG_FIELD_NUMBER: _builtins.int type: _builtins.str name: _builtins.str @@ -73,8 +71,6 @@ class Description(_message.Message): def token(self) -> _token_pb2.Token: ... @_builtins.property def commands(self) -> _containers.RepeatedCompositeFieldContainer[Global___CommandDescription]: ... - @_builtins.property - def broadcast(self) -> _any_pb2.Any: ... def __init__( self, *, @@ -85,22 +81,17 @@ class Description(_message.Message): info: _builtins.str | None = ..., session: _builtins.str | None = ..., commands: _abc.Iterable[Global___CommandDescription] | None = ..., - broadcast: _any_pb2.Any | None = ..., flag: _request_response_pb2.ResponseFlag.ValueType = ..., ) -> None: ... - _HasFieldArgType: _TypeAlias = _typing.Literal["_broadcast", b"_broadcast", "_info", b"_info", "_session", b"_session", "broadcast", b"broadcast", "info", b"info", "session", b"session", "token", b"token"] # noqa: Y015 + _HasFieldArgType: _TypeAlias = _typing.Literal["_info", b"_info", "_session", b"_session", "info", b"info", "session", b"session", "token", b"token"] # noqa: Y015 def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ... - _ClearFieldArgType: _TypeAlias = _typing.Literal["_broadcast", b"_broadcast", "_info", b"_info", "_session", b"_session", "broadcast", b"broadcast", "commands", b"commands", "endpoint", b"endpoint", "flag", b"flag", "info", b"info", "name", b"name", "session", b"session", "token", b"token", "type", b"type"] # noqa: Y015 + _ClearFieldArgType: _TypeAlias = _typing.Literal["_info", b"_info", "_session", b"_session", "commands", b"commands", "endpoint", b"endpoint", "flag", b"flag", "info", b"info", "name", b"name", "session", b"session", "token", b"token", "type", b"type"] # noqa: Y015 def ClearField(self, field_name: _ClearFieldArgType) -> None: ... - _WhichOneofReturnType__broadcast: _TypeAlias = _typing.Literal["broadcast"] # noqa: Y015 - _WhichOneofArgType__broadcast: _TypeAlias = _typing.Literal["_broadcast", b"_broadcast"] # noqa: Y015 _WhichOneofReturnType__info: _TypeAlias = _typing.Literal["info"] # noqa: Y015 _WhichOneofArgType__info: _TypeAlias = _typing.Literal["_info", b"_info"] # noqa: Y015 _WhichOneofReturnType__session: _TypeAlias = _typing.Literal["session"] # noqa: Y015 _WhichOneofArgType__session: _TypeAlias = _typing.Literal["_session", b"_session"] # noqa: Y015 @_typing.overload - def WhichOneof(self, oneof_group: _WhichOneofArgType__broadcast) -> _WhichOneofReturnType__broadcast | None: ... - @_typing.overload def WhichOneof(self, oneof_group: _WhichOneofArgType__info) -> _WhichOneofReturnType__info | None: ... @_typing.overload def WhichOneof(self, oneof_group: _WhichOneofArgType__session) -> _WhichOneofReturnType__session | None: ...