recipes

Documentation

Index

• type Cmd
  • func (c *Cmd) Run(cmds []commands.Command)
  • func (c *Cmd) Upload(artfs []artifacts.Artifact)
• type Recipe
  • func NewRecipe(log *logger.CLILogger, tpl *template.Template) *Recipe
  • func (r *Recipe) AddArtifact(artf artifacts.Artifact)
  • func (r *Recipe) AddCommand(cmd commands.Command)
  • func (r *Recipe) AddServers(srvs []servers.Server)
  • func (r *Recipe) Display(query string)
  • func (r *Recipe) Execute(srvs []servers.Server, kv *kv.KV, maxParallelProcesses int)
  • func (r *Recipe) PrepareArtifacts(artfs []artifacts.Artifact, dryrun bool)
• type SSH
  • func (ss *SSH) Close()
  • func (ss *SSH) Connect(s *servers.Server) error
  • func (ss *SSH) Run(commands []string)
  • func (ss *SSH) Upload(artfs []artifacts.Artifact)
• type SSHJob
• type SSHWorkerGroup
  • func NewSSHWorkerGroup(name string, log *logger.CLILogger, heartbeat time.Duration) *SSHWorkerGroup
  • func (w *SSHWorkerGroup) ExecRecipeOnServer(s servers.Server, recipe *Recipe)
  • func (w *SSHWorkerGroup) Name(id string) string
  • func (w *SSHWorkerGroup) Process(ctx context.Context, workerCtx *pool.WorkerContext, id string)

Types

type Cmd

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

func (*Cmd) Run

func (c *Cmd) Run(cmds []commands.Command)

func (*Cmd) Upload

func (c *Cmd) Upload(artfs []artifacts.Artifact)

type Recipe

type Recipe struct {
	Name   string
	OfType string
	Match  *servers.Match
	KV     map[string]string
	// contains filtered or unexported fields
}

func NewRecipe

func NewRecipe(log *logger.CLILogger, tpl *template.Template) *Recipe

func (*Recipe) AddArtifact

func (r *Recipe) AddArtifact(artf artifacts.Artifact)

func (*Recipe) AddCommand

func (r *Recipe) AddCommand(cmd commands.Command)

func (*Recipe) AddServers

func (r *Recipe) AddServers(srvs []servers.Server)

func (*Recipe) Display

func (r *Recipe) Display(query string)

func (*Recipe) Execute

func (r *Recipe) Execute(srvs []servers.Server, kv *kv.KV, maxParallelProcesses int)

func (*Recipe) PrepareArtifacts

func (r *Recipe) PrepareArtifacts(artfs []artifacts.Artifact, dryrun bool)

type SSH

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

func (*SSH) Close

func (ss *SSH) Close()

func (*SSH) Connect

func (ss *SSH) Connect(s *servers.Server) error

func (*SSH) Run

func (ss *SSH) Run(commands []string)

func (*SSH) Upload

func (ss *SSH) Upload(artfs []artifacts.Artifact)

type SSHJob

type SSHJob struct {
	Server servers.Server
	Recipe *Recipe
}

type SSHWorkerGroup

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

func NewSSHWorkerGroup

func NewSSHWorkerGroup(name string, log *logger.CLILogger, heartbeat time.Duration) *SSHWorkerGroup

NewWorkerGroup ...

func (*SSHWorkerGroup) ExecRecipeOnServer

func (w *SSHWorkerGroup) ExecRecipeOnServer(s servers.Server, recipe *Recipe)

func (*SSHWorkerGroup) Name

func (w *SSHWorkerGroup) Name(id string) string

func (*SSHWorkerGroup) Process

func (w *SSHWorkerGroup) Process(ctx context.Context, workerCtx *pool.WorkerContext, id string)