Changing socket dependency to file dependency.

README.md

@@ -70,11 +70,11 @@ Example:
 The Kubernetes-entrypoint will look for the configuration file `/configmaps/nova.conf/nova.conf`, template 
 `{{ .IP }} and {{ .HOSTNAME }}` tags and save the file as `/etc/nova/nova.conf`.
 
-### Socket
+### File
 Checks whether a given file exists and container has rights to read it.
 Example:
 
-`DEPENDENCY_SOCKET=/var/run/openvswitch/ovs.socket`
+`DEPENDENCY_FILE=/var/run/openvswitch/ovs.socket`
 
 ## Image
 

dependencies/file/file.go

@@ -0,0 +1,44 @@
+package file
+
+import (
+	"fmt"
+	"os"
+
+	entry "github.com/stackanetes/kubernetes-entrypoint/entrypoint"
+	"github.com/stackanetes/kubernetes-entrypoint/util/env"
+)
+
+type File struct {
+	name string
+}
+
+func init() {
+	fileEnv := fmt.Sprintf("%sFILE", entry.DependencyPrefix)
+	if fileDeps := env.SplitEnvToList(fileEnv); len(fileDeps) > 0 {
+		for _, dep := range fileDeps {
+			entry.Register(NewFile(dep))
+		}
+	}
+}
+
+func NewFile(name string) File {
+	return File{name: name}
+}
+
+func (s File) GetName() string {
+	return s.name
+}
+
+func (s File) IsResolved(entrypoint entry.EntrypointInterface) (bool, error) {
+	_, err := os.Stat(s.GetName())
+	if err == nil {
+		return true, nil
+	}
+	if os.IsNotExist(err) {
+		return false, fmt.Errorf("File %v doesn't exists", s.GetName())
+	}
+	if os.IsPermission(err) {
+		return false, fmt.Errorf("I have no permission to %v", s.GetName())
+	}
+	return false, err
+}

dependencies/socket/socket.go

@@ -2,9 +2,11 @@ package socket
 
 import (
 	"fmt"
+	"os"
+
 	entry "github.com/stackanetes/kubernetes-entrypoint/entrypoint"
+	"github.com/stackanetes/kubernetes-entrypoint/logger"
 	"github.com/stackanetes/kubernetes-entrypoint/util/env"
-	"os"
 )
 
 type Socket struct {
@@ -14,6 +16,7 @@ type Socket struct {
 func init() {
 	socketEnv := fmt.Sprintf("%sSOCKET", entry.DependencyPrefix)
 	if socketDeps := env.SplitEnvToList(socketEnv); len(socketDeps) > 0 {
+		logger.Info.Printf("%sSOCKET is deprecated and will be removed in next release", entry.DependencyPrefix)
 		for _, dep := range socketDeps {
 			entry.Register(NewSocket(dep))
 		}

kubernetes-entrypoint.go

@@ -8,9 +8,9 @@ import (
 	_ "github.com/stackanetes/kubernetes-entrypoint/dependencies/config"
 	_ "github.com/stackanetes/kubernetes-entrypoint/dependencies/container"
 	_ "github.com/stackanetes/kubernetes-entrypoint/dependencies/daemonset"
+	_ "github.com/stackanetes/kubernetes-entrypoint/dependencies/file"
 	_ "github.com/stackanetes/kubernetes-entrypoint/dependencies/job"
 	_ "github.com/stackanetes/kubernetes-entrypoint/dependencies/service"
-	_ "github.com/stackanetes/kubernetes-entrypoint/dependencies/socket"
 	"github.com/stackanetes/kubernetes-entrypoint/logger"
 	command "github.com/stackanetes/kubernetes-entrypoint/util/command"
 	"github.com/stackanetes/kubernetes-entrypoint/util/env"