o
    `j                     @   s4  d dl mZ ddlmZ G dd deZG dd deZG dd	 d	eZG d
d deZG dd deZG dd deZ	G dd deZ
G dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG d d! d!eZG d"d# d#eZG d$d% d%eZg d&Zd'S )(    )IntEnum   )
ApiMessagec                   @      e Zd ZdS )CreateTopicsRequestN__name__
__module____qualname__ r   r   Y/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/admin/topics.pyr          r   c                   @   r   )CreateTopicsResponseNr   r   r   r   r   r      r   r   c                       s   e Zd Zd fdd	Z  ZS )DeleteTopicsRequestNFc                    sR   |d u r| j n|}|d ur |dkr | jr | js dd | jD | _t j|||dS )N   c                 S   s   g | ]}|j qS r   )name).0topicr   r   r   
<listcomp>   s    z.DeleteTopicsRequest.encode.<locals>.<listcomp>)versionheaderframed)API_VERSIONtopicstopic_namessuperencode)selfr   r   r   	__class__r   r   r   
   s
   zDeleteTopicsRequest.encode)NFF)r   r	   r
   r   __classcell__r   r   r   r   r   	   s    r   c                   @   r   )DeleteTopicsResponseNr   r   r   r   r   r!      r   r!   c                   @   s   e Zd Zedd ZdS )CreatePartitionsRequestc                 C   s   d|d d d d d< |S )Nnullfieldsr   r   defaultr   )clsjsonr   r   r   
json_patch   s   z"CreatePartitionsRequest.json_patchN)r   r	   r
   classmethodr(   r   r   r   r   r"      s    r"   c                   @   r   )CreatePartitionsResponseNr   r   r   r   r   r*      r   r*   c                   @   r   )"AlterPartitionReassignmentsRequestNr   r   r   r   r   r+      r   r+   c                   @   r   )#AlterPartitionReassignmentsResponseNr   r   r   r   r   r,      r   r,   c                   @   r   )!ListPartitionReassignmentsRequestNr   r   r   r   r   r-      r   r-   c                   @   r   )"ListPartitionReassignmentsResponseNr   r   r   r   r   r.       r   r.   c                   @   r   )DescribeTopicPartitionsRequestNr   r   r   r   r   r/   "   r   r/   c                   @   r   )DescribeTopicPartitionsResponseNr   r   r   r   r   r0   #   r   r0   c                   @   r   )DeleteRecordsRequestNr   r   r   r   r   r1   %   r   r1   c                   @   r   )DeleteRecordsResponseNr   r   r   r   r   r2   &   r   r2   c                   @   r   )ElectLeadersRequestNr   r   r   r   r   r3   (   r   r3   c                   @   r   )ElectLeadersResponseNr   r   r   r   r   r4   )   r   r4   c                   @   s   e Zd ZdZdZdZdS )ElectionTypezLeader election typer      N)r   r	   r
   __doc__	PREFERREDUNCLEANr   r   r   r   r5   +   s    r5   )r   r   r   r!   r"   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   r4   r5   N)enumr   api_messager   r   r   r   r!   r"   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   r4   r5   __all__r   r   r   r   <module>   s(    	