Change 'interval' to something more meaningful
This commit is contained in:
parent
259b4d8d25
commit
23aff4b2c8
@ -1,19 +1,20 @@
|
|||||||
package entrypoint
|
package entrypoint
|
||||||
|
|
||||||
import (
|
import (
|
||||||
cli "github.com/stackanetes/kubernetes-entrypoint/client"
|
|
||||||
"github.com/stackanetes/kubernetes-entrypoint/logger"
|
|
||||||
"k8s.io/client-go/rest"
|
|
||||||
"os"
|
"os"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
cli "github.com/stackanetes/kubernetes-entrypoint/client"
|
||||||
|
"github.com/stackanetes/kubernetes-entrypoint/logger"
|
||||||
|
"k8s.io/client-go/rest"
|
||||||
)
|
)
|
||||||
|
|
||||||
var dependencies []Resolver // List containing all dependencies to be resolved
|
var dependencies []Resolver // List containing all dependencies to be resolved
|
||||||
const (
|
const (
|
||||||
//DependencyPrefix is a prefix for env variables
|
//DependencyPrefix is a prefix for env variables
|
||||||
DependencyPrefix = "DEPENDENCY_"
|
DependencyPrefix = "DEPENDENCY_"
|
||||||
interval = 2
|
resolverSleepInterval = 2
|
||||||
)
|
)
|
||||||
|
|
||||||
//Resolver is an interface which all dependencies should implement
|
//Resolver is an interface which all dependencies should implement
|
||||||
@ -79,7 +80,7 @@ func (e Entrypoint) Resolve() {
|
|||||||
if status, err = dep.IsResolved(e); err != nil {
|
if status, err = dep.IsResolved(e); err != nil {
|
||||||
logger.Warning.Printf("Resolving dependency for %v failed: %v", dep.GetName(), err)
|
logger.Warning.Printf("Resolving dependency for %v failed: %v", dep.GetName(), err)
|
||||||
}
|
}
|
||||||
time.Sleep(interval * time.Second)
|
time.Sleep(resolverSleepInterval * time.Second)
|
||||||
}
|
}
|
||||||
logger.Info.Printf("Dependency %v is resolved", dep.GetName())
|
logger.Info.Printf("Dependency %v is resolved", dep.GetName())
|
||||||
|
|
||||||
|
@ -27,6 +27,7 @@ func main() {
|
|||||||
logger.Error.Printf("Creating entrypoint failed: %v", err)
|
logger.Error.Printf("Creating entrypoint failed: %v", err)
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
|
|
||||||
entrypoint.Resolve()
|
entrypoint.Resolve()
|
||||||
|
|
||||||
if comm = env.SplitEnvToList("COMMAND", " "); len(comm) == 0 {
|
if comm = env.SplitEnvToList("COMMAND", " "); len(comm) == 0 {
|
||||||
@ -34,8 +35,8 @@ func main() {
|
|||||||
// is an init-container
|
// is an init-container
|
||||||
logger.Warning.Printf("COMMAND env is empty")
|
logger.Warning.Printf("COMMAND env is empty")
|
||||||
os.Exit(0)
|
os.Exit(0)
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if err = command.Execute(comm); err != nil {
|
if err = command.Execute(comm); err != nil {
|
||||||
logger.Error.Printf("Cannot execute command: %v", err)
|
logger.Error.Printf("Cannot execute command: %v", err)
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
|
Loading…
Reference in New Issue
Block a user