e1425a85e4
Not all properties can be set globally, and the "appName" in the global case is currently defaulted to `--global`. This is okay because domain label names cannot start with hyphens, and all app names must be valid domain label names.
121 lines
3.2 KiB
Go
121 lines
3.2 KiB
Go
package ps
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
|
|
"github.com/dokku/dokku/plugins/common"
|
|
)
|
|
|
|
// RunInSerial is the default value for whether to run a command in parallel or not
|
|
// and defaults to -1 (false)
|
|
const RunInSerial = 0
|
|
|
|
var (
|
|
// DefaultProperties is a map of all valid ps properties with corresponding default property values
|
|
DefaultProperties = map[string]string{
|
|
"restart-policy": "on-failure:10",
|
|
}
|
|
|
|
// GlobalProperties is a map of all valid global ps properties
|
|
GlobalProperties = map[string]bool{}
|
|
)
|
|
|
|
// Rebuild rebuilds app from base image
|
|
func Rebuild(appName string) error {
|
|
return common.PlugnTrigger("receive-app", []string{appName}...)
|
|
}
|
|
|
|
// Restart restarts the app
|
|
func Restart(appName string) error {
|
|
if !common.IsDeployed(appName) {
|
|
common.LogWarn(fmt.Sprintf("App %s has not been deployed", appName))
|
|
return nil
|
|
}
|
|
|
|
return common.PlugnTrigger("release-and-deploy", []string{appName}...)
|
|
}
|
|
|
|
// Restore ensures an app that should be running is running on boot
|
|
func Restore(appName string) error {
|
|
scheduler := common.GetAppScheduler(appName)
|
|
if err := common.PlugnTrigger("pre-restore", []string{scheduler, appName}...); err != nil {
|
|
return fmt.Errorf("Error running pre-restore: %s", err)
|
|
}
|
|
|
|
common.LogInfo1("Clearing potentially invalid proxy configuration")
|
|
if err := common.PlugnTrigger("proxy-clear-config", []string{appName}...); err != nil {
|
|
return fmt.Errorf("Error clearing proxy config: %s", err)
|
|
}
|
|
|
|
if !common.IsDeployed(appName) {
|
|
common.LogWarn(fmt.Sprintf("App %s has not been deployed", appName))
|
|
return nil
|
|
}
|
|
|
|
b, _ := common.PlugnTriggerOutput("config-get", []string{appName, "DOKKU_APP_RESTORE"}...)
|
|
restore := strings.TrimSpace(string(b[:]))
|
|
if restore == "0" {
|
|
common.LogWarn(fmt.Sprintf("Skipping ps:restore for %s as DOKKU_APP_RESTORE=%s", appName, restore))
|
|
return nil
|
|
}
|
|
|
|
common.LogInfo1("Starting app")
|
|
return Start(appName)
|
|
}
|
|
|
|
// Start starts the app
|
|
func Start(appName string) error {
|
|
imageTag, _ := common.GetRunningImageTag(appName)
|
|
|
|
if !common.IsDeployed(appName) {
|
|
common.LogWarn(fmt.Sprintf("App %s has not been deployed", appName))
|
|
return nil
|
|
}
|
|
|
|
if err := common.PlugnTrigger("pre-start", []string{appName}...); err != nil {
|
|
return fmt.Errorf("Failure in pre-start hook: %s", err)
|
|
}
|
|
|
|
runningState := getRunningState(appName)
|
|
|
|
if runningState == "mixed" {
|
|
common.LogWarn("App is running in mixed mode, releasing")
|
|
}
|
|
|
|
if runningState != "true" {
|
|
if err := common.PlugnTrigger("release-and-deploy", []string{appName, imageTag}...); err != nil {
|
|
return err
|
|
}
|
|
} else {
|
|
common.LogWarn(fmt.Sprintf("App %s already running", appName))
|
|
}
|
|
|
|
if err := common.PlugnTrigger("proxy-build-config", []string{appName}...); err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// Stop stops the app
|
|
func Stop(appName string) error {
|
|
if !common.IsDeployed(appName) {
|
|
common.LogWarn(fmt.Sprintf("App %s has not been deployed", appName))
|
|
return nil
|
|
}
|
|
|
|
common.LogQuiet(fmt.Sprintf("Stopping %s", appName))
|
|
scheduler := common.GetAppScheduler(appName)
|
|
|
|
if err := common.PlugnTrigger("scheduler-stop", []string{scheduler, appName}...); err != nil {
|
|
return err
|
|
}
|
|
|
|
if err := common.PlugnTrigger("post-stop", []string{appName}...); err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|