job

May 19, 2018

Changes in this version

type Command

+ func (c *Command) IsRemote() bool

+ type CommandTarget string

+ const CommandTargetLocal

May 4, 2018

Changes in this version

type Command

+ Timeout string

type Host

+ func (h *Host) String() string

type ScpData

+ func (s *ScpData) String() string

Dec 18, 2016

Changes in this version

+ const LoggerKey

+ const OutputKey

+ const SshClientKey

+ const StderrKey

+ const StdoutKey

+ const TemplatingKey

+ var KeepAliveInterval = 30 * time.Second

+ func VisitConfig(builder ConfigBuilder, c *Config) (interface{}, error)

+ type Branch interface

+ type Command struct

+ Command string

+ Commands []*Command

+ Flow string

+ IgnoreError bool

+ Name string

+ Retries uint

+ Stderr *Output

+ Stdout *Output

+ Target string

type Config

+ Telemetry bool

+ type ConfigBuilder interface

+ Command func(cmd *Command) interface{}

+ Commands func(cmd *Command) Group

+ ContextBounds func(child interface{}) interface{}

+ ErrorSafeguard func(child interface{}) interface{}

+ Forwarding func(f *Forwarding) interface{}

+ Host func(c *Config, h *Host) Group

+ HostLogger func(jobName string, h *Host) interface{}

+ Hosts func() Group

+ Job func(name string) Group

+ JobLogger func(jobName string) interface{}

+ LocalCommand func(cmd *Command) interface{}

+ Output func(o *Output) interface{}

+ Parallel func() Group

+ Retry func(child interface{}, retries uint) interface{}

+ SCP func(scp *ScpData) interface{}

+ SSHClient func(host, user, keyFile, password string, keyboardInteractive map[string]string) interface{}

+ Sequential func() Group

+ Stderr func(o *Output) interface{}

+ Stdout func(o *Output) interface{}

+ Templating func(c *Config, h *Host) interface{}

+ Timeout func(timeout time.Duration) interface{}

+ Tunnel func(f *Forwarding) interface{}

+ type ExecutionTreeBuilder struct

+ func (*ExecutionTreeBuilder) Command(cmd *Command) interface{}

+ func (*ExecutionTreeBuilder) Forwarding(f *Forwarding) interface{}

+ func (*ExecutionTreeBuilder) LocalCommand(cmd *Command) interface{}

+ func (*ExecutionTreeBuilder) Output(o *Output) interface{}

+ func (*ExecutionTreeBuilder) SSHClient(host, user, keyFile, password string, keyboardInteractive map[string]string) interface{}

+ func (*ExecutionTreeBuilder) Stderr(o *Output) interface{}

+ func (*ExecutionTreeBuilder) Tunnel(f *Forwarding) interface{}

+ func (e *ExecutionTreeBuilder) Commands(cmd *Command) Group

+ func (e *ExecutionTreeBuilder) ContextBounds(child interface{}) interface{}

+ func (e *ExecutionTreeBuilder) ErrorSafeguard(child interface{}) interface{}

+ func (e *ExecutionTreeBuilder) Host(c *Config, h *Host) Group

+ func (e *ExecutionTreeBuilder) HostLogger(jobName string, h *Host) interface{}

+ func (e *ExecutionTreeBuilder) Hosts() Group

+ func (e *ExecutionTreeBuilder) Job(name string) Group

+ func (e *ExecutionTreeBuilder) JobLogger(jobName string) interface{}

+ func (e *ExecutionTreeBuilder) Parallel() Group

+ func (e *ExecutionTreeBuilder) Retry(child interface{}, retries uint) interface{}

+ func (e *ExecutionTreeBuilder) SCP(scp *ScpData) interface{}

+ func (e *ExecutionTreeBuilder) Sequential() Group

+ func (e *ExecutionTreeBuilder) Stdout(o *Output) interface{}

+ func (e *ExecutionTreeBuilder) Templating(c *Config, h *Host) interface{}

+ func (e *ExecutionTreeBuilder) Timeout(timeout time.Duration) interface{}

+ type Forwarding struct

+ LocalHost string

+ LocalPort uint16

+ RemoteHost string

+ RemotePort uint16

+ type Group interface

+ Append func(children ...interface{})

+ Wrap func() interface{}

+ type Host struct

+ Addr string

+ KeyboardInteractive map[string]string

+ Name string

+ Password string

+ Port uint

+ PrivateKey string

+ Tags map[string]string

+ User string

+ type Leaf string

+ func (s Leaf) String(v *Vars) string

+ type Output struct

+ File string

+ Overwrite bool

+ Raw bool

+ func (o *Output) MarshalJSON() ([]byte, error)

+ func (o *Output) UnmarshalJSON(b []byte) error

+ func (o Output) String() string

+ type ScpData struct

+ Addr string

+ Key string

+ Port uint

+ Verbose bool

+ type SimpleBranch struct

+ Leafs []Stringer

+ Root Leaf

+ func (s *SimpleBranch) Append(children ...interface{})

+ func (s *SimpleBranch) String(v *Vars) string

+ func (s *SimpleBranch) Wrap() interface{}

+ type StringBuilder struct

+ Full bool

+ MaxCommands int

+ MaxHosts int

+ Raw bool

+ func (*StringBuilder) Forwarding(f *Forwarding) interface{}

+ func (*StringBuilder) Parallel() Group

+ func (*StringBuilder) SCP(scp *ScpData) interface{}

+ func (*StringBuilder) SSHClient(host, user, keyFile, password string, keyboardInteractive map[string]string) interface{}

+ func (*StringBuilder) Sequential() Group

+ func (*StringBuilder) Timeout(timeout time.Duration) interface{}

+ func (*StringBuilder) Tunnel(f *Forwarding) interface{}

+ func (s *StringBuilder) Command(cmd *Command) interface{}

+ func (s *StringBuilder) Commands(cmd *Command) Group

+ func (s *StringBuilder) ContextBounds(child interface{}) interface{}

+ func (s *StringBuilder) ErrorSafeguard(child interface{}) interface{}

+ func (s *StringBuilder) Host(c *Config, h *Host) Group

+ func (s *StringBuilder) HostLogger(jobName string, h *Host) interface{}

+ func (s *StringBuilder) Hosts() Group

+ func (s *StringBuilder) Job(name string) Group

+ func (s *StringBuilder) JobLogger(jobName string) interface{}

+ func (s *StringBuilder) LocalCommand(cmd *Command) interface{}

+ func (s *StringBuilder) Output(o *Output) interface{}

+ func (s *StringBuilder) Retry(child interface{}, retries uint) interface{}

+ func (s *StringBuilder) Stderr(o *Output) interface{}

+ func (s *StringBuilder) Stdout(o *Output) interface{}

+ func (s *StringBuilder) Templating(c *Config, h *Host) interface{}

+ type TemplatingEngine struct

+ Config *Config

+ Env map[string]string

+ Host *Host

+ func (t *TemplatingEngine) Interpolate(templ string) (string, error)

+ type TreeBuilder struct

+ type Vars struct

+ Te *TemplatingEngine

Dec 4, 2016

Changes in this version

+ var KeepaliveInterval = time.Millisecond

Sep 4, 2016

Changes in this version

+ type EventFilter func(e NodeEvent) bool

+ type LogMessage struct

+ File string

+ Line int

+ Message string

+ Timestamp time.Time

+ type Logger interface

+ Fatal func(v ...interface{})

+ Fatalf func(format string, v ...interface{})

+ Fatalln func(v ...interface{})

+ Flags func() int

+ Output func(calldepth int, s string) error

+ Panic func(v ...interface{})

+ Panicf func(format string, v ...interface{})

+ Panicln func(v ...interface{})

+ Prefix func() string

+ Print func(v ...interface{})

+ Printf func(format string, v ...interface{})

+ Println func(v ...interface{})

+ SetFlags func(flag int)

+ SetOutput func(w io.Writer)

+ SetPrefix func(prefix string)

+ type NodeEvent struct

+ Status NodeStatus

+ Text string

+ Timestamp time.Time

+ Typ string

+ type NodeEvents []NodeEvent

+ func (e *NodeEvents) Filter(f EventFilter) NodeEvents

+ func (e *NodeEvents) FilterStatus(status NodeStatus) NodeEvents

+ func (e *NodeEvents) FilterType(typ string) NodeEvents

+ type NodeStatus int

+ const CompletedNode

+ const FailedNode

+ const NotStartedNode

+ const RunningNode

+ type TelemetryInfo struct

+ func Instrument(c *Config) (*TelemetryInfo, error)

+ func (t *TelemetryInfo) Events() NodeEvents

+ func (t *TelemetryInfo) GetFlunc() (flunc.Flunc, <-chan string)

Aug 29, 2016

Changes in this version

type Config

+ Post *command

+ Pre *command

+ Tunnel *forwarding

Aug 14, 2016

Changes in this version

+ func InitializeSSHClientStore(ttl time.Duration)

+ type Config struct

+ Command *command

+ Forwarding *forwarding

+ Host *host

+ HostsFile *hostsFile

+ Name string

+ Output string

+ SCP *scp

+ Schedule string

+ Timeout string

+ func ReadConfig(file string) (*Config, error)

+ func (c *Config) ExecutionTree() (flunc.Flunc, error)

+ func (c *Config) JSON() string

+ func (c *Config) String() string

+ func (c *Config) Tree(full, raw bool, maxHosts, maxCommands int) string

+ type Stringer interface

+ String func(v *vars) string