HGKeeper

// Convey

// 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 implements the docker task types.

package docker

import (

"bitbucket.org/rw_grim/convey/command"

"bitbucket.org/rw_grim/convey/state"

"bitbucket.org/rw_grim/convey/tasks"

)

var (

// Tasks is a map of all docker tasks.

Tasks = map[string]tasks.Task{

"build": &Build{},

"export": &Export{},

"import": &Import{},

"login": &Login{},

"logout": &Logout{},

"pull": &Pull{},

"push": &Push{},

"remove": &Remove{},

"run": &Run{},

"tag": &Tag{},

"environment": &Environment{},

}

)

func dockerCommand(cmdv []string, st *state.State) []string {

cmd := command.NewGenerator()

cmd.Appendv(cmdv)

// if we have a docker config prepend it first

if st.DockerConfig != "" {

cmd.Prepend("--config", st.DockerConfig)

}

// finally prepend the actual docker command

cmd.Prepend("docker")

return cmd.Command()

}

// Docker runs a docker command.

func Docker(name string, cmdv []string, st *state.State) error {

return command.Run(name, dockerCommand(cmdv, st), st.PlanTimeout)

}

// DockerOutput runs a docker command but returns the output rather than

// outputting to the logger.

func DockerOutput(name string, cmdv []string, st *state.State) (string, string, error) {

return command.RunOutput(name, dockerCommand(cmdv, st), st.PlanTimeout)

}