feat(helm): add option to make cache persistent

Author: plaffitt

examples/deployment.yaml

@@ -21,7 +21,7 @@ spec:
         ports:
         - containerPort: 80
       - name: alpine
-        image: library/nginx
+        image: library/alpine
         imagePullPolicy: Always
         command:
           - sleep

examples/storageclass.yaml

@@ -0,0 +1,7 @@
+apiVersion: storage.k8s.io/v1
+kind: StorageClass
+metadata:
+  name: csi-hostpath
+provisioner: hostpath.csi.k8s.io
+reclaimPolicy: Delete
+volumeBindingMode: Immediate

helm/docker-cache-registry/templates/registry-deploy.yaml

@@ -27,3 +27,14 @@ spec:
             - name: {{ .name }}
               value: {{ .value | quote }}
             {{- end }}
+          volumeMounts:
+            {{- if .Values.registry.persistence.enabled }}
+            - mountPath: /var/lib/registry
+              name: registry
+            {{- end }}
+      volumes:
+        {{- if .Values.registry.persistence.enabled }}
+        - name: registry
+          persistentVolumeClaim:
+            claimName: docker-cache-registry-pvc
+        {{- end }}

helm/docker-cache-registry/templates/registry-pvc.yaml

@@ -0,0 +1,13 @@
+{{- if .Values.registry.persistence.enabled }}
+apiVersion: v1
+kind: PersistentVolumeClaim
+metadata:
+  name: docker-cache-registry-pvc
+spec:
+  accessModes:
+    - ReadWriteOnce
+  storageClassName: {{ .Values.registry.persistence.storageClass }}
+  resources:
+    requests:
+      storage: {{ .Values.registry.persistence.size }}
+{{- end }}

helm/docker-cache-registry/values.yaml

@@ -11,6 +11,12 @@ proxy:
   verbosity: 1
   env: []
 
+registry:
+  persistence:
+    enabled: false
+    storageClass: null
+    size: 20GiB
+
 tugger:
   createMutatingWebhook: true
   rules:

internal/registry/registry.go

@@ -54,7 +54,7 @@ func imageExists(ref name.Reference) bool {
 }
 
 func DeleteImage(imageName string) error {
-	ref, err := name.ParseReference(Endpoint + "/" + imageName)
+	ref, err := name.ParseReference(Endpoint+"/"+imageName, name.Insecure)
 	if err != nil {
 		return err
 	}
@@ -78,11 +78,11 @@ func DeleteImage(imageName string) error {
 }
 
 func CacheImage(imageName string) (bool, error) {
-	destRef, err := name.ParseReference(Endpoint + "/" + imageName)
+	destRef, err := name.ParseReference(Endpoint+"/"+imageName, name.Insecure)
 	if err != nil {
 		return false, err
 	}
-	sourceRef, err := name.ParseReference(imageName)
+	sourceRef, err := name.ParseReference(imageName, name.Insecure)
 	if err != nil {
 		return false, err
 	}