Documentation ¶
Index ¶
- type AbsorbError
- type BaseConfigProvider
- type Command
- type CommandSignal
- type CommandStart
- type CommandWait
- type ConfigComparer
- type ConfigProvider
- type ConfigWriter
- type Errors
- type InParallel
- type Instruction
- type InterpreterEnv
- type LazyPath
- type LogMsg
- type MutableConfigProvider
- func (mcp *MutableConfigProvider) AddHost(host string) *MutableConfigProvider
- func (mcp *MutableConfigProvider) ChangeF(f uint8) *MutableConfigProvider
- func (mcp *MutableConfigProvider) Clone() *MutableConfigProvider
- func (mcp *MutableConfigProvider) Eval() (*config.ConfigurationJSON, error)
- func (mcp *MutableConfigProvider) NewConfigComparer(hosts ...string) *ConfigComparer
- func (mcp *MutableConfigProvider) Ports() ([]uint16, error)
- func (mcp *MutableConfigProvider) RemoveHost(host string) *MutableConfigProvider
- func (mcp *MutableConfigProvider) Writer(lp LazyPath) *ConfigWriter
- type PathCopier
- type PathJoin
- type PathProvider
- type PickOne
- type Program
- type RM
- type RMStart
- type Setup
- func (s *Setup) AbsorbError(instr Instruction) *AbsorbError
- func (s *Setup) Exec(l log.Logger) error
- func (s *Setup) InParallel(instrs ...Instruction) *InParallel
- func (s *Setup) Log(msg string) LogMsg
- func (s *Setup) NewCmd(exePath *PathProvider, args []string, cwd *PathProvider, env []string) *Command
- func (s *Setup) NewRM(name string, port uint16, certPath, configPath LazyPath) *RM
- func (s *Setup) PickOne(instrs ...Instruction) *PickOne
- func (s *Setup) SetEnv(envMap harness.TestEnv)
- func (s *Setup) Sleep(d time.Duration) *Sleep
- func (s *Setup) SleepRandom(min, max time.Duration) *Sleep
- func (s *Setup) String() string
- func (s *Setup) UntilError(instr Instruction) Instruction
- func (s *Setup) UntilStopped(instr Instruction) *UntilStopped
- type Sleep
- type UntilError
- type UntilStopped
- type UntilStoppedStop
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AbsorbError ¶
type AbsorbError struct {
// contains filtered or unexported fields
}
func (AbsorbError) Exec ¶
func (ae AbsorbError) Exec(l log.Logger) error
func (AbsorbError) String ¶
func (ae AbsorbError) String() string
type BaseConfigProvider ¶
type BaseConfigProvider config.ConfigurationJSON
func (*BaseConfigProvider) Eval ¶
func (bcp *BaseConfigProvider) Eval() (*config.ConfigurationJSON, error)
type Command ¶
type Command struct {
// contains filtered or unexported fields
}
func (*Command) Kill ¶
func (cmd *Command) Kill() *CommandSignal
func (*Command) Signal ¶
func (cmd *Command) Signal(sig os.Signal) *CommandSignal
func (*Command) Start ¶
func (cmd *Command) Start() *CommandStart
func (*Command) Terminate ¶
func (cmd *Command) Terminate() *CommandSignal
func (*Command) Wait ¶
func (cmd *Command) Wait() *CommandWait
type CommandSignal ¶
type CommandSignal struct { *Command // contains filtered or unexported fields }
func (*CommandSignal) Exec ¶
func (cmds *CommandSignal) Exec(l log.Logger) error
func (*CommandSignal) String ¶
func (cmds *CommandSignal) String() string
type CommandStart ¶
type CommandStart Command
func (*CommandStart) Exec ¶
func (cmd *CommandStart) Exec(l log.Logger) error
func (*CommandStart) String ¶
func (cmd *CommandStart) String() string
type CommandWait ¶
type CommandWait Command
func (*CommandWait) Exec ¶
func (cmdw *CommandWait) Exec(l log.Logger) error
func (*CommandWait) String ¶
func (cmdw *CommandWait) String() string
type ConfigComparer ¶
type ConfigComparer struct {
// contains filtered or unexported fields
}
func (*ConfigComparer) Exec ¶
func (cc *ConfigComparer) Exec(l log.Logger) error
func (*ConfigComparer) String ¶
func (cc *ConfigComparer) String() string
type ConfigProvider ¶
type ConfigProvider interface {
Eval() (*config.ConfigurationJSON, error)
}
type ConfigWriter ¶
type ConfigWriter struct {
// contains filtered or unexported fields
}
func (*ConfigWriter) Exec ¶
func (cw *ConfigWriter) Exec(l log.Logger) error
func (*ConfigWriter) String ¶
func (cw *ConfigWriter) String() string
type InParallel ¶
type InParallel struct {
// contains filtered or unexported fields
}
func (*InParallel) Exec ¶
func (ip *InParallel) Exec(l log.Logger) error
func (*InParallel) String ¶
func (ip *InParallel) String() string
type InterpreterEnv ¶
func NewInterpreterEnv ¶
func NewInterpreterEnv() *InterpreterEnv
func (InterpreterEnv) MaybeExit ¶
func (ie InterpreterEnv) MaybeExit(err error) error
func (InterpreterEnv) Run ¶
func (ie InterpreterEnv) Run(setup *Setup, prog Instruction) error
type MutableConfigProvider ¶
type MutableConfigProvider struct {
// contains filtered or unexported fields
}
func NewMutableConfigProvider ¶
func NewMutableConfigProvider(c *config.ConfigurationJSON) *MutableConfigProvider
func (*MutableConfigProvider) AddHost ¶
func (mcp *MutableConfigProvider) AddHost(host string) *MutableConfigProvider
func (*MutableConfigProvider) ChangeF ¶
func (mcp *MutableConfigProvider) ChangeF(f uint8) *MutableConfigProvider
func (*MutableConfigProvider) Clone ¶
func (mcp *MutableConfigProvider) Clone() *MutableConfigProvider
func (*MutableConfigProvider) Eval ¶
func (mcp *MutableConfigProvider) Eval() (*config.ConfigurationJSON, error)
func (*MutableConfigProvider) NewConfigComparer ¶
func (mcp *MutableConfigProvider) NewConfigComparer(hosts ...string) *ConfigComparer
func (*MutableConfigProvider) Ports ¶
func (mcp *MutableConfigProvider) Ports() ([]uint16, error)
func (*MutableConfigProvider) RemoveHost ¶
func (mcp *MutableConfigProvider) RemoveHost(host string) *MutableConfigProvider
func (*MutableConfigProvider) Writer ¶
func (mcp *MutableConfigProvider) Writer(lp LazyPath) *ConfigWriter
type PathCopier ¶
type PathCopier struct {
// contains filtered or unexported fields
}
func (*PathCopier) Exec ¶
func (pc *PathCopier) Exec(l log.Logger) error
func (*PathCopier) String ¶
func (pc *PathCopier) String() string
type PathJoin ¶
type PathJoin struct {
// contains filtered or unexported fields
}
type PathProvider ¶
type PathProvider struct {
// contains filtered or unexported fields
}
func NewPathProvider ¶
func NewPathProvider(p string, isCmd bool) (*PathProvider, error)
func (*PathProvider) CopyTo ¶
func (pp *PathProvider) CopyTo(dir, receiver *PathProvider) Instruction
func (*PathProvider) EnsureDir ¶
func (pp *PathProvider) EnsureDir() error
func (*PathProvider) Join ¶
func (pp *PathProvider) Join(str string) *PathJoin
func (*PathProvider) Path ¶
func (pp *PathProvider) Path() string
func (*PathProvider) SetPath ¶
func (pp *PathProvider) SetPath(p string, isCmd bool) (err error)
type PickOne ¶
type PickOne struct {
// contains filtered or unexported fields
}
type Program ¶
type Program []Instruction
type RM ¶
type Setup ¶
type Setup struct { GosBin *PathProvider GosConfig *PathProvider GosCert *PathProvider Dir *PathProvider // contains filtered or unexported fields }
func (*Setup) AbsorbError ¶
func (s *Setup) AbsorbError(instr Instruction) *AbsorbError
func (*Setup) InParallel ¶
func (s *Setup) InParallel(instrs ...Instruction) *InParallel
func (*Setup) NewCmd ¶
func (s *Setup) NewCmd(exePath *PathProvider, args []string, cwd *PathProvider, env []string) *Command
func (*Setup) NewRM ¶
func (*Setup) PickOne ¶
func (s *Setup) PickOne(instrs ...Instruction) *PickOne
func (*Setup) UntilError ¶
func (s *Setup) UntilError(instr Instruction) Instruction
func (*Setup) UntilStopped ¶
func (s *Setup) UntilStopped(instr Instruction) *UntilStopped
type Sleep ¶
type Sleep struct {
// contains filtered or unexported fields
}
type UntilError ¶
type UntilError struct {
// contains filtered or unexported fields
}
func (*UntilError) Exec ¶
func (ue *UntilError) Exec(l log.Logger) error
func (*UntilError) String ¶
func (ue *UntilError) String() string
type UntilStopped ¶
type UntilStopped struct {
// contains filtered or unexported fields
}
func (*UntilStopped) Exec ¶
func (us *UntilStopped) Exec(l log.Logger) error
func (*UntilStopped) Stop ¶
func (us *UntilStopped) Stop() *UntilStoppedStop
func (*UntilStopped) String ¶
func (us *UntilStopped) String() string
type UntilStoppedStop ¶
type UntilStoppedStop UntilStopped
func (*UntilStoppedStop) Exec ¶
func (uss *UntilStoppedStop) Exec(l log.Logger) error
func (*UntilStoppedStop) String ¶
func (uss *UntilStoppedStop) String() string
Click to show internal directories.
Click to hide internal directories.