func main()

in network/benchmarks/netperf/launch.go [442:499]


func main() {
	flag.Parse()
	fmt.Println("Network Performance Test")
	fmt.Println("Parameters :")
	fmt.Println("Iterations      : ", iterations)
	fmt.Println("Test Namespace  : ", testNamespace)
	fmt.Println("Docker image    : ", netperfImage)
	fmt.Println("------------------------------------------------------------")

<<<<<<< HEAD
	testParams := lib.TestParams{
		Iterations:    iterations,
		Tag:           tag,
		TestNamespace: testNamespace,
		Image:         netperfImage,
		CleanupOnly:   cleanupOnly,
		TestFrom:      testFrom,
		TestTo:        testTo,
		JsonOutput:    jsonOutput,
		KubeConfig:    kubeConfig,
	}
	results, err := lib.PerformTests(testParams)
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}
	fmt.Println("Results :")
	for _, result := range results {
		fmt.Println("CSV Result File  : ", result.CsvResultFile)
		fmt.Println("JSON Result File : ", result.JsonResultFile)
	}
=======
	ctx := context.Background()

	var c *kubernetes.Clientset
	if c = setupClient(); c == nil {
		fmt.Println("Failed to setup REST client to Kubernetes cluster")
		return
	}
	if cleanupOnly {
		cleanup(ctx, c)
		return
	}
	nodes := getMinionNodes(ctx, c)
	if nodes == nil {
		return
	}
	if len(nodes.Items) < 2 {
		fmt.Println("Insufficient number of nodes for test (need minimum 2 nodes)")
		return
	}
	primaryNode = nodes.Items[0]
	secondaryNode = nodes.Items[1]
	fmt.Printf("Selected primary,secondary nodes = (%s, %s)\n", primaryNode.GetName(), secondaryNode.GetName())
	executeTests(ctx, c)
	cleanup(ctx, c)
>>>>>>> origin/master
}