Method existsCommand

pkg/utils/redis/sentinel.go:221–239

(client *Client, names []string)

}

func (s *Sentinel) existsCommand(client *Client, names []string) (map[string]bool, error) {
	go func() {
		for _, name := range names {
			client.Send("SENTINEL", "get-master-addr-by-name", name)
		}
		if len(names) != 0 {
			client.Flush()
		}
	}()
	exists := make(map[string]bool, len(names))
	for _, name := range names {
		r, err := client.Receive()
		if err != nil {
			return nil, errors.Trace(err)
		}
		exists[name] = (r != nil)
	}
	return exists, nil
}

func (s *Sentinel) slavesCommand(client *Client, names []string) (map[string][]map[string]string, error) {
	exists, err := s.existsCommand(client, names)