runner

Documentation

Index

• type Connector
• type Playbook
• type ProcResp
• type Process
  • func (p *Process) Gen(targets []string, tmplRdr io.Reader, respWr io.Writer) error
  • func (p *Process) Run(ctx context.Context, task, target string) (s ProcResp, err error)

Types

type Connector

type Connector interface {
	Connect(ctx context.Context, hostAddr, hostName, user string) (*executor.Remote, error)
}

Connector is an interface for connecting to a host, and returning remote executer.

type Playbook

type Playbook interface {
	AllTasks() []config.Task
	Task(name string) (*config.Task, error)
	TasksByTag(tag string) []string
	TargetHosts(name string) ([]config.Destination, error)
	AllSecretValues() []string
	UpdateTasksTargets(vars map[string]string)
	UpdateRegisteredVars(vars map[string]string)
}

Playbook is an interface for getting task and target information from playbook.

type ProcResp

type ProcResp struct {
	Vars       map[string]string
	Registered map[string]string
	Commands   int
	Hosts      int
}

ProcResp holds the information about processed commands and hosts.

type Process

type Process struct {
	Concurrency int
	Connector   Connector
	Playbook    Playbook
	Logs        executor.Logs
	Verbose     bool
	Verbose2    bool
	Dry         bool
	Local       bool
	SSHShell    string
	SSHTempDir  string

	Skip []string
	Only []string
}

Process is a struct that holds the information needed to run a process. It responsible for running a task on a target hosts.

func (*Process) Gen

func (p *Process) Gen(targets []string, tmplRdr io.Reader, respWr io.Writer) error

Gen generates the list target hosts for a given target, applying templates.

func (*Process) Run

func (p *Process) Run(ctx context.Context, task, target string) (s ProcResp, err error)

Run runs a task for a set of target hosts. Runs in parallel with limited concurrency, each host is processed in separate goroutine. Returns ProcResp with the information about processed commands and hosts plus vars from all thr commands.