Skip to content

Commit

Permalink
schemagen: add double quotes around shell vars
Browse files Browse the repository at this point in the history
Signed-off-by: Jean-Louis Leroy <[email protected]>
  • Loading branch information
jll63 committed Dec 27, 2024
1 parent 8ef7afd commit 36a7238
Show file tree
Hide file tree
Showing 2 changed files with 85 additions and 1 deletion.
34 changes: 34 additions & 0 deletions src/python/blazingmq/dev/it/tweaks/generated.py
Original file line number Diff line number Diff line change
Expand Up @@ -165,6 +165,34 @@ def __call__(

syslog = Syslog()

class LogDump(metaclass=TweakMetaclass):
class RecordBufferSize(metaclass=TweakMetaclass):

def __call__(self, value: int) -> Callable: ...

record_buffer_size = RecordBufferSize()

class RecordingLevel(metaclass=TweakMetaclass):

def __call__(self, value: str) -> Callable: ...

recording_level = RecordingLevel()

class TriggerLevel(metaclass=TweakMetaclass):

def __call__(self, value: str) -> Callable: ...

trigger_level = TriggerLevel()

def __call__(
self,
value: typing.Union[
blazingmq.schemas.mqbcfg.LogDumpConfig, NoneType
],
) -> Callable: ...

log_dump = LogDump()

def __call__(
self,
value: typing.Union[
Expand Down Expand Up @@ -769,6 +797,12 @@ def __call__(self, value: bool) -> Callable: ...

advertise_subscriptions = AdvertiseSubscriptions()

class RouteCommandTimeoutMs(metaclass=TweakMetaclass):

def __call__(self, value: int) -> Callable: ...

route_command_timeout_ms = RouteCommandTimeoutMs()

def __call__(
self, value: typing.Union[blazingmq.schemas.mqbcfg.AppConfig, NoneType]
) -> Callable: ...
Expand Down
52 changes: 51 additions & 1 deletion src/python/blazingmq/schemas/mqbcfg.py
Original file line number Diff line number Diff line change
Expand Up @@ -397,6 +397,37 @@ class Heartbeat:
)


@dataclass
class LogDumpConfig:
record_buffer_size: int = field(
default=32768,
metadata={
"name": "recordBufferSize",
"type": "Element",
"namespace": "http://bloomberg.com/schemas/mqbcfg",
"required": True,
},
)
recording_level: str = field(
default="OFF",
metadata={
"name": "recordingLevel",
"type": "Element",
"namespace": "http://bloomberg.com/schemas/mqbcfg",
"required": True,
},
)
trigger_level: str = field(
default="OFF",
metadata={
"name": "triggerLevel",
"type": "Element",
"namespace": "http://bloomberg.com/schemas/mqbcfg",
"required": True,
},
)


class MasterAssignmentAlgorithm(Enum):
"""Enumeration of the various algorithm's used for assigning a master to.
Expand Down Expand Up @@ -1157,6 +1188,15 @@ class LogController:
"required": True,
},
)
log_dump: Optional[LogDumpConfig] = field(
default=None,
metadata={
"name": "logDump",
"type": "Element",
"namespace": "http://bloomberg.com/schemas/mqbcfg",
"required": True,
},
)


@dataclass
Expand Down Expand Up @@ -1855,7 +1895,8 @@ class AppConfig:
plugins..............: configuration for the plugins
msgPropertiesSupport.: information about if/how to advertise support for v2 message properties
configureStream......: send new ConfigureStream instead of old ConfigureQueue
advertiseSubscriptions.: temporarily control use of ConfigureStream in SDK/&gt;
advertiseSubscriptions.: temporarily control use of ConfigureStream in SDK
routeCommandTimeoutMs: maximum amount of time to wait for a routed command's response
"""

broker_instance_name: Optional[str] = field(
Expand Down Expand Up @@ -2018,6 +2059,15 @@ class AppConfig:
"required": True,
},
)
route_command_timeout_ms: int = field(
default=3000,
metadata={
"name": "routeCommandTimeoutMs",
"type": "Element",
"namespace": "http://bloomberg.com/schemas/mqbcfg",
"required": True,
},
)


@dataclass
Expand Down

0 comments on commit 36a7238

Please sign in to comment.