Versions in this module Expand all Collapse all v0 v0.13.32 Dec 20, 2012 v0.13.2 Dec 20, 2012 v0.13.1 Dec 8, 2012 v0.13.0 Dec 6, 2012 Changes in this version + func AddFile(file string) + func CreatePidAndArgumentsMessage(pid int, arguments string) string + func CreateSpawnCommandMessage(identifier string) string + func CreateSpawnSlaveMessage(identifier string) string + func Error(msg string) + func ErrorCantCreateListener() + func ErrorConfigCommandCouldntStart(msg, output string) + func ErrorConfigCommandCrashed(output string) + func ErrorConfigFileInvalidFormat() + func ErrorConfigFileInvalidJson() + func ErrorFileMonitorWrapperCrashed(err error) + func ExitNow(code int, finalOuputCallback func()) + func ParseActionResponseMessage(msg string) (string, error) + func ParseClientCommandRequestMessage(msg string) (string, int, string, error) + func ParseFeatureMessage(msg string) (string, error) + func ParsePidMessage(msg string) (int, string, error) + func Run() + func StartClientHandler(tree *ProcessTree, done chan bool) chan bool + func StartFileMonitor(tree *ProcessTree, done chan bool) chan bool + func StartSlaveMonitor(tree *ProcessTree, done chan bool) chan bool + func StartStatusChart(tree *ProcessTree, done chan bool) chan bool + func StatusChartUpdate() + type CommandNode struct + Aliases []string + type CommandRequest struct + Name string + Retchan chan *os.File + type ProcessTree struct + Commands []*CommandNode + ExecCommand string + Root *SlaveNode + SlavesByName map[string]*SlaveNode + func BuildProcessTree() *ProcessTree + func (tree *ProcessTree) AllCommandsAndAliases() []string + func (tree *ProcessTree) FindCommand(requested string) *CommandNode + func (tree *ProcessTree) FindSlaveByName(name string) *SlaveNode + func (tree *ProcessTree) NewCommandNode(name string, aliases []string, parent *SlaveNode) *CommandNode + func (tree *ProcessTree) NewSlaveNode(identifier string, parent *SlaveNode) *SlaveNode + func (tree *ProcessTree) RestartNodesWithFeature(file string) + type ProcessTreeNode struct + Name string + Parent *SlaveNode + type SlaveMonitor struct + type SlaveNode struct + Commands []*CommandNode + Error string + Features map[string]bool + L sync.Mutex + Pid int + Slaves []*SlaveNode + func (s *SlaveNode) ForceKill() + func (s *SlaveNode) RequestCommandBoot(request *CommandRequest) + func (s *SlaveNode) RequestRestart() + func (s *SlaveNode) RequestSlaveBoot(slave *SlaveNode) + func (s *SlaveNode) Run(monitor *SlaveMonitor) + func (s *SlaveNode) SlaveWasInitialized(pid int, usock *unixsocket.Usock) + func (s *SlaveNode) WaitUntilReadyOrCrashed() + type StatusChart struct + Commands []*CommandNode + L sync.Mutex + RootSlave *SlaveNode + type StringChannelWriter struct + Notif chan string + func (s *StringChannelWriter) Write(o []byte) (int, error)
Go to main page