wharfie

Documentation

Index

• Constants
• Variables
• func RunExec(cmd string)
• type Option
  • func WithBundleValue(d bool) Option
  • func WithConstraints(s string) Option
  • func WithDebugValue(d bool) Option
  • func WithDockerCertPath(s string) Option
  • func WithDockerImage(s string) Option
  • func WithDockerSocket(s string) Option
  • func WithHomedir(s string) Option
  • func WithJobId(s string) Option
  • func WithNodeList(nl string) Option
  • func WithReplicas(rep int) Option
  • func WithUser(s string) Option
  • func WithUsername(s string) Option
  • func WithVolumes(s string) Option
• type Options
• type SshArgs
• type Wharfie
  • func New(ver string, opts ...Option) Wharfie
  • func (w *Wharfie) AddJobIdLabel() (err error)
  • func (w *Wharfie) Connect()
  • func (w *Wharfie) CreateNetwork() (id string, err error)
  • func (w *Wharfie) CreateService() (err error)
  • func (w *Wharfie) GetNodesFiltered() ([]swarm.Node, error)
  • func (w *Wharfie) GetServiceTask(node string) (task swarm.Task, err error)
  • func (w *Wharfie) GetTasks() (tasks []swarm.Task, err error)
  • func (w *Wharfie) Log(level, msg string)
  • func (w *Wharfie) Remove()
  • func (w *Wharfie) RemoveService() (err error)
  • func (w *Wharfie) RmJobIdLabel() (err error)
  • func (w *Wharfie) Ssh(ctx *cli.Context)
  • func (w *Wharfie) Stage()
  • func (w *Wharfie) WaitForService() (err error)

Constants

const (
	// Debug mode.
	Debug              = false
	DOCKER_API_VERSION = "v1.30"
	DOCKER_API_HOST    = "unix:///var/run/docker.sock"
	DOCKER_CERT_PATH   = "/etc/docker/"
)

Variables

var (
	DOCKER_VOLUMES = []string{"/home/:/home/"}
)

Functions

func RunExec

func RunExec(cmd string)

Types

type Option

type Option func(*Options)

func WithBundleValue

func WithBundleValue(d bool) Option

func WithConstraints

func WithConstraints(s string) Option

func WithDebugValue

func WithDebugValue(d bool) Option

func WithDockerCertPath

func WithDockerCertPath(s string) Option

func WithDockerImage

func WithDockerImage(s string) Option

func WithDockerSocket

func WithDockerSocket(s string) Option

func WithHomedir

func WithHomedir(s string) Option

func WithJobId

func WithJobId(s string) Option

func WithNodeList

func WithNodeList(nl string) Option

func WithReplicas

func WithReplicas(rep int) Option

func WithUser

func WithUser(s string) Option

func WithUsername

func WithUsername(s string) Option

func WithVolumes

func WithVolumes(s string) Option

type Options

type Options struct {
	Version                                     string
	DockerSocket, DockerCertPath, DockerImage   string
	Constraints, JobId, Username, User, Homedir string
	NodeList, Volumes                           []string
	Debug, Bundle                               bool
	Replicas                                    int
}

type SshArgs

type SshArgs struct {
}

type Wharfie

type Wharfie struct {
	// contains filtered or unexported fields
}

func New

func New(ver string, opts ...Option) Wharfie

func (*Wharfie) AddJobIdLabel

func (w *Wharfie) AddJobIdLabel() (err error)

func (*Wharfie) Connect

func (w *Wharfie) Connect()

func (*Wharfie) CreateNetwork

func (w *Wharfie) CreateNetwork() (id string, err error)

func (*Wharfie) CreateService

func (w *Wharfie) CreateService() (err error)

func (*Wharfie) GetNodesFiltered

func (w *Wharfie) GetNodesFiltered() ([]swarm.Node, error)

func (*Wharfie) GetServiceTask

func (w *Wharfie) GetServiceTask(node string) (task swarm.Task, err error)

func (*Wharfie) GetTasks

func (w *Wharfie) GetTasks() (tasks []swarm.Task, err error)

func (*Wharfie) Log

func (w *Wharfie) Log(level, msg string)

func (*Wharfie) Remove

func (w *Wharfie) Remove()

func (*Wharfie) RemoveService

func (w *Wharfie) RemoveService() (err error)

func (*Wharfie) RmJobIdLabel

func (w *Wharfie) RmJobIdLabel() (err error)

func (*Wharfie) Ssh

func (w *Wharfie) Ssh(ctx *cli.Context)

func (*Wharfie) Stage

func (w *Wharfie) Stage()

func (*Wharfie) WaitForService

func (w *Wharfie) WaitForService() (err error)