code: func getPortworxService(host volume.VolumeHost) (*v1.Service, error) {
  	kubeClient := host.GetKubeClient()
  	if kubeClient == nil {
  		err := fmt.Errorf("Failed to get kubeclient when creating portworx client")
  		klog.Errorf(err.Error())
  		return nil, err
  	}
  
  	opts := metav1.GetOptions{}
  	svc, err := kubeClient.CoreV1().Services(api.NamespaceSystem).Get(pxServiceName, opts)
  	if err != nil {
  		klog.Errorf("Failed to get service. Err: %v", err)
  		return nil, err
  	}
  
  	if svc == nil {
  		err = fmt.Errorf("Service: %v not found. Consult Portworx docs to deploy it", pxServiceName)
  		klog.Errorf(err.Error())
  		return nil, err
  	}
  
  	return svc, nil
  }
docs: // getPortworxService returns the portworx cluster service from the API server