grim/convey

Bump the version
v0.14.0-alpha4
2018-02-20, Gary Kramlich
89afa53fab1b
Bump the version
// 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 (
"fmt"
"strings"
"time"
"github.com/aphistic/gomol"
"bitbucket.org/rw_grim/convey/logging"
"bitbucket.org/rw_grim/convey/state"
"bitbucket.org/rw_grim/convey/util"
)
// Workspace represents a docker workspace.
type Workspace struct {
name string
volumeName string
mountPoint string
logger *gomol.LogAdapter
state *state.State
}
func (ws *Workspace) findMountPoint(st *state.State) error {
cmdv := []string{
"inspect",
"--format",
"{{range .Mounts}}{{if eq .Destination \"/workspace\" }}{{.Source}}{{end}}{{end}}",
ws.volumeName,
}
stdout, stderr, err := DockerOutput("findMountPoint", cmdv, st)
if err != nil {
if lErr := ws.logger.Errorf("%s", stderr); lErr != nil {
fmt.Printf("error reporting error: %s\n", lErr)
}
return err
}
ws.mountPoint = strings.TrimSpace(stdout)
return nil
}
// NewWorkspace creates a new docker workspace.
func NewWorkspace(st *state.State) (*Workspace, error) {
ws := &Workspace{
name: util.ID(),
logger: logging.NewAdapter("workspace"),
state: st,
}
cmdv := []string{
"create",
"--name=" + ws.name,
"convey/workspace",
}
out, _, err := DockerOutput("create workspace", cmdv, st)
if err != nil {
return nil, err
}
ws.volumeName = strings.TrimSpace(out)
err = ws.findMountPoint(st)
if err != nil {
return nil, err
}
if lErr := ws.logger.Debugf("created workspace: %#v", ws); lErr != nil {
fmt.Printf("error reporting debug: %s\n", lErr)
}
return ws, nil
}
// Name returns the name of the docker workspace.
func (ws *Workspace) Name() string {
return ws.name
}
// Destroy removes the docker workspace.
func (ws *Workspace) Destroy() error {
// monkey with the timeout so our cleanup always runs
oldTimeout := ws.state.PlanTimeout
defer func() {
ws.state.PlanTimeout = oldTimeout
}()
ws.state.PlanTimeout = 15 * time.Minute
cmdv := []string{"rm", "-v", ws.name}
return Docker("remove workspace", cmdv, ws.state)
}