Function Call

kontrol/helper_test.go:255–280

(kitePairs HelloKites)

type HelloKites map[*HelloKite]*HelloKite

func Call(kitePairs HelloKites) error {
	merr := &multiError{}

	for local, remote := range kitePairs {
		call := fmt.Sprintf("%s -> %s", local.Kite.Kite().Name, remote.Kite.Kite().Name)

		got, err := local.Hello(remote)
		if err != nil {
			err = fmt.Errorf("%s: error calling: %s", call, err)
			merr.err = append(merr.err, err)
			continue
		}

		if want := fmt.Sprintf("%s says hello", remote.Kite.Kite().Name); got != want {
			err = fmt.Errorf("%s: invalid response: got %q, want %q", call, got, want)
			merr.err = append(merr.err, err)
			continue
		}
	}

	if len(merr.err) != 0 {
		return merr
	}

	return nil
}

func WaitTillConnected(conf *Config, timeout time.Duration, hks ...*HelloKite) error {
	k := kite.New("WaitTillConnected", "1.0.0")