Add logging endpoint

schema/druncschema/generic.proto

@@ -2,6 +2,14 @@ syntax = "proto3";
 
 package dunedaq.druncschema;
 
+
+enum OutcomeFlag {
+  SUCCESS = 0;
+  FAIL = 1;
+  UNKNOWN = 2;
+}
+
+
 message Empty { }
 
 message PlainText {
@@ -30,4 +38,8 @@ message string_msg{
 }
 message bool_msg{
   bool value=1;
+}
+
+message OutcomeStatus{
+  OutcomeFlag flag=1;
 }

schema/druncschema/process_manager.proto

@@ -5,8 +5,10 @@ package dunedaq.druncschema.process_manager;
 import "druncschema/request_response.proto";
 import "druncschema/description.proto";
 import "druncschema/token.proto";
+import "druncschema/generic.proto";
 
 service ProcessManager {
+  rpc send_msg  (Request) returns (OutcomeStatus) {}
   rpc describe  (Request) returns (Description) {}
   rpc boot      (BootRequest) returns (ProcessInstanceList) {}
   rpc terminate (Request) returns (ProcessInstanceList) {}

src/druncschema/authoriser_pb2.pyi

@@ -11,10 +11,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -84,5 +84,6 @@ class AuthoriserRequest(_message.Message):
     def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
     _ClearFieldArgType: _TypeAlias = _typing.Literal["action", b"action", "system", b"system", "token", b"token"]  # noqa: Y015
     def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
 
 Global___AuthoriserRequest: _TypeAlias = AuthoriserRequest  # noqa: Y015

src/druncschema/broadcast_pb2.pyi

@@ -11,10 +11,10 @@ import builtins as _builtins
 import sys
 import typing as _typing
 
-if sys.version_info >= (3, 10):
-    from typing import TypeAlias as _TypeAlias
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
 else:
-    from typing_extensions import TypeAlias as _TypeAlias
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -79,8 +79,11 @@ class KafkaBroadcastHandlerConfiguration(_message.Message):
         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
 
@@ -98,8 +101,11 @@ class Emitter(_message.Message):
         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
 
@@ -126,6 +132,7 @@ class BroadcastMessage(_message.Message):
     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
 
@@ -140,8 +147,11 @@ class BroadcastRequest(_message.Message):
         *,
         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
 
@@ -156,7 +166,10 @@ class BroadcastResponse(_message.Message):
         *,
         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