def create_fn()

in NodePortController/src/main.py [0:0]

• 14 lines of code
• 5 McCabe index (conditional complexity)

def create_fn(meta, spec, namespace, status, logger, **kwargs):
  if 'statefulset.kubernetes.io/pod-name' in meta['labels']:
    label_selector = {'statefulset.kubernetes.io/pod-name': meta['labels']['statefulset.kubernetes.io/pod-name']}
    service_ports = []
    logging.debug(spec['containers'])
    for container in spec['containers']:
      if 'ports' in container:
        for port in container['ports']:
                service_ports.append(client.models.V1ServicePort(port=port['containerPort'],protocol='UDP'))
        api_response = create_node_port_service(namespace, label_selector, service_ports)
        node_port_spec = api_response.spec
        node_port_ports = node_port_spec.ports
        #logging.debug(node_port_ports)
        node_port = node_port_ports[0].node_port
        #TODO Get nodePort from api_response
        instance_id, public_ip = get_instance_id(spec['nodeName'])