original_docstring: Creates a managed private endpoint.
  
          :param resource_group_name: The name of the resource group containing the Kusto cluster.
          :type resource_group_name: str
          :param cluster_name: The name of the Kusto cluster.
          :type cluster_name: str
          :param managed_private_endpoint_name: The name of the managed private endpoint.
          :type managed_private_endpoint_name: str
          :param parameters: The managed private endpoint parameters.
          :type parameters: ~kusto_management_client.models.ManagedPrivateEndpoint
          :keyword callable cls: A custom type or function that will be passed the direct response
          :keyword str continuation_token: A continuation token to restart a poller from a saved state.
          :keyword polling: By default, your polling method will be ARMPolling.
           Pass in False for this operation to not poll, or pass in your own initialized polling object for a personal polling strategy.
          :paramtype polling: bool or ~azure.core.polling.PollingMethod
          :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
          :return: An instance of LROPoller that returns either ManagedPrivateEndpoint or the result of cls(response)
          :rtype: ~azure.core.polling.LROPoller[~kusto_management_client.models.ManagedPrivateEndpoint]
          :raises ~azure.core.exceptions.HttpResponseError:
          
docstring: Creates a managed private endpoint.
docstring_tokens: Creates a managed private endpoint .
code: def begin_create_or_update(
          self,
          resource_group_name,  # type: str
          cluster_name,  # type: str
          managed_private_endpoint_name,  # type: str
          parameters,  # type: "_models.ManagedPrivateEndpoint"
          **kwargs  # type: Any
      ):
          # type: (...) -> LROPoller["_models.ManagedPrivateEndpoint"]
          """Creates a managed private endpoint.
  
          :param resource_group_name: The name of the resource group containing the Kusto cluster.
          :type resource_group_name: str
          :param cluster_name: The name of the Kusto cluster.
          :type cluster_name: str
          :param managed_private_endpoint_name: The name of the managed private endpoint.
          :type managed_private_endpoint_name: str
          :param parameters: The managed private endpoint parameters.
          :type parameters: ~kusto_management_client.models.ManagedPrivateEndpoint
          :keyword callable cls: A custom type or function that will be passed the direct response
          :keyword str continuation_token: A continuation token to restart a poller from a saved state.
          :keyword polling: By default, your polling method will be ARMPolling.
           Pass in False for this operation to not poll, or pass in your own initialized polling object for a personal polling strategy.
          :paramtype polling: bool or ~azure.core.polling.PollingMethod
          :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
          :return: An instance of LROPoller that returns either ManagedPrivateEndpoint or the result of cls(response)
          :rtype: ~azure.core.polling.LROPoller[~kusto_management_client.models.ManagedPrivateEndpoint]
          :raises ~azure.core.exceptions.HttpResponseError:
          """
          polling = kwargs.pop('polling', True)  # type: Union[bool, PollingMethod]
          cls = kwargs.pop('cls', None)  # type: ClsType["_models.ManagedPrivateEndpoint"]
          lro_delay = kwargs.pop(
              'polling_interval',
              self._config.polling_interval
          )
          cont_token = kwargs.pop('continuation_token', None)  # type: Optional[str]
          if cont_token is None:
              raw_result = self._create_or_update_initial(
                  resource_group_name=resource_group_name,
                  cluster_name=cluster_name,
                  managed_private_endpoint_name=managed_private_endpoint_name,
                  parameters=parameters,
                  cls=lambda x,y,z: x,
                  **kwargs
              )
  
          kwargs.pop('error_map', None)
          kwargs.pop('content_type', None)
  
          def get_long_running_output(pipeline_response):
              deserialized = self._deserialize('ManagedPrivateEndpoint', pipeline_response)
  
              if cls:
                  return cls(pipeline_response, deserialized, {})
              return deserialized
  
          path_format_arguments = {
              'subscriptionId': self._serialize.url("self._config.subscription_id", self._config.subscription_id, 'str'),
              'resourceGroupName': self._serialize.url("resource_group_name", resource_group_name, 'str'),
              'clusterName': self._serialize.url("cluster_name", cluster_name, 'str'),
              'managedPrivateEndpointName': self._serialize.url("managed_private_endpoint_name", managed_private_endpoint_name, 'str'),
          }
  
          if polling is True: polling_method = ARMPolling(lro_delay, path_format_arguments=path_format_arguments,  **kwargs)
          elif polling is False: polling_method = NoPolling()
          else: polling_method = polling
          if cont_token:
              return LROPoller.from_continuation_token(
                  polling_method=polling_method,
                  continuation_token=cont_token,
                  client=self._client,
                  deserialization_callback=get_long_running_output
              )
          else:
              return LROPoller(self._client, raw_result, get_long_running_output, polling_method)
code_tokens: def begin_create_or_update ( self , resource_group_name , cluster_name , managed_private_endpoint_name , parameters , ** kwargs ) : polling = kwargs . pop ( 'polling' , True ) cls = kwargs . pop ( 'cls' , None ) lro_delay = kwargs . pop ( 'polling_interval' , self . _config . polling_interval ) cont_token = kwargs . pop ( 'continuation_token' , None ) if cont_token is None : raw_result = self . _create_or_update_initial ( resource_group_name = resource_group_name , cluster_name = cluster_name , managed_private_endpoint_name = managed_private_endpoint_name , parameters = parameters , cls = lambda x , y , z : x , ** kwargs ) kwargs . pop ( 'error_map' , None ) kwargs . pop ( 'content_type' , None ) def get_long_running_output ( pipeline_response ) : deserialized = self . _deserialize ( 'ManagedPrivateEndpoint' , pipeline_response ) if cls : return cls ( pipeline_response , deserialized , { } ) return deserialized path_format_arguments = { 'subscriptionId' : self . _serialize . url ( "self._config.subscription_id" , self . _config . subscription_id , 'str' ) , 'resourceGroupName' : self . _serialize . url ( "resource_group_name" , resource_group_name , 'str' ) , 'clusterName' : self . _serialize . url ( "cluster_name" , cluster_name , 'str' ) , 'managedPrivateEndpointName' : self . _serialize . url ( "managed_private_endpoint_name" , managed_private_endpoint_name , 'str' ) , } if polling is True : polling_method = ARMPolling ( lro_delay , path_format_arguments = path_format_arguments , ** kwargs ) elif polling is False : polling_method = NoPolling ( ) else : polling_method = polling if cont_token : return LROPoller . from_continuation_token ( polling_method = polling_method , continuation_token = cont_token , client = self . _client , deserialization_callback = get_long_running_output ) else : return LROPoller ( self . _client , raw_result , get_long_running_output , polling_method )
short_docstring: Creates a managed private endpoint.
short_docstring_tokens: Creates a managed private endpoint .
comment: # type: str$SEP$# type: str$SEP$# type: str$SEP$# type: "_models.ManagedPrivateEndpoint"$SEP$# type: Any$SEP$# type: (...) -> LROPoller["_models.ManagedPrivateEndpoint"]$SEP$"""Creates a managed private endpoint.
  
          :param resource_group_name: The name of the resource group containing the Kusto cluster.
          :type resource_group_name: str
          :param cluster_name: The name of the Kusto cluster.
          :type cluster_name: str
          :param managed_private_endpoint_name: The name of the managed private endpoint.
          :type managed_private_endpoint_name: str
          :param parameters: The managed private endpoint parameters.
          :type parameters: ~kusto_management_client.models.ManagedPrivateEndpoint
          :keyword callable cls: A custom type or function that will be passed the direct response
          :keyword str continuation_token: A continuation token to restart a poller from a saved state.
          :keyword polling: By default, your polling method will be ARMPolling.
           Pass in False for this operation to not poll, or pass in your own initialized polling object for a personal polling strategy.
          :paramtype polling: bool or ~azure.core.polling.PollingMethod
          :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
          :return: An instance of LROPoller that returns either ManagedPrivateEndpoint or the result of cls(response)
          :rtype: ~azure.core.polling.LROPoller[~kusto_management_client.models.ManagedPrivateEndpoint]
          :raises ~azure.core.exceptions.HttpResponseError:
          """$SEP$# type: Union[bool, PollingMethod]$SEP$# type: ClsType["_models.ManagedPrivateEndpoint"]$SEP$# type: Optional[str]