Initial Checkin

This adds an initial implementation. It works but has little error handling. Do not use for production. It is based on the layout from the csi-driver-host-path repo. Signed-off-by: Kevin Fox <Kevin.Fox@pnnl.gov>

Author: kfox1111

Dockerfile

@@ -0,0 +1,12 @@
+FROM centos:centos7
+LABEL maintainers="Kubernetes Authors"
+LABEL description="Image Driver"
+
+RUN \
+ yum install -y epel-release && \
+ yum install -y buildah && \
+ yum clean all
+
+COPY ./bin/imageplugin /imageplugin
+ENTRYPOINT ["/imageplugin"]
+

Gopkg.lock

@@ -0,0 +1,73 @@
+
+# Gopkg.toml example
+#
+# Refer to https://github.com/golang/dep/blob/master/docs/Gopkg.toml.md
+# for detailed Gopkg.toml documentation.
+#
+# required = ["github.com/user/thing/cmd/thing"]
+# ignored = ["github.com/user/project/pkgX", "bitbucket.org/user/project/pkgA/pkgY"]
+#
+# [[constraint]]
+# name = "github.com/user/project"
+# version = "1.0.0"
+#
+# [[constraint]]
+# name = "github.com/user/project2"
+# branch = "dev"
+# source = "github.com/myfork/project2"
+#
+# [[override]]
+# name = "github.com/x/y"
+# version = "2.4.0"
+
+[prune]
+ go-tests = true
+ unused-packages = true
+
+[[constraint]]
+ name = "github.com/container-storage-interface/spec"
+ version = "1.0.0"
+
+[[constraint]]
+ branch = "master"
+ name = "github.com/golang/glog"
+
+[[override]]
+ revision = "5db89f0ca68677abc5eefce8f2a0a772c98ba52d"
+ name = "github.com/docker/distribution"
+
+[[constraint]]
+ name = "github.com/pborman/uuid"
+ version = "1.1.0"
+
+[[constraint]]
+ branch = "master"
+ name = "golang.org/x/net"
+
+[[constraint]]
+ name = "google.golang.org/grpc"
+ version = "1.10.0"
+
+[[constraint]]
+ name = "k8s.io/kubernetes"
+ version = "v1.12.0"
+
+[[override]]
+ version = "kubernetes-1.12.0"
+ name = "k8s.io/api"
+
+[[override]]
+ version = "kubernetes-1.12.0"
+ name = "k8s.io/apiserver"
+
+[[override]]
+ name = "github.com/golang/protobuf"
+ version = "v1.1.0"
+
+[[override]]
+ name = "github.com/json-iterator/go"
+ version = "1.1.4"
+
+[[override]]
+ name = "gopkg.in/square/go-jose.v2"
+ version = "2.1.7"

Gopkg.toml

@@ -14,6 +14,7 @@
 
 # TODO: add a Dockerfile and uncomment the following line
 # CMDS=imagepopulatorplugin
+CMDS=imageplugin
 all: build
 
 include release-tools/build.make

Makefile

@@ -14,3 +14,62 @@ You can reach the maintainers of this project at:
 ### Code of conduct
 
 Participation in the Kubernetes community is governed by the [Kubernetes Code of Conduct](code-of-conduct.md).
+
+## How it works:
+
+Currently the driver makes use of buildah to download the container image if it is not already available, launch a new instance of it named after the volumeHandle, and mount it.
+
+In the future, integration with CRI would be desirable so the driver could ask via CRI that the Container Runtime perform these activities in a generic way.
+
+## Usage:
+
+**This is a prototype driver. Do not use for production**
+
+It also requires features that are still in development.
+
+### Build imageplugin
+```
+$ make image
+```
+
+### Installing into Kubernetes
+```
+deploy/deploy-image.sh
+```
+
+### Example Usage in Kubernetes
+```
+apiVersion: v1
+kind: Pod
+metadata:
+ name: nginx
+spec:
+ containers:
+ - name: nginx
+ image: nginx:1.13-alpine
+ ports:
+ - containerPort: 80
+ volumeMount:
+ - name: data
+ mountPath: /usr/share/nginx/html
+ volumes:
+ - name: data
+ csi:
+ driver: image.csi.k8s.io
+ volumeAttributes:
+ image: kfox1111/misc:test
+```
+
+### Start Image driver manually
+```
+$ sudo ./bin/imageplugin --endpoint tcp://127.0.0.1:10000 --nodeid CSINode -v=5
+```
+
+### Test using csc
+Get ```csc``` tool from https://github.com/rexray/gocsi/tree/master/csc
+
+### Mount the image
+$ csc -e tcp://127.0.0.1:10000 node publish abcdefg --attrib image=kfox1111/misc:test --cap MULTI_NODE_MULTI_WRITER,block --target-path /tmp/csi
+
+### Unmount the image
+$ csc -e tcp://127.0.0.1:10000 node unpublish abcdefg --target-path /tmp/csi

README.md

@@ -16,5 +16,31 @@ limitations under the License.
 
 package main
 
+import (
+"flag"
+"os"
+
+"github.com/kubernetes-csi/csi-driver-image-populator/pkg/image"
+)
+
+func init() {
+flag.Set("logtostderr", "true")
+}
+
+var (
+endpoint = flag.String("endpoint", "unix://tmp/csi.sock", "CSI endpoint")
+driverName = flag.String("drivername", "image.csi.k8s.io", "name of the driver")
+nodeID = flag.String("nodeid", "", "node id")
+)
+
 func main() {
+flag.Parse()
+
+handle()
+os.Exit(0)
+}
+
+func handle() {
+driver := image.NewDriver(*driverName, *nodeID, *endpoint)
+driver.Run()
 }

cmd/imageplugin/main.go

@@ -0,0 +1,7 @@
+package main
+
+import "testing"
+
+func TestStub(t *testing.T) {
+
+}