grim/convey

add a Destroy function to fs.Directory

2020-05-27, Gary Kramlich
7f4709517632
add a Destroy function to fs.Directory
// Convey
// Copyright 2016-2018 Gary Kramlich <grim@reaperworld.com>
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program. If not, see <http://www.gnu.org/licenses/>.
package docker
import (
"strings"
"time"
log "github.com/sirupsen/logrus"
"keep.imfreedom.org/grim/convey/runtime"
)
// HealthCheck represents a docker health check.
type HealthCheck struct {
Command string `yaml:"command"`
Interval time.Duration `yaml:"interval"`
Retries int `yaml:"retries"`
StartPeriod time.Duration `yaml:"start-period"`
Timeout time.Duration `yaml:"timeout"`
}
func containerHasHealthCheck(name, cid string, rt *runtime.Runtime, logger *log.Entry) (bool, error) {
cmdv := []string{
"inspect",
"-f",
"\"{{if .Config.Healthcheck}}true{{else}}false{{end}}\"",
cid,
}
stdout, stderr, err := DockerOutput(name+"/healthcheck", cmdv, rt)
if err != nil {
logger.Error(stderr)
return false, err
}
if strings.TrimSpace(stdout) == "true" {
return true, nil
}
return false, nil
}
func containerIsHealthy(name, cid string, rt *runtime.Runtime, logger *log.Entry) (bool, error) {
cmdv := []string{
"inspect",
"-f",
"\"{{.State.Health.Status}}\"",
cid,
}
stdout, stderr, err := DockerOutput(name+"/healthcheck", cmdv, rt)
if err != nil {
logger.Error(stderr)
return false, err
}
if strings.ToLower(strings.TrimSpace(stdout)) == "healthy" {
return true, err
}
return false, nil
}