Skip to content

Remaining dedicated grpc messages schemas #82

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
jamesturner246 wants to merge 6 commits into
base: develop
Choose a base branch
from
Open

Remaining dedicated grpc messages schemas #82

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
3c8fa5b
Dedicated grpc messages for take_control.
jamesturner246 Dec 5, 2025
a703fc1
Dedicated grpc messages for surrender_control.
jamesturner246 Dec 5, 2025
d1b85bc
Dedicated grpc messages for who_is_in_charge.
jamesturner246 Dec 5, 2025
c528c27
Dedicated grpc messages for to_error.
jamesturner246 Dec 5, 2025
a762b06
Don't need a text field for to_error response.
jamesturner246 Dec 5, 2025
d924b8e
Recompiling the schema
Jan 30, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
67 changes: 63 additions & 4 deletions schema/druncschema/controller.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,11 +18,11 @@ service Controller {
rpc exclude (ExcludeRequest) returns (ExcludeResponse) {}
rpc recompute_status (RecomputeStatusRequest) returns (RecomputeStatusResponse) {}

rpc take_control (Request) returns (Response) {}
rpc surrender_control (Request) returns (Response) {}
rpc who_is_in_charge (Request) returns (Response) {}
rpc take_control (TakeControlRequest) returns (TakeControlResponse) {}
rpc surrender_control (SurrenderControlRequest) returns (SurrenderControlResponse) {}
rpc who_is_in_charge (WhoIsInChargeRequest) returns (WhoIsInChargeResponse) {}

rpc to_error (Request) returns (Response) {}
rpc to_error (ToErrorRequest) returns (ToErrorResponse) {}
}

message AddressedCommand {
Expand Down Expand Up @@ -105,6 +105,65 @@ message ExcludeResponse {
ResponseFlag flag = 5;
}

message TakeControlRequest {
Token token = 1;
string target = 2;
bool execute_along_path = 3;
bool execute_on_all_subsequent_children_in_path = 4;
}

message TakeControlResponse {
Token token = 1;
string name = 2;
string text = 3;
repeated TakeControlResponse children = 4;
ResponseFlag flag = 5;
}

message SurrenderControlRequest {
Token token = 1;
string target = 2;
bool execute_along_path = 3;
bool execute_on_all_subsequent_children_in_path = 4;
}

message SurrenderControlResponse {
Token token = 1;
string name = 2;
string text = 3;
repeated SurrenderControlResponse children = 4;
ResponseFlag flag = 5;
}

message WhoIsInChargeRequest {
Token token = 1;
string target = 2;
bool execute_along_path = 3;
bool execute_on_all_subsequent_children_in_path = 4;
}

message WhoIsInChargeResponse {
Token token = 1;
string name = 2;
string text = 3;
repeated WhoIsInChargeResponse children = 4;
ResponseFlag flag = 5;
}

message ToErrorRequest {
Token token = 1;
string target = 2;
bool execute_along_path = 3;
bool execute_on_all_subsequent_children_in_path = 4;
}

message ToErrorResponse {
Token token = 1;
string name = 2;
repeated ToErrorResponse children = 3;
ResponseFlag flag = 4;
}

message StatusRequest {
Token token = 1;
string target = 2;
Expand Down
72 changes: 37 additions & 35 deletions src/druncschema/authoriser_pb2.pyi
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,27 +3,27 @@
isort:skip_file
"""

import builtins
import druncschema.token_pb2
import google.protobuf.descriptor
import google.protobuf.internal.enum_type_wrapper
import google.protobuf.message
from druncschema import token_pb2 as _token_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
import typing as _typing

if sys.version_info >= (3, 10):
import typing as typing_extensions
from typing import TypeAlias as _TypeAlias
else:
import typing_extensions
from typing_extensions import TypeAlias as _TypeAlias

DESCRIPTOR: google.protobuf.descriptor.FileDescriptor
DESCRIPTOR: _descriptor.FileDescriptor

class _ActionType:
ValueType = typing.NewType("ValueType", builtins.int)
V: typing_extensions.TypeAlias = ValueType
ValueType = _typing.NewType("ValueType", _builtins.int)
V: _TypeAlias = ValueType # noqa: Y015

class _ActionTypeEnumTypeWrapper(google.protobuf.internal.enum_type_wrapper._EnumTypeWrapper[_ActionType.ValueType], builtins.type):
DESCRIPTOR: google.protobuf.descriptor.EnumDescriptor
class _ActionTypeEnumTypeWrapper(_enum_type_wrapper._EnumTypeWrapper[_ActionType.ValueType], _builtins.type):
DESCRIPTOR: _descriptor.EnumDescriptor
CREATE: _ActionType.ValueType # 0
READ: _ActionType.ValueType # 1
UPDATE: _ActionType.ValueType # 2
Expand All @@ -37,14 +37,14 @@ READ: ActionType.ValueType # 1
UPDATE: ActionType.ValueType # 2
DELETE: ActionType.ValueType # 3
EXPERT: ActionType.ValueType # 4
global___ActionType = ActionType
Global___ActionType: _TypeAlias = ActionType # noqa: Y015

class _SystemType:
ValueType = typing.NewType("ValueType", builtins.int)
V: typing_extensions.TypeAlias = ValueType
ValueType = _typing.NewType("ValueType", _builtins.int)
V: _TypeAlias = ValueType # noqa: Y015

class _SystemTypeEnumTypeWrapper(google.protobuf.internal.enum_type_wrapper._EnumTypeWrapper[_SystemType.ValueType], builtins.type):
DESCRIPTOR: google.protobuf.descriptor.EnumDescriptor
class _SystemTypeEnumTypeWrapper(_enum_type_wrapper._EnumTypeWrapper[_SystemType.ValueType], _builtins.type):
DESCRIPTOR: _descriptor.EnumDescriptor
CONTROLLER: _SystemType.ValueType # 0
APPLICATION: _SystemType.ValueType # 1
PROCESS_MANAGER: _SystemType.ValueType # 2
Expand All @@ -60,27 +60,29 @@ PROCESS_MANAGER: SystemType.ValueType # 2
SESSION_MANAGER: SystemType.ValueType # 3
RESOURCE_MANAGER: SystemType.ValueType # 4
AUTHORISER_SERVICE: SystemType.ValueType # 5
global___SystemType = SystemType
Global___SystemType: _TypeAlias = SystemType # noqa: Y015

@typing.final
class AuthoriserRequest(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor
@_typing.final
class AuthoriserRequest(_message.Message):
DESCRIPTOR: _descriptor.Descriptor

TOKEN_FIELD_NUMBER: builtins.int
ACTION_FIELD_NUMBER: builtins.int
SYSTEM_FIELD_NUMBER: builtins.int
action: global___ActionType.ValueType
system: global___SystemType.ValueType
@property
def token(self) -> druncschema.token_pb2.Token: ...
TOKEN_FIELD_NUMBER: _builtins.int
ACTION_FIELD_NUMBER: _builtins.int
SYSTEM_FIELD_NUMBER: _builtins.int
action: Global___ActionType.ValueType
system: Global___SystemType.ValueType
@_builtins.property
def token(self) -> _token_pb2.Token: ...
def __init__(
self,
*,
token: druncschema.token_pb2.Token | None = ...,
action: global___ActionType.ValueType = ...,
system: global___SystemType.ValueType = ...,
token: _token_pb2.Token | None = ...,
action: Global___ActionType.ValueType = ...,
system: Global___SystemType.ValueType = ...,
) -> None: ...
def HasField(self, field_name: typing.Literal["token", b"token"]) -> builtins.bool: ...
def ClearField(self, field_name: typing.Literal["action", b"action", "system", b"system", "token", b"token"]) -> None: ...
_HasFieldArgType: _TypeAlias = _typing.Literal["token", b"token"] # noqa: Y015
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: ...

global___AuthoriserRequest = AuthoriserRequest
Global___AuthoriserRequest: _TypeAlias = AuthoriserRequest # noqa: Y015
150 changes: 78 additions & 72 deletions src/druncschema/broadcast_pb2.pyi
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,27 +3,27 @@
isort:skip_file
"""

import builtins
import google.protobuf.any_pb2
import google.protobuf.descriptor
import google.protobuf.internal.enum_type_wrapper
import google.protobuf.message
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
import typing as _typing

if sys.version_info >= (3, 10):
import typing as typing_extensions
from typing import TypeAlias as _TypeAlias
else:
import typing_extensions
from typing_extensions import TypeAlias as _TypeAlias

DESCRIPTOR: google.protobuf.descriptor.FileDescriptor
DESCRIPTOR: _descriptor.FileDescriptor

class _BroadcastType:
ValueType = typing.NewType("ValueType", builtins.int)
V: typing_extensions.TypeAlias = ValueType
ValueType = _typing.NewType("ValueType", _builtins.int)
V: _TypeAlias = ValueType # noqa: Y015

class _BroadcastTypeEnumTypeWrapper(google.protobuf.internal.enum_type_wrapper._EnumTypeWrapper[_BroadcastType.ValueType], builtins.type):
DESCRIPTOR: google.protobuf.descriptor.EnumDescriptor
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
Expand Down Expand Up @@ -63,94 +63,100 @@ 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 = BroadcastType
Global___BroadcastType: _TypeAlias = BroadcastType # noqa: Y015

@typing.final
class KafkaBroadcastHandlerConfiguration(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor
@_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
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 = ...,
kafka_address: _builtins.str = ...,
topic: _builtins.str = ...,
) -> None: ...
def ClearField(self, field_name: typing.Literal["kafka_address", b"kafka_address", "topic", b"topic"]) -> None: ...
_ClearFieldArgType: _TypeAlias = _typing.Literal["kafka_address", b"kafka_address", "topic", b"topic"] # noqa: Y015
def ClearField(self, field_name: _ClearFieldArgType) -> None: ...

global___KafkaBroadcastHandlerConfiguration = KafkaBroadcastHandlerConfiguration
Global___KafkaBroadcastHandlerConfiguration: _TypeAlias = KafkaBroadcastHandlerConfiguration # noqa: Y015

@typing.final
class Emitter(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor
@_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
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 = ...,
process: _builtins.str = ...,
session: _builtins.str = ...,
) -> None: ...
def ClearField(self, field_name: typing.Literal["process", b"process", "session", b"session"]) -> None: ...

global___Emitter = Emitter

@typing.final
class BroadcastMessage(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor

EMITTER_FIELD_NUMBER: builtins.int
TYPE_FIELD_NUMBER: builtins.int
DATA_FIELD_NUMBER: builtins.int
type: global___BroadcastType.ValueType
@property
def emitter(self) -> global___Emitter: ...
@property
def data(self) -> google.protobuf.any_pb2.Any: ...
_ClearFieldArgType: _TypeAlias = _typing.Literal["process", b"process", "session", b"session"] # noqa: Y015
def ClearField(self, field_name: _ClearFieldArgType) -> 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: google.protobuf.any_pb2.Any | None = ...,
emitter: Global___Emitter | None = ...,
type: Global___BroadcastType.ValueType = ...,
data: _any_pb2.Any | None = ...,
) -> None: ...
def HasField(self, field_name: typing.Literal["data", b"data", "emitter", b"emitter"]) -> builtins.bool: ...
def ClearField(self, field_name: typing.Literal["data", b"data", "emitter", b"emitter", "type", b"type"]) -> 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: ...

global___BroadcastMessage = BroadcastMessage
Global___BroadcastMessage: _TypeAlias = BroadcastMessage # noqa: Y015

@typing.final
class BroadcastRequest(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor
@_typing.final
class BroadcastRequest(_message.Message):
DESCRIPTOR: _descriptor.Descriptor

BROADCAST_RECEIVER_ADDRESS_FIELD_NUMBER: builtins.int
broadcast_receiver_address: builtins.str
BROADCAST_RECEIVER_ADDRESS_FIELD_NUMBER: _builtins.int
broadcast_receiver_address: _builtins.str
def __init__(
self,
*,
broadcast_receiver_address: builtins.str = ...,
broadcast_receiver_address: _builtins.str = ...,
) -> None: ...
def ClearField(self, field_name: typing.Literal["broadcast_receiver_address", b"broadcast_receiver_address"]) -> None: ...
_ClearFieldArgType: _TypeAlias = _typing.Literal["broadcast_receiver_address", b"broadcast_receiver_address"] # noqa: Y015
def ClearField(self, field_name: _ClearFieldArgType) -> None: ...

global___BroadcastRequest = BroadcastRequest
Global___BroadcastRequest: _TypeAlias = BroadcastRequest # noqa: Y015

@typing.final
class BroadcastResponse(google.protobuf.message.Message):
DESCRIPTOR: google.protobuf.descriptor.Descriptor
@_typing.final
class BroadcastResponse(_message.Message):
DESCRIPTOR: _descriptor.Descriptor

SUCCESS_FIELD_NUMBER: builtins.int
success: builtins.bool
SUCCESS_FIELD_NUMBER: _builtins.int
success: _builtins.bool
def __init__(
self,
*,
success: builtins.bool = ...,
success: _builtins.bool = ...,
) -> None: ...
def ClearField(self, field_name: typing.Literal["success", b"success"]) -> None: ...
_ClearFieldArgType: _TypeAlias = _typing.Literal["success", b"success"] # noqa: Y015
def ClearField(self, field_name: _ClearFieldArgType) -> None: ...

global___BroadcastResponse = BroadcastResponse
Global___BroadcastResponse: _TypeAlias = BroadcastResponse # noqa: Y015
Loading