code: def get_allocator(self, allocator: str = "default"):
      session = self._create_session()
      response = session.get(
          self.service_url
          + "broker-stats/allocator-stats/{}".format(allocator)
      )
      return response
  
imports: import json
  import logging
  import requests
  from requests.adapters import HTTPAdapter
  from urllib3.util.retry import Retry
label_desc: Use image node_id 3 for calling the PulsarManager obj's underlying member method code with example usage: obj.get_allocator(allocator) and returns: response