File: //proc/self/root/usr/local/lib/python3.9/site-packages/kombu/__pycache__/matcher.cpython-39.pyc
a
X>h� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZm Z ddl
m Z ddl m
Z
eeegef ZG d d
� d
e�ZG d d � d �Ze� ZejZejZejZd
d�dd�Zd
d�dd�Ze� e� e�d� e d�D ]\ZZeej ge�R � q�dS )zPattern matching registry.� )� annotations)�fnmatch)�match)�Callable�cast� )� entrypoints)� bytes_to_strc @ s e Zd ZdZdS )�MatcherNotInstalledz Matcher not installed/found.N)�__name__�
__module__� __qualname__�__doc__� r r �7/usr/local/lib/python3.9/site-packages/kombu/matcher.pyr
s r
c @ sr e Zd ZdZeZdgZdd�dd�Zdddd �d
d �Zddd �d
d�Zddd �dd�Z ddddddd�dd�Z
dS )�MatcherRegistryz#Pattern matching function registry.�pcre�None��returnc C s i | _ d | _d S )N)� _matchers�_default_matcher)�selfr r r �__init__ s zMatcherRegistry.__init__�str�MatcherFunction)�name�matcherr c C s || j |< dS )z$Add matcher by name to the registry.N)r )r r r r r r �register s zMatcherRegistry.register)r r c C s8 z| j �|� W n" ty2 | �d|� ���Y n0 dS )z)Remove matcher by name from the registry.�No matcher installed for N)r �pop�KeyErrorr
�r r r r r �
unregister! s �zMatcherRegistry.unregisterc C s8 z| j | | _W n" ty2 | �d|� ���Y n0 dS )aH Set the default matching method.
:param name: The name of the registered matching method.
For example, `glob` (default), `pcre`, or any custom
methods registered using :meth:`register`.
:raises MatcherNotInstalled: If the matching method requested
is not available.
r N)r r r! r
r" r r r �_set_default_matcher* s
�z$MatcherRegistry._set_default_matcherN�bytesz
str | Nonezdict[str, str] | None�bool)�data�patternr �matcher_kwargsr c C sp |r | j �|�s | �d|� ���| j |p*d }|| jv rJt|�}t|�}nt|�}t|�}|||fi |pji ��S )zCall the matcher.r �glob)r �getr
�matcher_pattern_firstr )r r' r( r r) Z
match_funcZ first_argZ
second_argr r r r ; s �
zMatcherRegistry.match)NN) r r r
r r
r, r r r# r$ r r r r r r s �r r r c C s t �dt� dS )z$Register glob into default registry.r* N)�registryr r r r r r �
register_glob} s r. c C s t �dttt�� dS )z$Register pcre into default registry.r N)r- r r r �rematchr r r r �
register_pcre� s r0 r* zkombu.matchersN) r �
__future__r r �rer r/ �typingr r Z utils.compatr Zutils.encodingr r r& r � Exceptionr
r r- r r# r. r0 r$ �ep�argsr r r r r �<module> s( ?