code: func (p *flockerPlugin) newFlockerClient(hostIP string) (*flockerapi.Client, error) {
  	host := env.GetEnvAsStringOrFallback("FLOCKER_CONTROL_SERVICE_HOST", defaultHost)
  	port, err := env.GetEnvAsIntOrFallback("FLOCKER_CONTROL_SERVICE_PORT", defaultPort)
  
  	if err != nil {
  		return nil, err
  	}
  	caCertPath := env.GetEnvAsStringOrFallback("FLOCKER_CONTROL_SERVICE_CA_FILE", defaultCACertFile)
  	keyPath := env.GetEnvAsStringOrFallback("FLOCKER_CONTROL_SERVICE_CLIENT_KEY_FILE", defaultClientKeyFile)
  	certPath := env.GetEnvAsStringOrFallback("FLOCKER_CONTROL_SERVICE_CLIENT_CERT_FILE", defaultClientCertFile)
  
  	c, err := flockerapi.NewClient(host, port, hostIP, caCertPath, keyPath, certPath)
  	return c, err
  }
docs: // newFlockerClient uses environment variables and pod attributes to return a
  // flocker client capable of talking with the Flocker control service.