From e74e86276e8e059de27f1c26a08f5e503504a501 Mon Sep 17 00:00:00 2001 From: Yuan Jing Vincent Yan Date: Mon, 29 Jul 2024 16:24:51 -0400 Subject: [PATCH] mqbconf, mqbcfg: Generated Python code Signed-off-by: Yuan Jing Vincent Yan --- .../blazingmq/dev/it/tweaks/generated.py | 175 +++++++++++++++++- src/python/blazingmq/schemas/mqbcfg.py | 9 - src/python/blazingmq/schemas/mqbconf.py | 13 +- 3 files changed, 181 insertions(+), 16 deletions(-) diff --git a/src/python/blazingmq/dev/it/tweaks/generated.py b/src/python/blazingmq/dev/it/tweaks/generated.py index c39c3dcf7c..7f635a0426 100644 --- a/src/python/blazingmq/dev/it/tweaks/generated.py +++ b/src/python/blazingmq/dev/it/tweaks/generated.py @@ -40,6 +40,7 @@ def __call__(self, tweak: Callable) -> Callable: class Broker: class TaskConfig(metaclass=TweakMetaclass): class AllocatorType(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[ @@ -50,12 +51,14 @@ def __call__( allocator_type = AllocatorType() class AllocationLimit(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... allocation_limit = AllocationLimit() class LogController(metaclass=TweakMetaclass): class FileName(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -63,6 +66,7 @@ def __call__( file_name = FileName() class FileMaxAgeDays(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -70,6 +74,7 @@ def __call__( file_max_age_days = FileMaxAgeDays() class RotationBytes(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -77,6 +82,7 @@ def __call__( rotation_bytes = RotationBytes() class LogfileFormat(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -84,6 +90,7 @@ def __call__( logfile_format = LogfileFormat() class ConsoleFormat(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -91,6 +98,7 @@ def __call__( console_format = ConsoleFormat() class LoggingVerbosity(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -98,11 +106,13 @@ def __call__( logging_verbosity = LoggingVerbosity() class BslsLogSeverityThreshold(metaclass=TweakMetaclass): + def __call__(self, value: str) -> Callable: ... bsls_log_severity_threshold = BslsLogSeverityThreshold() class ConsoleSeverityThreshold(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -110,17 +120,20 @@ def __call__( console_severity_threshold = ConsoleSeverityThreshold() class Categories(metaclass=TweakMetaclass): + def __call__(self, value: None) -> Callable: ... categories = Categories() class Syslog(metaclass=TweakMetaclass): class Enabled(metaclass=TweakMetaclass): + def __call__(self, value: bool) -> Callable: ... enabled = Enabled() class AppName(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -128,6 +141,7 @@ def __call__( app_name = AppName() class LogFormat(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -135,6 +149,7 @@ def __call__( log_format = LogFormat() class Verbosity(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -167,51 +182,61 @@ def __call__( class AppConfig(metaclass=TweakMetaclass): class BrokerInstanceName(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... broker_instance_name = BrokerInstanceName() class BrokerVersion(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... broker_version = BrokerVersion() class ConfigVersion(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... config_version = ConfigVersion() class EtcDir(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... etc_dir = EtcDir() class HostName(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... host_name = HostName() class HostTags(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... host_tags = HostTags() class HostDataCenter(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... host_data_center = HostDataCenter() class IsRunningOnDev(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[bool, NoneType]) -> Callable: ... is_running_on_dev = IsRunningOnDev() class LogsObserverMaxSize(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... logs_observer_max_size = LogsObserverMaxSize() class LatencyMonitorDomain(metaclass=TweakMetaclass): + def __call__(self, value: str) -> Callable: ... latency_monitor_domain = LatencyMonitorDomain() @@ -219,6 +244,7 @@ def __call__(self, value: str) -> Callable: ... class DispatcherConfig(metaclass=TweakMetaclass): class Sessions(metaclass=TweakMetaclass): class NumProcessors(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -227,6 +253,7 @@ def __call__( class ProcessorConfig(metaclass=TweakMetaclass): class QueueSize(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -234,6 +261,7 @@ def __call__( queue_size = QueueSize() class QueueSizeLowWatermark(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -241,6 +269,7 @@ def __call__( queue_size_low_watermark = QueueSizeLowWatermark() class QueueSizeHighWatermark(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -268,6 +297,7 @@ def __call__( class Queues(metaclass=TweakMetaclass): class NumProcessors(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -276,6 +306,7 @@ def __call__( class ProcessorConfig(metaclass=TweakMetaclass): class QueueSize(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -283,6 +314,7 @@ def __call__( queue_size = QueueSize() class QueueSizeLowWatermark(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -290,6 +322,7 @@ def __call__( queue_size_low_watermark = QueueSizeLowWatermark() class QueueSizeHighWatermark(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -317,6 +350,7 @@ def __call__( class Clusters(metaclass=TweakMetaclass): class NumProcessors(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -325,6 +359,7 @@ def __call__( class ProcessorConfig(metaclass=TweakMetaclass): class QueueSize(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -332,6 +367,7 @@ def __call__( queue_size = QueueSize() class QueueSizeLowWatermark(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -339,6 +375,7 @@ def __call__( queue_size_low_watermark = QueueSizeLowWatermark() class QueueSizeHighWatermark(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -375,59 +412,63 @@ def __call__( class Stats(metaclass=TweakMetaclass): class SnapshotInterval(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... snapshot_interval = SnapshotInterval() - class AppIdTagDomains(metaclass=TweakMetaclass): - - def __call__(self, value: None) -> Callable: ... - - app_id_tag_domains = AppIdTagDomains() - class Plugins(metaclass=TweakMetaclass): class Name(metaclass=TweakMetaclass): + def __call__(self, value: str) -> Callable: ... name = Name() class QueueSize(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... queue_size = QueueSize() class QueueHighWatermark(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... queue_high_watermark = QueueHighWatermark() class QueueLowWatermark(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... queue_low_watermark = QueueLowWatermark() class PublishInterval(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... publish_interval = PublishInterval() class NamespacePrefix(metaclass=TweakMetaclass): + def __call__(self, value: str) -> Callable: ... namespace_prefix = NamespacePrefix() class Hosts(metaclass=TweakMetaclass): + def __call__(self, value: None) -> Callable: ... hosts = Hosts() class InstanceId(metaclass=TweakMetaclass): + def __call__(self, value: str) -> Callable: ... instance_id = InstanceId() class PrometheusSpecific(metaclass=TweakMetaclass): class Mode(metaclass=TweakMetaclass): + def __call__( self, value: blazingmq.schemas.mqbcfg.ExportMode ) -> Callable: ... @@ -435,11 +476,13 @@ def __call__( mode = Mode() class Host(metaclass=TweakMetaclass): + def __call__(self, value: str) -> Callable: ... host = Host() class Port(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... port = Port() @@ -460,11 +503,13 @@ def __call__(self, value: None) -> Callable: ... class Printer(metaclass=TweakMetaclass): class PrintInterval(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... print_interval = PrintInterval() class File(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -472,6 +517,7 @@ def __call__( file = File() class MaxAgeDays(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -479,11 +525,13 @@ def __call__( max_age_days = MaxAgeDays() class RotateBytes(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... rotate_bytes = RotateBytes() class RotateDays(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... rotate_days = RotateDays() @@ -507,21 +555,25 @@ def __call__( class NetworkInterfaces(metaclass=TweakMetaclass): class Heartbeats(metaclass=TweakMetaclass): class Client(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... client = Client() class DownstreamBroker(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... downstream_broker = DownstreamBroker() class UpstreamBroker(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... upstream_broker = UpstreamBroker() class ClusterPeer(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... cluster_peer = ClusterPeer() @@ -537,6 +589,7 @@ def __call__( class TcpInterface(metaclass=TweakMetaclass): class Name(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -544,6 +597,7 @@ def __call__( name = Name() class Port(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -551,6 +605,7 @@ def __call__( port = Port() class IoThreads(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -558,11 +613,13 @@ def __call__( io_threads = IoThreads() class MaxConnections(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_connections = MaxConnections() class LowWatermark(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -570,6 +627,7 @@ def __call__( low_watermark = LowWatermark() class HighWatermark(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -577,16 +635,19 @@ def __call__( high_watermark = HighWatermark() class NodeLowWatermark(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... node_low_watermark = NodeLowWatermark() class NodeHighWatermark(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... node_high_watermark = NodeHighWatermark() class HeartbeatIntervalMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... heartbeat_interval_ms = HeartbeatIntervalMs() @@ -611,6 +672,7 @@ def __call__( class BmqconfConfig(metaclass=TweakMetaclass): class CacheTtlseconds(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -628,11 +690,13 @@ def __call__( class Plugins(metaclass=TweakMetaclass): class Libraries(metaclass=TweakMetaclass): + def __call__(self, value: None) -> Callable: ... libraries = Libraries() class Enabled(metaclass=TweakMetaclass): + def __call__(self, value: None) -> Callable: ... enabled = Enabled() @@ -646,16 +710,19 @@ def __call__( class MessagePropertiesV2(metaclass=TweakMetaclass): class AdvertiseV2Support(metaclass=TweakMetaclass): + def __call__(self, value: bool) -> Callable: ... advertise_v2_support = AdvertiseV2Support() class MinCppSdkVersion(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... min_cpp_sdk_version = MinCppSdkVersion() class MinJavaSdkVersion(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... min_java_sdk_version = MinJavaSdkVersion() @@ -670,6 +737,7 @@ def __call__( message_properties_v2 = MessagePropertiesV2() class ConfigureStream(metaclass=TweakMetaclass): + def __call__(self, value: bool) -> Callable: ... configure_stream = ConfigureStream() @@ -688,6 +756,7 @@ def __call__( class Domain: class Name(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... name = Name() @@ -695,10 +764,17 @@ def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... class Mode(metaclass=TweakMetaclass): class Fanout(metaclass=TweakMetaclass): class AppIds(metaclass=TweakMetaclass): + def __call__(self, value: None) -> Callable: ... app_ids = AppIds() + class PublishAppIdMetrics(metaclass=TweakMetaclass): + + def __call__(self, value: bool) -> Callable: ... + + publish_app_id_metrics = PublishAppIdMetrics() + def __call__( self, value: typing.Union[ @@ -709,6 +785,7 @@ def __call__( fanout = Fanout() class Priority(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[ @@ -719,6 +796,7 @@ def __call__( priority = Priority() class Broadcast(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[ @@ -737,6 +815,7 @@ def __call__( class Storage(metaclass=TweakMetaclass): class DomainLimits(metaclass=TweakMetaclass): class Messages(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -744,11 +823,13 @@ def __call__( messages = Messages() class MessagesWatermarkRatio(metaclass=TweakMetaclass): + def __call__(self, value: decimal.Decimal) -> Callable: ... messages_watermark_ratio = MessagesWatermarkRatio() class Bytes(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -756,6 +837,7 @@ def __call__( bytes = Bytes() class BytesWatermarkRatio(metaclass=TweakMetaclass): + def __call__(self, value: decimal.Decimal) -> Callable: ... bytes_watermark_ratio = BytesWatermarkRatio() @@ -769,6 +851,7 @@ def __call__( class QueueLimits(metaclass=TweakMetaclass): class Messages(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -776,11 +859,13 @@ def __call__( messages = Messages() class MessagesWatermarkRatio(metaclass=TweakMetaclass): + def __call__(self, value: decimal.Decimal) -> Callable: ... messages_watermark_ratio = MessagesWatermarkRatio() class Bytes(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[int, NoneType] ) -> Callable: ... @@ -788,6 +873,7 @@ def __call__( bytes = Bytes() class BytesWatermarkRatio(metaclass=TweakMetaclass): + def __call__(self, value: decimal.Decimal) -> Callable: ... bytes_watermark_ratio = BytesWatermarkRatio() @@ -801,6 +887,7 @@ def __call__( class Config(metaclass=TweakMetaclass): class InMemory(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[ @@ -811,6 +898,7 @@ def __call__( in_memory = InMemory() class FileBacked(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[ @@ -837,32 +925,38 @@ def __call__( storage = Storage() class MaxConsumers(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_consumers = MaxConsumers() class MaxProducers(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_producers = MaxProducers() class MaxQueues(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_queues = MaxQueues() class MsgGroupIdConfig(metaclass=TweakMetaclass): class Rebalance(metaclass=TweakMetaclass): + def __call__(self, value: bool) -> Callable: ... rebalance = Rebalance() class MaxGroups(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_groups = MaxGroups() class TtlSeconds(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... ttl_seconds = TtlSeconds() @@ -877,27 +971,32 @@ def __call__( msg_group_id_config = MsgGroupIdConfig() class MaxIdleTime(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_idle_time = MaxIdleTime() class MessageTtl(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... message_ttl = MessageTtl() class MaxDeliveryAttempts(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_delivery_attempts = MaxDeliveryAttempts() class DeduplicationTimeMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... deduplication_time_ms = DeduplicationTimeMs() class Consistency(metaclass=TweakMetaclass): class Eventual(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[ @@ -908,6 +1007,7 @@ def __call__( eventual = Eventual() class Strong(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[ @@ -926,12 +1026,14 @@ def __call__( class Subscriptions(metaclass=TweakMetaclass): class AppId(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... app_id = AppId() class Expression(metaclass=TweakMetaclass): class Version(metaclass=TweakMetaclass): + def __call__( self, value: blazingmq.schemas.mqbconf.ExpressionVersion ) -> Callable: ... @@ -939,6 +1041,7 @@ def __call__( version = Version() class Text(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -958,22 +1061,26 @@ def __call__(self, value: None) -> Callable: ... class Cluster: class Name(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... name = Name() class Nodes(metaclass=TweakMetaclass): class Id(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... id = Id() class Name(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... name = Name() class DataCenter(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... data_center = DataCenter() @@ -981,6 +1088,7 @@ def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... class Transport(metaclass=TweakMetaclass): class Tcp(metaclass=TweakMetaclass): class Endpoint(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[str, NoneType] ) -> Callable: ... @@ -1011,97 +1119,116 @@ def __call__(self, value: None) -> Callable: ... class PartitionConfig(metaclass=TweakMetaclass): class NumPartitions(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... num_partitions = NumPartitions() class Location(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... location = Location() class ArchiveLocation(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[str, NoneType]) -> Callable: ... archive_location = ArchiveLocation() class MaxDataFileSize(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... max_data_file_size = MaxDataFileSize() class MaxJournalFileSize(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... max_journal_file_size = MaxJournalFileSize() class MaxQlistFileSize(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... max_qlist_file_size = MaxQlistFileSize() class Preallocate(metaclass=TweakMetaclass): + def __call__(self, value: bool) -> Callable: ... preallocate = Preallocate() class MaxArchivedFileSets(metaclass=TweakMetaclass): + def __call__(self, value: typing.Union[int, NoneType]) -> Callable: ... max_archived_file_sets = MaxArchivedFileSets() class PrefaultPages(metaclass=TweakMetaclass): + def __call__(self, value: bool) -> Callable: ... prefault_pages = PrefaultPages() class FlushAtShutdown(metaclass=TweakMetaclass): + def __call__(self, value: bool) -> Callable: ... flush_at_shutdown = FlushAtShutdown() class SyncConfig(metaclass=TweakMetaclass): class StartupRecoveryMaxDurationMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... startup_recovery_max_duration_ms = StartupRecoveryMaxDurationMs() class MaxAttemptsStorageSync(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_attempts_storage_sync = MaxAttemptsStorageSync() class StorageSyncReqTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... storage_sync_req_timeout_ms = StorageSyncReqTimeoutMs() class MasterSyncMaxDurationMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... master_sync_max_duration_ms = MasterSyncMaxDurationMs() class PartitionSyncStateReqTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... partition_sync_state_req_timeout_ms = PartitionSyncStateReqTimeoutMs() class PartitionSyncDataReqTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... partition_sync_data_req_timeout_ms = PartitionSyncDataReqTimeoutMs() class StartupWaitDurationMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... startup_wait_duration_ms = StartupWaitDurationMs() class FileChunkSize(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... file_chunk_size = FileChunkSize() class PartitionSyncEventSize(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... partition_sync_event_size = PartitionSyncEventSize() @@ -1123,6 +1250,7 @@ def __call__( partition_config = PartitionConfig() class MasterAssignment(metaclass=TweakMetaclass): + def __call__( self, value: typing.Union[ @@ -1134,46 +1262,55 @@ def __call__( class Elector(metaclass=TweakMetaclass): class InitialWaitTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... initial_wait_timeout_ms = InitialWaitTimeoutMs() class MaxRandomWaitTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_random_wait_timeout_ms = MaxRandomWaitTimeoutMs() class ScoutingResultTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... scouting_result_timeout_ms = ScoutingResultTimeoutMs() class ElectionResultTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... election_result_timeout_ms = ElectionResultTimeoutMs() class HeartbeatBroadcastPeriodMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... heartbeat_broadcast_period_ms = HeartbeatBroadcastPeriodMs() class HeartbeatCheckPeriodMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... heartbeat_check_period_ms = HeartbeatCheckPeriodMs() class HeartbeatMissCount(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... heartbeat_miss_count = HeartbeatMissCount() class Quorum(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... quorum = Quorum() class LeaderSyncDelayMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... leader_sync_delay_ms = LeaderSyncDelayMs() @@ -1187,61 +1324,73 @@ def __call__( class QueueOperations(metaclass=TweakMetaclass): class OpenTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... open_timeout_ms = OpenTimeoutMs() class ConfigureTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... configure_timeout_ms = ConfigureTimeoutMs() class CloseTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... close_timeout_ms = CloseTimeoutMs() class ReopenTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... reopen_timeout_ms = ReopenTimeoutMs() class ReopenRetryIntervalMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... reopen_retry_interval_ms = ReopenRetryIntervalMs() class ReopenMaxAttempts(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... reopen_max_attempts = ReopenMaxAttempts() class AssignmentTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... assignment_timeout_ms = AssignmentTimeoutMs() class KeepaliveDurationMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... keepalive_duration_ms = KeepaliveDurationMs() class ConsumptionMonitorPeriodMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... consumption_monitor_period_ms = ConsumptionMonitorPeriodMs() class StopTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... stop_timeout_ms = StopTimeoutMs() class ShutdownTimeoutMs(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... shutdown_timeout_ms = ShutdownTimeoutMs() class AckWindowSize(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... ack_window_size = AckWindowSize() @@ -1257,11 +1406,13 @@ def __call__( class ClusterAttributes(metaclass=TweakMetaclass): class IsCslmodeEnabled(metaclass=TweakMetaclass): + def __call__(self, value: bool) -> Callable: ... is_cslmode_enabled = IsCslmodeEnabled() class IsFsmworkflow(metaclass=TweakMetaclass): + def __call__(self, value: bool) -> Callable: ... is_fsmworkflow = IsFsmworkflow() @@ -1277,41 +1428,49 @@ def __call__( class ClusterMonitorConfig(metaclass=TweakMetaclass): class MaxTimeLeader(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_time_leader = MaxTimeLeader() class MaxTimeMaster(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_time_master = MaxTimeMaster() class MaxTimeNode(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_time_node = MaxTimeNode() class MaxTimeFailover(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... max_time_failover = MaxTimeFailover() class ThresholdLeader(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... threshold_leader = ThresholdLeader() class ThresholdMaster(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... threshold_master = ThresholdMaster() class ThresholdNode(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... threshold_node = ThresholdNode() class ThresholdFailover(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... threshold_failover = ThresholdFailover() @@ -1327,21 +1486,25 @@ def __call__( class MessageThrottleConfig(metaclass=TweakMetaclass): class LowThreshold(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... low_threshold = LowThreshold() class HighThreshold(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... high_threshold = HighThreshold() class LowInterval(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... low_interval = LowInterval() class HighInterval(metaclass=TweakMetaclass): + def __call__(self, value: int) -> Callable: ... high_interval = HighInterval() diff --git a/src/python/blazingmq/schemas/mqbcfg.py b/src/python/blazingmq/schemas/mqbcfg.py index c7b82076ea..35d9b2c415 100644 --- a/src/python/blazingmq/schemas/mqbcfg.py +++ b/src/python/blazingmq/schemas/mqbcfg.py @@ -1773,15 +1773,6 @@ class StatsConfig: "required": True, }, ) - app_id_tag_domains: List[str] = field( - default_factory=list, - metadata={ - "name": "appIdTagDomains", - "type": "Element", - "namespace": "http://bloomberg.com/schemas/mqbcfg", - "min_occurs": 1, - }, - ) plugins: List[StatPluginConfig] = field( default_factory=list, metadata={ diff --git a/src/python/blazingmq/schemas/mqbconf.py b/src/python/blazingmq/schemas/mqbconf.py index 70d1141183..b16a744d00 100644 --- a/src/python/blazingmq/schemas/mqbconf.py +++ b/src/python/blazingmq/schemas/mqbconf.py @@ -284,7 +284,9 @@ class QueueModeBroadcast: class QueueModeFanout: """Configuration for a fanout queue. - appIDs.: List of appIDs authorized to consume from the queue. + appIDs.............: List of appIDs authorized to consume from the + queue. + publishAppIdMetrics: Whether to publish appId metrics. """ app_ids: List[str] = field( @@ -296,6 +298,15 @@ class QueueModeFanout: "min_occurs": 1, }, ) + publish_app_id_metrics: bool = field( + default=False, + metadata={ + "name": "publishAppIdMetrics", + "type": "Element", + "namespace": "urn:x-bloomberg-com:mqbconfm", + "required": True, + }, + ) @dataclass