// Copyright (c) 2018 SpiralScout // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in all // copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE // SOFTWARE. package http import ( "errors" tm "github.com/buger/goterm" "github.com/dustin/go-humanize" "github.com/olekukonko/tablewriter" "github.com/shirou/gopsutil/process" "github.com/spf13/cobra" rr "github.com/spiral/roadrunner/cmd/rr/cmd" "github.com/spiral/roadrunner/cmd/rr/utils" "github.com/spiral/roadrunner/service" "github.com/spiral/roadrunner/service/http" rrpc "github.com/spiral/roadrunner/service/rpc" "net/rpc" "os" "os/signal" "strconv" "syscall" "time" ) var ( interactive bool stopSignal = make(chan os.Signal, 1) ) func init() { workersCommand := &cobra.Command{ Use: "http:workers", Short: "List workers associated with RoadRunner HTTP service", RunE: workersHandler, } workersCommand.Flags().BoolVarP( &interactive, "interactive", "i", false, "render interactive workers table", ) rr.CLI.AddCommand(workersCommand) signal.Notify(stopSignal, syscall.SIGTERM) signal.Notify(stopSignal, syscall.SIGINT) } func workersHandler(cmd *cobra.Command, args []string) (err error) { defer func() { if r, ok := recover().(error); ok { err = r } }() svc, st := rr.Container.Get(rrpc.ID) if st < service.StatusConfigured { return errors.New("RPC service is not configured") } client, err := svc.(*rrpc.Service).Client() if err != nil { return err } defer client.Close() if !interactive { showWorkers(client) return nil } tm.Clear() for { select { case <-stopSignal: return nil case <-time.NewTicker(time.Millisecond * 500).C: tm.MoveCursor(1, 1) showWorkers(client) tm.Flush() } } } func showWorkers(client *rpc.Client) { var r http.WorkerList if err := client.Call("http.Workers", true, &r); err != nil { panic(err) } tw := tablewriter.NewWriter(os.Stdout) tw.SetHeader([]string{"PID", "Status", "Execs", "Memory", "Created"}) tw.SetColMinWidth(0, 7) tw.SetColMinWidth(1, 9) tw.SetColMinWidth(2, 7) tw.SetColMinWidth(3, 7) tw.SetColMinWidth(4, 18) for _, w := range r.Workers { tw.Append([]string{ strconv.Itoa(w.Pid), renderStatus(w.Status), renderJobs(w.NumJobs), renderMemory(w.Pid), renderAlive(time.Unix(0, w.Created)), }) } tw.Render() } func renderStatus(status string) string { switch status { case "inactive": return utils.Sprintf("inactive") case "ready": return utils.Sprintf("ready") case "working": return utils.Sprintf("working") case "stopped": return utils.Sprintf("stopped") case "errored": return utils.Sprintf("errored") } return status } func renderJobs(number int64) string { return humanize.Comma(int64(number)) } func renderAlive(t time.Time) string { return humanize.RelTime(t, time.Now(), "ago", "") } func renderMemory(pid int) string { p, _ := process.NewProcess(int32(pid)) i, err := p.MemoryInfo() if err != nil { return err.Error() } return humanize.Bytes(i.RSS) }