diff --git a/setup/class.yaml b/setup/class.yaml index c3ddfb4..d4ba9da 100644 --- a/setup/class.yaml +++ b/setup/class.yaml @@ -1,5 +1,5 @@ kind: StorageClass apiVersion: storage.k8s.io/v1beta1 metadata: - name: example-hostpath -provisioner: example.com/hostpath + name: hostpath-provisioner +provisioner: itix.fr/hostpath diff --git a/src/hostpath-provisioner/hostpath-provisioner.go b/src/hostpath-provisioner/hostpath-provisioner.go index 49cb21f..e65d910 100644 --- a/src/hostpath-provisioner/hostpath-provisioner.go +++ b/src/hostpath-provisioner/hostpath-provisioner.go @@ -35,7 +35,7 @@ import ( const ( resyncPeriod = 15 * time.Second - provisionerName = "example.com/hostpath" + provisionerName = "itix.fr/hostpath" exponentialBackOffOnError = false failedRetryThreshold = 5 leasePeriod = controller.DefaultLeaseDuration @@ -58,8 +58,12 @@ func NewHostPathProvisioner() controller.Provisioner { if nodeName == "" { glog.Fatal("env variable NODE_NAME must be set so that this provisioner can identify itself") } + hostPath := os.Getenv("HOSTPATH_TO_USE") + if hostPath == "" { + glog.Fatal("env variable HOSTPATH_TO_USE must be set") + } return &hostPathProvisioner{ - pvDir: "/tmp/hostpath-provisioner", + pvDir: hostPath, identity: nodeName, } } @@ -110,9 +114,11 @@ func (p *hostPathProvisioner) Delete(volume *v1.PersistentVolume) error { } path := path.Join(p.pvDir, volume.Name) - if err := os.RemoveAll(path); err != nil { - return err - } + + // Not for the moment, please ! + //if err := os.RemoveAll(path); err != nil { + // return err + //} return nil }