
                         8    S r SSKJr  SSKJr  SSKJr  S rS rg)z#Module for Managed Kafka arguments.    )concepts)	yaml_data)concept_parsersc                     [         R                  R                  S5      n[        R                  R                  S[        R                  R                  UR                  5       SS9SSS9R                  U 5        g)z5Sets up an argument for the schema registry resource.zmanaged_kafka.schema_registryschema_registryTis_positionalzThe schema registry resource.)requiredNr   ResourceYAMLDataFromPathr   ConceptParserForResourcer   ResourceSpecFromYamlGetDataAddToParser)parserschema_registry_datas     9lib/googlecloudsdk/command_lib/managed_kafka/arguments.pyAddSchemaRegistryArgToParserr      su    "33<<% ++$$

&
&
( %  & ,  K    c                     [         R                  R                  S5      n[        R                  R                  S[        R                  R                  UR                  5       SS9SSSS0S9R                  U 5        g	)
z-Sets up an argument for the subject resource.zmanaged_kafka.subjectsubjectTr   zThe subject resource.zschema-registryz
--registry)r
   flag_name_overridesNr   )r   subject_datas     r   AddSubjectArgToParserr   %   sx    ++445LM,++$$



  %  ,l; ,  Kr   N)	__doc__ googlecloudsdk.calliope.conceptsr   $googlecloudsdk.command_lib.util.apisr   (googlecloudsdk.command_lib.util.conceptsr   r   r    r   r   <module>r#      s    * 5 : Dr   