:jxPdZddlmZddlmZmZmZmZmZm Z m Z m Z GddZ y)z Configuration Accessor This module provides accessor methods for accessing configuration objects. It offers type-safe configuration access. Key Features: - Type-safe configuration access - Accessor methods for common configurations )Optional)Config DisplayConfig GlobalConfigMonitoringConfigPipelineConfigRateLimitConfig TaskConfigWorkerManagerConfigc(eZdZdZdefdZdefdZdefdZ de fdZ de fdZ d edeefd Zdeefd Zd edeefd ZdeefdZdeefdZdeefdZdefdZdefdZdedefdZdedefdZdefdZde fdZ!defdZ"de#fdZ$y)ConfigAccessorz-Accessor for retrieving configuration objectsconfigc||_y)zgInitialize configuration accessor Args: config: Main configuration object N)r)selfrs 6/root/.openclaw/workspace/harvester/config/accessor.py__init__zConfigAccessor.__init__s  returnc.|jjS)ziGet global configuration Returns: GlobalConfig: Global configuration object )r global_configrs rget_global_configz ConfigAccessor.get_global_config's {{(((rc.|jjS)zoGet pipeline configuration Returns: PipelineConfig: Pipeline configuration object )rpipeliners rget_pipeline_configz"ConfigAccessor.get_pipeline_config/s {{###rc.|jjS)z|Get system monitoring configuration Returns: MonitoringConfig: Monitoring configuration object )r monitoringrs rget_monitoring_configz$ConfigAccessor.get_monitoring_config7s {{%%%rc.|jjS)zlGet display configuration Returns: DisplayConfig: Display configuration object )rdisplayrs rget_display_configz!ConfigAccessor.get_display_config?s {{"""r task_namec`|jjD]}|j|k(s|cSy)zGet task configuration by name Args: task_name: Name of the task Returns: Optional[TaskConfig]: Task configuration or None if not found N)rtasksname)rr#tasks rget_task_configzConfigAccessor.get_task_configGs3KK%% DyyI%  rcn|jjDcgc]}|js|c}Scc}w)zGet all enabled task configurations Returns: list[TaskConfig]: List of enabled task configurations )rr%enabled)rr's rget_enabled_tasksz ConfigAccessor.get_enabled_tasksUs( "&!2!2CdllCCCs22r&cL|jjj|S)zGet rate limit configuration by name Args: name: Name of the rate limit configuration Returns: Optional[RateLimitConfig]: Rate limit configuration or None if not found )r ratelimitsget)rr&s rget_rate_limit_configz$ConfigAccessor.get_rate_limit_config]s{{%%))$//rcV|jjjjS)ziGet GitHub session tokens Returns: list[str]: List of GitHub session tokens )rrgithub_credentialssessionsrs rget_github_sessionsz"ConfigAccessor.get_github_sessionshs {{((;;DDDrcV|jjjjS)zaGet GitHub API tokens Returns: list[str]: List of GitHub API tokens )rrr1tokensrs rget_github_tokensz ConfigAccessor.get_github_tokensps {{((;;BBBrcB|jjjS)zcGet user agent strings Returns: list[str]: List of user agent strings )rr user_agentsrs rget_user_agentszConfigAccessor.get_user_agentsxs {{((444rcj|jjjjjS)zrGet load balance strategy for GitHub credentials Returns: str: Load balance strategy )rrr1strategyvaluers rget_load_balance_strategyz(ConfigAccessor.get_load_balance_strategys& {{((;;DDJJJrcB|jjjS)zaGet workspace directory path Returns: str: Workspace directory path )rr workspacers rget_workspace_dirz ConfigAccessor.get_workspace_dirs {{((222rstagecb|jjjj|dS)zGet thread count for a pipeline stage Args: stage: Pipeline stage name Returns: int: Thread count for the stage r)rrthreadsr.rrAs rget_thread_countzConfigAccessor.get_thread_counts'{{##++//q99rcb|jjjj|dS)zGet queue size for a pipeline stage Args: stage: Pipeline stage name Returns: int: Queue size for the stage i)rr queue_sizesr.rDs rget_queue_sizezConfigAccessor.get_queue_sizes'{{##//33E4@@rc|jjj}|j|j|j |j dS)zjGet monitoring thresholds as dictionary Returns: dict: Monitoring thresholds ) error_rate queue_size memory_usage response_time)rr thresholdsrJrKrLrM)rrNs rget_monitoring_thresholdsz(ConfigAccessor.get_monitoring_thresholdssG [[++66 $//$//&33'55   rcB|jjjS)zyCheck if statistics display is enabled Returns: bool: True if statistics display is enabled )rr show_statsrs ris_stats_enabledzConfigAccessor.is_stats_enableds {{%%000rcB|jjjS)zrGet statistics display interval Returns: int: Statistics display interval in seconds )rrstats_intervalrs rget_stats_intervalz!ConfigAccessor.get_stats_intervals {{%%444rc.|jjS)zGet worker manager configuration Returns: WorkerManagerConfig: Worker manager configuration object )rworkerrs rget_worker_manager_configz(ConfigAccessor.get_worker_manager_configs {{!!!rN)%__name__ __module__ __qualname____doc__rrrrr rrrrr"strrr r(listr+r r/r3r6r9r=r@intrErHdictrOboolrRrUr rXrrrrs-7v)<)$^$&'7&#M#  *1E D4 #3D 0# 0(?2K 0ET#YEC49C5c5K3K333 :c :c : AC AC A  4  1$15C5"+>"rrN) r\typingrschemasrrrrr r r r rrbrrres*    n"n"r