
    +d                         d dl Z d dlZd dlZd dlZd dlZd dlZddlmZ  ej	        d          Z
d ZddZedk    r  ej         eej                             dS dS )	    N   )IntakeServerintakec                 .    t          j        d           d S )Nr   )sysexit)signalframes     :lib/python3.11/site-packages/intake/cli/server/__main__.pycall_exit_on_sigtermr      s    HQKKKKK    c           	      L   ddl m} ddlm} | t          j        } t          j        d          }|                    ddt          |d         d	
           |                    ddd           |                    ddd           |                    ddt          dd           |                    ddd           |                    ddd           |                    ddt          d           |                    dd t          |                    d!d"          d#
           |                    d$%           |                    | d&d                    }|j        r$t          j        t          j        t"                     t$                              d'           |j        D ]}t$                              d(|z              |j        }|j        }t-          |          d&k    r7 ||d         |)          }t$                              d*|d         z             n0 |||j        |+          }t$                              d*|z             |j        r=t$                              d,d-                    t5          |                    z              t$                              d.|j        |j        fz             t;          |          }	|	                                }
|	                    d/0           |
                     |j        |j        1           	 tB          j"        j#        $                                %                                 d S # tL          $ r t$          '                    d2           Y d S tP          $ r(}t$          '                    d3|z             Y d }~d S d }~ww xY w)4Nr   )open_catalog)confzIntake Catalog Server)descriptionz-pz--portportz#port number for server to listen on)typedefaulthelpz--list-entries
store_truezlist catalog entries at startup)actionr   z--sys-exit-on-sigtermzJinternal flag used during unit testing to ensure .coverage file is writtencatalog_argsFILE+zName of catalog YAML file)metavarr   nargsr   z	--flattenflatten)destr   z--no-flattenstore_falsez--ttlttl<   )r   r   r   z-az	--addressaddress	localhostzladdress to use as a host, defaults to the address in the configuration file, if provided otherwise localhostT)r   r   zCreating catalog from:z  - %s)r    zcatalog_args: %s)r   r    zEntries:,zListening on %s:%dg      @)close_idle_after)r"   ExitingzExiting due to %s))r   r   intake.configr   r   argvargparseArgumentParseradd_argumentintstrgetset_defaults
parse_argssys_exit_on_sigtermr	   SIGTERMr   loggerinfor   r    lenr   list_entriesjoinlistr"   r   r   make_appstart_periodic_functionslistentornadoioloopIOLoopcurrentstartKeyboardInterruptcritical	Exception)r(   r   r   parserargsargcatargsr    catalogserverappes               r   mainrL      s   ######"""""" x$1HIIIF
hS$v,Mrsss
(Defff
/  L[  \  \  \
SRmnnn
)LIII
Y}MMM
e#rBBB
K00~     %%%T!""X&&D <fn&:;;;
KK()))  $ $HsN####G
(C
7||q 2,wqzs333&34444,w#FFF&0111 :J$w--!8!88999
KK$di'@@AAA'""F
//

C
##V#<<<JJty$,J///1%%''--///// # # #	"""""" 1 1 1+a/0000000001s   5M $N#2	N#;NN#__main__)N)r)   loggingr	   r   tornado.ioloopr<   tornado.webrI   r   	getLoggerr3   r   rL   __name__r   r(    r   r   <module>rT      s       



                    		8	$	$  91 91 91 91x z CHTT#(^^ r   