()
| 30 | } |
| 31 | |
| 32 | func (p *process) String() string { |
| 33 | return fmt.Sprintf("%s:%d-%s:%s", p.Hostname, p.Pid, p.ID, strings.Join(p.Queues, ",")) |
| 34 | } |
| 35 | |
| 36 | func (p *process) open(conn *RedisConn) error { |
| 37 | conn.Send("SADD", fmt.Sprintf("%sworkers", workerSettings.Namespace), p) |
no outgoing calls